SCTP: API to configure some tunables - vpp

diff options

author	Marco Varlese <marco.varlese@suse.com>	2018-03-05 15:12:29 +0100
committer	Damjan Marion <dmarion.lists@gmail.com>	2018-03-05 18:41:26 +0000
commit	c7fe4f39bca709a9ca094ffd4465490fa780a576 (patch)
tree	4b310511183637a02c4f92a81b2557aa547cdb06 /src/vnet/sctp/sctp_output.c
parent	53da221b13225695516ec7469ca29d82bb10e594 (diff)

SCTP: API to configure some tunables

This patch adds the possibility to configure some behaviors of the SCTP stack based on some tunable parameters (mainly ON/OFF). For the time being, that is limited to the bundling option (multiplexing messages) and to delaying the SACK message. Change-Id: I696493e0309e47163c1e119c7d9f82f7d8ee6b87 Signed-off-by: Marco Varlese <marco.varlese@suse.com>

Diffstat (limited to 'src/vnet/sctp/sctp_output.c')

-rw-r--r--

src/vnet/sctp/sctp_output.c

1 files changed, 5 insertions, 5 deletions

#!/usr/bin/env python3 # Copyright (c) 2021 Graphiant, Inc. import unittest import scapy.compat from scapy.layers.inet import IP, UDP from scapy.layers.l2 import Ether from scapy.packet import Raw from framework import VppTestCase, VppTestRunner from vpp_papi import VppEnum from vpp_policer import VppPolicer, PolicerAction NUM_PKTS = 67 class TestPolicerInput(VppTestCase): """ Policer on an input interface """ vpp_worker_count = 2 def setUp(self): super(TestPolicerInput, self).setUp() self.create_pg_interfaces(range(2)) for i in self.pg_interfaces: i.admin_up() i.config_ip4() i.resolve_arp() self.pkt = (Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac) / IP(src=self.pg0.remote_ip4, dst=self.pg1.remote_ip4) / UDP(sport=1234, dport=1234) / Raw(b'\xa5' * 100)) def tearDown(self): for i in self.pg_interfaces: i.unconfig_ip4() i.admin_down() super(TestPolicerInput, self).tearDown() def test_policer_input(self): """ Input Policing """ pkts = self.pkt * NUM_PKTS action_tx = PolicerAction( VppEnum.vl_api_sse2_qos_action_type_t.SSE2_QOS_ACTION_API_TRANSMIT, 0) policer = VppPolicer(self, "pol1", 80, 0, 1000, 0, conform_action=action_tx, exceed_action=action_tx, violate_action=action_tx) policer.add_vpp_config() # Start policing on pg0 policer.apply_vpp_config(self.pg0.sw_if_index, True) rx = self.send_and_expect(self.pg0, pkts, self.pg1, worker=0) stats = policer.get_stats() # Single rate, 2 colour policer - expect conform, violate but no exceed self.assertGreater(stats['conform_packets'], 0) self.assertEqual(stats['exceed_packets'], 0) self.assertGreater(stats['violate_packets'], 0) # Stop policing on pg0 policer.apply_vpp_config(self.pg0.sw_if_index, False) rx = self.send_and_expect(self.pg0, pkts, self.pg1, worker=0) statsnew = policer.get_stats() # No new packets counted self.assertEqual(stats, statsnew) policer.remove_vpp_config() def test_policer_handoff(self): """ Worker thread handoff """ pkts = self.pkt * NUM_PKTS action_tx = PolicerAction( VppEnum.vl_api_sse2_qos_action_type_t.SSE2_QOS_ACTION_API_TRANSMIT, 0) policer = VppPolicer(self, "pol2", 80, 0, 1000, 0, conform_action=action_tx, exceed_action=action_tx, violate_action=action_tx) policer.add_vpp_config() # Bind the policer to worker 1 policer.bind_vpp_config(1, True) # Start policing on pg0 policer.apply_vpp_config(self.pg0.sw_if_index, True) for worker in [0, 1]: self.send_and_expect(self.pg0, pkts, self.pg1, worker=worker) self.logger.debug(self.vapi.cli("show trace max 100")) stats = policer.get_stats() stats0 = policer.get_stats(worker=0) stats1 = policer.get_stats(worker=1) # Worker 1, should have done all the policing self.assertEqual(stats, stats1) # Worker 0, should have handed everything off self.assertEqual(stats0['conform_packets'], 0) self.assertEqual(stats0['exceed_packets'], 0) self.assertEqual(stats0['violate_packets'], 0) # Unbind the policer from worker 1 and repeat policer.bind_vpp_config(1, False) for worker in [0, 1]: self.send_and_expect(self.pg0, pkts, self.pg1, worker=worker) self.logger.debug(self.vapi.cli("show trace max 100")) # The policer should auto-bind to worker 0 when packets arrive stats = policer.get_stats() # The 2 workers should now have policed the same amount stats = policer.get_stats() stats0 = policer.get_stats(worker=0) stats1 = policer.get_stats(worker=1) self.assertGreater(stats0['conform_packets'], 0) self.assertEqual(stats0['exceed_packets'], 0) self.assertGreater(stats0['violate_packets'], 0) self.assertGreater(stats1['conform_packets'], 0) self.assertEqual(stats1['exceed_packets'], 0) self.assertGreater(stats1['violate_packets'], 0) self.assertEqual(stats0['conform_packets'] + stats1['conform_packets'], stats['conform_packets']) self.assertEqual(stats0['violate_packets'] + stats1['violate_packets'], stats['violate_packets']) # Stop policing on pg0 policer.apply_vpp_config(self.pg0.sw_if_index, False) policer.remove_vpp_config() if __name__ == '__main__': unittest.main(testRunner=VppTestRunner)


context:
space:
mode: