1

src/etcp.c

@@ -91,7 +91,7 @@ struct ETCP_CONN* etcp_connection_create(struct UTUN_INSTANCE* instance, char* n
     etcp->input_send_q = queue_new(instance->ua, INFLIGHT_INITIAL_HASH_SIZE, "input_send_q"); // Hash for send_q
     etcp->input_wait_ack = queue_new(instance->ua, INFLIGHT_INITIAL_HASH_SIZE, "input_wait_ack"); // Hash for wait_ack
     etcp->recv_q = queue_new(instance->ua, INFLIGHT_INITIAL_HASH_SIZE, "recv_q"); // Hash for send_q
-    etcp->ack_q = queue_new(instance->ua, 0, "ack_q");
+    etcp->ack_q = queue_new(instance->ua, INFLIGHT_INITIAL_HASH_SIZE, "ack_q");
     etcp->inflight_pool = memory_pool_init(sizeof(struct INFLIGHT_PACKET));
     etcp->io_pool = memory_pool_init(sizeof(struct ETCP_FRAGMENT));
     etcp->optimal_inflight=10000;

src/routing.c

@@ -151,7 +151,7 @@ static void route_pkt(struct UTUN_INSTANCE* instance, struct ll_entry* entry, ui
             conn = (struct ETCP_CONN*)path_entry->data;
         }
         if (!conn) {
-            EBUG_WARN(DEBUG_CATEGORY_ROUTING, "route_pkt: no path for node %016llx dst=%s conn=%s", 
+            DEBUG_WARN(DEBUG_CATEGORY_ROUTING, "route_pkt: no path for node %016llx dst=%s conn=%s", 
                       nq->node.node_id, ip_to_str(&addr, AF_INET).str, conn ? conn->log_name : "null");
             instance->dropped_packets++;
             queue_entry_free(entry);