Simple simulation tests without TLS

Author: huitema

UnitTest1/unittest1.cpp

@@ -1947,6 +1947,23 @@ namespace UnitTest1
             Assert::AreEqual(ret, 0);
         }
 
+        TEST_METHOD(qmux_loop)
+        {
+            int ret = qmux_loop_test();
+            Assert::AreEqual(ret, 0);
+        }
+
+        TEST_METHOD(qmux_loop_delay)
+        {
+            int ret = qmux_loop_delay_test();
+            Assert::AreEqual(ret, 0);
+        }
+
+        TEST_METHOD(qmux_loop_idle)
+        {
+            int ret = qmux_loop_idle_test();
+            Assert::AreEqual(ret, 0);
+        }
         TEST_METHOD(perflog)
         {
             int ret = perflog_test();

picoquic/picoquic.h

@@ -1163,7 +1163,7 @@ void picoquic_default_quality_update(picoquic_quic_t* quic, uint64_t pacing_rate
 * that was created.
 */
 
-typedef void (*picoquic_create_socket_fn)(void* create_socket_ctx,
+typedef void* (*picoquic_create_socket_fn)(void* create_socket_ctx,
     int af, int type, int protocol,
     struct sockaddr* addr_local, struct sockaddr* addr_remote, int interface_index);
 

picoquic/picoquic_internal.h

@@ -701,6 +701,10 @@ typedef struct st_picoquic_quic_t {
     /* Creation of additional socket, if authorized by packet loop. */
     picoquic_create_socket_fn create_socket_fn;
     void* create_socket_ctx;
+    /* Handling of QMux*/
+    picoquic_cnx_t* qmux_pending_first;
+    picoquic_cnx_t* qmux_pending_last;
+    picohash_table* qmux_socket_id_table;
 
     /* Logging APIS */
     void* F_log;
@@ -1400,6 +1404,8 @@ typedef struct st_picoquic_cnx_t {
     picoquic_ack_context_t ack_ctx[picoquic_nb_packet_context];
     /* Sequence number of the next observed address frame */
     uint64_t observed_number;
+    /* Handling of qmux queues */
+    picoquic_cnx_t* qmux_pending_next;
     /* Handling of QMUX socket */
     void* qmux_socket_id;
     picohash_item registered_socket_id_item;