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

port: immediately update poll set when other threads are polling

Browse Source
This commit is contained in:
Bert Belder 2017-09-25 19:42:01 +02:00
parent 729fa3c733
commit 929ea10ebd
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/port.c
View File

@ -123,6 +123,11 @@ static int _ep_port_update_events(ep_port_t* port_info) {
return 0;
}
static void _ep_port_update_events_if_polling(ep_port_t* port_info) {
if (port_info->active_poll_count > 0)
_ep_port_update_events(port_info);
}
static int _ep_port_feed_events(ep_port_t* port_info,
OVERLAPPED_ENTRY* completion_list,
int completion_count,
@ -154,6 +159,8 @@ static int _ep_port_poll(ep_port_t* port_info,
if (_ep_port_update_events(port_info) < 0)
return -1;
port_info->active_poll_count++;
LeaveCriticalSection(&port_info->lock);
BOOL r = GetQueuedCompletionStatusEx(port_info->iocp,
@ -165,6 +172,8 @@ static int _ep_port_poll(ep_port_t* port_info,
EnterCriticalSection(&port_info->lock);
port_info->active_poll_count--;
if (!r)
return_error(-1);
@ -226,6 +235,8 @@ int ep_port_wait(ep_port_t* port_info,
gqcs_timeout = (DWORD)(due - now);
} while (gqcs_timeout > 0);
_ep_port_update_events_if_polling(port_info);
LeaveCriticalSection(&port_info->lock);
if (result >= 0)
@ -248,6 +259,8 @@ static int _ep_port_ctl_add(ep_port_t* port_info,
return -1;
}
_ep_port_update_events_if_polling(port_info);
return 0;
}
@ -261,6 +274,8 @@ static int _ep_port_ctl_mod(ep_port_t* port_info,
if (ep_sock_set_event(port_info, sock_info, ev) < 0)
return -1;
_ep_port_update_events_if_polling(port_info);
return 0;
}

1
src/port.h
View File

@ -24,6 +24,7 @@ typedef struct ep_port {
queue_t update_queue;
reflock_tree_node_t handle_tree_node;
CRITICAL_SECTION lock;
size_t active_poll_count;
} ep_port_t;
EPOLL_INTERNAL ep_port_t* ep_port_new(HANDLE* iocp_out);