github-mirrors/thirdparty-AsyncTCPSock
1
0
Fork 0
mirror of https://github.com/eledio-devices/thirdparty-AsyncTCPSock.git synced 2025-10-31 00:32:37 +01:00
Code Issues Packages Projects Releases Wiki Activity

Extract poll interval duration into macro

Browse Source
This commit is contained in:
Alex Villacís Lasso
2021-09-06 12:54:22 -05:00
parent 5c2fef785e
commit 511459ca3b
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/AsyncTCP.cpp
View File

@@ -46,6 +46,8 @@ typedef std::list<AsyncSocketBase *>::iterator sockIterator;
void _asynctcpsock_task(void *); void _asynctcpsock_task(void *);
#define ASYNCTCPSOCK_POLL_INTERVAL 125
#define MAX_PAYLOAD_SIZE 1360 #define MAX_PAYLOAD_SIZE 1360
// Since the only task reading from these sockets is the asyncTcpPSock task // Since the only task reading from these sockets is the asyncTcpPSock task
@@ -184,14 +186,16 @@ void _asynctcpsock_task(void *)
// Ugly hack to work around the apparent situation of select() call NOT // Ugly hack to work around the apparent situation of select() call NOT
// yielding to other tasks if using a nonzero wait period. // yielding to other tasks if using a nonzero wait period.
uint32_t d = (nActive == 0 && t2 - t1 < 125) ? 125 - (t2 - t1) : 1; uint32_t d = (nActive == 0 && t2 - t1 < ASYNCTCPSOCK_POLL_INTERVAL)
? ASYNCTCPSOCK_POLL_INTERVAL - (t2 - t1)
: 1;
delay(d); delay(d);
// Collect and run activity poll on all pollable sockets // Collect and run activity poll on all pollable sockets
xSemaphoreTakeRecursive(_asyncsock_mutex, (TickType_t)portMAX_DELAY); xSemaphoreTakeRecursive(_asyncsock_mutex, (TickType_t)portMAX_DELAY);
for (it = _socketBaseList.begin(); it != _socketBaseList.end(); it++) { for (it = _socketBaseList.begin(); it != _socketBaseList.end(); it++) {
(*it)->_selected = false; (*it)->_selected = false;
if (millis() - (*it)->_sock_lastactivity >= 125) { if (millis() - (*it)->_sock_lastactivity >= ASYNCTCPSOCK_POLL_INTERVAL) {
(*it)->_sock_lastactivity = millis(); (*it)->_sock_lastactivity = millis();
sockList.push_back(*it); sockList.push_back(*it);
} }