Mercurial > hg > nginx
comparison src/os/unix/ngx_recv.c @ 188:0061d1f0908d
nginx-0.0.1-2003-11-18-11:04:34 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Tue, 18 Nov 2003 08:04:34 +0000 |
parents | 1bf718ce0dde |
children | 05592fd7a436 |
comparison
equal
deleted
inserted
replaced
187:5a9bbe99008b | 188:0061d1f0908d |
---|---|
38 } | 38 } |
39 } | 39 } |
40 } | 40 } |
41 | 41 |
42 do { | 42 do { |
43 rev->ready = 1; | |
44 | |
45 n = recv(c->fd, buf, size, 0); | 43 n = recv(c->fd, buf, size, 0); |
46 | 44 |
47 ngx_log_debug(c->log, "recv: %d:%d" _ n _ size); | 45 ngx_log_debug(c->log, "recv: %d:%d" _ n _ size); |
48 | 46 |
49 if (n >= 0) { | 47 if (n >= 0) { |
77 } | 75 } |
78 | 76 |
79 return n; | 77 return n; |
80 } | 78 } |
81 | 79 |
82 rev->ready = 0; | |
83 n = ngx_unix_recv_error(rev, ngx_socket_errno); | 80 n = ngx_unix_recv_error(rev, ngx_socket_errno); |
84 | 81 |
85 } while (n == NGX_EINTR); | 82 } while (n == NGX_EINTR); |
83 | |
84 /* NGX_ERROR || NGX_AGAIN */ | |
85 | |
86 rev->ready = 0; | |
86 | 87 |
87 if (n == NGX_ERROR){ | 88 if (n == NGX_ERROR){ |
88 rev->error = 1; | 89 rev->error = 1; |
89 } | 90 } |
90 | 91 |
99 ngx_event_t *rev; | 100 ngx_event_t *rev; |
100 | 101 |
101 rev = c->read; | 102 rev = c->read; |
102 | 103 |
103 do { | 104 do { |
104 rev->ready = 1; | |
105 | |
106 n = recv(c->fd, buf, size, 0); | 105 n = recv(c->fd, buf, size, 0); |
107 | 106 |
108 ngx_log_debug(c->log, "recv: %d:%d" _ n _ size); | 107 ngx_log_debug(c->log, "recv: %d:%d" _ n _ size); |
109 | 108 |
110 if (n >= 0) { | 109 if (n >= 0) { |
117 } | 116 } |
118 | 117 |
119 return n; | 118 return n; |
120 } | 119 } |
121 | 120 |
122 rev->ready = 0; | |
123 n = ngx_unix_recv_error(rev, ngx_socket_errno); | 121 n = ngx_unix_recv_error(rev, ngx_socket_errno); |
124 | 122 |
125 } while (n == NGX_EINTR); | 123 } while (n == NGX_EINTR); |
124 | |
125 /* NGX_ERROR || NGX_AGAIN */ | |
126 | |
127 rev->ready = 0; | |
126 | 128 |
127 if (n == NGX_ERROR){ | 129 if (n == NGX_ERROR){ |
128 rev->error = 1; | 130 rev->error = 1; |
129 } | 131 } |
130 | 132 |