f8f516a8b0
Memfd backed shared memory segments can only be negotiated over sockets. For such scenarios, the existing redirect mechanism that establishes cut-through sessions does not work anymore as the two peer application do not share such a socket. This patch adds support for local sessions, as opposed to sessions backed by a transport connection, in a way that is almost transparent to the two applications by reusing the existing binary api messages. Moreover, all segment allocations are now entirely done through the segment manager valloc, so segment overlaps due to independent allocations previously required for redirects are completely avoided. The one notable characteristic of local sessions (cut-through from app perspective) notification messages is that they carry pointers to two event queues, one for each app peer, instead of one. For transport-backed sessions one of the queues can be inferred but for local session they cannot. Change-Id: Ia443fb63e2d9d8e43490275062a708f039038175 Signed-off-by: Florin Coras <fcoras@cisco.com>
97 lines
3.1 KiB
Python
97 lines
3.1 KiB
Python
#!/usr/bin/env python
|
|
|
|
import unittest
|
|
|
|
from framework import VppTestCase, VppTestRunner
|
|
from vpp_ip_route import VppIpTable, VppIpRoute, VppRoutePath
|
|
|
|
|
|
class TestSession(VppTestCase):
|
|
""" Session Test Case """
|
|
|
|
@classmethod
|
|
def setUpClass(cls):
|
|
super(TestSession, cls).setUpClass()
|
|
|
|
def setUp(self):
|
|
super(TestSession, self).setUp()
|
|
|
|
self.vapi.session_enable_disable(is_enabled=1)
|
|
self.create_loopback_interfaces(range(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()
|
|
|
|
super(TestSession, self).tearDown()
|
|
self.vapi.session_enable_disable(is_enabled=1)
|
|
|
|
def test_session(self):
|
|
""" Session Unit Tests """
|
|
error = self.vapi.cli("test session all")
|
|
|
|
if error:
|
|
self.logger.critical(error)
|
|
self.assertEqual(error.find("failed"), -1)
|
|
|
|
def test_segment_manager_alloc(self):
|
|
""" Session Segment Manager Multiple Segment Allocation """
|
|
|
|
# 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 with small private segments
|
|
uri = "tcp://" + self.loop0.local_ip4 + "/1234"
|
|
error = self.vapi.cli("test echo server appns 0 fifo-size 64 " +
|
|
"private-segment-size 1m uri " + uri)
|
|
if error:
|
|
self.logger.critical(error)
|
|
self.assertEqual(error.find("failed"), -1)
|
|
|
|
error = self.vapi.cli("test echo client nclients 100 appns 1 " +
|
|
"no-output fifo-size 64 syn-timeout 2 " +
|
|
"private-segment-size 1m uri " + uri)
|
|
if error:
|
|
self.logger.critical(error)
|
|
self.assertEqual(error.find("failed"), -1)
|
|
|
|
if self.vpp_dead:
|
|
self.assert_equal(0)
|
|
|
|
# Delete inter-table routes
|
|
ip_t01.remove_vpp_config()
|
|
ip_t10.remove_vpp_config()
|
|
|
|
if __name__ == '__main__':
|
|
unittest.main(testRunner=VppTestRunner)
|