tests: tag the tests that do not work with multi-worker configuration
[vpp.git] / src / plugins / quic / test / test_quic.py
index 8109018..d984b99 100644 (file)
@@ -5,6 +5,7 @@ import unittest
 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
@@ -77,9 +78,9 @@ class QUICTestCase(VppTestCase):
             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
@@ -110,7 +111,7 @@ class QUICTestCase(VppTestCase):
 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()
@@ -138,16 +139,20 @@ class QUICEchoIntTestCase(QUICTestCase):
             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")
@@ -156,9 +161,11 @@ class QUICEchoIntSerialTestCase(QUICEchoIntTestCase):
         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")
 
@@ -174,7 +181,7 @@ class QUICEchoExtTestCase(QUICTestCase):
     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",
@@ -271,6 +278,7 @@ class QUICEchoExtTransferTestCase(QUICEchoExtTestCase):
     timeout = 60
 
     def test_quic_ext_transfer(self):
+        """QUIC external transfer"""
         self.server()
         self.client()
         self.validate_ext_test_results()
@@ -285,6 +293,7 @@ class QUICEchoExtTransferBigTestCase(QUICEchoExtTestCase):
 
     @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()
@@ -296,6 +305,7 @@ class QUICEchoExtQcloseRxTestCase(QUICEchoExtTestCase):
     @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()
@@ -307,6 +317,7 @@ class QUICEchoExtQcloseTxTestCase(QUICEchoExtTestCase):
     @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")
@@ -319,6 +330,7 @@ class QUICEchoExtEarlyQcloseRxTestCase(QUICEchoExtTestCase):
     @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")
@@ -331,6 +343,7 @@ class QUICEchoExtEarlyQcloseTxTestCase(QUICEchoExtTestCase):
     @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")
@@ -343,6 +356,7 @@ class QUICEchoExtScloseRxTestCase(QUICEchoExtTestCase):
     @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()
@@ -354,6 +368,7 @@ class QUICEchoExtScloseTxTestCase(QUICEchoExtTestCase):
     @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()
@@ -365,6 +380,7 @@ class QUICEchoExtEarlyScloseRxTestCase(QUICEchoExtTestCase):
     @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")
@@ -377,6 +393,7 @@ class QUICEchoExtEarlyScloseTxTestCase(QUICEchoExtTestCase):
     @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")
@@ -389,6 +406,7 @@ class QUICEchoExtServerStreamTestCase(QUICEchoExtTestCase):
     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()
@@ -404,6 +422,7 @@ class QUICEchoExtServerStreamBigTestCase(QUICEchoExtTestCase):
 
     @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()
@@ -416,6 +435,7 @@ class QUICEchoExtServerStreamQcloseRxTestCase(QUICEchoExtTestCase):
     @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()
@@ -428,6 +448,7 @@ class QUICEchoExtServerStreamQcloseTxTestCase(QUICEchoExtTestCase):
     @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")
@@ -441,6 +462,7 @@ class QUICEchoExtServerStreamEarlyQcloseRxTestCase(QUICEchoExtTestCase):
     @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")
@@ -454,6 +476,7 @@ class QUICEchoExtServerStreamEarlyQcloseTxTestCase(QUICEchoExtTestCase):
     @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")
@@ -467,6 +490,7 @@ class QUICEchoExtServerStreamScloseRxTestCase(QUICEchoExtTestCase):
     @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()
@@ -479,6 +503,7 @@ class QUICEchoExtServerStreamScloseTxTestCase(QUICEchoExtTestCase):
     @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()
@@ -491,6 +516,7 @@ class QUICEchoExtServerStreamEarlyScloseRxTestCase(QUICEchoExtTestCase):
     @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")
@@ -504,6 +530,7 @@ class QUICEchoExtServerStreamEarlyScloseTxTestCase(QUICEchoExtTestCase):
     @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")
@@ -517,6 +544,7 @@ class QUICEchoExtServerStreamWorkersTestCase(QUICEchoExtTestCase):
     @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()