diff options
Diffstat (limited to '')
| -rw-r--r-- | src/event/ngx_event_connect.c | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/src/event/ngx_event_connect.c b/src/event/ngx_event_connect.c index 0fa0f70e2..db56f10a3 100644 --- a/src/event/ngx_event_connect.c +++ b/src/event/ngx_event_connect.c @@ -264,6 +264,16 @@ int ngx_event_connect_peer(ngx_peer_connection_t *pc) } } + if (ngx_add_conn) { + if (rc == -1) { + /* NGX_EINPROGRESS */ + return NGX_AGAIN; + } + + ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected"); + return NGX_OK; + } + if (ngx_event_flags & NGX_USE_AIO_EVENT) { /* aio, iocp */ @@ -294,8 +304,6 @@ int ngx_event_connect_peer(ngx_peer_connection_t *pc) return NGX_OK; } - /* TODO: epoll */ - if (ngx_event_flags & NGX_USE_CLEAR_EVENT) { /* kqueue */ event = NGX_CLEAR_EVENT; |