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

Merge pull request #1 from yubox-node-org/master

Browse Source 
Library update
This commit is contained in:
Pavel Brychta
2022-12-11 12:43:55 +01:00
committed by GitHub
parent 3d6671a542 1212289f0b
commit d12b2ef2ed
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/AsyncTCP.cpp
View File

@@ -114,7 +114,6 @@ void _asynctcpsock_task(void *)
struct timeval tv; struct timeval tv;
tv.tv_sec = 0; tv.tv_sec = 0;
tv.tv_usec = ASYNCTCPSOCK_POLL_INTERVAL * 1000; tv.tv_usec = ASYNCTCPSOCK_POLL_INTERVAL * 1000;
uint32_t t1 = millis();
xSemaphoreGiveRecursive(_asyncsock_mutex); xSemaphoreGiveRecursive(_asyncsock_mutex);
@@ -301,7 +300,7 @@ AsyncClient::AsyncClient(int sockfd)
{ {
_write_mutex = xSemaphoreCreateMutex(); _write_mutex = xSemaphoreCreateMutex();
if (sockfd != -1) { if (sockfd != -1) {
int r = fcntl( sockfd, F_SETFL, fcntl( sockfd, F_GETFL, 0 ) | O_NONBLOCK ); fcntl( sockfd, F_SETFL, fcntl( sockfd, F_GETFL, 0 ) | O_NONBLOCK );
// Updating state visible to asyncTcpSock task // Updating state visible to asyncTcpSock task
xSemaphoreTakeRecursive(_asyncsock_mutex, (TickType_t)portMAX_DELAY); xSemaphoreTakeRecursive(_asyncsock_mutex, (TickType_t)portMAX_DELAY);
@@ -899,7 +898,7 @@ void AsyncClient::_sockIsReadable(void)
void AsyncClient::_sockPoll(void) void AsyncClient::_sockPoll(void)
{ {
if (_socket == -1) return; if (!connected()) return;
uint32_t now = millis(); uint32_t now = millis();
@@ -1244,7 +1243,7 @@ void AsyncServer::begin()
log_e("listen error: %d - %s", errno, strerror(errno)); log_e("listen error: %d - %s", errno, strerror(errno));
return; return;
} }
int r = fcntl(sockfd, F_SETFL, O_NONBLOCK); fcntl(sockfd, F_SETFL, O_NONBLOCK);
// Updating state visible to asyncTcpSock task // Updating state visible to asyncTcpSock task
xSemaphoreTakeRecursive(_asyncsock_mutex, (TickType_t)portMAX_DELAY); xSemaphoreTakeRecursive(_asyncsock_mutex, (TickType_t)portMAX_DELAY);