ev 25 core/ngx_core.h typedef void (*ngx_event_handler_pt)(ngx_event_t *ev); ev 17 core/ngx_cycle.c static void ngx_clean_old_cycles(ngx_event_t *ev); ev 1330 core/ngx_cycle.c ngx_clean_old_cycles(ngx_event_t *ev) ev 1376 core/ngx_cycle.c ngx_add_timer(ev, 30000); ev 39 core/ngx_open_file_cache.c static void ngx_open_file_cache_remove(ngx_event_t *ev); ev 860 core/ngx_open_file_cache.c ngx_open_file_cache_remove(ngx_event_t *ev) ev 865 core/ngx_open_file_cache.c fev = ev->data; ev 880 core/ngx_open_file_cache.c ngx_close_cached_file(fev->cache, file, 0, ev->log); ev 884 core/ngx_open_file_cache.c ngx_free(ev->data); ev 885 core/ngx_open_file_cache.c ngx_free(ev); ev 65 core/ngx_resolver.c static void ngx_resolver_resend_handler(ngx_event_t *ev); ev 83 core/ngx_resolver.c static void ngx_resolver_timeout_handler(ngx_event_t *ev); ev 857 core/ngx_resolver.c ngx_resolver_resend_handler(ngx_event_t *ev) ev 862 core/ngx_resolver.c r = ev->data; ev 1952 core/ngx_resolver.c ngx_resolver_timeout_handler(ngx_event_t *ev) ev 1956 core/ngx_resolver.c ctx = ev->data; ev 17 event/modules/ngx_aio_module.c static ngx_int_t ngx_aio_add_event(ngx_event_t *ev, ngx_int_t event, ev 19 event/modules/ngx_aio_module.c static ngx_int_t ngx_aio_del_event(ngx_event_t *ev, ngx_int_t event, ev 103 event/modules/ngx_aio_module.c ngx_aio_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 105 event/modules/ngx_aio_module.c return ngx_kqueue_module_ctx.actions.add(ev, event, flags); ev 110 event/modules/ngx_aio_module.c ngx_aio_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 112 event/modules/ngx_aio_module.c return ngx_kqueue_module_ctx.actions.del(ev, event, flags); ev 37 event/modules/ngx_devpoll_module.c static ngx_int_t ngx_devpoll_add_event(ngx_event_t *ev, ngx_int_t event, ev 39 event/modules/ngx_devpoll_module.c static ngx_int_t ngx_devpoll_del_event(ngx_event_t *ev, ngx_int_t event, ev 41 event/modules/ngx_devpoll_module.c static ngx_int_t ngx_devpoll_set_event(ngx_event_t *ev, ngx_int_t event, ev 215 event/modules/ngx_devpoll_module.c ngx_devpoll_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 226 event/modules/ngx_devpoll_module.c c = ev->data; ev 227 event/modules/ngx_devpoll_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 231 event/modules/ngx_devpoll_module.c ev->active = 1; ev 233 event/modules/ngx_devpoll_module.c return ngx_devpoll_set_event(ev, event, 0); ev 238 event/modules/ngx_devpoll_module.c ngx_devpoll_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 243 event/modules/ngx_devpoll_module.c c = ev->data; ev 249 event/modules/ngx_devpoll_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 252 event/modules/ngx_devpoll_module.c if (ngx_devpoll_set_event(ev, POLLREMOVE, flags) == NGX_ERROR) { ev 256 event/modules/ngx_devpoll_module.c ev->active = 0; ev 288 event/modules/ngx_devpoll_module.c ngx_devpoll_set_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 293 event/modules/ngx_devpoll_module.c c = ev->data; ev 295 event/modules/ngx_devpoll_module.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 299 event/modules/ngx_devpoll_module.c ngx_log_error(NGX_LOG_WARN, ev->log, 0, ev 304 event/modules/ngx_devpoll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, ev 316 event/modules/ngx_devpoll_module.c change_index[nchanges] = ev; ev 317 event/modules/ngx_devpoll_module.c ev->index = nchanges; ev 324 event/modules/ngx_devpoll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, ev 94 event/modules/ngx_epoll_module.c static ngx_int_t ngx_epoll_add_event(ngx_event_t *ev, ngx_int_t event, ev 96 event/modules/ngx_epoll_module.c static ngx_int_t ngx_epoll_del_event(ngx_event_t *ev, ngx_int_t event, ev 105 event/modules/ngx_epoll_module.c static void ngx_epoll_eventfd_handler(ngx_event_t *ev); ev 336 event/modules/ngx_epoll_module.c ngx_epoll_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 344 event/modules/ngx_epoll_module.c c = ev->data; ev 372 event/modules/ngx_epoll_module.c ee.data.ptr = (void *) ((uintptr_t) c | ev->instance); ev 374 event/modules/ngx_epoll_module.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 379 event/modules/ngx_epoll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, ev 384 event/modules/ngx_epoll_module.c ev->active = 1; ev 386 event/modules/ngx_epoll_module.c ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1 : 0; ev 394 event/modules/ngx_epoll_module.c ngx_epoll_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 409 event/modules/ngx_epoll_module.c ev->active = 0; ev 413 event/modules/ngx_epoll_module.c c = ev->data; ev 427 event/modules/ngx_epoll_module.c ee.data.ptr = (void *) ((uintptr_t) c | ev->instance); ev 435 event/modules/ngx_epoll_module.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 440 event/modules/ngx_epoll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, ev 445 event/modules/ngx_epoll_module.c ev->active = 0; ev 675 event/modules/ngx_epoll_module.c ngx_epoll_eventfd_handler(ngx_event_t *ev) ev 686 event/modules/ngx_epoll_module.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, 0, "eventfd handler"); ev 692 event/modules/ngx_epoll_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ev->log, 0, "eventfd: %d", n); ev 700 event/modules/ngx_epoll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, err, "read(eventfd) failed"); ev 704 event/modules/ngx_epoll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, 0, ev 716 event/modules/ngx_epoll_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 724 event/modules/ngx_epoll_module.c ngx_log_debug4(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 749 event/modules/ngx_epoll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, -events, "io_getevents() failed"); ev 100 event/modules/ngx_eventport_module.c static ngx_int_t ngx_eventport_add_event(ngx_event_t *ev, ngx_int_t event, ev 102 event/modules/ngx_eventport_module.c static ngx_int_t ngx_eventport_del_event(ngx_event_t *ev, ngx_int_t event, ev 268 event/modules/ngx_eventport_module.c ngx_eventport_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 274 event/modules/ngx_eventport_module.c c = ev->data; ev 297 event/modules/ngx_eventport_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 301 event/modules/ngx_eventport_module.c (void *) ((uintptr_t) ev | ev->instance)) ev 304 event/modules/ngx_eventport_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, ev 309 event/modules/ngx_eventport_module.c ev->active = 1; ev 310 event/modules/ngx_eventport_module.c ev->oneshot = 1; ev 317 event/modules/ngx_eventport_module.c ngx_eventport_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 329 event/modules/ngx_eventport_module.c ev->active = 0; ev 330 event/modules/ngx_eventport_module.c ev->oneshot = 0; ev 334 event/modules/ngx_eventport_module.c c = ev->data; ev 346 event/modules/ngx_eventport_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 350 event/modules/ngx_eventport_module.c (void *) ((uintptr_t) ev | ev->instance)) ev 353 event/modules/ngx_eventport_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, ev 359 event/modules/ngx_eventport_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 363 event/modules/ngx_eventport_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, ev 369 event/modules/ngx_eventport_module.c ev->active = 0; ev 370 event/modules/ngx_eventport_module.c ev->oneshot = 0; ev 385 event/modules/ngx_eventport_module.c ngx_event_t *ev, *rev, *wev, **queue; ev 446 event/modules/ngx_eventport_module.c ev = event_list[i].portev_user; ev 452 event/modules/ngx_eventport_module.c instance = (uintptr_t) ev & 1; ev 453 event/modules/ngx_eventport_module.c ev = (ngx_event_t *) ((uintptr_t) ev & (uintptr_t) ~1); ev 455 event/modules/ngx_eventport_module.c if (ev->closed || ev->instance != instance) { ev 463 event/modules/ngx_eventport_module.c "eventport: stale event %p", ev); ev 497 event/modules/ngx_eventport_module.c c = ev->data; ev 522 event/modules/ngx_eventport_module.c if (ev->closed) { ev 534 event/modules/ngx_eventport_module.c (void *) ((uintptr_t) ev | ev->instance)) ev 537 event/modules/ngx_eventport_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, ev 20 event/modules/ngx_kqueue_module.c static ngx_int_t ngx_kqueue_add_event(ngx_event_t *ev, ngx_int_t event, ev 22 event/modules/ngx_kqueue_module.c static ngx_int_t ngx_kqueue_del_event(ngx_event_t *ev, ngx_int_t event, ev 24 event/modules/ngx_kqueue_module.c static ngx_int_t ngx_kqueue_set_event(ngx_event_t *ev, ngx_int_t filter, ev 279 event/modules/ngx_kqueue_module.c ngx_kqueue_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 287 event/modules/ngx_kqueue_module.c ev->active = 1; ev 288 event/modules/ngx_kqueue_module.c ev->disabled = 0; ev 289 event/modules/ngx_kqueue_module.c ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1 : 0; ev 295 event/modules/ngx_kqueue_module.c if (ev->index < nchanges ev 296 event/modules/ngx_kqueue_module.c && ((uintptr_t) change_list[ev->index].udata & (uintptr_t) ~1) ev 297 event/modules/ngx_kqueue_module.c == (uintptr_t) ev) ev 299 event/modules/ngx_kqueue_module.c if (change_list[ev->index].flags == EV_DISABLE) { ev 306 event/modules/ngx_kqueue_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 308 event/modules/ngx_kqueue_module.c ngx_event_ident(ev->data), event); ev 310 event/modules/ngx_kqueue_module.c if (ev->index < --nchanges) { ev 313 event/modules/ngx_kqueue_module.c change_list[ev->index] = change_list[nchanges]; ev 314 event/modules/ngx_kqueue_module.c e->index = ev->index; ev 322 event/modules/ngx_kqueue_module.c c = ev->data; ev 324 event/modules/ngx_kqueue_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, 0, ev 334 event/modules/ngx_kqueue_module.c rc = ngx_kqueue_set_event(ev, event, EV_ADD|EV_ENABLE|flags); ev 343 event/modules/ngx_kqueue_module.c ngx_kqueue_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 348 event/modules/ngx_kqueue_module.c ev->active = 0; ev 349 event/modules/ngx_kqueue_module.c ev->disabled = 0; ev 353 event/modules/ngx_kqueue_module.c if (ev->index < nchanges ev 354 event/modules/ngx_kqueue_module.c && ((uintptr_t) change_list[ev->index].udata & (uintptr_t) ~1) ev 355 event/modules/ngx_kqueue_module.c == (uintptr_t) ev) ev 357 event/modules/ngx_kqueue_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 359 event/modules/ngx_kqueue_module.c ngx_event_ident(ev->data), event); ev 365 event/modules/ngx_kqueue_module.c if (ev->index < nchanges) { ev 368 event/modules/ngx_kqueue_module.c change_list[ev->index] = change_list[nchanges]; ev 369 event/modules/ngx_kqueue_module.c e->index = ev->index; ev 389 event/modules/ngx_kqueue_module.c ev->disabled = 1; ev 395 event/modules/ngx_kqueue_module.c rc = ngx_kqueue_set_event(ev, event, flags); ev 404 event/modules/ngx_kqueue_module.c ngx_kqueue_set_event(ngx_event_t *ev, ngx_int_t filter, ngx_uint_t flags) ev 410 event/modules/ngx_kqueue_module.c c = ev->data; ev 412 event/modules/ngx_kqueue_module.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 417 event/modules/ngx_kqueue_module.c ngx_log_error(NGX_LOG_WARN, ev->log, 0, ev 426 event/modules/ngx_kqueue_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, "kevent() failed"); ev 438 event/modules/ngx_kqueue_module.c kev->udata = NGX_KQUEUE_UDATA_T ((uintptr_t) ev | ev->instance); ev 454 event/modules/ngx_kqueue_module.c kev->data = ev->available; ev 466 event/modules/ngx_kqueue_module.c ev->index = nchanges; ev 473 event/modules/ngx_kqueue_module.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, 0, "kevent flush"); ev 478 event/modules/ngx_kqueue_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, "kevent() failed"); ev 497 event/modules/ngx_kqueue_module.c ngx_event_t *ev, **queue; ev 598 event/modules/ngx_kqueue_module.c ev = (ngx_event_t *) event_list[i].udata; ev 605 event/modules/ngx_kqueue_module.c instance = (uintptr_t) ev & 1; ev 606 event/modules/ngx_kqueue_module.c ev = (ngx_event_t *) ((uintptr_t) ev & (uintptr_t) ~1); ev 608 event/modules/ngx_kqueue_module.c if (ev->closed || ev->instance != instance) { ev 616 event/modules/ngx_kqueue_module.c "kevent: stale event %p", ev); ev 620 event/modules/ngx_kqueue_module.c if (ev->log && (ev->log->log_level & NGX_LOG_DEBUG_CONNECTION)) { ev 621 event/modules/ngx_kqueue_module.c ngx_kqueue_dump_event(ev->log, &event_list[i]); ev 624 event/modules/ngx_kqueue_module.c if (ev->oneshot) { ev 625 event/modules/ngx_kqueue_module.c ev->active = 0; ev 630 event/modules/ngx_kqueue_module.c if ((flags & NGX_POST_THREAD_EVENTS) && !ev->accept) { ev 631 event/modules/ngx_kqueue_module.c ev->posted_ready = 1; ev 632 event/modules/ngx_kqueue_module.c ev->posted_available = event_list[i].data; ev 635 event/modules/ngx_kqueue_module.c ev->posted_eof = 1; ev 636 event/modules/ngx_kqueue_module.c ev->posted_errno = event_list[i].fflags; ev 639 event/modules/ngx_kqueue_module.c ngx_locked_post_event(ev, &ngx_posted_events); ev 646 event/modules/ngx_kqueue_module.c ev->available = event_list[i].data; ev 649 event/modules/ngx_kqueue_module.c ev->pending_eof = 1; ev 650 event/modules/ngx_kqueue_module.c ev->kq_errno = event_list[i].fflags; ev 653 event/modules/ngx_kqueue_module.c ev->ready = 1; ev 658 event/modules/ngx_kqueue_module.c ev->kq_vnode = 1; ev 663 event/modules/ngx_kqueue_module.c ev->complete = 1; ev 664 event/modules/ngx_kqueue_module.c ev->ready = 1; ev 676 event/modules/ngx_kqueue_module.c queue = (ngx_event_t **) (ev->accept ? &ngx_posted_accept_events: ev 678 event/modules/ngx_kqueue_module.c ngx_locked_post_event(ev, queue); ev 683 event/modules/ngx_kqueue_module.c ev->handler(ev); ev 14 event/modules/ngx_poll_module.c static ngx_int_t ngx_poll_add_event(ngx_event_t *ev, ngx_int_t event, ev 16 event/modules/ngx_poll_module.c static ngx_int_t ngx_poll_del_event(ngx_event_t *ev, ngx_int_t event, ev 113 event/modules/ngx_poll_module.c ngx_poll_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 118 event/modules/ngx_poll_module.c c = ev->data; ev 120 event/modules/ngx_poll_module.c ev->active = 1; ev 122 event/modules/ngx_poll_module.c if (ev->index != NGX_INVALID_INDEX) { ev 123 event/modules/ngx_poll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, 0, ev 141 event/modules/ngx_poll_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 149 event/modules/ngx_poll_module.c ev->index = nevents; ev 153 event/modules/ngx_poll_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 157 event/modules/ngx_poll_module.c ev->index = e->index; ev 165 event/modules/ngx_poll_module.c ngx_poll_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 170 event/modules/ngx_poll_module.c c = ev->data; ev 172 event/modules/ngx_poll_module.c ev->active = 0; ev 174 event/modules/ngx_poll_module.c if (ev->index == NGX_INVALID_INDEX) { ev 175 event/modules/ngx_poll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, 0, ev 194 event/modules/ngx_poll_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 200 event/modules/ngx_poll_module.c if (ev->index < (ngx_uint_t) nevents) { ev 202 event/modules/ngx_poll_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 203 event/modules/ngx_poll_module.c "index: copy event %ui to %i", nevents, ev->index); ev 205 event/modules/ngx_poll_module.c event_list[ev->index] = event_list[nevents]; ev 210 event/modules/ngx_poll_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, 0, ev 215 event/modules/ngx_poll_module.c c->read->index = ev->index; ev 219 event/modules/ngx_poll_module.c c->write->index = ev->index; ev 225 event/modules/ngx_poll_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 231 event/modules/ngx_poll_module.c ev->index = NGX_INVALID_INDEX; ev 244 event/modules/ngx_poll_module.c ngx_event_t *ev, **queue; ev 376 event/modules/ngx_poll_module.c ev = c->read; ev 378 event/modules/ngx_poll_module.c if ((flags & NGX_POST_THREAD_EVENTS) && !ev->accept) { ev 379 event/modules/ngx_poll_module.c ev->posted_ready = 1; ev 382 event/modules/ngx_poll_module.c ev->ready = 1; ev 385 event/modules/ngx_poll_module.c queue = (ngx_event_t **) (ev->accept ? &ngx_posted_accept_events: ev 387 event/modules/ngx_poll_module.c ngx_locked_post_event(ev, queue); ev 392 event/modules/ngx_poll_module.c ev = c->write; ev 395 event/modules/ngx_poll_module.c ev->posted_ready = 1; ev 398 event/modules/ngx_poll_module.c ev->ready = 1; ev 401 event/modules/ngx_poll_module.c ngx_locked_post_event(ev, &ngx_posted_events); ev 14 event/modules/ngx_select_module.c static ngx_int_t ngx_select_add_event(ngx_event_t *ev, ngx_int_t event, ev 16 event/modules/ngx_select_module.c static ngx_int_t ngx_select_del_event(ngx_event_t *ev, ngx_int_t event, ev 124 event/modules/ngx_select_module.c ngx_select_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 128 event/modules/ngx_select_module.c c = ev->data; ev 130 event/modules/ngx_select_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 133 event/modules/ngx_select_module.c if (ev->index != NGX_INVALID_INDEX) { ev 134 event/modules/ngx_select_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, 0, ev 139 event/modules/ngx_select_module.c if ((event == NGX_READ_EVENT && ev->write) ev 140 event/modules/ngx_select_module.c || (event == NGX_WRITE_EVENT && !ev->write)) ev 142 event/modules/ngx_select_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, 0, ev 144 event/modules/ngx_select_module.c ev->write ? "write" : "read", c->fd, event); ev 159 event/modules/ngx_select_module.c ev->active = 1; ev 161 event/modules/ngx_select_module.c event_index[nevents] = ev; ev 162 event/modules/ngx_select_module.c ev->index = nevents; ev 170 event/modules/ngx_select_module.c ngx_select_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 175 event/modules/ngx_select_module.c c = ev->data; ev 177 event/modules/ngx_select_module.c ev->active = 0; ev 179 event/modules/ngx_select_module.c if (ev->index == NGX_INVALID_INDEX) { ev 183 event/modules/ngx_select_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 197 event/modules/ngx_select_module.c if (ev->index < --nevents) { ev 199 event/modules/ngx_select_module.c event_index[ev->index] = e; ev 200 event/modules/ngx_select_module.c e->index = ev->index; ev 203 event/modules/ngx_select_module.c ev->index = NGX_INVALID_INDEX; ev 216 event/modules/ngx_select_module.c ngx_event_t *ev, **queue; ev 235 event/modules/ngx_select_module.c ev = event_index[i]; ev 236 event/modules/ngx_select_module.c c = ev->data; ev 238 event/modules/ngx_select_module.c "select event: fd:%d wr:%d", c->fd, ev->write); ev 312 event/modules/ngx_select_module.c ev = event_index[i]; ev 313 event/modules/ngx_select_module.c c = ev->data; ev 316 event/modules/ngx_select_module.c if (ev->write) { ev 332 event/modules/ngx_select_module.c ev->ready = 1; ev 334 event/modules/ngx_select_module.c queue = (ngx_event_t **) (ev->accept ? &ngx_posted_accept_events: ev 336 event/modules/ngx_select_module.c ngx_locked_post_event(ev, queue); ev 14 event/modules/ngx_win32_select_module.c static ngx_int_t ngx_select_add_event(ngx_event_t *ev, ngx_int_t event, ev 16 event/modules/ngx_win32_select_module.c static ngx_int_t ngx_select_del_event(ngx_event_t *ev, ngx_int_t event, ev 126 event/modules/ngx_win32_select_module.c ngx_select_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 130 event/modules/ngx_win32_select_module.c c = ev->data; ev 132 event/modules/ngx_win32_select_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 135 event/modules/ngx_win32_select_module.c if (ev->index != NGX_INVALID_INDEX) { ev 136 event/modules/ngx_win32_select_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, 0, ev 141 event/modules/ngx_win32_select_module.c if ((event == NGX_READ_EVENT && ev->write) ev 142 event/modules/ngx_win32_select_module.c || (event == NGX_WRITE_EVENT && !ev->write)) ev 144 event/modules/ngx_win32_select_module.c ngx_log_error(NGX_LOG_ALERT, ev->log, 0, ev 146 event/modules/ngx_win32_select_module.c ev->write ? "write" : "read", c->fd, event); ev 153 event/modules/ngx_win32_select_module.c ngx_log_error(NGX_LOG_ERR, ev->log, 0, ev 168 event/modules/ngx_win32_select_module.c ev->active = 1; ev 170 event/modules/ngx_win32_select_module.c event_index[nevents] = ev; ev 171 event/modules/ngx_win32_select_module.c ev->index = nevents; ev 179 event/modules/ngx_win32_select_module.c ngx_select_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) ev 184 event/modules/ngx_win32_select_module.c c = ev->data; ev 186 event/modules/ngx_win32_select_module.c ev->active = 0; ev 188 event/modules/ngx_win32_select_module.c if (ev->index == NGX_INVALID_INDEX) { ev 192 event/modules/ngx_win32_select_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 204 event/modules/ngx_win32_select_module.c if (ev->index < --nevents) { ev 206 event/modules/ngx_win32_select_module.c event_index[ev->index] = e; ev 207 event/modules/ngx_win32_select_module.c e->index = ev->index; ev 210 event/modules/ngx_win32_select_module.c ev->index = NGX_INVALID_INDEX; ev 223 event/modules/ngx_win32_select_module.c ngx_event_t *ev, **queue; ev 230 event/modules/ngx_win32_select_module.c ev = event_index[i]; ev 231 event/modules/ngx_win32_select_module.c c = ev->data; ev 233 event/modules/ngx_win32_select_module.c "select event: fd:%d wr:%d", c->fd, ev->write); ev 303 event/modules/ngx_win32_select_module.c ev = event_index[i]; ev 304 event/modules/ngx_win32_select_module.c c = ev->data; ev 307 event/modules/ngx_win32_select_module.c if (ev->write) { ev 323 event/modules/ngx_win32_select_module.c ev->ready = 1; ev 325 event/modules/ngx_win32_select_module.c queue = (ngx_event_t **) (ev->accept ? &ngx_posted_accept_events: ev 327 event/modules/ngx_win32_select_module.c ngx_locked_post_event(ev, queue); ev 230 event/ngx_event.h ngx_int_t (*add)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags); ev 231 event/ngx_event.h ngx_int_t (*del)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags); ev 233 event/ngx_event.h ngx_int_t (*enable)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags); ev 234 event/ngx_event.h ngx_int_t (*disable)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags); ev 539 event/ngx_event.h void ngx_event_accept(ngx_event_t *ev); ev 550 event/ngx_event.h void ngx_event_acceptex(ngx_event_t *ev); ev 18 event/ngx_event_accept.c ngx_event_accept(ngx_event_t *ev) ev 36 event/ngx_event_accept.c ev->available = 1; ev 39 event/ngx_event_accept.c ev->available = ecf->multi_accept; ev 42 event/ngx_event_accept.c lc = ev->data; ev 44 event/ngx_event_accept.c ev->ready = 0; ev 46 event/ngx_event_accept.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 47 event/ngx_event_accept.c "accept on %V, ready: %d", &ls->addr_text, ev->available); ev 67 event/ngx_event_accept.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, err, ev 75 event/ngx_event_accept.c ev->log, err, ev 86 event/ngx_event_accept.c ev->log, err, "accept() failed"); ev 91 event/ngx_event_accept.c ev->available--; ev 94 event/ngx_event_accept.c if (ev->available) { ev 109 event/ngx_event_accept.c c = ngx_get_connection(s, ev->log); ev 113 event/ngx_event_accept.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno, ev 124 event/ngx_event_accept.c c->pool = ngx_create_pool(ls->pool_size, ev->log); ev 149 event/ngx_event_accept.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno, ev 159 event/ngx_event_accept.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno, ev 204 event/ngx_event_accept.c if (ev->deferred_accept) { ev 286 event/ngx_event_accept.c ev->available--; ev 289 event/ngx_event_accept.c } while (ev->available); ev 14 event/ngx_event_busy_lock.c static void ngx_event_busy_lock_handler(ngx_event_t *ev); ev 15 event/ngx_event_busy_lock.c static void ngx_event_busy_lock_posted_handler(ngx_event_t *ev); ev 116 event/ngx_event_busy_lock.c ngx_event_t *ev; ev 149 event/ngx_event_busy_lock.c ev = wakeup->event; ev 151 event/ngx_event_busy_lock.c ngx_post_event(ev, &ngx_posted_events); ev 164 event/ngx_event_busy_lock.c ev = wakeup->event; ev 166 event/ngx_event_busy_lock.c if (ev->timer_set) { ev 167 event/ngx_event_busy_lock.c ngx_del_timer(ev); ev 170 event/ngx_event_busy_lock.c ngx_post_event(ev, &ngx_posted_events); ev 270 event/ngx_event_busy_lock.c ngx_event_busy_lock_handler(ngx_event_t *ev) ev 272 event/ngx_event_busy_lock.c ev->handler = ngx_event_busy_lock_posted_handler; ev 274 event/ngx_event_busy_lock.c ngx_post_event(ev, &ngx_posted_events); ev 279 event/ngx_event_busy_lock.c ngx_event_busy_lock_posted_handler(ngx_event_t *ev) ev 283 event/ngx_event_busy_lock.c ctx = ev->data; ev 284 event/ngx_event_busy_lock.c ctx->handler(ev); ev 13 event/ngx_event_mutex.c ngx_event_t *ev) ev 15 event/ngx_event_mutex.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 21 event/ngx_event_mutex.c m->events = ev; ev 24 event/ngx_event_mutex.c m->last->next = ev; ev 27 event/ngx_event_mutex.c m->last = ev; ev 28 event/ngx_event_mutex.c ev->next = NULL; ev 31 event/ngx_event_mutex.c ev->light = 1; ev 34 event/ngx_event_mutex.c ngx_add_timer(ev, timer); ev 47 event/ngx_event_mutex.c ngx_event_t *ev; ev 61 event/ngx_event_mutex.c ev = m->events; ev 62 event/ngx_event_mutex.c m->events = ev->next; ev 64 event/ngx_event_mutex.c ev->next = (ngx_event_t *) ngx_posted_events; ev 65 event/ngx_event_mutex.c ngx_posted_events = ev; ev 20 event/ngx_event_openssl.c static void ngx_ssl_handshake_handler(ngx_event_t *ev); ev 24 event/ngx_event_openssl.c static void ngx_ssl_shutdown_handler(ngx_event_t *ev); ev 672 event/ngx_event_openssl.c ngx_ssl_handshake_handler(ngx_event_t *ev) ev 676 event/ngx_event_openssl.c c = ev->data; ev 679 event/ngx_event_openssl.c "SSL handshake handler: %d", ev->write); ev 681 event/ngx_event_openssl.c if (ev->timedout) { ev 1250 event/ngx_event_openssl.c ngx_ssl_shutdown_handler(ngx_event_t *ev) ev 1255 event/ngx_event_openssl.c c = ev->data; ev 1258 event/ngx_event_openssl.c if (ev->timedout) { ev 1262 event/ngx_event_openssl.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, 0, "SSL shutdown handler"); ev 24 event/ngx_event_posted.c ngx_event_t *ev; ev 28 event/ngx_event_posted.c ev = (ngx_event_t *) *posted; ev 31 event/ngx_event_posted.c "posted event %p", ev); ev 33 event/ngx_event_posted.c if (ev == NULL) { ev 37 event/ngx_event_posted.c ngx_delete_posted_event(ev); ev 39 event/ngx_event_posted.c ev->handler(ev); ev 52 event/ngx_event_posted.c ngx_event_t *ev; ev 60 event/ngx_event_posted.c for (ev = (ngx_event_t *) ngx_posted_events; ev; ev = ev->next) { ev 61 event/ngx_event_posted.c if (*(ev->lock) == 0) { ev 86 event/ngx_event_posted.c ngx_event_t *ev; ev 90 event/ngx_event_posted.c ev = (ngx_event_t *) ngx_posted_events; ev 95 event/ngx_event_posted.c "posted event %p", ev); ev 97 event/ngx_event_posted.c if (ev == NULL) { ev 101 event/ngx_event_posted.c if (ngx_trylock(ev->lock) == 0) { ev 104 event/ngx_event_posted.c "posted event %p is busy", ev); ev 106 event/ngx_event_posted.c ev = ev->next; ev 110 event/ngx_event_posted.c if (ev->lock != ev->own_lock) { ev 111 event/ngx_event_posted.c if (*(ev->own_lock)) { ev 113 event/ngx_event_posted.c "the own lock of the posted event %p is busy", ev); ev 114 event/ngx_event_posted.c ngx_unlock(ev->lock); ev 115 event/ngx_event_posted.c ev = ev->next; ev 118 event/ngx_event_posted.c *(ev->own_lock) = 1; ev 121 event/ngx_event_posted.c ngx_delete_posted_event(ev); ev 123 event/ngx_event_posted.c ev->locked = 1; ev 125 event/ngx_event_posted.c ev->ready |= ev->posted_ready; ev 126 event/ngx_event_posted.c ev->timedout |= ev->posted_timedout; ev 127 event/ngx_event_posted.c ev->pending_eof |= ev->posted_eof; ev 129 event/ngx_event_posted.c ev->kq_errno |= ev->posted_errno; ev 131 event/ngx_event_posted.c if (ev->posted_available) { ev 132 event/ngx_event_posted.c ev->available = ev->posted_available; ev 135 event/ngx_event_posted.c ev->posted_ready = 0; ev 136 event/ngx_event_posted.c ev->posted_timedout = 0; ev 137 event/ngx_event_posted.c ev->posted_eof = 0; ev 139 event/ngx_event_posted.c ev->posted_errno = 0; ev 141 event/ngx_event_posted.c ev->posted_available = 0; ev 145 event/ngx_event_posted.c ev->handler(ev); ev 149 event/ngx_event_posted.c if (ev->locked) { ev 150 event/ngx_event_posted.c ngx_unlock(ev->lock); ev 152 event/ngx_event_posted.c if (ev->lock != ev->own_lock) { ev 153 event/ngx_event_posted.c ngx_unlock(ev->own_lock); ev 158 event/ngx_event_posted.c "posted event %p is done", ev); ev 21 event/ngx_event_posted.h #define ngx_locked_post_event(ev, queue) \ ev 23 event/ngx_event_posted.h if (ev->prev == NULL) { \ ev 24 event/ngx_event_posted.h ev->next = (ngx_event_t *) *queue; \ ev 25 event/ngx_event_posted.h ev->prev = (ngx_event_t **) queue; \ ev 26 event/ngx_event_posted.h *queue = ev; \ ev 28 event/ngx_event_posted.h if (ev->next) { \ ev 29 event/ngx_event_posted.h ev->next->prev = &ev->next; \ ev 32 event/ngx_event_posted.h ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0, "post event %p", ev); \ ev 35 event/ngx_event_posted.h ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0, \ ev 36 event/ngx_event_posted.h "update posted event %p", ev); \ ev 40 event/ngx_event_posted.h #define ngx_post_event(ev, queue) \ ev 43 event/ngx_event_posted.h ngx_locked_post_event(ev, queue); \ ev 47 event/ngx_event_posted.h #define ngx_delete_posted_event(ev) \ ev 49 event/ngx_event_posted.h *(ev->prev) = ev->next; \ ev 51 event/ngx_event_posted.h if (ev->next) { \ ev 52 event/ngx_event_posted.h ev->next->prev = ev->prev; \ ev 55 event/ngx_event_posted.h ev->prev = NULL; \ ev 56 event/ngx_event_posted.h ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0, \ ev 57 event/ngx_event_posted.h "delete posted event %p", ev); ev 78 event/ngx_event_timer.c ngx_event_t *ev; ev 99 event/ngx_event_timer.c ev = (ngx_event_t *) ((char *) node - offsetof(ngx_event_t, timer)); ev 103 event/ngx_event_timer.c if (ngx_threaded && ngx_trylock(ev->lock) == 0) { ev 113 event/ngx_event_timer.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 114 event/ngx_event_timer.c "event %p is busy in expire timers", ev); ev 119 event/ngx_event_timer.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 121 event/ngx_event_timer.c ngx_event_ident(ev->data), ev->timer.key); ev 123 event/ngx_event_timer.c ngx_rbtree_delete(&ngx_event_timer_rbtree, &ev->timer); ev 128 event/ngx_event_timer.c ev->timer.left = NULL; ev 129 event/ngx_event_timer.c ev->timer.right = NULL; ev 130 event/ngx_event_timer.c ev->timer.parent = NULL; ev 133 event/ngx_event_timer.c ev->timer_set = 0; ev 137 event/ngx_event_timer.c ev->posted_timedout = 1; ev 139 event/ngx_event_timer.c ngx_post_event(ev, &ngx_posted_events); ev 141 event/ngx_event_timer.c ngx_unlock(ev->lock); ev 147 event/ngx_event_timer.c ev->timedout = 1; ev 149 event/ngx_event_timer.c ev->handler(ev); ev 35 event/ngx_event_timer.h ngx_event_del_timer(ngx_event_t *ev) ev 37 event/ngx_event_timer.h ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 39 event/ngx_event_timer.h ngx_event_ident(ev->data), ev->timer.key); ev 43 event/ngx_event_timer.h ngx_rbtree_delete(&ngx_event_timer_rbtree, &ev->timer); ev 48 event/ngx_event_timer.h ev->timer.left = NULL; ev 49 event/ngx_event_timer.h ev->timer.right = NULL; ev 50 event/ngx_event_timer.h ev->timer.parent = NULL; ev 53 event/ngx_event_timer.h ev->timer_set = 0; ev 58 event/ngx_event_timer.h ngx_event_add_timer(ngx_event_t *ev, ngx_msec_t timer) ev 65 event/ngx_event_timer.h if (ev->timer_set) { ev 73 event/ngx_event_timer.h diff = (ngx_msec_int_t) (key - ev->timer.key); ev 76 event/ngx_event_timer.h ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 78 event/ngx_event_timer.h ngx_event_ident(ev->data), ev->timer.key, key); ev 82 event/ngx_event_timer.h ngx_del_timer(ev); ev 85 event/ngx_event_timer.h ev->timer.key = key; ev 87 event/ngx_event_timer.h ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0, ev 89 event/ngx_event_timer.h ngx_event_ident(ev->data), timer, ev->timer.key); ev 93 event/ngx_event_timer.h ngx_rbtree_insert(&ngx_event_timer_rbtree, &ev->timer); ev 97 event/ngx_event_timer.h ev->timer_set = 1; ev 37 http/ngx_http_busy_lock.h void (*event_handler)(ngx_event_t *ev); ev 20 http/ngx_http_copy_filter_module.c static void ngx_http_copy_aio_event_handler(ngx_event_t *ev); ev 22 http/ngx_http_copy_filter_module.c static void ngx_http_copy_aio_sendfile_event_handler(ngx_event_t *ev); ev 221 http/ngx_http_copy_filter_module.c ngx_http_copy_aio_event_handler(ngx_event_t *ev) ev 226 http/ngx_http_copy_filter_module.c aio = ev->data; ev 239 http/ngx_http_copy_filter_module.c ngx_http_copy_aio_sendfile_event_handler(ngx_event_t *ev) ev 244 http/ngx_http_copy_filter_module.c aio = ev->data; ev 249 http/ngx_http_copy_filter_module.c ev->complete = 0; ev 18 http/ngx_http_file_cache.c static void ngx_http_cache_aio_event_handler(ngx_event_t *ev); ev 490 http/ngx_http_file_cache.c ngx_http_cache_aio_event_handler(ngx_event_t *ev) ev 495 http/ngx_http_file_cache.c aio = ev->data; ev 12 http/ngx_http_request.c static void ngx_http_init_request(ngx_event_t *ev); ev 39 http/ngx_http_request.c static void ngx_http_request_handler(ngx_event_t *ev); ev 48 http/ngx_http_request.c static void ngx_http_keepalive_handler(ngx_event_t *ev); ev 50 http/ngx_http_request.c static void ngx_http_lingering_close_handler(ngx_event_t *ev); ev 1781 http/ngx_http_request.c ngx_http_request_handler(ngx_event_t *ev) ev 1787 http/ngx_http_request.c c = ev->data; ev 1796 http/ngx_http_request.c if (ev->write) { ev 26 http/ngx_http_upstream.c ngx_event_t *ev); ev 880 http/ngx_http_upstream.c ngx_http_upstream_handler(ngx_event_t *ev) ev 887 http/ngx_http_upstream.c c = ev->data; ev 899 http/ngx_http_upstream.c if (ev->write) { ev 926 http/ngx_http_upstream.c ngx_event_t *ev) ev 935 http/ngx_http_upstream.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, ev->log, 0, ev 937 http/ngx_http_upstream.c ev->write, &r->uri); ev 943 http/ngx_http_upstream.c if ((ngx_event_flags & NGX_USE_LEVEL_EVENT) && ev->active) { ev 945 http/ngx_http_upstream.c event = ev->write ? NGX_WRITE_EVENT : NGX_READ_EVENT; ev 947 http/ngx_http_upstream.c if (ngx_del_event(ev, event, 0) != NGX_OK) { ev 966 http/ngx_http_upstream.c if (!ev->pending_eof) { ev 970 http/ngx_http_upstream.c ev->eof = 1; ev 973 http/ngx_http_upstream.c if (ev->kq_errno) { ev 974 http/ngx_http_upstream.c ev->error = 1; ev 978 http/ngx_http_upstream.c ngx_log_error(NGX_LOG_INFO, ev->log, ev->kq_errno, ev 986 http/ngx_http_upstream.c ngx_log_error(NGX_LOG_INFO, ev->log, ev->kq_errno, ev 1004 http/ngx_http_upstream.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, ev->log, err, ev 1007 http/ngx_http_upstream.c if (ev->write && (n >= 0 || err == NGX_EAGAIN)) { ev 1011 http/ngx_http_upstream.c if ((ngx_event_flags & NGX_USE_LEVEL_EVENT) && ev->active) { ev 1013 http/ngx_http_upstream.c event = ev->write ? NGX_WRITE_EVENT : NGX_READ_EVENT; ev 1015 http/ngx_http_upstream.c if (ngx_del_event(ev, event, 0) != NGX_OK) { ev 1031 http/ngx_http_upstream.c ev->error = 1; ev 1037 http/ngx_http_upstream.c ev->eof = 1; ev 1041 http/ngx_http_upstream.c ngx_log_error(NGX_LOG_INFO, ev->log, err, ev 1049 http/ngx_http_upstream.c ngx_log_error(NGX_LOG_INFO, ev->log, err, ev 71 mail/ngx_mail_auth_http_module.c static void ngx_mail_auth_http_dummy_handler(ngx_event_t *ev); ev 1121 mail/ngx_mail_auth_http_module.c ngx_mail_auth_http_dummy_handler(ngx_event_t *ev) ev 1123 mail/ngx_mail_auth_http_module.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, ev->log, 0, ev 27 mail/ngx_mail_proxy_module.c static void ngx_mail_proxy_dummy_handler(ngx_event_t *ev); ev 30 mail/ngx_mail_proxy_module.c static void ngx_mail_proxy_handler(ngx_event_t *ev); ev 836 mail/ngx_mail_proxy_module.c ngx_mail_proxy_handler(ngx_event_t *ev) ev 847 mail/ngx_mail_proxy_module.c c = ev->data; ev 850 mail/ngx_mail_proxy_module.c if (ev->timedout) { ev 868 mail/ngx_mail_proxy_module.c if (ev->write) { ev 884 mail/ngx_mail_proxy_module.c if (ev->write) { ev 900 mail/ngx_mail_proxy_module.c do_write = ev->write ? 1 : 0; ev 902 mail/ngx_mail_proxy_module.c ngx_log_debug3(NGX_LOG_DEBUG_MAIL, ev->log, 0, ev 199 os/unix/ngx_channel.c ngx_event_t *ev, *rev, *wev; ev 226 os/unix/ngx_channel.c ev = (event == NGX_READ_EVENT) ? rev : wev; ev 228 os/unix/ngx_channel.c ev->handler = handler; ev 237 os/unix/ngx_channel.c if (ngx_add_event(ev, event, 0) == NGX_ERROR) { ev 34 os/unix/ngx_file_aio_read.c ngx_event_t *ev); ev 35 os/unix/ngx_file_aio_read.c static void ngx_file_aio_event_handler(ngx_event_t *ev); ev 43 os/unix/ngx_file_aio_read.c ngx_event_t *ev; ev 69 os/unix/ngx_file_aio_read.c ev = &aio->event; ev 71 os/unix/ngx_file_aio_read.c if (!ev->ready) { ev 79 os/unix/ngx_file_aio_read.c ev->complete, offset, size, &file->name); ev 81 os/unix/ngx_file_aio_read.c if (ev->complete) { ev 82 os/unix/ngx_file_aio_read.c ev->complete = 0; ev 101 os/unix/ngx_file_aio_read.c aio->aiocb.aio_sigevent.sigev_value.sigval_ptr = ev; ev 103 os/unix/ngx_file_aio_read.c ev->handler = ngx_file_aio_event_handler; ev 128 os/unix/ngx_file_aio_read.c ev->active = 1; ev 129 os/unix/ngx_file_aio_read.c ev->ready = 0; ev 130 os/unix/ngx_file_aio_read.c ev->complete = 0; ev 132 os/unix/ngx_file_aio_read.c return ngx_file_aio_result(aio->file, aio, ev); ev 137 os/unix/ngx_file_aio_read.c ngx_file_aio_result(ngx_file_t *file, ngx_event_aio_t *aio, ngx_event_t *ev) ev 158 os/unix/ngx_file_aio_read.c if (ev->ready) { ev 159 os/unix/ngx_file_aio_read.c ev->ready = 0; ev 169 os/unix/ngx_file_aio_read.c ev->ready = 0; ev 181 os/unix/ngx_file_aio_read.c ev->ready = 0; ev 190 os/unix/ngx_file_aio_read.c ev->ready = 1; ev 191 os/unix/ngx_file_aio_read.c ev->active = 0; ev 201 os/unix/ngx_file_aio_read.c ngx_file_aio_event_handler(ngx_event_t *ev) ev 205 os/unix/ngx_file_aio_read.c aio = ev->data; ev 207 os/unix/ngx_file_aio_read.c ngx_log_debug2(NGX_LOG_DEBUG_CORE, ev->log, 0, ev 210 os/unix/ngx_file_aio_read.c if (ngx_file_aio_result(aio->file, aio, ev) != NGX_AGAIN) { ev 211 os/unix/ngx_file_aio_read.c aio->handler(ev); ev 16 os/unix/ngx_linux_aio_read.c static void ngx_file_aio_event_handler(ngx_event_t *ev); ev 32 os/unix/ngx_linux_aio_read.c ngx_event_t *ev; ev 55 os/unix/ngx_linux_aio_read.c ev = &aio->event; ev 57 os/unix/ngx_linux_aio_read.c if (!ev->ready) { ev 65 os/unix/ngx_linux_aio_read.c ev->complete, offset, size, &file->name); ev 67 os/unix/ngx_linux_aio_read.c if (ev->complete) { ev 68 os/unix/ngx_linux_aio_read.c ev->active = 0; ev 69 os/unix/ngx_linux_aio_read.c ev->complete = 0; ev 82 os/unix/ngx_linux_aio_read.c aio->aiocb.aio_data = (uint64_t) (uintptr_t) ev; ev 91 os/unix/ngx_linux_aio_read.c ev->handler = ngx_file_aio_event_handler; ev 98 os/unix/ngx_linux_aio_read.c ev->active = 1; ev 99 os/unix/ngx_linux_aio_read.c ev->ready = 0; ev 100 os/unix/ngx_linux_aio_read.c ev->complete = 0; ev 124 os/unix/ngx_linux_aio_read.c ngx_file_aio_event_handler(ngx_event_t *ev) ev 128 os/unix/ngx_linux_aio_read.c aio = ev->data; ev 130 os/unix/ngx_linux_aio_read.c ngx_log_debug2(NGX_LOG_DEBUG_CORE, ev->log, 0, ev 133 os/unix/ngx_linux_aio_read.c aio->handler(ev); ev 24 os/unix/ngx_process_cycle.c static void ngx_channel_handler(ngx_event_t *ev); ev 30 os/unix/ngx_process_cycle.c static void ngx_cache_manager_process_handler(ngx_event_t *ev); ev 31 os/unix/ngx_process_cycle.c static void ngx_cache_loader_process_handler(ngx_event_t *ev); ev 1072 os/unix/ngx_process_cycle.c ngx_channel_handler(ngx_event_t *ev) ev 1078 os/unix/ngx_process_cycle.c if (ev->timedout) { ev 1079 os/unix/ngx_process_cycle.c ev->timedout = 0; ev 1083 os/unix/ngx_process_cycle.c c = ev->data; ev 1085 os/unix/ngx_process_cycle.c ngx_log_debug0(NGX_LOG_DEBUG_CORE, ev->log, 0, "channel handler"); ev 1089 os/unix/ngx_process_cycle.c n = ngx_read_channel(c->fd, &ch, sizeof(ngx_channel_t), ev->log); ev 1091 os/unix/ngx_process_cycle.c ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0, "channel: %i", n); ev 1104 os/unix/ngx_process_cycle.c if (ngx_add_event(ev, NGX_READ_EVENT, 0) == NGX_ERROR) { ev 1113 os/unix/ngx_process_cycle.c ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0, ev 1132 os/unix/ngx_process_cycle.c ngx_log_debug3(NGX_LOG_DEBUG_CORE, ev->log, 0, ev 1142 os/unix/ngx_process_cycle.c ngx_log_debug4(NGX_LOG_DEBUG_CORE, ev->log, 0, ev 1148 os/unix/ngx_process_cycle.c ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, ev 1293 os/unix/ngx_process_cycle.c ngx_event_t ev; ev 1303 os/unix/ngx_process_cycle.c ngx_memzero(&ev, sizeof(ngx_event_t)); ev 1304 os/unix/ngx_process_cycle.c ev.handler = ctx->handler; ev 1305 os/unix/ngx_process_cycle.c ev.data = ident; ev 1306 os/unix/ngx_process_cycle.c ev.log = cycle->log; ev 1313 os/unix/ngx_process_cycle.c ngx_add_timer(&ev, ctx->delay); ev 1334 os/unix/ngx_process_cycle.c ngx_cache_manager_process_handler(ngx_event_t *ev) ev 1358 os/unix/ngx_process_cycle.c ngx_add_timer(ev, next * 1000); ev 1363 os/unix/ngx_process_cycle.c ngx_cache_loader_process_handler(ngx_event_t *ev)