Lines Matching refs:rev

18     ngx_event_t  *rev;  in ngx_unix_recv()  local
20 rev = c->read; in ngx_unix_recv()
27 rev->pending_eof, rev->available, rev->kq_errno); in ngx_unix_recv()
29 if (rev->available == 0) { in ngx_unix_recv()
30 if (rev->pending_eof) { in ngx_unix_recv()
31 rev->ready = 0; in ngx_unix_recv()
32 rev->eof = 1; in ngx_unix_recv()
34 if (rev->kq_errno) { in ngx_unix_recv()
35 rev->error = 1; in ngx_unix_recv()
36 ngx_set_socket_errno(rev->kq_errno); in ngx_unix_recv()
38 return ngx_connection_error(c, rev->kq_errno, in ngx_unix_recv()
45 rev->ready = 0; in ngx_unix_recv()
58 rev->pending_eof, rev->available); in ngx_unix_recv()
60 if (rev->available == 0 && !rev->pending_eof) { in ngx_unix_recv()
61 rev->ready = 0; in ngx_unix_recv()
75 rev->ready = 0; in ngx_unix_recv()
76 rev->eof = 1; in ngx_unix_recv()
86 rev->available = 0; in ngx_unix_recv()
99 rev->available -= n; in ngx_unix_recv()
106 if (rev->available <= 0) { in ngx_unix_recv()
107 if (!rev->pending_eof) { in ngx_unix_recv()
108 rev->ready = 0; in ngx_unix_recv()
111 rev->available = 0; in ngx_unix_recv()
121 if (rev->available >= 0) { in ngx_unix_recv()
122 rev->available -= n; in ngx_unix_recv()
131 if (rev->available < 0) { in ngx_unix_recv()
132 rev->available = 0; in ngx_unix_recv()
133 rev->ready = 0; in ngx_unix_recv()
137 "recv: avail:%d", rev->available); in ngx_unix_recv()
141 if (ngx_socket_nread(c->fd, &rev->available) == -1) { in ngx_unix_recv()
148 "recv: avail:%d", rev->available); in ngx_unix_recv()
159 if (!rev->pending_eof) { in ngx_unix_recv()
160 rev->ready = 0; in ngx_unix_recv()
163 rev->available = 0; in ngx_unix_recv()
174 rev->ready = 0; in ngx_unix_recv()
194 rev->ready = 0; in ngx_unix_recv()
197 rev->error = 1; in ngx_unix_recv()