Mercurial > hg > nginx

comparison src/os/unix/ngx_recv.c @ 188:0061d1f0908d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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