Issue 169

mathieucarbou · Dec 11, 2024 · 5241048 · 5241048
1 parent 4841e26
commit 5241048
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/AsyncTCP.cpp b/src/AsyncTCP.cpp
@@ -303,8 +303,10 @@ static int8_t _tcp_connected(void * arg, tcp_pcb * pcb, int8_t err) {
 
 static int8_t _tcp_poll(void * arg, struct tcp_pcb * pcb) {
     // throttle polling events queing when event queue is getting filled up, let it handle _onack's
-    if (uxQueueMessagesWaiting(_async_queue) > (rand() % CONFIG_ASYNC_TCP_QUEUE_SIZE / 2 + CONFIG_ASYNC_TCP_QUEUE_SIZE / 4) )
+    if (uxQueueMessagesWaiting(_async_queue) > (rand() % CONFIG_ASYNC_TCP_QUEUE_SIZE / 2 + CONFIG_ASYNC_TCP_QUEUE_SIZE / 4) ) {
+        log_d("throttling _tcp_poll");
         return ERR_OK;
+    }
 
     //ets_printf("+P: 0x%08x\n", pcb);
     lwip_event_packet_t * e = (lwip_event_packet_t *)malloc(sizeof(lwip_event_packet_t));