diff options
author | Marc Hoersken <info@marc-hoersken.de> | 2020-03-29 17:18:34 +0200 |
---|---|---|
committer | Marc Hoersken <info@marc-hoersken.de> | 2020-04-03 12:37:39 +0200 |
commit | 57476a91e4c8028fcd47b8d322a2248dd2cb5091 (patch) | |
tree | 4f07e6ff94107a74e3fca40ceb1da0de6b210a1e /tests/server | |
parent | 3d1f35eb13fbf0c16008830d5f8841910b308ee4 (diff) |
sockfilt: remove redundancy in timeout handling
And update other logmsg output in select_ws on Windows.
Diffstat (limited to 'tests/server')
-rw-r--r-- | tests/server/sockfilt.c | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/tests/server/sockfilt.c b/tests/server/sockfilt.c index 26bbf416d..6863d17ce 100644 --- a/tests/server/sockfilt.c +++ b/tests/server/sockfilt.c @@ -750,7 +750,7 @@ struct select_ws_data { HANDLE thread; /* the internal thread handle (indexed by thd) */ }; static int select_ws(int nfds, fd_set *readfds, fd_set *writefds, - fd_set *exceptfds, struct timeval *timeout) + fd_set *exceptfds, struct timeval *tv) { HANDLE abort, mutex, signal, handle, *handles; fd_set readsock, writesock, exceptsock; @@ -768,9 +768,17 @@ static int select_ws(int nfds, fd_set *readfds, fd_set *writefds, return -1; } + /* convert struct timeval to milliseconds */ + if(tv) { + milliseconds = (tv->tv_sec*1000)+(DWORD)(((double)tv->tv_usec)/1000.0); + } + else { + milliseconds = INFINITE; + } + /* check if we got descriptors, sleep in case we got none */ if(!nfds) { - Sleep((timeout->tv_sec*1000)+(DWORD)(((double)timeout->tv_usec)/1000.0)); + SleepEx(milliseconds, FALSE); return 0; } @@ -906,14 +914,6 @@ static int select_ws(int nfds, fd_set *readfds, fd_set *writefds, } } - /* convert struct timeval to milliseconds */ - if(timeout) { - milliseconds = ((timeout->tv_sec * 1000) + (timeout->tv_usec / 1000)); - } - else { - milliseconds = INFINITE; - } - /* wait for one of the internal handles to trigger */ wait = WaitForMultipleObjectsEx(nfd, handles, FALSE, milliseconds, FALSE); @@ -981,13 +981,13 @@ static int select_ws(int nfds, fd_set *readfds, fd_set *writefds, for(fds = 0; fds < nfds; fds++) { if(FD_ISSET(fds, readfds)) - logmsg("select_ws: %d is readable", fds); + logmsg("[select_ws] %d is readable", fds); if(FD_ISSET(fds, writefds)) - logmsg("select_ws: %d is writable", fds); + logmsg("[select_ws] %d is writable", fds); if(FD_ISSET(fds, exceptfds)) - logmsg("select_ws: %d is excepted", fds); + logmsg("[select_ws] %d is exceptional", fds); } for(idx = 0; idx < wsa; idx++) { |