aboutsummaryrefslogtreecommitdiffstats
path: root/src/vnet/udp
AgeCommit message (Expand)AuthorFilesLines
2020-06-27udp: align udp_encap_t_ to 2 cachelinesVadym Martsynovskyy1-4/+4
2020-06-23udp: jump over ip4 optionsFlorin Coras1-3/+3
2020-05-29misc: ipfix-export unformat u16 collector_port fixElias Rudberg2-0/+18
2020-04-16udp: fix buffer traceAndreas Schultz1-3/+2
2020-04-10udp: remove connected udp transport protoFlorin Coras1-60/+0
2020-04-10udp: fix local node no port error counterFlorin Coras1-9/+6
2020-04-09udp: fix coverity warningFlorin Coras1-1/+1
2020-04-08udp: cleanup input nodeFlorin Coras4-175/+211
2020-04-07udp: move cli to separate fileFlorin Coras4-205/+229
2020-04-07udp session: allow dgram ip fragmentationFlorin Coras2-12/+8
2020-04-07udp session: jumbo frames and configurable mtuFlorin Coras3-2/+39
2020-04-06session udp: shared local endpointsFlorin Coras1-7/+35
2020-04-03session: improve error reportingFlorin Coras1-8/+7
2020-04-03session udp: fix transport flags and migrationFlorin Coras2-1/+7
2020-04-02udp session vcl: add udp iperf testFlorin Coras1-9/+18
2020-04-01udp: improvements to cliFlorin Coras2-13/+64
2020-04-01udp: track connection port sharingFlorin Coras4-31/+122
2020-03-31udp: validate input data lengthFlorin Coras1-4/+7
2020-03-30session udp: flag for connected udpFlorin Coras1-3/+13
2020-03-25session: api to add new transport typesFlorin Coras1-0/+4
2020-03-19session tcp udp: consolidate transport snd apisFlorin Coras1-14/+11
2020-03-19ip: change ip API enums address_family and ip_proto size to u8Jakub Grajciar1-4/+4
2020-03-09udp: fix UDP socket byte order in lookupAndreas Schultz1-1/+2
2020-01-16udp: fix ipv6 listen port registrationFlorin Coras1-1/+1
2020-01-10docs: Edit FEATURE.yaml files so they can be publishedJohn DeNisco1-2/+2
2020-01-03udp: add features.yamlFlorin Coras1-0/+9
2020-01-02session: fix listener global endpoint lookupFlorin Coras1-0/+3
2019-12-10api: multiple connections per processDave Barach1-1/+1
2019-10-01session: fix use-after-freeBenoît Ganne1-1/+2
2019-09-25udp: do not send received packets to error-dropAloys Augustin1-192/+173
2019-08-08udp: fix rx event generationFlorin Coras1-6/+20
2019-08-08udp: fix connections moveAloys Augustin1-1/+4
2019-08-06udp: fix session migrate when not neededNathan Skrzypczak1-15/+21
2019-07-23udp: fix typo in udp connectinon flagsDave Wallace1-1/+1
2019-07-23udp: fix connection flagsAloys Augustin1-3/+3
2019-07-22udp: support close with dataFlorin Coras3-19/+41
2019-07-19fib: FIB Entry trackingNeale Ranns1-11/+6
2019-07-12quic: fix show session verboseAloys Augustin1-3/+3
2019-07-12session: add thread index to all formattersAloys Augustin1-0/+2
2019-07-09udp: UDPC handle open failNathan Skrzypczak1-6/+9
2019-06-28session: add half_open_has_fifos for UDPCNathan Skrzypczak1-0/+1
2019-06-27session: Add transport vft protocol optionsNathan Skrzypczak1-7/+14
2019-06-18fib: fib api updatesNeale Ranns1-1/+1
2019-06-17session: use listener_handle instead of listener_indexNathan Skrzypczak1-1/+2
2019-05-22fix show session verbose crash with udp transportDave Wallace1-0/+2
2019-05-17UDP-Local: fix unregistered portsNeale Ranns1-64/+51
2019-05-16init / exit function orderingDave Barach1-10/+9
2019-05-14Unregister UDPC port only when ownedNathan Skrzypczak3-2/+9
2019-05-03Fix FIB initialization in UDP inputNathan Skrzypczak1-0/+1
2019-05-03Add packet headers in UDPC fifosAloys Augustin2-38/+23
s="n">assertEqual(rx.src, tx[IPv6].src) self.assertEqual(rx.dst, tx[IPv6].dst) self.assertEqual(rx.hlim, tx[IPv6].hlim) def test_udp_encap(self): """ UDP Encap test """ # # construct a UDP encap object through each of the peers # v4 through the first two peears, v6 through the second. # udp_encap_0 = VppUdpEncap(self, 0, self.pg0.local_ip4, self.pg0.remote_ip4, 330, 440) udp_encap_1 = VppUdpEncap(self, 1, self.pg1.local_ip4, self.pg1.remote_ip4, 331, 441, table_id=1) udp_encap_2 = VppUdpEncap(self, 2, self.pg2.local_ip6, self.pg2.remote_ip6, 332, 442, table_id=2, is_ip6=1) udp_encap_3 = VppUdpEncap(self, 3, self.pg3.local_ip6, self.pg3.remote_ip6, 333, 443, table_id=3, is_ip6=1) udp_encap_0.add_vpp_config() udp_encap_1.add_vpp_config() udp_encap_2.add_vpp_config() udp_encap_3.add_vpp_config() # # Routes via each UDP encap object - all combinations of v4 and v6. # route_4o4 = VppIpRoute(self, "1.1.0.1", 32, [VppRoutePath("0.0.0.0", 0xFFFFFFFF, is_udp_encap=1, next_hop_id=0)]) route_4o6 = VppIpRoute(self, "1.1.2.1", 32, [VppRoutePath("0.0.0.0", 0xFFFFFFFF, is_udp_encap=1, next_hop_id=2)]) route_6o4 = VppIpRoute(self, "2001::1", 128, [VppRoutePath("0.0.0.0", 0xFFFFFFFF, is_udp_encap=1, next_hop_id=1)], is_ip6=1) route_6o6 = VppIpRoute(self, "2001::3", 128, [VppRoutePath("0.0.0.0", 0xFFFFFFFF, is_udp_encap=1, next_hop_id=3)], is_ip6=1) route_4o4.add_vpp_config() route_4o6.add_vpp_config() route_6o6.add_vpp_config() route_6o4.add_vpp_config() # # 4o4 encap # p_4o4 = (Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac) / IP(src="2.2.2.2", dst="1.1.0.1") / UDP(sport=1234, dport=1234) / Raw('\xa5' * 100)) rx = self.send_and_expect(self.pg0, p_4o4*65, self.pg0) for p in rx: self.validate_outer4(p, udp_encap_0) p = IP(p["UDP"].payload.load) self.validate_inner4(p, p_4o4) # # 4o6 encap # p_4o6 = (Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac) / IP(src="2.2.2.2", dst="1.1.2.1") / UDP(sport=1234, dport=1234) / Raw('\xa5' * 100)) rx = self.send_and_expect(self.pg0, p_4o6*65, self.pg2) for p in rx: self.validate_outer6(p, udp_encap_2) p = IP(p["UDP"].payload.load) self.validate_inner4(p, p_4o6) # # 6o4 encap # p_6o4 = (Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac) / IPv6(src="2001::100", dst="2001::1") / UDP(sport=1234, dport=1234) / Raw('\xa5' * 100)) rx = self.send_and_expect(self.pg0, p_6o4*65, self.pg1) for p in rx: self.validate_outer4(p, udp_encap_1) p = IPv6(p["UDP"].payload.load) self.validate_inner6(p, p_6o4) # # 6o6 encap # p_6o6 = (Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac) / IPv6(src="2001::100", dst="2001::3") / UDP(sport=1234, dport=1234) / Raw('\xa5' * 100)) rx = self.send_and_expect(self.pg0, p_6o6*65, self.pg3) for p in rx: self.validate_outer6(p, udp_encap_3) p = IPv6(p["UDP"].payload.load) self.validate_inner6(p, p_6o6) # # A route with an output label # the TTL of the inner packet is decremented on LSP ingress # route_4oMPLSo4 = VppIpRoute(self, "1.1.2.22", 32, [VppRoutePath("0.0.0.0", 0xFFFFFFFF, is_udp_encap=1, next_hop_id=1, labels=[VppMplsLabel(66)])]) route_4oMPLSo4.add_vpp_config() p_4omo4 = (Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac) / IP(src="2.2.2.2", dst="1.1.2.22") / UDP(sport=1234, dport=1234) / Raw('\xa5' * 100)) rx = self.send_and_expect(self.pg0, p_4omo4*65, self.pg1) for p in rx: self.validate_outer4(p, udp_encap_1) p = MPLS(p["UDP"].payload.load) self.validate_inner4(p, p_4omo4, ttl=63) class TestUDP(VppTestCase): """ UDP Test Case """ @classmethod def setUpClass(cls): super(TestUDP, cls).setUpClass() def setUp(self): super(TestUDP, self).setUp() self.vapi.session_enable_disable(is_enabled=1) self.create_loopback_interfaces(2) table_id = 0 for i in self.lo_interfaces: i.admin_up() if table_id != 0: tbl = VppIpTable(self, table_id) tbl.add_vpp_config() i.set_table_ip4(table_id) i.config_ip4() table_id += 1 # Configure namespaces self.vapi.app_namespace_add(namespace_id="0", sw_if_index=self.loop0.sw_if_index) self.vapi.app_namespace_add(namespace_id="1", sw_if_index=self.loop1.sw_if_index) def tearDown(self): for i in self.lo_interfaces: i.unconfig_ip4() i.set_table_ip4(0) i.admin_down() self.vapi.session_enable_disable(is_enabled=0) super(TestUDP, self).tearDown() def test_udp_transfer(self): """ UDP echo client/server transfer """ # Add inter-table routes ip_t01 = VppIpRoute(self, self.loop1.local_ip4, 32, [VppRoutePath("0.0.0.0", 0xffffffff, nh_table_id=1)]) ip_t10 = VppIpRoute(self, self.loop0.local_ip4, 32, [VppRoutePath("0.0.0.0", 0xffffffff, nh_table_id=0)], table_id=1) ip_t01.add_vpp_config() ip_t10.add_vpp_config() # Start builtin server and client uri = "udp://" + self.loop0.local_ip4 + "/1234" error = self.vapi.cli("test echo server appns 0 fifo-size 4 no-echo" + "uri " + uri) if error: self.logger.critical(error) self.assertEqual(error.find("failed"), -1) error = self.vapi.cli("test echo client mbytes 10 appns 1 " + "fifo-size 4 no-output test-bytes " + "syn-timeout 2 no-return uri " + uri) if error: self.logger.critical(error) self.assertEqual(error.find("failed"), -1) # Delete inter-table routes ip_t01.remove_vpp_config() ip_t10.remove_vpp_config() if __name__ == '__main__': unittest.main(testRunner=VppTestRunner)