diff options
Diffstat (limited to '')
| -rw-r--r-- | src/event/ngx_event_recv.c | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/src/event/ngx_event_recv.c b/src/event/ngx_event_recv.c index 75afcb854..1874b913f 100644 --- a/src/event/ngx_event_recv.c +++ b/src/event/ngx_event_recv.c @@ -1,5 +1,6 @@ #include <ngx_config.h> +#include <ngx_core.h> #include <ngx_errno.h> #include <ngx_log.h> #include <ngx_recv.h> @@ -22,10 +23,10 @@ int ngx_event_recv_core(ngx_event_t *ev, char *buf, size_t size) if (ev->eof && ev->available == 0) { if (ev->error) { ngx_log_error(NGX_LOG_ERR, ev->log, ev->error, - "ngx_event_recv: recv failed while %s", + "ngx_event_recv: recv() failed while %s", ev->log->action); - return -1; + return NGX_ERROR; } return 0; @@ -39,14 +40,16 @@ int ngx_event_recv_core(ngx_event_t *ev, char *buf, size_t size) if (err == NGX_EAGAIN) { ngx_log_error(NGX_LOG_INFO, ev->log, err, - "ngx_event_recv: EAGAIN while %s", ev->log->action); - return -2; + "ngx_event_recv: recv() returns EAGAIN while %s", + ev->log->action); + return NGX_AGAIN; } ngx_log_error(NGX_LOG_INFO, ev->log, err, - "ngx_event_recv: recv failed while %s", ev->log->action); + "ngx_event_recv: recv() failed while %s", + ev->log->action); - return -1; + return NGX_ERROR; } #if (HAVE_KQUEUE) |