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

src: inline some small and single-caller functions

Browse Source
This commit is contained in:
Bert Belder 2020-06-03 12:04:25 +02:00
parent f8325fba92
commit 4a7e05917f
No known key found for this signature in database
GPG Key ID: 7A77887B2E2ED461
2 changed files with 23 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
src/port.c
View File

@ -81,7 +81,7 @@ err1:
return NULL; return NULL;
} }
static int port__close_iocp(port_state_t* port_state) { static inline int port__close_iocp(port_state_t* port_state) {
HANDLE iocp_handle = port_state->iocp_handle; HANDLE iocp_handle = port_state->iocp_handle;
port_state->iocp_handle = NULL; port_state->iocp_handle = NULL;
@ -150,15 +150,15 @@ static int port__update_events(port_state_t* port_state) {
return 0; return 0;
} }
static void port__update_events_if_polling(port_state_t* port_state) { static inline void port__update_events_if_polling(port_state_t* port_state) {
if (port_state->active_poll_count > 0) if (port_state->active_poll_count > 0)
port__update_events(port_state); port__update_events(port_state);
} }
static int port__feed_events(port_state_t* port_state, static inline int port__feed_events(port_state_t* port_state,
struct epoll_event* epoll_events, struct epoll_event* epoll_events,
OVERLAPPED_ENTRY* iocp_events, OVERLAPPED_ENTRY* iocp_events,
DWORD iocp_event_count) { DWORD iocp_event_count) {
int epoll_event_count = 0; int epoll_event_count = 0;
DWORD i; DWORD i;
@ -173,11 +173,11 @@ static int port__feed_events(port_state_t* port_state,
return epoll_event_count; return epoll_event_count;
} }
static int port__poll(port_state_t* port_state, static inline int port__poll(port_state_t* port_state,
struct epoll_event* epoll_events, struct epoll_event* epoll_events,
OVERLAPPED_ENTRY* iocp_events, OVERLAPPED_ENTRY* iocp_events,
DWORD maxevents, DWORD maxevents,
DWORD timeout) { DWORD timeout) {
DWORD completion_count; DWORD completion_count;
if (port__update_events(port_state) < 0) if (port__update_events(port_state) < 0)
@ -283,9 +283,9 @@ int port_wait(port_state_t* port_state,
return -1; return -1;
} }
static int port__ctl_add(port_state_t* port_state, static inline int port__ctl_add(port_state_t* port_state,
SOCKET sock, SOCKET sock,
struct epoll_event* ev) { struct epoll_event* ev) {
sock_state_t* sock_state = sock_new(port_state, sock); sock_state_t* sock_state = sock_new(port_state, sock);
if (sock_state == NULL) if (sock_state == NULL)
return -1; return -1;
@ -300,9 +300,9 @@ static int port__ctl_add(port_state_t* port_state,
return 0; return 0;
} }
static int port__ctl_mod(port_state_t* port_state, static inline int port__ctl_mod(port_state_t* port_state,
SOCKET sock, SOCKET sock,
struct epoll_event* ev) { struct epoll_event* ev) {
sock_state_t* sock_state = port_find_socket(port_state, sock); sock_state_t* sock_state = port_find_socket(port_state, sock);
if (sock_state == NULL) if (sock_state == NULL)
return -1; return -1;
@ -315,7 +315,7 @@ static int port__ctl_mod(port_state_t* port_state,
return 0; return 0;
} }
static int port__ctl_del(port_state_t* port_state, SOCKET sock) { static inline int port__ctl_del(port_state_t* port_state, SOCKET sock) {
sock_state_t* sock_state = port_find_socket(port_state, sock); sock_state_t* sock_state = port_find_socket(port_state, sock);
if (sock_state == NULL) if (sock_state == NULL)
return -1; return -1;
@ -325,10 +325,10 @@ static int port__ctl_del(port_state_t* port_state, SOCKET sock) {
return 0; return 0;
} }
static int port__ctl_op(port_state_t* port_state, static inline int port__ctl_op(port_state_t* port_state,
int op, int op,
SOCKET sock, SOCKET sock,
struct epoll_event* ev) { struct epoll_event* ev) {
switch (op) { switch (op) {
case EPOLL_CTL_ADD: case EPOLL_CTL_ADD:
return port__ctl_add(port_state, sock, ev); return port__ctl_add(port_state, sock, ev);

2
src/sock.c
View File

@ -51,7 +51,7 @@ static inline void sock__free(sock_state_t* sock_state) {
free(sock_state); free(sock_state);
} }
static int sock__cancel_poll(sock_state_t* sock_state) { static inline int sock__cancel_poll(sock_state_t* sock_state) {
assert(sock_state->poll_status == SOCK__POLL_PENDING); assert(sock_state->poll_status == SOCK__POLL_PENDING);
if (afd_cancel_poll(poll_group_get_afd_device_handle(sock_state->poll_group), if (afd_cancel_poll(poll_group_get_afd_device_handle(sock_state->poll_group),