me-no-dev/AsyncTCP
1
0
Fork 1
mirror of https://github.com/me-no-dev/AsyncTCP.git synced 2025-09-25 22:00:54 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #32 from vortigont/queue_ctrl

Browse Source 
throttle polling events when message queue gets filled up
This commit is contained in:
Mathieu Carbou
2024-12-11 19:53:31 +01:00
committed by GitHub
parent 67f0fa607c 8302dba2b8
commit 362beab638
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/AsyncTCP.cpp
View File

@@ -302,6 +302,12 @@ 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) ) {
log_d("throttling");
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));
e->event = LWIP_TCP_POLL;