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

port: manipulate request count through ep_port_(add|del)_req

Browse Source
This commit is contained in:
Bert Belder 2017-09-11 01:38:24 +02:00
parent 4d9a24a708
commit 1f795ae60f
3 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/epoll-socket.c
View File

@ -92,15 +92,16 @@ void ep_sock_register_poll_req(ep_port_t* port_info, ep_sock_t* sock_info) {
_ep_sock_private_t* sock_private = _ep_sock_private(sock_info);
assert(!_ep_sock_is_deleted(sock_private));
ep_port_add_req(port_info);
sock_private->poll_req_count++;
port_info->poll_req_count++;
}
void ep_sock_unregister_poll_req(ep_port_t* port_info, ep_sock_t* sock_info) {
_ep_sock_private_t* sock_private = _ep_sock_private(sock_info);
ep_port_del_req(port_info);
sock_private->poll_req_count--;
port_info->poll_req_count--;
_ep_sock_maybe_free(sock_private);
}

8
src/epoll.c
View File

@ -320,6 +320,14 @@ int ep_port_del_socket(ep_port_t* port_info, handle_tree_entry_t* tree_entry) {
return handle_tree_del(&port_info->sock_tree, tree_entry);
}
void ep_port_add_req(ep_port_t* port_info) {
port_info->poll_req_count++;
}
void ep_port_del_req(ep_port_t* port_info) {
port_info->poll_req_count--;
}
SOCKET ep_port_get_driver_socket(ep_port_t* port_info, SOCKET socket) {
ssize_t index;
size_t i;

3
src/port.h
View File

@ -30,6 +30,9 @@ EPOLL_INTERNAL int ep_port_add_socket(ep_port_t* port_info,
EPOLL_INTERNAL int ep_port_del_socket(ep_port_t* port_info,
handle_tree_entry_t* tree_entry);
EPOLL_INTERNAL void ep_port_add_req(ep_port_t* port_info);
EPOLL_INTERNAL void ep_port_del_req(ep_port_t* port_info);
EPOLL_INTERNAL void ep_port_request_socket_update(ep_port_t* port_info,
ep_sock_t* sock_info);
EPOLL_INTERNAL void ep_port_clear_socket_update(ep_port_t* port_info,