import os
import subprocess
import signal
+from framework import tag_fixme_vpp_workers
from framework import VppTestCase, VppTestRunner, running_extended_tests, \
Worker
from vpp_ip_route import VppIpTable, VppIpRoute, VppRoutePath
table_id += 1
# Configure namespaces
- self.vapi.app_namespace_add_del(namespace_id=b"server",
+ self.vapi.app_namespace_add_del(namespace_id="server",
sw_if_index=self.loop0.sw_if_index)
- self.vapi.app_namespace_add_del(namespace_id=b"client",
+ self.vapi.app_namespace_add_del(namespace_id="client",
sw_if_index=self.loop1.sw_if_index)
# Add inter-table routes
class QUICEchoIntTestCase(QUICTestCase):
"""QUIC Echo Internal Test Case"""
test_bytes = ' test-bytes'
- extra_vpp_punt_config = ["session", "{", "enable", "}"]
+ extra_vpp_punt_config = ["session", "{", "enable", "poll-main", "}"]
def setUp(self):
super(QUICEchoIntTestCase, self).setUp()
self.assertNotIn("failed", error)
+@tag_fixme_vpp_workers
class QUICEchoIntTransferTestCase(QUICEchoIntTestCase):
"""QUIC Echo Internal Transfer Test Case"""
def test_quic_int_transfer(self):
+ """QUIC internal transfer"""
self.server()
self.client("no-output", "mbytes", "2")
+@tag_fixme_vpp_workers
class QUICEchoIntSerialTestCase(QUICEchoIntTestCase):
"""QUIC Echo Internal Serial Transfer Test Case"""
def test_quic_serial_int_transfer(self):
+ """QUIC serial internal transfer"""
self.server()
self.client("no-output", "mbytes", "2")
self.client("no-output", "mbytes", "2")
self.client("no-output", "mbytes", "2")
+@tag_fixme_vpp_workers
class QUICEchoIntMStreamTestCase(QUICEchoIntTestCase):
"""QUIC Echo Internal MultiStream Test Case"""
def test_quic_int_multistream_transfer(self):
+ """QUIC internal multi-stream transfer"""
self.server()
self.client("nclients", "10", "mbytes", "1", "no-output")
server_fifo_size = "1M"
client_fifo_size = "4M"
extra_vpp_punt_config = ["session", "{",
- "enable", "evt_qs_memfd_seg",
+ "enable", "poll-main", "evt_qs_memfd_seg",
"evt_qs_seg_size", "64M",
"event-queue-length", f"{evt_q_len}",
"preallocated-sessions", "1024",
timeout = 60
def test_quic_ext_transfer(self):
+ """QUIC external transfer"""
self.server()
self.client()
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
def test_quic_ext_transfer_big(self):
+ """QUIC external transfer, big stream"""
self.server("TX=0", "RX=2G")
self.client("TX=2G", "RX=0")
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_qclose_rx(self):
+ """QUIC external transfer, rx close"""
self.server("TX=0", "RX=10M", "qclose=Y", "sclose=N")
self.client("TX=10M", "RX=0", "qclose=W", "sclose=W")
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_qclose_tx(self):
+ """QUIC external transfer, tx close"""
self.server("TX=0", "RX=10M", "qclose=W", "sclose=W",
"rx-results-diff")
self.client("TX=10M", "RX=0", "qclose=Y", "sclose=N")
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_early_qclose_rx(self):
+ """QUIC external transfer, early rx close"""
self.server("TX=0", "RX=10M", "qclose=Y", "sclose=N")
self.client("TX=20M", "RX=0", "qclose=W", "sclose=W",
"tx-results-diff")
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_early_qclose_tx(self):
+ """QUIC external transfer, early tx close"""
self.server("TX=0", "RX=20M", "qclose=W", "sclose=W",
"rx-results-diff")
self.client("TX=10M", "RX=0", "qclose=Y", "sclose=N")
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_sclose_rx(self):
+ """QUIC external transfer, rx stream close"""
self.server("TX=0", "RX=10M", "qclose=N", "sclose=Y")
self.client("TX=10M", "RX=0", "qclose=W", "sclose=W")
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_sclose_tx(self):
+ """QUIC external transfer, tx stream close"""
self.server("TX=0", "RX=10M", "qclose=W", "sclose=W")
self.client("TX=10M", "RX=0", "qclose=Y", "sclose=Y")
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_early_sclose_rx(self):
+ """QUIC external transfer, early rx stream close"""
self.server("TX=0", "RX=10M", "qclose=N", "sclose=Y")
self.client("TX=20M", "RX=0", "qclose=W", "sclose=W",
"tx-results-diff")
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_early_sclose_tx(self):
+ """QUIC external transfer, early tx stream close"""
self.server("TX=0", "RX=20M", "qclose=W", "sclose=W",
"rx-results-diff")
self.client("TX=10M", "RX=0", "qclose=Y", "sclose=Y")
timeout = 60
def test_quic_ext_transfer_server_stream(self):
+ """QUIC external server transfer"""
self.server("TX=10M", "RX=0")
self.client("TX=0", "RX=10M")
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
def test_quic_ext_transfer_server_stream_big(self):
+ """QUIC external server transfer, big stream"""
self.server("TX=2G", "RX=0")
self.client("TX=0", "RX=2G")
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_server_stream_qclose_rx(self):
+ """QUIC external server transfer, rx close"""
self.server("TX=10M", "RX=0", "qclose=W", "sclose=W")
self.client("TX=0", "RX=10M", "qclose=Y", "sclose=N")
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_server_stream_qclose_tx(self):
+ """QUIC external server transfer, tx close"""
self.server("TX=10M", "RX=0", "qclose=Y", "sclose=N")
self.client("TX=0", "RX=10M", "qclose=W", "sclose=W",
"rx-results-diff")
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_server_stream_early_qclose_rx(self):
+ """QUIC external server transfer, early rx close"""
self.server("TX=20M", "RX=0", "qclose=W", "sclose=W",
"tx-results-diff")
self.client("TX=0", "RX=10M", "qclose=Y", "sclose=N")
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_server_stream_early_qclose_tx(self):
+ """QUIC external server transfer, early tx close"""
self.server("TX=10M", "RX=0", "qclose=Y", "sclose=N")
self.client("TX=0", "RX=20M", "qclose=W", "sclose=W",
"rx-results-diff")
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_server_stream_sclose_rx(self):
+ """QUIC external server transfer, rx stream close"""
self.server("TX=10M", "RX=0", "qclose=W", "sclose=W")
self.client("TX=0", "RX=10M", "qclose=N", "sclose=Y")
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_server_stream_sclose_tx(self):
+ """QUIC external server transfer, tx stream close"""
self.server("TX=10M", "RX=0", "qclose=Y", "sclose=Y")
self.client("TX=0", "RX=10M", "qclose=W", "sclose=W")
self.validate_ext_test_results()
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_server_stream_early_sclose_rx(self):
+ """QUIC external server transfer, early rx stream close"""
self.server("TX=20M", "RX=0", "qclose=W", "sclose=W",
"tx-results-diff")
self.client("TX=0", "RX=10M", "qclose=N", "sclose=Y")
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_server_stream_early_sclose_tx(self):
+ """QUIC external server transfer, early tx stream close"""
self.server("TX=10M", "RX=0", "qclose=Y", "sclose=Y")
self.client("TX=0", "RX=20M", "qclose=W", "sclose=W",
"rx-results-diff")
@unittest.skipUnless(running_extended_tests, "part of extended tests")
@unittest.skip("testcase under development")
def test_quic_ext_transfer_server_stream_multi_workers(self):
+ """QUIC external server transfer, multi-worker"""
self.server("nclients", "4", "quic-streams", "4", "TX=10M", "RX=0")
self.client("nclients", "4", "quic-streams", "4", "TX=0", "RX=10M")
self.validate_ext_test_results()