rev 707 core/ngx_connection.c ngx_event_t *rev, *wev; rev 748 core/ngx_connection.c rev = c->read; rev 753 core/ngx_connection.c c->read = rev; rev 758 core/ngx_connection.c instance = rev->instance; rev 760 core/ngx_connection.c ngx_memzero(rev, sizeof(ngx_event_t)); rev 763 core/ngx_connection.c rev->instance = !instance; rev 766 core/ngx_connection.c rev->index = NGX_INVALID_INDEX; rev 769 core/ngx_connection.c rev->data = c; rev 68 core/ngx_resolver.c static void ngx_resolver_read_response(ngx_event_t *rev); rev 943 core/ngx_resolver.c ngx_resolver_read_response(ngx_event_t *rev) rev 949 core/ngx_resolver.c c = rev->data; rev 960 core/ngx_resolver.c } while (rev->ready); rev 2107 core/ngx_resolver.c ngx_event_t *rev, *wev; rev 2146 core/ngx_resolver.c rev = c->read; rev 2149 core/ngx_resolver.c rev->log = &uc->log; rev 2160 core/ngx_resolver.c rev->lock = &c->lock; rev 2162 core/ngx_resolver.c rev->own_lock = &c->lock; rev 2191 core/ngx_resolver.c if (ngx_add_event(rev, NGX_READ_EVENT, event) != NGX_OK) { rev 346 event/modules/ngx_devpoll_module.c ngx_event_t *rev, *wev, **queue; rev 494 event/modules/ngx_devpoll_module.c rev = c->read; rev 496 event/modules/ngx_devpoll_module.c if ((revents & POLLIN) && rev->active) { rev 498 event/modules/ngx_devpoll_module.c if ((flags & NGX_POST_THREAD_EVENTS) && !rev->accept) { rev 499 event/modules/ngx_devpoll_module.c rev->posted_ready = 1; rev 502 event/modules/ngx_devpoll_module.c rev->ready = 1; rev 506 event/modules/ngx_devpoll_module.c queue = (ngx_event_t **) (rev->accept ? rev 509 event/modules/ngx_devpoll_module.c ngx_locked_post_event(rev, queue); rev 512 event/modules/ngx_devpoll_module.c rev->handler(rev); rev 522 event/modules/ngx_epoll_module.c ngx_event_t *rev, *wev, **queue; rev 576 event/modules/ngx_epoll_module.c rev = c->read; rev 578 event/modules/ngx_epoll_module.c if (c->fd == -1 || rev->instance != instance) { rev 626 event/modules/ngx_epoll_module.c if ((revents & EPOLLIN) && rev->active) { rev 628 event/modules/ngx_epoll_module.c if ((flags & NGX_POST_THREAD_EVENTS) && !rev->accept) { rev 629 event/modules/ngx_epoll_module.c rev->posted_ready = 1; rev 632 event/modules/ngx_epoll_module.c rev->ready = 1; rev 636 event/modules/ngx_epoll_module.c queue = (ngx_event_t **) (rev->accept ? rev 639 event/modules/ngx_epoll_module.c ngx_locked_post_event(rev, queue); rev 642 event/modules/ngx_epoll_module.c rev->handler(rev); rev 385 event/modules/ngx_eventport_module.c ngx_event_t *ev, *rev, *wev, **queue; rev 498 event/modules/ngx_eventport_module.c rev = c->read; rev 501 event/modules/ngx_eventport_module.c rev->active = 0; rev 506 event/modules/ngx_eventport_module.c if ((flags & NGX_POST_THREAD_EVENTS) && !rev->accept) { rev 507 event/modules/ngx_eventport_module.c rev->posted_ready = 1; rev 510 event/modules/ngx_eventport_module.c rev->ready = 1; rev 514 event/modules/ngx_eventport_module.c queue = (ngx_event_t **) (rev->accept ? rev 517 event/modules/ngx_eventport_module.c ngx_locked_post_event(rev, queue); rev 520 event/modules/ngx_eventport_module.c rev->handler(rev); rev 527 event/modules/ngx_eventport_module.c if (rev->accept) { rev 297 event/modules/ngx_rtsig_module.c ngx_event_t *rev, *wev, **queue; rev 374 event/modules/ngx_rtsig_module.c rev = c->read; rev 376 event/modules/ngx_rtsig_module.c if (rev->instance != instance) { rev 389 event/modules/ngx_rtsig_module.c if ((si.si_band & (POLLIN|POLLHUP|POLLERR)) && rev->active) { rev 391 event/modules/ngx_rtsig_module.c rev->ready = 1; rev 394 event/modules/ngx_rtsig_module.c queue = (ngx_event_t **) (rev->accept ? rev 397 event/modules/ngx_rtsig_module.c ngx_locked_post_event(rev, queue); rev 400 event/modules/ngx_rtsig_module.c rev->handler(rev); rev 470 event/modules/ngx_rtsig_module.c ngx_event_t *rev, *wev, **queue; rev 553 event/modules/ngx_rtsig_module.c rev = c->read; rev 555 event/modules/ngx_rtsig_module.c if (rev->active rev 556 event/modules/ngx_rtsig_module.c && !rev->closed rev 557 event/modules/ngx_rtsig_module.c && rev->handler rev 563 event/modules/ngx_rtsig_module.c if ((flags & NGX_POST_THREAD_EVENTS) && !rev->accept) { rev 564 event/modules/ngx_rtsig_module.c rev->posted_ready = 1; rev 567 event/modules/ngx_rtsig_module.c rev->ready = 1; rev 571 event/modules/ngx_rtsig_module.c queue = (ngx_event_t **) (rev->accept ? rev 574 event/modules/ngx_rtsig_module.c ngx_locked_post_event(rev, queue); rev 577 event/modules/ngx_rtsig_module.c rev->handler(rev); rev 279 event/ngx_event.c ngx_handle_read_event(ngx_event_t *rev, ngx_uint_t flags) rev 285 event/ngx_event.c if (!rev->active && !rev->ready) { rev 286 event/ngx_event.c if (ngx_add_event(rev, NGX_READ_EVENT, NGX_CLEAR_EVENT) rev 299 event/ngx_event.c if (!rev->active && !rev->ready) { rev 300 event/ngx_event.c if (ngx_add_event(rev, NGX_READ_EVENT, NGX_LEVEL_EVENT) rev 309 event/ngx_event.c if (rev->active && (rev->ready || (flags & NGX_CLOSE_EVENT))) { rev 310 event/ngx_event.c if (ngx_del_event(rev, NGX_READ_EVENT, NGX_LEVEL_EVENT | flags) rev 323 event/ngx_event.c if (!rev->active && !rev->ready) { rev 324 event/ngx_event.c if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { rev 331 event/ngx_event.c if (rev->oneshot && !rev->ready) { rev 332 event/ngx_event.c if (ngx_del_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { rev 577 event/ngx_event.c ngx_event_t *rev, *wev; rev 687 event/ngx_event.c rev = cycle->read_events; rev 689 event/ngx_event.c rev[i].closed = 1; rev 690 event/ngx_event.c rev[i].instance = 1; rev 692 event/ngx_event.c rev[i].lock = &c[i].lock; rev 693 event/ngx_event.c rev[i].own_lock = &c[i].lock; rev 749 event/ngx_event.c rev = c->read; rev 751 event/ngx_event.c rev->log = c->log; rev 752 event/ngx_event.c rev->accept = 1; rev 755 event/ngx_event.c rev->deferred_accept = ls[i].deferred_accept; rev 783 event/ngx_event.c rev->handler = ngx_event_acceptex; rev 789 event/ngx_event.c if (ngx_add_event(rev, 0, NGX_IOCP_ACCEPT) == NGX_ERROR) { rev 803 event/ngx_event.c rev->handler = ngx_event_accept; rev 809 event/ngx_event.c if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { rev 816 event/ngx_event.c rev->handler = ngx_event_accept; rev 828 event/ngx_event.c if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { rev 545 event/ngx_event.h ngx_int_t ngx_handle_read_event(ngx_event_t *rev, ngx_uint_t flags); rev 24 event/ngx_event_accept.c ngx_event_t *rev, *wev; rev 194 event/ngx_event_accept.c rev = c->read; rev 201 event/ngx_event_accept.c rev->ready = 1; rev 205 event/ngx_event_accept.c rev->ready = 1; rev 207 event/ngx_event_accept.c rev->available = 1; rev 211 event/ngx_event_accept.c rev->log = log; rev 230 event/ngx_event_accept.c rev->lock = &c->lock; rev 232 event/ngx_event_accept.c rev->own_lock = &c->lock; rev 21 event/ngx_event_connect.c ngx_event_t *rev, *wev; rev 96 event/ngx_event_connect.c rev = c->read; rev 99 event/ngx_event_connect.c rev->log = pc->log; rev 110 event/ngx_event_connect.c rev->lock = pc->lock; rev 112 event/ngx_event_connect.c rev->own_lock = &c->lock; rev 201 event/ngx_event_connect.c rev->ready = 1; rev 220 event/ngx_event_connect.c if (ngx_add_event(rev, NGX_READ_EVENT, event) != NGX_OK) { rev 23 event/ngx_event_openssl.c static void ngx_ssl_read_handler(ngx_event_t *rev); rev 1151 event/ngx_event_openssl.c ngx_ssl_read_handler(ngx_event_t *rev) rev 1155 event/ngx_event_openssl.c c = rev->data; rev 28 event/ngx_event_pipe.c ngx_event_t *rev, *wev; rev 62 event/ngx_event_pipe.c rev = p->upstream->read; rev 64 event/ngx_event_pipe.c flags = (rev->eof || rev->error) ? NGX_CLOSE_EVENT : 0; rev 66 event/ngx_event_pipe.c if (ngx_handle_read_event(rev, flags) != NGX_OK) { rev 70 event/ngx_event_pipe.c if (rev->active && !rev->ready) { rev 71 event/ngx_event_pipe.c ngx_add_timer(rev, p->read_timeout); rev 73 event/ngx_event_pipe.c } else if (rev->timer_set) { rev 74 event/ngx_event_pipe.c ngx_del_timer(rev); rev 13 http/ngx_http_request.c static void ngx_http_process_request_line(ngx_event_t *rev); rev 14 http/ngx_http_request.c static void ngx_http_process_request_headers(ngx_event_t *rev); rev 62 http/ngx_http_request.c static void ngx_http_ssl_handshake(ngx_event_t *rev); rev 184 http/ngx_http_request.c ngx_event_t *rev; rev 204 http/ngx_http_request.c rev = c->read; rev 205 http/ngx_http_request.c rev->handler = ngx_http_init_request; rev 212 http/ngx_http_request.c if (rev->ready) { rev 216 http/ngx_http_request.c ngx_post_event(rev, &ngx_posted_events); rev 220 http/ngx_http_request.c ngx_http_init_request(rev); rev 224 http/ngx_http_request.c ngx_add_timer(rev, c->listening->post_accept_timeout); rev 226 http/ngx_http_request.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 237 http/ngx_http_request.c ngx_http_init_request(ngx_event_t *rev) rev 261 http/ngx_http_request.c c = rev->data; rev 263 http/ngx_http_request.c if (rev->timedout) { rev 394 http/ngx_http_request.c rev->handler = ngx_http_process_request_line; rev 424 http/ngx_http_request.c rev->handler = ngx_http_ssl_handshake; rev 518 http/ngx_http_request.c rev->handler(rev); rev 525 http/ngx_http_request.c ngx_http_ssl_handshake(ngx_event_t *rev) rev 533 http/ngx_http_request.c c = rev->data; rev 536 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, rev 539 http/ngx_http_request.c if (rev->timedout) { rev 550 http/ngx_http_request.c if (!rev->timer_set) { rev 551 http/ngx_http_request.c ngx_add_timer(rev, c->listening->post_accept_timeout); rev 554 http/ngx_http_request.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 563 http/ngx_http_request.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, rev->log, 0, rev 570 http/ngx_http_request.c if (!rev->timer_set) { rev 571 http/ngx_http_request.c ngx_add_timer(rev, c->listening->post_accept_timeout); rev 583 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, rev 592 http/ngx_http_request.c rev->handler = ngx_http_process_request_line; rev 593 http/ngx_http_request.c ngx_http_process_request_line(rev); rev 685 http/ngx_http_request.c ngx_http_process_request_line(ngx_event_t *rev) rev 694 http/ngx_http_request.c c = rev->data; rev 697 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, rev 700 http/ngx_http_request.c if (rev->timedout) { rev 892 http/ngx_http_request.c rev->handler = ngx_http_process_request_headers; rev 893 http/ngx_http_request.c ngx_http_process_request_headers(rev); rev 934 http/ngx_http_request.c ngx_http_process_request_headers(ngx_event_t *rev) rev 947 http/ngx_http_request.c c = rev->data; rev 950 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, rev 953 http/ngx_http_request.c if (rev->timedout) { rev 1121 http/ngx_http_request.c ngx_event_t *rev; rev 1126 http/ngx_http_request.c rev = c->read; rev 1134 http/ngx_http_request.c if (rev->ready) { rev 1142 http/ngx_http_request.c if (!rev->timer_set) { rev 1144 http/ngx_http_request.c ngx_add_timer(rev, cscf->client_header_timeout); rev 1147 http/ngx_http_request.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 2310 http/ngx_http_request.c ngx_event_t *rev; rev 2314 http/ngx_http_request.c rev = c->read; rev 2322 http/ngx_http_request.c if (!rev->pending_eof) { rev 2326 http/ngx_http_request.c rev->eof = 1; rev 2328 http/ngx_http_request.c err = rev->kq_errno; rev 2338 http/ngx_http_request.c rev->eof = 1; rev 2348 http/ngx_http_request.c rev->eof = 1; rev 2357 http/ngx_http_request.c if ((ngx_event_flags & NGX_USE_LEVEL_EVENT) && rev->active) { rev 2359 http/ngx_http_request.c if (ngx_del_event(rev, NGX_READ_EVENT, 0) != NGX_OK) { rev 2369 http/ngx_http_request.c rev->error = 1; rev 2385 http/ngx_http_request.c ngx_event_t *rev, *wev; rev 2392 http/ngx_http_request.c rev = c->read; rev 2401 http/ngx_http_request.c ngx_add_timer(rev, clcf->lingering_timeout); rev 2454 http/ngx_http_request.c ngx_add_timer(rev, clcf->keepalive_timeout); rev 2456 http/ngx_http_request.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 2475 http/ngx_http_request.c rev->handler = ngx_http_init_request; rev 2476 http/ngx_http_request.c ngx_post_event(rev, &ngx_posted_events); rev 2540 http/ngx_http_request.c rev->handler = ngx_http_keepalive_handler; rev 2599 http/ngx_http_request.c if (rev->ready) { rev 2600 http/ngx_http_request.c ngx_post_event(rev, &ngx_posted_events); rev 2606 http/ngx_http_request.c ngx_http_keepalive_handler(ngx_event_t *rev) rev 2613 http/ngx_http_request.c c = rev->data; rev 2617 http/ngx_http_request.c if (rev->timedout || c->close) { rev 2625 http/ngx_http_request.c if (rev->pending_eof) { rev 2627 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, rev->kq_errno, rev 2676 http/ngx_http_request.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 2709 http/ngx_http_request.c ngx_http_init_request(rev); rev 2716 http/ngx_http_request.c ngx_event_t *rev, *wev; rev 2724 http/ngx_http_request.c rev = c->read; rev 2725 http/ngx_http_request.c rev->handler = ngx_http_lingering_close_handler; rev 2728 http/ngx_http_request.c ngx_add_timer(rev, clcf->lingering_timeout); rev 2730 http/ngx_http_request.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 2752 http/ngx_http_request.c if (rev->ready) { rev 2753 http/ngx_http_request.c ngx_http_lingering_close_handler(rev); rev 2759 http/ngx_http_request.c ngx_http_lingering_close_handler(ngx_event_t *rev) rev 2768 http/ngx_http_request.c c = rev->data; rev 2774 http/ngx_http_request.c if (rev->timedout) { rev 2796 http/ngx_http_request.c } while (rev->ready); rev 2798 http/ngx_http_request.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 2811 http/ngx_http_request.c ngx_add_timer(rev, timer); rev 436 http/ngx_http_request_body.c ngx_event_t *rev; rev 446 http/ngx_http_request_body.c rev = r->connection->read; rev 448 http/ngx_http_request_body.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, "http set discard body"); rev 450 http/ngx_http_request_body.c if (rev->timer_set) { rev 451 http/ngx_http_request_body.c ngx_del_timer(rev); rev 474 http/ngx_http_request_body.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 495 http/ngx_http_request_body.c ngx_event_t *rev; rev 500 http/ngx_http_request_body.c rev = c->read; rev 502 http/ngx_http_request_body.c if (rev->timedout) { rev 534 http/ngx_http_request_body.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 550 http/ngx_http_request_body.c ngx_add_timer(rev, timer); rev 1515 http/ngx_http_upstream.c ngx_add_timer(rev, u->read_timeout); rev 1936 http/ngx_http_upstream.c ngx_event_t *rev; rev 1940 http/ngx_http_upstream.c rev = c->read; rev 1945 http/ngx_http_upstream.c if (rev->timedout) { rev 1982 http/ngx_http_upstream.c if (!rev->ready) { rev 1987 http/ngx_http_upstream.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 1992 http/ngx_http_upstream.c if (rev->active) { rev 1993 http/ngx_http_upstream.c ngx_add_timer(rev, u->conf->read_timeout); rev 1995 http/ngx_http_upstream.c } else if (rev->timer_set) { rev 1996 http/ngx_http_upstream.c ngx_del_timer(rev); rev 308 mail/ngx_mail.h typedef void (*ngx_mail_init_protocol_pt)(ngx_event_t *rev); rev 309 mail/ngx_mail.h typedef void (*ngx_mail_auth_state_pt)(ngx_event_t *rev); rev 365 mail/ngx_mail.h void ngx_mail_starttls_handler(ngx_event_t *rev); rev 62 mail/ngx_mail_auth_http_module.c static void ngx_mail_auth_http_read_handler(ngx_event_t *rev); rev 67 mail/ngx_mail_auth_http_module.c static void ngx_mail_auth_sleep_handler(ngx_event_t *rev); rev 70 mail/ngx_mail_auth_http_module.c static void ngx_mail_auth_http_block_read(ngx_event_t *rev); rev 290 mail/ngx_mail_auth_http_module.c ngx_mail_auth_http_read_handler(ngx_event_t *rev) rev 297 mail/ngx_mail_auth_http_module.c c = rev->data; rev 300 mail/ngx_mail_auth_http_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 305 mail/ngx_mail_auth_http_module.c if (rev->timedout) { rev 306 mail/ngx_mail_auth_http_module.c ngx_log_error(NGX_LOG_ERR, rev->log, NGX_ETIMEDOUT, rev 856 mail/ngx_mail_auth_http_module.c ngx_mail_auth_sleep_handler(ngx_event_t *rev) rev 862 mail/ngx_mail_auth_http_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail auth sleep handler"); rev 864 mail/ngx_mail_auth_http_module.c c = rev->data; rev 867 mail/ngx_mail_auth_http_module.c if (rev->timedout) { rev 869 mail/ngx_mail_auth_http_module.c rev->timedout = 0; rev 879 mail/ngx_mail_auth_http_module.c rev->handler = cscf->protocol->auth_state; rev 892 mail/ngx_mail_auth_http_module.c ngx_add_timer(rev, cscf->timeout); rev 894 mail/ngx_mail_auth_http_module.c if (rev->ready) { rev 895 mail/ngx_mail_auth_http_module.c rev->handler(rev); rev 899 mail/ngx_mail_auth_http_module.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 906 mail/ngx_mail_auth_http_module.c if (rev->active) { rev 907 mail/ngx_mail_auth_http_module.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 1098 mail/ngx_mail_auth_http_module.c ngx_mail_auth_http_block_read(ngx_event_t *rev) rev 1104 mail/ngx_mail_auth_http_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 1107 mail/ngx_mail_auth_http_module.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 1108 mail/ngx_mail_auth_http_module.c c = rev->data; rev 189 mail/ngx_mail_handler.c ngx_mail_starttls_handler(ngx_event_t *rev) rev 195 mail/ngx_mail_handler.c c = rev->data; rev 57 mail/ngx_mail_imap_handler.c ngx_mail_imap_init_protocol(ngx_event_t *rev) rev 63 mail/ngx_mail_imap_handler.c c = rev->data; rev 67 mail/ngx_mail_imap_handler.c if (rev->timedout) { rev 96 mail/ngx_mail_imap_handler.c ngx_mail_imap_auth_state(rev); rev 101 mail/ngx_mail_imap_handler.c ngx_mail_imap_auth_state(ngx_event_t *rev) rev 110 mail/ngx_mail_imap_handler.c c = rev->data; rev 115 mail/ngx_mail_imap_handler.c if (rev->timedout) { rev 30 mail/ngx_mail_imap_module.h void ngx_mail_imap_init_protocol(ngx_event_t *rev); rev 31 mail/ngx_mail_imap_module.h void ngx_mail_imap_auth_state(ngx_event_t *rev); rev 78 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_init_protocol(ngx_event_t *rev) rev 83 mail/ngx_mail_pop3_handler.c c = rev->data; rev 87 mail/ngx_mail_pop3_handler.c if (rev->timedout) { rev 114 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_auth_state(rev); rev 119 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_auth_state(ngx_event_t *rev) rev 125 mail/ngx_mail_pop3_handler.c c = rev->data; rev 130 mail/ngx_mail_pop3_handler.c if (rev->timedout) { rev 29 mail/ngx_mail_pop3_module.h void ngx_mail_pop3_init_protocol(ngx_event_t *rev); rev 30 mail/ngx_mail_pop3_module.h void ngx_mail_pop3_auth_state(ngx_event_t *rev); rev 23 mail/ngx_mail_proxy_module.c static void ngx_mail_proxy_block_read(ngx_event_t *rev); rev 24 mail/ngx_mail_proxy_module.c static void ngx_mail_proxy_pop3_handler(ngx_event_t *rev); rev 25 mail/ngx_mail_proxy_module.c static void ngx_mail_proxy_imap_handler(ngx_event_t *rev); rev 26 mail/ngx_mail_proxy_module.c static void ngx_mail_proxy_smtp_handler(ngx_event_t *rev); rev 197 mail/ngx_mail_proxy_module.c ngx_mail_proxy_block_read(ngx_event_t *rev) rev 202 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy block read"); rev 204 mail/ngx_mail_proxy_module.c if (ngx_handle_read_event(rev, 0) != NGX_OK) { rev 205 mail/ngx_mail_proxy_module.c c = rev->data; rev 214 mail/ngx_mail_proxy_module.c ngx_mail_proxy_pop3_handler(ngx_event_t *rev) rev 223 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 226 mail/ngx_mail_proxy_module.c c = rev->data; rev 229 mail/ngx_mail_proxy_module.c if (rev->timedout) { rev 251 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy send user"); rev 270 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy send pass"); rev 291 mail/ngx_mail_proxy_module.c rev->handler = ngx_mail_proxy_handler; rev 327 mail/ngx_mail_proxy_module.c ngx_mail_proxy_imap_handler(ngx_event_t *rev) rev 336 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 339 mail/ngx_mail_proxy_module.c c = rev->data; rev 342 mail/ngx_mail_proxy_module.c if (rev->timedout) { rev 364 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 385 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy send user"); rev 404 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 425 mail/ngx_mail_proxy_module.c rev->handler = ngx_mail_proxy_handler; rev 461 mail/ngx_mail_proxy_module.c ngx_mail_proxy_smtp_handler(ngx_event_t *rev) rev 472 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 475 mail/ngx_mail_proxy_module.c c = rev->data; rev 478 mail/ngx_mail_proxy_module.c if (rev->timedout) { rev 500 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy send ehlo"); rev 535 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 569 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 594 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 614 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, rev 649 mail/ngx_mail_proxy_module.c rev->handler = ngx_mail_proxy_handler; rev 15 mail/ngx_mail_smtp_handler.c static void ngx_mail_smtp_resolve_name(ngx_event_t *rev); rev 18 mail/ngx_mail_smtp_handler.c static void ngx_mail_smtp_invalid_pipelining(ngx_event_t *rev); rev 150 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_resolve_name(ngx_event_t *rev) rev 157 mail/ngx_mail_smtp_handler.c c = rev->data; rev 272 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_invalid_pipelining(ngx_event_t *rev) rev 279 mail/ngx_mail_smtp_handler.c c = rev->data; rev 284 mail/ngx_mail_smtp_handler.c if (rev->timedout) { rev 288 mail/ngx_mail_smtp_handler.c rev->timedout = 0; rev 330 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_init_protocol(ngx_event_t *rev) rev 335 mail/ngx_mail_smtp_handler.c c = rev->data; rev 339 mail/ngx_mail_smtp_handler.c if (rev->timedout) { rev 357 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_auth_state(rev); rev 384 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_auth_state(ngx_event_t *rev) rev 390 mail/ngx_mail_smtp_handler.c c = rev->data; rev 395 mail/ngx_mail_smtp_handler.c if (rev->timedout) { rev 36 mail/ngx_mail_smtp_module.h void ngx_mail_smtp_init_protocol(ngx_event_t *rev); rev 37 mail/ngx_mail_smtp_module.h void ngx_mail_smtp_auth_state(ngx_event_t *rev); rev 19 os/unix/ngx_aio_read.c ngx_event_t *rev; rev 21 os/unix/ngx_aio_read.c rev = c->read; rev 23 os/unix/ngx_aio_read.c if (!rev->ready) { rev 29 os/unix/ngx_aio_read.c "rev->complete: %d", rev->complete); rev 33 os/unix/ngx_aio_read.c if (!rev->complete) { rev 34 os/unix/ngx_aio_read.c ngx_memzero(&rev->aiocb, sizeof(struct aiocb)); rev 36 os/unix/ngx_aio_read.c rev->aiocb.aio_fildes = c->fd; rev 37 os/unix/ngx_aio_read.c rev->aiocb.aio_buf = buf; rev 38 os/unix/ngx_aio_read.c rev->aiocb.aio_nbytes = size; rev 41 os/unix/ngx_aio_read.c rev->aiocb.aio_sigevent.sigev_notify_kqueue = ngx_kqueue; rev 42 os/unix/ngx_aio_read.c rev->aiocb.aio_sigevent.sigev_notify = SIGEV_KEVENT; rev 43 os/unix/ngx_aio_read.c rev->aiocb.aio_sigevent.sigev_value.sigval_ptr = rev; rev 46 os/unix/ngx_aio_read.c if (aio_read(&rev->aiocb) == -1) { rev 47 os/unix/ngx_aio_read.c ngx_log_error(NGX_LOG_CRIT, rev->log, ngx_errno, rev 49 os/unix/ngx_aio_read.c rev->error = 1; rev 56 os/unix/ngx_aio_read.c rev->active = 1; rev 57 os/unix/ngx_aio_read.c rev->ready = 0; rev 60 os/unix/ngx_aio_read.c rev->complete = 0; rev 62 os/unix/ngx_aio_read.c n = aio_error(&rev->aiocb); rev 65 os/unix/ngx_aio_read.c rev->error = 1; rev 71 os/unix/ngx_aio_read.c if (rev->ready) { rev 74 os/unix/ngx_aio_read.c rev->ready = 0; rev 80 os/unix/ngx_aio_read.c rev->error = 1; rev 81 os/unix/ngx_aio_read.c rev->ready = 0; rev 85 os/unix/ngx_aio_read.c n = aio_return(&rev->aiocb); rev 90 os/unix/ngx_aio_read.c rev->error = 1; rev 91 os/unix/ngx_aio_read.c rev->ready = 0; rev 95 os/unix/ngx_aio_read.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, rev->log, 0, rev 99 os/unix/ngx_aio_read.c rev->eof = 1; rev 100 os/unix/ngx_aio_read.c rev->ready = 0; rev 102 os/unix/ngx_aio_read.c rev->ready = 1; rev 105 os/unix/ngx_aio_read.c rev->active = 0; rev 199 os/unix/ngx_channel.c ngx_event_t *ev, *rev, *wev; rev 210 os/unix/ngx_channel.c rev = c->read; rev 213 os/unix/ngx_channel.c rev->log = cycle->log; rev 217 os/unix/ngx_channel.c rev->lock = &c->lock; rev 219 os/unix/ngx_channel.c rev->own_lock = &c->lock; rev 223 os/unix/ngx_channel.c rev->channel = 1; rev 226 os/unix/ngx_channel.c ev = (event == NGX_READ_EVENT) ? rev : wev; rev 24 os/unix/ngx_readv_chain.c ngx_event_t *rev; rev 27 os/unix/ngx_readv_chain.c rev = c->read; rev 32 os/unix/ngx_readv_chain.c rev->pending_eof, rev->available, rev->kq_errno); rev 34 os/unix/ngx_readv_chain.c if (rev->available == 0) { rev 35 os/unix/ngx_readv_chain.c if (rev->pending_eof) { rev 36 os/unix/ngx_readv_chain.c rev->ready = 0; rev 37 os/unix/ngx_readv_chain.c rev->eof = 1; rev 39 os/unix/ngx_readv_chain.c ngx_log_error(NGX_LOG_INFO, c->log, rev->kq_errno, rev 42 os/unix/ngx_readv_chain.c if (rev->kq_errno) { rev 43 os/unix/ngx_readv_chain.c rev->error = 1; rev 44 os/unix/ngx_readv_chain.c ngx_set_socket_errno(rev->kq_errno); rev 90 os/unix/ngx_readv_chain.c rev = c->read; rev 97 os/unix/ngx_readv_chain.c rev->available -= n; rev 104 os/unix/ngx_readv_chain.c if (rev->available <= 0) { rev 105 os/unix/ngx_readv_chain.c if (!rev->pending_eof) { rev 106 os/unix/ngx_readv_chain.c rev->ready = 0; rev 109 os/unix/ngx_readv_chain.c if (rev->available < 0) { rev 110 os/unix/ngx_readv_chain.c rev->available = 0; rev 124 os/unix/ngx_readv_chain.c "%d available bytes", rev->available); rev 127 os/unix/ngx_readv_chain.c rev->eof = 1; rev 128 os/unix/ngx_readv_chain.c rev->available = 0; rev 135 os/unix/ngx_readv_chain.c rev->ready = 0; rev 139 os/unix/ngx_readv_chain.c rev->eof = 1; rev 159 os/unix/ngx_readv_chain.c rev->ready = 0; rev 177 os/unix/ngx_readv_chain.c ngx_event_t *rev; rev 214 os/unix/ngx_readv_chain.c rev = c->read; rev 220 os/unix/ngx_readv_chain.c rev->ready = 0; rev 221 os/unix/ngx_readv_chain.c rev->eof = 1; rev 228 os/unix/ngx_readv_chain.c rev->ready = 0; rev 248 os/unix/ngx_readv_chain.c rev->ready = 0; rev 19 os/unix/ngx_recv.c ngx_event_t *rev; rev 21 os/unix/ngx_recv.c rev = c->read; rev 26 os/unix/ngx_recv.c rev->pending_eof, rev->available, rev->kq_errno); rev 28 os/unix/ngx_recv.c if (rev->available == 0) { rev 29 os/unix/ngx_recv.c if (rev->pending_eof) { rev 30 os/unix/ngx_recv.c rev->ready = 0; rev 31 os/unix/ngx_recv.c rev->eof = 1; rev 33 os/unix/ngx_recv.c if (rev->kq_errno) { rev 34 os/unix/ngx_recv.c rev->error = 1; rev 35 os/unix/ngx_recv.c ngx_set_socket_errno(rev->kq_errno); rev 37 os/unix/ngx_recv.c return ngx_connection_error(c, rev->kq_errno, rev 44 os/unix/ngx_recv.c rev->ready = 0; rev 58 os/unix/ngx_recv.c rev->available -= n; rev 65 os/unix/ngx_recv.c if (rev->available <= 0) { rev 66 os/unix/ngx_recv.c if (!rev->pending_eof) { rev 67 os/unix/ngx_recv.c rev->ready = 0; rev 70 os/unix/ngx_recv.c if (rev->available < 0) { rev 71 os/unix/ngx_recv.c rev->available = 0; rev 82 os/unix/ngx_recv.c rev->eof = 1; rev 83 os/unix/ngx_recv.c rev->available = 0; rev 90 os/unix/ngx_recv.c rev->ready = 0; rev 94 os/unix/ngx_recv.c rev->eof = 1; rev 114 os/unix/ngx_recv.c rev->ready = 0; rev 117 os/unix/ngx_recv.c rev->error = 1; rev 130 os/unix/ngx_recv.c ngx_event_t *rev; rev 132 os/unix/ngx_recv.c rev = c->read; rev 141 os/unix/ngx_recv.c rev->ready = 0; rev 142 os/unix/ngx_recv.c rev->eof = 1; rev 150 os/unix/ngx_recv.c rev->ready = 0; rev 170 os/unix/ngx_recv.c rev->ready = 0; rev 173 os/unix/ngx_recv.c rev->error = 1; rev 19 os/unix/ngx_udp_recv.c ngx_event_t *rev; rev 21 os/unix/ngx_udp_recv.c rev = c->read; rev 31 os/unix/ngx_udp_recv.c rev->available -= n; rev 38 os/unix/ngx_udp_recv.c if (rev->available <= 0) { rev 39 os/unix/ngx_udp_recv.c rev->ready = 0; rev 40 os/unix/ngx_udp_recv.c rev->available = 0; rev 61 os/unix/ngx_udp_recv.c rev->ready = 0; rev 64 os/unix/ngx_udp_recv.c rev->error = 1; rev 77 os/unix/ngx_udp_recv.c ngx_event_t *rev; rev 79 os/unix/ngx_udp_recv.c rev = c->read; rev 105 os/unix/ngx_udp_recv.c rev->ready = 0; rev 108 os/unix/ngx_udp_recv.c rev->error = 1;