comparison src/event/ngx_event_recv.c @ 6:669801705ab1

nginx-0.0.1-2002-08-26-19:18:19 import
author Igor Sysoev <igor@sysoev.ru>
date Mon, 26 Aug 2002 15:18:19 +0000
parents c5f071d376e5
children b5481d6fbbd4
comparison
equal deleted inserted replaced
5:62b1a364857c 6:669801705ab1
12 ngx_err_t err; 12 ngx_err_t err;
13 ngx_connection_t *c; 13 ngx_connection_t *c;
14 14
15 c = (ngx_connection_t *) ev->data; 15 c = (ngx_connection_t *) ev->data;
16 16
17 if (ev->timedout) {
18 ngx_set_socket_errno(NGX_ETIMEDOUT);
19 ngx_log_error(NGX_LOG_ERR, ev->log, NGX_ETIMEDOUT, "recv() failed");
20 return NGX_ERROR;
21 }
22
17 #if (HAVE_KQUEUE) 23 #if (HAVE_KQUEUE)
18 ngx_log_debug(ev->log, "ngx_event_recv: eof:%d, avail:%d, err:%d" _ 24 ngx_log_debug(ev->log, "ngx_event_recv: eof:%d, avail:%d, err:%d" _
19 ev->eof _ ev->available _ ev->error); 25 ev->eof _ ev->available _ ev->error);
20 #if !(USE_KQUEUE) 26 #if !(USE_KQUEUE)
21 if (ngx_event_type == NGX_KQUEUE_EVENT) 27 if (ngx_event_type == NGX_KQUEUE_EVENT)
22 #endif 28 #endif
23 if (ev->eof && ev->available == 0) { 29 if (ev->eof && ev->available == 0) {
24 if (ev->error) { 30 if (ev->error) {
25 ngx_log_error(NGX_LOG_ERR, ev->log, ev->error, 31 ngx_log_error(NGX_LOG_ERR, ev->log, ev->error, "recv() failed");
26 "ngx_event_recv: recv() failed while %s",
27 ev->log->action);
28
29 return NGX_ERROR; 32 return NGX_ERROR;
30 } 33 }
31 34
32 return 0; 35 return 0;
33 } 36 }
37 40
38 if (n == -1) { 41 if (n == -1) {
39 err = ngx_socket_errno; 42 err = ngx_socket_errno;
40 43
41 if (err == NGX_EAGAIN) { 44 if (err == NGX_EAGAIN) {
42 ngx_log_error(NGX_LOG_INFO, ev->log, err, 45 ngx_log_error(NGX_LOG_INFO, ev->log, err, "recv() returns EAGAIN");
43 "ngx_event_recv: recv() returns EAGAIN while %s",
44 ev->log->action);
45 return NGX_AGAIN; 46 return NGX_AGAIN;
46 } 47 }
47 48
48 ngx_log_error(NGX_LOG_INFO, ev->log, err, 49 ngx_log_error(NGX_LOG_ERR, ev->log, err, "recv() failed");
49 "ngx_event_recv: recv() failed while %s",
50 ev->log->action);
51
52 return NGX_ERROR; 50 return NGX_ERROR;
53 } 51 }
54 52
55 #if (HAVE_KQUEUE) 53 #if (HAVE_KQUEUE)
56 #if !(USE_KQUEUE) 54 #if !(USE_KQUEUE)