read 650 core/ngx_connection.c if (c->read->active) { read 662 core/ngx_connection.c ngx_del_event(c->read, NGX_READ_EVENT, 0); read 665 core/ngx_connection.c ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT); read 748 core/ngx_connection.c rev = c->read; read 753 core/ngx_connection.c c->read = rev; read 807 core/ngx_connection.c if (c->read->timer_set) { read 808 core/ngx_connection.c ngx_del_timer(c->read); read 819 core/ngx_connection.c if (c->read->active || c->read->disabled) { read 820 core/ngx_connection.c ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT); read 838 core/ngx_connection.c if (c->read->prev) { read 839 core/ngx_connection.c ngx_delete_posted_event(c->read); read 846 core/ngx_connection.c c->read->closed = 1; read 851 core/ngx_connection.c c->read->locked = 0; read 859 core/ngx_connection.c if (c->read->prev) { read 860 core/ngx_connection.c ngx_delete_posted_event(c->read); read 867 core/ngx_connection.c c->read->closed = 1; read 953 core/ngx_connection.c c->read->handler(c->read); read 108 core/ngx_connection.h ngx_event_t *read; read 102 core/ngx_open_file_cache.h ngx_event_t *read; read 837 core/ngx_resolver.c uc->connection->read->handler = ngx_resolver_read_response; read 838 core/ngx_resolver.c uc->connection->read->resolver = 1; read 2146 core/ngx_resolver.c rev = c->read; read 121 event/modules/ngx_aio_module.c if (c->read->active == 0 && c->write->active == 0) { read 134 event/modules/ngx_aio_module.c c->read->active = 0; read 140 event/modules/ngx_aio_module.c c->read->active = 0; read 259 event/modules/ngx_devpoll_module.c e = (event == POLLIN) ? c->write : c->read; read 275 event/modules/ngx_devpoll_module.c e = c->read; read 494 event/modules/ngx_devpoll_module.c rev = c->read; read 262 event/modules/ngx_epoll_module.c ngx_eventfd_conn.read = &ngx_eventfd_event; read 356 event/modules/ngx_epoll_module.c e = c->read; read 420 event/modules/ngx_epoll_module.c e = c->read; read 457 event/modules/ngx_epoll_module.c ee.data.ptr = (void *) ((uintptr_t) c | c->read->instance); read 468 event/modules/ngx_epoll_module.c c->read->active = 1; read 488 event/modules/ngx_epoll_module.c c->read->active = 0; read 506 event/modules/ngx_epoll_module.c c->read->active = 0; read 576 event/modules/ngx_epoll_module.c rev = c->read; read 688 event/modules/ngx_epoll_module.c n = read(ngx_eventfd, &ready, 8); read 286 event/modules/ngx_eventport_module.c e = c->read; read 341 event/modules/ngx_eventport_module.c e = c->read; read 498 event/modules/ngx_eventport_module.c rev = c->read; read 135 event/modules/ngx_poll_module.c e = c->read; read 188 event/modules/ngx_poll_module.c e = c->read; read 214 event/modules/ngx_poll_module.c if (c->read->index == (ngx_uint_t) nevents) { read 215 event/modules/ngx_poll_module.c c->read->index = ev->index; read 376 event/modules/ngx_poll_module.c ev = c->read; read 200 event/modules/ngx_rtsig_module.c if (c->read->accept && c->read->disabled) { read 211 event/modules/ngx_rtsig_module.c c->read->active = 1; read 212 event/modules/ngx_rtsig_module.c c->read->disabled = 0; read 217 event/modules/ngx_rtsig_module.c signo = rtscf->signo + c->read->instance; read 248 event/modules/ngx_rtsig_module.c c->read->active = 1; read 261 event/modules/ngx_rtsig_module.c if ((flags & NGX_DISABLE_EVENT) && c->read->accept) { read 266 event/modules/ngx_rtsig_module.c c->read->active = 0; read 267 event/modules/ngx_rtsig_module.c c->read->disabled = 1; read 272 event/modules/ngx_rtsig_module.c c->read->active = 0; read 283 event/modules/ngx_rtsig_module.c c->read->active = 0; read 374 event/modules/ngx_rtsig_module.c rev = c->read; read 498 event/modules/ngx_rtsig_module.c if (c->read->active && c->read->handler) { read 553 event/modules/ngx_rtsig_module.c rev = c->read; read 719 event/ngx_event.c c[i].read = &cycle->read_events[i]; read 749 event/ngx_event.c rev = c->read; read 768 event/ngx_event.c if (ngx_del_event(old->read, NGX_READ_EVENT, NGX_CLOSE_EVENT) read 194 event/ngx_event_accept.c rev = c->read; read 353 event/ngx_event_accept.c if (ngx_add_event(c->read, NGX_READ_EVENT, 0) == NGX_ERROR) { read 375 event/ngx_event_accept.c if (!c->read->active) { read 385 event/ngx_event_accept.c if (ngx_del_event(c->read, NGX_READ_EVENT, NGX_DISABLE_EVENT) read 96 event/ngx_event_connect.c rev = c->read; read 552 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 627 event/ngx_event_openssl.c c->read->ready = 0; read 628 event/ngx_event_openssl.c c->read->handler = ngx_ssl_handshake_handler; read 631 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 640 event/ngx_event_openssl.c c->read->handler = ngx_ssl_handshake_handler; read 654 event/ngx_event_openssl.c c->read->eof = 1; read 663 event/ngx_event_openssl.c c->read->error = 1; read 731 event/ngx_event_openssl.c c->read->ready = 1; read 748 event/ngx_event_openssl.c c->read->error = 1; read 753 event/ngx_event_openssl.c c->read->ready = 0; read 754 event/ngx_event_openssl.c c->read->eof = 1; read 799 event/ngx_event_openssl.c c->read->ready = 0; read 800 event/ngx_event_openssl.c c->read->eof = 1; read 804 event/ngx_event_openssl.c c->read->error = 1; read 861 event/ngx_event_openssl.c c->read->ready = 0; read 910 event/ngx_event_openssl.c c->read->handler(c->read); read 1091 event/ngx_event_openssl.c c->read->handler = c->ssl->saved_read_handler; read 1093 event/ngx_event_openssl.c c->read->ready = 1; read 1095 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 1099 event/ngx_event_openssl.c ngx_post_event(c->read, &ngx_posted_events); read 1121 event/ngx_event_openssl.c c->read->ready = 0; read 1123 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 1133 event/ngx_event_openssl.c c->ssl->saved_read_handler = c->read->handler; read 1134 event/ngx_event_openssl.c c->read->handler = ngx_ssl_read_handler; read 1220 event/ngx_event_openssl.c c->read->handler = ngx_ssl_shutdown_handler; read 1223 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 1232 event/ngx_event_openssl.c ngx_add_timer(c->read, 30000); read 45 event/ngx_event_pipe.c p->read = 0; read 54 event/ngx_event_pipe.c if (!p->read && !p->upstream_blocked) { read 62 event/ngx_event_pipe.c rev = p->upstream->read; read 111 event/ngx_event_pipe.c "pipe read upstream: %d", p->upstream->read->ready); read 119 event/ngx_event_pipe.c if (p->preread_bufs == NULL && !p->upstream->read->ready) { read 135 event/ngx_event_pipe.c p->read = 1; read 148 event/ngx_event_pipe.c if (p->upstream->read->available == 0 read 149 event/ngx_event_pipe.c && p->upstream->read->pending_eof) read 151 event/ngx_event_pipe.c p->upstream->read->ready = 0; read 152 event/ngx_event_pipe.c p->upstream->read->eof = 0; read 154 event/ngx_event_pipe.c p->read = 1; read 156 event/ngx_event_pipe.c if (p->upstream->read->kq_errno) { read 157 event/ngx_event_pipe.c p->upstream->read->error = 1; read 162 event/ngx_event_pipe.c p->upstream->read->kq_errno, read 239 event/ngx_event_pipe.c && p->upstream->read->active read 240 event/ngx_event_pipe.c && p->upstream->read->ready) read 242 event/ngx_event_pipe.c if (ngx_del_event(p->upstream->read, NGX_READ_EVENT, 0) read 295 event/ngx_event_pipe.c p->read = 1; read 49 event/ngx_event_pipe.h unsigned read:1; read 256 http/modules/ngx_http_limit_req_module.c if (ngx_handle_read_event(r->connection->read, 0) != NGX_OK) { read 290 http/modules/ngx_http_limit_req_module.c if (ngx_handle_read_event(r->connection->read, 0) != NGX_OK) { read 204 http/ngx_http_request.c rev = c->read; read 614 http/ngx_http_request.c c->read->handler = ngx_http_process_request_line; read 617 http/ngx_http_request.c ngx_http_process_request_line(c->read); read 1126 http/ngx_http_request.c rev = c->read; read 1635 http/ngx_http_request.c if (c->read->timer_set) { read 1636 http/ngx_http_request.c ngx_del_timer(c->read); read 1646 http/ngx_http_request.c c->read->handler = ngx_http_request_handler; read 1926 http/ngx_http_request.c if (c->read->timer_set) { read 1927 http/ngx_http_request.c ngx_del_timer(c->read); read 1935 http/ngx_http_request.c c->read->handler = ngx_http_request_handler; read 2040 http/ngx_http_request.c if (c->read->timer_set) { read 2041 http/ngx_http_request.c ngx_del_timer(c->read); read 2049 http/ngx_http_request.c if (c->read->eof) { read 2133 http/ngx_http_request.c ngx_add_timer(r->connection->read, clcf->lingering_timeout); read 2295 http/ngx_http_request.c && r->connection->read->active) read 2297 http/ngx_http_request.c if (ngx_del_event(r->connection->read, NGX_READ_EVENT, 0) != NGX_OK) { read 2314 http/ngx_http_request.c rev = c->read; read 2392 http/ngx_http_request.c rev = c->read; read 2724 http/ngx_http_request.c rev = c->read; read 245 http/ngx_http_request_body.c if (r->connection->read->timedout) { read 332 http/ngx_http_request_body.c if (!c->read->ready) { read 334 http/ngx_http_request_body.c ngx_add_timer(c->read, clcf->client_body_timeout); read 336 http/ngx_http_request_body.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 344 http/ngx_http_request_body.c if (c->read->timer_set) { read 345 http/ngx_http_request_body.c ngx_del_timer(c->read); read 446 http/ngx_http_request_body.c rev = r->connection->read; read 500 http/ngx_http_request_body.c rev = c->read; read 571 http/ngx_http_request_body.c if (!r->connection->read->ready) { read 411 http/ngx_http_upstream.c "http init upstream, client timer: %d", c->read->timer_set); read 413 http/ngx_http_upstream.c if (c->read->timer_set) { read 414 http/ngx_http_upstream.c ngx_del_timer(c->read); read 913 http/ngx_http_upstream.c ngx_http_upstream_check_broken_connection(r, r->connection->read); read 1120 http/ngx_http_upstream.c c->read->handler = ngx_http_upstream_handler; read 1130 http/ngx_http_upstream.c c->read->log = c->log; read 1251 http/ngx_http_upstream.c c->read->handler = ngx_http_upstream_handler; read 1386 http/ngx_http_upstream.c ngx_add_timer(c->read, u->conf->read_timeout); read 1389 http/ngx_http_upstream.c if (c->read->ready) { read 1466 http/ngx_http_upstream.c if (c->read->timedout) { read 1518 http/ngx_http_upstream.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 1940 http/ngx_http_upstream.c rev = c->read; read 2107 http/ngx_http_upstream.c if (u->peer.connection->read->ready) { read 2344 http/ngx_http_upstream.c if (c->read->timedout) { read 2393 http/ngx_http_upstream.c || upstream->read->eof read 2394 http/ngx_http_upstream.c || upstream->read->error) read 2411 http/ngx_http_upstream.c if (size && upstream->read->ready) { read 2454 http/ngx_http_upstream.c if (ngx_handle_read_event(upstream->read, 0) != NGX_OK) { read 2459 http/ngx_http_upstream.c if (upstream->read->active && !upstream->read->ready) { read 2460 http/ngx_http_upstream.c ngx_add_timer(upstream->read, u->conf->read_timeout); read 2462 http/ngx_http_upstream.c } else if (upstream->read->timer_set) { read 2463 http/ngx_http_upstream.c ngx_del_timer(upstream->read); read 2600 http/ngx_http_upstream.c if (c->read->timedout) { read 386 http/ngx_http_upstream_round_robin.c c->read->lock = c->read->own_lock; read 209 mail/ngx_mail_auth_http_module.c s->connection->read->handler = ngx_mail_auth_http_block_read; read 210 mail/ngx_mail_auth_http_module.c ctx->peer.connection->read->handler = ngx_mail_auth_http_read_handler; read 215 mail/ngx_mail_auth_http_module.c ngx_add_timer(ctx->peer.connection->read, ahcf->timeout); read 723 mail/ngx_mail_auth_http_module.c ngx_add_timer(s->connection->read, (ngx_msec_t) (timer * 1000)); read 725 mail/ngx_mail_auth_http_module.c s->connection->read->handler = ngx_mail_auth_sleep_handler; read 740 mail/ngx_mail_auth_http_module.c ngx_add_timer(s->connection->read, (ngx_msec_t) (timer * 1000)); read 742 mail/ngx_mail_auth_http_module.c s->connection->read->handler = ngx_mail_auth_sleep_handler; read 224 mail/ngx_mail_handler.c ngx_add_timer(c->read, cscf->timeout); read 248 mail/ngx_mail_handler.c c->read->handler = cscf->protocol->init_protocol; read 251 mail/ngx_mail_handler.c cscf->protocol->init_protocol(c->read); read 256 mail/ngx_mail_handler.c c->read->ready = 0; read 575 mail/ngx_mail_handler.c c->read->handler(c->read); read 619 mail/ngx_mail_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 669 mail/ngx_mail_handler.c if (c->read->timer_set) { read 670 mail/ngx_mail_handler.c ngx_del_timer(c->read); read 44 mail/ngx_mail_imap_handler.c c->read->handler = ngx_mail_imap_init_protocol; read 46 mail/ngx_mail_imap_handler.c ngx_add_timer(c->read, cscf->timeout); read 48 mail/ngx_mail_imap_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 94 mail/ngx_mail_imap_handler.c c->read->handler = ngx_mail_imap_auth_state; read 448 mail/ngx_mail_imap_handler.c c->read->handler = ngx_mail_starttls_handler; read 65 mail/ngx_mail_pop3_handler.c c->read->handler = ngx_mail_pop3_init_protocol; read 67 mail/ngx_mail_pop3_handler.c ngx_add_timer(c->read, cscf->timeout); read 69 mail/ngx_mail_pop3_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 112 mail/ngx_mail_pop3_handler.c c->read->handler = ngx_mail_pop3_auth_state; read 378 mail/ngx_mail_pop3_handler.c c->read->handler = ngx_mail_starttls_handler; read 157 mail/ngx_mail_proxy_module.c ngx_add_timer(p->upstream.connection->read, cscf->timeout); read 162 mail/ngx_mail_proxy_module.c s->connection->read->handler = ngx_mail_proxy_block_read; read 179 mail/ngx_mail_proxy_module.c p->upstream.connection->read->handler = ngx_mail_proxy_pop3_handler; read 184 mail/ngx_mail_proxy_module.c p->upstream.connection->read->handler = ngx_mail_proxy_imap_handler; read 189 mail/ngx_mail_proxy_module.c p->upstream.connection->read->handler = ngx_mail_proxy_smtp_handler; read 289 mail/ngx_mail_proxy_module.c s->connection->read->handler = ngx_mail_proxy_handler; read 295 mail/ngx_mail_proxy_module.c ngx_add_timer(s->connection->read, pcf->timeout); read 296 mail/ngx_mail_proxy_module.c ngx_del_timer(c->read); read 423 mail/ngx_mail_proxy_module.c s->connection->read->handler = ngx_mail_proxy_handler; read 429 mail/ngx_mail_proxy_module.c ngx_add_timer(s->connection->read, pcf->timeout); read 430 mail/ngx_mail_proxy_module.c ngx_del_timer(c->read); read 647 mail/ngx_mail_proxy_module.c s->connection->read->handler = ngx_mail_proxy_handler; read 653 mail/ngx_mail_proxy_module.c ngx_add_timer(s->connection->read, pcf->timeout); read 654 mail/ngx_mail_proxy_module.c ngx_del_timer(c->read); read 935 mail/ngx_mail_proxy_module.c if (size && src->read->ready) { read 952 mail/ngx_mail_proxy_module.c src->read->eof = 1; read 961 mail/ngx_mail_proxy_module.c if ((s->connection->read->eof && s->buffer->pos == s->buffer->last) read 962 mail/ngx_mail_proxy_module.c || (s->proxy->upstream.connection->read->eof read 964 mail/ngx_mail_proxy_module.c || (s->connection->read->eof read 965 mail/ngx_mail_proxy_module.c && s->proxy->upstream.connection->read->eof)) read 981 mail/ngx_mail_proxy_module.c if (ngx_handle_read_event(dst->read, 0) != NGX_OK) { read 991 mail/ngx_mail_proxy_module.c if (ngx_handle_read_event(src->read, 0) != NGX_OK) { read 998 mail/ngx_mail_proxy_module.c ngx_add_timer(c->read, pcf->timeout); read 143 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_resolve_name; read 145 mail/ngx_mail_smtp_handler.c ngx_post_event(c->read, &ngx_posted_events); read 252 mail/ngx_mail_smtp_handler.c ngx_add_timer(c->read, timeout); read 254 mail/ngx_mail_smtp_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 259 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_invalid_pipelining; read 263 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_init_protocol; read 292 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_init_protocol; read 294 mail/ngx_mail_smtp_handler.c ngx_add_timer(c->read, cscf->timeout); read 296 mail/ngx_mail_smtp_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 355 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_auth_state; read 797 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_starttls_handler; read 826 mail/ngx_mail_smtp_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { read 21 os/unix/ngx_aio_read.c rev = c->read; read 20 os/unix/ngx_aio_read_chain.c if (c->read->pending_eof) { read 21 os/unix/ngx_aio_read_chain.c c->read->ready = 0; read 31 os/unix/ngx_aio_read_chain.c if (!c->read->ready) { read 60 os/unix/ngx_aio_read_chain.c c->read->pending_eof = 1; read 62 os/unix/ngx_aio_read_chain.c c->read->eof = 0; read 63 os/unix/ngx_aio_read_chain.c c->read->ready = 1; read 210 os/unix/ngx_channel.c rev = c->read; read 48 os/unix/ngx_files.c n = read(file->fd, buf, size); read 109 os/unix/ngx_files.h #define ngx_read_fd read read 786 os/unix/ngx_process_cycle.c c[i].read->handler(c[i].read); read 1030 os/unix/ngx_process_cycle.c && c[i].read read 1031 os/unix/ngx_process_cycle.c && !c[i].read->accept read 1032 os/unix/ngx_process_cycle.c && !c[i].read->channel read 1033 os/unix/ngx_process_cycle.c && !c[i].read->resolver) read 27 os/unix/ngx_readv_chain.c rev = c->read; read 90 os/unix/ngx_readv_chain.c rev = c->read; read 162 os/unix/ngx_readv_chain.c c->read->error = 1; read 214 os/unix/ngx_readv_chain.c rev = c->read; read 251 os/unix/ngx_readv_chain.c c->read->error = 1; read 21 os/unix/ngx_recv.c rev = c->read; read 132 os/unix/ngx_recv.c rev = c->read; read 21 os/unix/ngx_udp_recv.c rev = c->read; read 79 os/unix/ngx_udp_recv.c rev = c->read;