coffee/wepoll
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

port: make ep_port_wait() thread-safe

Browse Source
This commit is contained in:
Bert Belder 2017-09-25 19:18:13 +02:00
parent d3a69678cf
commit e37f4b2ccb
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/port.c
View File

@ -143,6 +143,8 @@ static int _ep_port_poll(ep_port_t* port_info,
if (_ep_port_update_events(port_info) < 0)
return -1;
LeaveCriticalSection(&port_info->lock);
BOOL r = GetQueuedCompletionStatusEx(port_info->iocp,
iocp_events,
maxevents,
@ -150,6 +152,8 @@ static int _ep_port_poll(ep_port_t* port_info,
timeout,
FALSE);
EnterCriticalSection(&port_info->lock);
if (!r)
return_error(-1);
@ -187,6 +191,8 @@ int ep_port_wait(ep_port_t* port_info,
gqcs_timeout = INFINITE;
}
EnterCriticalSection(&port_info->lock);
/* Dequeue completion packets until either at least one interesting event
* has been discovered, or the timeout is reached.
*/
@ -211,6 +217,8 @@ int ep_port_wait(ep_port_t* port_info,
gqcs_timeout = (DWORD)(due - now);
} while (gqcs_timeout > 0);
LeaveCriticalSection(&port_info->lock);
if (result >= 0)
return result;
else if (GetLastError() == WAIT_TIMEOUT)