wev 707 core/ngx_connection.c ngx_event_t *rev, *wev; wev 749 core/ngx_connection.c wev = c->write; wev 754 core/ngx_connection.c c->write = wev; wev 761 core/ngx_connection.c ngx_memzero(wev, sizeof(ngx_event_t)); wev 764 core/ngx_connection.c wev->instance = !instance; wev 767 core/ngx_connection.c wev->index = NGX_INVALID_INDEX; wev 770 core/ngx_connection.c wev->data = c; wev 772 core/ngx_connection.c wev->write = 1; wev 2107 core/ngx_resolver.c ngx_event_t *rev, *wev; wev 2147 core/ngx_resolver.c wev = c->write; wev 2150 core/ngx_resolver.c wev->log = &uc->log; wev 2161 core/ngx_resolver.c wev->lock = &c->lock; wev 2163 core/ngx_resolver.c wev->own_lock = &c->lock; wev 2182 core/ngx_resolver.c wev->ready = 1; wev 346 event/modules/ngx_devpoll_module.c ngx_event_t *rev, *wev, **queue; wev 516 event/modules/ngx_devpoll_module.c wev = c->write; wev 518 event/modules/ngx_devpoll_module.c if ((revents & POLLOUT) && wev->active) { wev 521 event/modules/ngx_devpoll_module.c wev->posted_ready = 1; wev 524 event/modules/ngx_devpoll_module.c wev->ready = 1; wev 528 event/modules/ngx_devpoll_module.c ngx_locked_post_event(wev, &ngx_posted_events); wev 531 event/modules/ngx_devpoll_module.c wev->handler(wev); wev 522 event/modules/ngx_epoll_module.c ngx_event_t *rev, *wev, **queue; wev 646 event/modules/ngx_epoll_module.c wev = c->write; wev 648 event/modules/ngx_epoll_module.c if ((revents & EPOLLOUT) && wev->active) { wev 651 event/modules/ngx_epoll_module.c wev->posted_ready = 1; wev 654 event/modules/ngx_epoll_module.c wev->ready = 1; wev 658 event/modules/ngx_epoll_module.c ngx_locked_post_event(wev, &ngx_posted_events); wev 661 event/modules/ngx_epoll_module.c wev->handler(wev); wev 385 event/modules/ngx_eventport_module.c ngx_event_t *ev, *rev, *wev, **queue; wev 499 event/modules/ngx_eventport_module.c wev = c->write; wev 502 event/modules/ngx_eventport_module.c wev->active = 0; wev 547 event/modules/ngx_eventport_module.c wev->posted_ready = 1; wev 550 event/modules/ngx_eventport_module.c wev->ready = 1; wev 554 event/modules/ngx_eventport_module.c ngx_locked_post_event(wev, &ngx_posted_events); wev 557 event/modules/ngx_eventport_module.c wev->handler(wev); wev 297 event/modules/ngx_rtsig_module.c ngx_event_t *rev, *wev, **queue; wev 404 event/modules/ngx_rtsig_module.c wev = c->write; wev 406 event/modules/ngx_rtsig_module.c if ((si.si_band & (POLLOUT|POLLHUP|POLLERR)) && wev->active) { wev 408 event/modules/ngx_rtsig_module.c wev->ready = 1; wev 411 event/modules/ngx_rtsig_module.c ngx_locked_post_event(wev, &ngx_posted_events); wev 414 event/modules/ngx_rtsig_module.c wev->handler(wev); wev 470 event/modules/ngx_rtsig_module.c ngx_event_t *rev, *wev, **queue; wev 581 event/modules/ngx_rtsig_module.c wev = c->write; wev 583 event/modules/ngx_rtsig_module.c if (wev->active wev 584 event/modules/ngx_rtsig_module.c && !wev->closed wev 585 event/modules/ngx_rtsig_module.c && wev->handler wev 592 event/modules/ngx_rtsig_module.c wev->posted_ready = 1; wev 595 event/modules/ngx_rtsig_module.c wev->ready = 1; wev 599 event/modules/ngx_rtsig_module.c ngx_locked_post_event(wev, &ngx_posted_events); wev 602 event/modules/ngx_rtsig_module.c wev->handler(wev); wev 347 event/ngx_event.c ngx_handle_write_event(ngx_event_t *wev, size_t lowat) wev 352 event/ngx_event.c c = wev->data; wev 363 event/ngx_event.c if (!wev->active && !wev->ready) { wev 364 event/ngx_event.c if (ngx_add_event(wev, NGX_WRITE_EVENT, wev 378 event/ngx_event.c if (!wev->active && !wev->ready) { wev 379 event/ngx_event.c if (ngx_add_event(wev, NGX_WRITE_EVENT, NGX_LEVEL_EVENT) wev 388 event/ngx_event.c if (wev->active && wev->ready) { wev 389 event/ngx_event.c if (ngx_del_event(wev, NGX_WRITE_EVENT, NGX_LEVEL_EVENT) wev 402 event/ngx_event.c if (!wev->active && !wev->ready) { wev 403 event/ngx_event.c if (ngx_add_event(wev, NGX_WRITE_EVENT, 0) == NGX_ERROR) { wev 410 event/ngx_event.c if (wev->oneshot && wev->ready) { wev 411 event/ngx_event.c if (ngx_del_event(wev, NGX_WRITE_EVENT, 0) == NGX_ERROR) { wev 577 event/ngx_event.c ngx_event_t *rev, *wev; wev 703 event/ngx_event.c wev = cycle->write_events; wev 705 event/ngx_event.c wev[i].closed = 1; wev 707 event/ngx_event.c wev[i].lock = &c[i].lock; wev 708 event/ngx_event.c wev[i].own_lock = &c[i].lock; wev 546 event/ngx_event.h ngx_int_t ngx_handle_write_event(ngx_event_t *wev, size_t lowat); wev 24 event/ngx_event_accept.c ngx_event_t *rev, *wev; wev 195 event/ngx_event_accept.c wev = c->write; wev 197 event/ngx_event_accept.c wev->ready = 1; wev 212 event/ngx_event_accept.c wev->log = log; wev 231 event/ngx_event_accept.c wev->lock = &c->lock; wev 233 event/ngx_event_accept.c wev->own_lock = &c->lock; wev 21 event/ngx_event_connect.c ngx_event_t *rev, *wev; wev 97 event/ngx_event_connect.c wev = c->write; wev 100 event/ngx_event_connect.c wev->log = pc->log; wev 111 event/ngx_event_connect.c wev->lock = pc->lock; wev 113 event/ngx_event_connect.c wev->own_lock = &c->lock; wev 176 event/ngx_event_connect.c wev->ready = 1; wev 202 event/ngx_event_connect.c wev->ready = 1; wev 228 event/ngx_event_connect.c if (ngx_add_event(wev, NGX_WRITE_EVENT, event) != NGX_OK) { wev 237 event/ngx_event_connect.c wev->ready = 1; wev 22 event/ngx_event_openssl.c static void ngx_ssl_write_handler(ngx_event_t *wev); wev 904 event/ngx_event_openssl.c ngx_ssl_write_handler(ngx_event_t *wev) wev 908 event/ngx_event_openssl.c c = wev->data; wev 28 event/ngx_event_pipe.c ngx_event_t *rev, *wev; wev 79 event/ngx_event_pipe.c wev = p->downstream->write; wev 80 event/ngx_event_pipe.c if (ngx_handle_write_event(wev, p->send_lowat) != NGX_OK) { wev 84 event/ngx_event_pipe.c if (!wev->delayed) { wev 85 event/ngx_event_pipe.c if (wev->active && !wev->ready) { wev 86 event/ngx_event_pipe.c ngx_add_timer(wev, p->send_timeout); wev 88 event/ngx_event_pipe.c } else if (wev->timer_set) { wev 89 event/ngx_event_pipe.c ngx_del_timer(wev); wev 272 http/modules/ngx_http_limit_req_module.c ngx_event_t *wev; wev 277 http/modules/ngx_http_limit_req_module.c wev = r->connection->write; wev 279 http/modules/ngx_http_limit_req_module.c if (!wev->timedout) { wev 281 http/modules/ngx_http_limit_req_module.c if (ngx_handle_write_event(wev, 0) != NGX_OK) { wev 288 http/modules/ngx_http_limit_req_module.c wev->timedout = 0; wev 272 http/modules/perl/ngx_http_perl_module.c ngx_event_t *wev; wev 277 http/modules/perl/ngx_http_perl_module.c wev = r->connection->write; wev 279 http/modules/perl/ngx_http_perl_module.c if (wev->timedout) { wev 280 http/modules/perl/ngx_http_perl_module.c wev->timedout = 0; wev 285 http/modules/perl/ngx_http_perl_module.c if (ngx_handle_write_event(wev, 0) != NGX_OK) { wev 103 http/ngx_http.h void ngx_http_empty_handler(ngx_event_t *wev); wev 2161 http/ngx_http_request.c ngx_event_t *wev; wev 2171 http/ngx_http_request.c wev = r->connection->write; wev 2173 http/ngx_http_request.c if (wev->ready && wev->delayed) { wev 2178 http/ngx_http_request.c if (!wev->delayed) { wev 2179 http/ngx_http_request.c ngx_add_timer(wev, clcf->send_timeout); wev 2182 http/ngx_http_request.c if (ngx_handle_write_event(wev, clcf->send_lowat) != NGX_OK) { wev 2195 http/ngx_http_request.c ngx_event_t *wev; wev 2200 http/ngx_http_request.c wev = c->write; wev 2202 http/ngx_http_request.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, wev->log, 0, wev 2207 http/ngx_http_request.c if (wev->timedout) { wev 2208 http/ngx_http_request.c if (!wev->delayed) { wev 2217 http/ngx_http_request.c wev->timedout = 0; wev 2218 http/ngx_http_request.c wev->delayed = 0; wev 2220 http/ngx_http_request.c if (!wev->ready) { wev 2221 http/ngx_http_request.c ngx_add_timer(wev, clcf->send_timeout); wev 2223 http/ngx_http_request.c if (ngx_handle_write_event(wev, clcf->send_lowat) != NGX_OK) { wev 2231 http/ngx_http_request.c if (wev->delayed || r->aio) { wev 2232 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, wev->log, 0, wev 2235 http/ngx_http_request.c if (ngx_handle_write_event(wev, clcf->send_lowat) != NGX_OK) { wev 2256 http/ngx_http_request.c if (!wev->ready && !wev->delayed) { wev 2257 http/ngx_http_request.c ngx_add_timer(wev, clcf->send_timeout); wev 2260 http/ngx_http_request.c if (ngx_handle_write_event(wev, clcf->send_lowat) != NGX_OK) { wev 2267 http/ngx_http_request.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, wev->log, 0, wev 2385 http/ngx_http_request.c ngx_event_t *rev, *wev; wev 2461 http/ngx_http_request.c wev = c->write; wev 2462 http/ngx_http_request.c wev->handler = ngx_http_empty_handler; wev 2542 http/ngx_http_request.c if (wev->active && (ngx_event_flags & NGX_USE_LEVEL_EVENT)) { wev 2543 http/ngx_http_request.c if (ngx_del_event(wev, NGX_WRITE_EVENT, 0) != NGX_OK) { wev 2716 http/ngx_http_request.c ngx_event_t *rev, *wev; wev 2735 http/ngx_http_request.c wev = c->write; wev 2736 http/ngx_http_request.c wev->handler = ngx_http_empty_handler; wev 2738 http/ngx_http_request.c if (wev->active && (ngx_event_flags & NGX_USE_LEVEL_EVENT)) { wev 2739 http/ngx_http_request.c if (ngx_del_event(wev, NGX_WRITE_EVENT, 0) != NGX_OK) { wev 2816 http/ngx_http_request.c ngx_http_empty_handler(ngx_event_t *wev) wev 2818 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, wev->log, 0, "http empty handler"); wev 2307 http/ngx_http_upstream.c ngx_event_t *wev; wev 2313 http/ngx_http_upstream.c wev = c->write; wev 2320 http/ngx_http_upstream.c if (wev->timedout) { wev 2520 http/ngx_http_upstream.c ngx_event_t *wev; wev 2528 http/ngx_http_upstream.c wev = c->write; wev 2535 http/ngx_http_upstream.c if (wev->timedout) { wev 2537 http/ngx_http_upstream.c if (wev->delayed) { wev 2539 http/ngx_http_upstream.c wev->timedout = 0; wev 2540 http/ngx_http_upstream.c wev->delayed = 0; wev 2542 http/ngx_http_upstream.c if (!wev->ready) { wev 2543 http/ngx_http_upstream.c ngx_add_timer(wev, p->send_timeout); wev 2545 http/ngx_http_upstream.c if (ngx_handle_write_event(wev, p->send_lowat) != NGX_OK) { wev 2552 http/ngx_http_upstream.c if (ngx_event_pipe(p, wev->write) == NGX_ABORT) { wev 2565 http/ngx_http_upstream.c if (wev->delayed) { wev 2570 http/ngx_http_upstream.c if (ngx_handle_write_event(wev, p->send_lowat) != NGX_OK) { wev 385 mail/ngx_mail.h void ngx_mail_send(ngx_event_t *wev); wev 61 mail/ngx_mail_auth_http_module.c static void ngx_mail_auth_http_write_handler(ngx_event_t *wev); wev 226 mail/ngx_mail_auth_http_module.c ngx_mail_auth_http_write_handler(ngx_event_t *wev) wev 234 mail/ngx_mail_auth_http_module.c c = wev->data; wev 239 mail/ngx_mail_auth_http_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, wev->log, 0, wev 242 mail/ngx_mail_auth_http_module.c if (wev->timedout) { wev 243 mail/ngx_mail_auth_http_module.c ngx_log_error(NGX_LOG_ERR, wev->log, NGX_ETIMEDOUT, wev 266 mail/ngx_mail_auth_http_module.c wev->handler = ngx_mail_auth_http_dummy_handler; wev 268 mail/ngx_mail_auth_http_module.c if (wev->timer_set) { wev 269 mail/ngx_mail_auth_http_module.c ngx_del_timer(wev); wev 272 mail/ngx_mail_auth_http_module.c if (ngx_handle_write_event(wev, 0) != NGX_OK) { wev 282 mail/ngx_mail_auth_http_module.c if (!wev->timer_set) { wev 284 mail/ngx_mail_auth_http_module.c ngx_add_timer(wev, ahcf->timeout); wev 535 mail/ngx_mail_handler.c ngx_mail_send(ngx_event_t *wev) wev 542 mail/ngx_mail_handler.c c = wev->data; wev 545 mail/ngx_mail_handler.c if (wev->timedout) { wev 565 mail/ngx_mail_handler.c if (wev->timer_set) { wev 566 mail/ngx_mail_handler.c ngx_del_timer(wev); wev 685 mail/ngx_mail_proxy_module.c ngx_mail_proxy_dummy_handler(ngx_event_t *wev) wev 690 mail/ngx_mail_proxy_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, wev->log, 0, "mail proxy dummy handler"); wev 692 mail/ngx_mail_proxy_module.c if (ngx_handle_write_event(wev, 0) != NGX_OK) { wev 693 mail/ngx_mail_proxy_module.c c = wev->data; wev 19 os/unix/ngx_aio_write.c ngx_event_t *wev; wev 21 os/unix/ngx_aio_write.c wev = c->write; wev 23 os/unix/ngx_aio_write.c if (!wev->ready) { wev 27 os/unix/ngx_aio_write.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, wev->log, 0, wev 28 os/unix/ngx_aio_write.c "aio: wev->complete: %d", wev->complete); wev 30 os/unix/ngx_aio_write.c if (!wev->complete) { wev 31 os/unix/ngx_aio_write.c ngx_memzero(&wev->aiocb, sizeof(struct aiocb)); wev 33 os/unix/ngx_aio_write.c wev->aiocb.aio_fildes = c->fd; wev 34 os/unix/ngx_aio_write.c wev->aiocb.aio_buf = buf; wev 35 os/unix/ngx_aio_write.c wev->aiocb.aio_nbytes = size; wev 38 os/unix/ngx_aio_write.c wev->aiocb.aio_sigevent.sigev_notify_kqueue = ngx_kqueue; wev 39 os/unix/ngx_aio_write.c wev->aiocb.aio_sigevent.sigev_notify = SIGEV_KEVENT; wev 40 os/unix/ngx_aio_write.c wev->aiocb.aio_sigevent.sigev_value.sigval_ptr = wev; wev 43 os/unix/ngx_aio_write.c if (aio_write(&wev->aiocb) == -1) { wev 44 os/unix/ngx_aio_write.c ngx_log_error(NGX_LOG_CRIT, wev->log, ngx_errno, wev 49 os/unix/ngx_aio_write.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, wev->log, 0, "aio_write: OK"); wev 51 os/unix/ngx_aio_write.c wev->active = 1; wev 52 os/unix/ngx_aio_write.c wev->ready = 0; wev 55 os/unix/ngx_aio_write.c wev->complete = 0; wev 57 os/unix/ngx_aio_write.c n = aio_error(&wev->aiocb); wev 59 os/unix/ngx_aio_write.c ngx_log_error(NGX_LOG_CRIT, wev->log, ngx_errno, "aio_error() failed"); wev 60 os/unix/ngx_aio_write.c wev->error = 1; wev 66 os/unix/ngx_aio_write.c if (wev->ready) { wev 67 os/unix/ngx_aio_write.c ngx_log_error(NGX_LOG_ALERT, wev->log, n, wev 69 os/unix/ngx_aio_write.c wev->ready = 0; wev 74 os/unix/ngx_aio_write.c ngx_log_error(NGX_LOG_CRIT, wev->log, n, "aio_write() failed"); wev 75 os/unix/ngx_aio_write.c wev->error = 1; wev 76 os/unix/ngx_aio_write.c wev->ready = 0; wev 79 os/unix/ngx_aio_write.c n = aio_return(&wev->aiocb); wev 81 os/unix/ngx_aio_write.c ngx_log_error(NGX_LOG_ALERT, wev->log, ngx_errno, wev 85 os/unix/ngx_aio_write.c ngx_log_error(NGX_LOG_CRIT, wev->log, n, "aio_return() %d", n); wev 91 os/unix/ngx_aio_write.c n = aio_return(&wev->aiocb); wev 93 os/unix/ngx_aio_write.c ngx_log_error(NGX_LOG_ALERT, wev->log, ngx_errno, wev 96 os/unix/ngx_aio_write.c wev->error = 1; wev 97 os/unix/ngx_aio_write.c wev->ready = 0; wev 102 os/unix/ngx_aio_write.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, wev->log, 0, "aio_write: %d", n); wev 104 os/unix/ngx_aio_write.c wev->active = 0; wev 105 os/unix/ngx_aio_write.c wev->ready = 1; wev 199 os/unix/ngx_channel.c ngx_event_t *ev, *rev, *wev; wev 211 os/unix/ngx_channel.c wev = c->write; wev 214 os/unix/ngx_channel.c wev->log = cycle->log; wev 218 os/unix/ngx_channel.c wev->lock = &c->lock; wev 220 os/unix/ngx_channel.c wev->own_lock = &c->lock; wev 224 os/unix/ngx_channel.c wev->channel = 1; wev 226 os/unix/ngx_channel.c ev = (event == NGX_READ_EVENT) ? rev : wev; wev 49 os/unix/ngx_darwin_sendfile_chain.c ngx_event_t *wev; wev 54 os/unix/ngx_darwin_sendfile_chain.c wev = c->write; wev 56 os/unix/ngx_darwin_sendfile_chain.c if (!wev->ready) { wev 62 os/unix/ngx_darwin_sendfile_chain.c if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { wev 63 os/unix/ngx_darwin_sendfile_chain.c (void) ngx_connection_error(c, wev->kq_errno, wev 65 os/unix/ngx_darwin_sendfile_chain.c wev->error = 1; wev 249 os/unix/ngx_darwin_sendfile_chain.c wev->error = 1; wev 295 os/unix/ngx_darwin_sendfile_chain.c wev->error = 1; wev 355 os/unix/ngx_darwin_sendfile_chain.c wev->ready = 0; wev 51 os/unix/ngx_freebsd_sendfile_chain.c ngx_event_t *wev; wev 56 os/unix/ngx_freebsd_sendfile_chain.c wev = c->write; wev 58 os/unix/ngx_freebsd_sendfile_chain.c if (!wev->ready) { wev 64 os/unix/ngx_freebsd_sendfile_chain.c if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { wev 65 os/unix/ngx_freebsd_sendfile_chain.c (void) ngx_connection_error(c, wev->kq_errno, wev 67 os/unix/ngx_freebsd_sendfile_chain.c wev->error = 1; wev 235 os/unix/ngx_freebsd_sendfile_chain.c wev->error = 1; wev 291 os/unix/ngx_freebsd_sendfile_chain.c wev->error = 1; wev 341 os/unix/ngx_freebsd_sendfile_chain.c wev->error = 1; wev 411 os/unix/ngx_freebsd_sendfile_chain.c wev->ready = 0; wev 420 os/unix/ngx_freebsd_sendfile_chain.c wev->ready = 0; wev 47 os/unix/ngx_linux_sendfile_chain.c ngx_event_t *wev; wev 56 os/unix/ngx_linux_sendfile_chain.c wev = c->write; wev 58 os/unix/ngx_linux_sendfile_chain.c if (!wev->ready) { wev 172 os/unix/ngx_linux_sendfile_chain.c wev->error = 1; wev 197 os/unix/ngx_linux_sendfile_chain.c wev->error = 1; wev 275 os/unix/ngx_linux_sendfile_chain.c wev->error = 1; wev 305 os/unix/ngx_linux_sendfile_chain.c wev->error = 1; wev 367 os/unix/ngx_linux_sendfile_chain.c wev->ready = 0; wev 17 os/unix/ngx_send.c ngx_event_t *wev; wev 19 os/unix/ngx_send.c wev = c->write; wev 23 os/unix/ngx_send.c if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { wev 24 os/unix/ngx_send.c (void) ngx_connection_error(c, wev->kq_errno, wev 26 os/unix/ngx_send.c wev->error = 1; wev 40 os/unix/ngx_send.c wev->ready = 0; wev 52 os/unix/ngx_send.c wev->ready = 0; wev 57 os/unix/ngx_send.c wev->ready = 0; wev 67 os/unix/ngx_send.c wev->error = 1; wev 54 os/unix/ngx_solaris_sendfilev_chain.c ngx_event_t *wev; wev 57 os/unix/ngx_solaris_sendfilev_chain.c wev = c->write; wev 59 os/unix/ngx_solaris_sendfilev_chain.c if (!wev->ready) { wev 180 os/unix/ngx_solaris_sendfilev_chain.c wev->error = 1; wev 240 os/unix/ngx_solaris_sendfilev_chain.c wev->ready = 0; wev 29 os/unix/ngx_writev_chain.c ngx_event_t *wev; wev 32 os/unix/ngx_writev_chain.c wev = c->write; wev 34 os/unix/ngx_writev_chain.c if (!wev->ready) { wev 40 os/unix/ngx_writev_chain.c if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { wev 41 os/unix/ngx_writev_chain.c (void) ngx_connection_error(c, wev->kq_errno, wev 43 os/unix/ngx_writev_chain.c wev->error = 1; wev 122 os/unix/ngx_writev_chain.c wev->error = 1; wev 170 os/unix/ngx_writev_chain.c wev->ready = 0;