diff options
| author | Igor Sysoev <igor@sysoev.ru> | 2003-11-17 16:15:03 +0000 |
|---|---|---|
| committer | Igor Sysoev <igor@sysoev.ru> | 2003-11-17 16:15:03 +0000 |
| commit | d7fdb3535bc277d0bc16d31981bb84d30c45500f (patch) | |
| tree | 4ddeecc1f37dd3d2626b6a79806000a9466b3436 /src/event/ngx_event_connectex.c | |
| parent | f2e676aa1585de170b39cf3e9d71b88db47e4b1b (diff) | |
| download | nginx-d7fdb3535bc277d0bc16d31981bb84d30c45500f.tar.gz nginx-d7fdb3535bc277d0bc16d31981bb84d30c45500f.tar.bz2 | |
nginx-0.0.1-2003-11-17-19:15:03 import
Diffstat (limited to 'src/event/ngx_event_connectex.c')
| -rw-r--r-- | src/event/ngx_event_connectex.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/event/ngx_event_connectex.c b/src/event/ngx_event_connectex.c index 79833c647..ed1228384 100644 --- a/src/event/ngx_event_connectex.c +++ b/src/event/ngx_event_connectex.c @@ -14,8 +14,8 @@ static ngx_connection_t pending_connects[NGX_MAX_PENDING_CONN]; static HANDLE pending_connect_event; __declspec(thread) int nevents = 0; -__declspec(thread) WSAEVENT events[WSA_MAXIMUM_WAIT_EVENTS]; -__declspec(thread) ngx_connection_t *conn[WSA_MAXIMUM_WAIT_EVENTS]; +__declspec(thread) WSAEVENT events[WSA_MAXIMUM_WAIT_EVENTS + 1]; +__declspec(thread) ngx_connection_t *conn[WSA_MAXIMUM_WAIT_EVENTS + 1]; @@ -121,7 +121,7 @@ void ngx_iocp_wait_events(int main) conn[0] = NULL; for ( ;; ) { - offset = (nevents == WSA_MAXIMUM_WAIT_EVENTS) ? 1: 0; + offset = (nevents == WSA_MAXIMUM_WAIT_EVENTS + 1) ? 1: 0; timeout = (nevents == 1 && !first) ? 60000: INFINITE; n = WSAWaitForMultipleEvents(nevents - offset, events[offset], @@ -133,7 +133,7 @@ void ngx_iocp_wait_events(int main) } if (n == WAIT_TIMEOUT) { - if (nevents == 1 && !main) { + if (nevents == 2 && !main) { ExitThread(0); } @@ -145,9 +145,9 @@ void ngx_iocp_wait_events(int main) n -= WSA_WAIT_EVENT_0; - if (n == 0) { + if (events[n] == NULL) { - /* the first event is pending_connect_event */ + /* the pending_connect_event */ if (nevents == WSA_MAXIMUM_WAIT_EVENTS) { ngx_iocp_new_thread(0); |