24 static ngx_int_t ngx_kqueue_add_event(ngx_event_t *ev, ngx_int_t event,
26 static ngx_int_t ngx_kqueue_del_event(ngx_event_t *ev, ngx_int_t event,
28 static ngx_int_t ngx_kqueue_set_event(ngx_event_t *ev, ngx_int_t filter,
294 ngx_kqueue_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags)  in ngx_kqueue_add_event()  argument
302     ev->active = 1;  in ngx_kqueue_add_event()
303     ev->disabled = 0;  in ngx_kqueue_add_event()
304     ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1 : 0;  in ngx_kqueue_add_event()
308     if (ev->index < nchanges  in ngx_kqueue_add_event()
309         && ((uintptr_t) change_list[ev->index].udata & (uintptr_t) ~1)  in ngx_kqueue_add_event()
310             == (uintptr_t) ev)  in ngx_kqueue_add_event()
312         if (change_list[ev->index].flags == EV_DISABLE) {  in ngx_kqueue_add_event()
319             ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,  in ngx_kqueue_add_event()
321                            ngx_event_ident(ev->data), event);  in ngx_kqueue_add_event()
323             if (ev->index < --nchanges) {  in ngx_kqueue_add_event()
326                 change_list[ev->index] = change_list[nchanges];  in ngx_kqueue_add_event()
327                 e->index = ev->index;  in ngx_kqueue_add_event()
333         c = ev->data;  in ngx_kqueue_add_event()
335         ngx_log_error(NGX_LOG_ALERT, ev->log, 0,  in ngx_kqueue_add_event()
343     rc = ngx_kqueue_set_event(ev, event, EV_ADD|EV_ENABLE|flags);  in ngx_kqueue_add_event()
350 ngx_kqueue_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags)  in ngx_kqueue_del_event()  argument
355     ev->active = 0;  in ngx_kqueue_del_event()
356     ev->disabled = 0;  in ngx_kqueue_del_event()
358     if (ev->index < nchanges  in ngx_kqueue_del_event()
359         && ((uintptr_t) change_list[ev->index].udata & (uintptr_t) ~1)  in ngx_kqueue_del_event()
360             == (uintptr_t) ev)  in ngx_kqueue_del_event()
362         ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,  in ngx_kqueue_del_event()
364                        ngx_event_ident(ev->data), event);  in ngx_kqueue_del_event()
370         if (ev->index < nchanges) {  in ngx_kqueue_del_event()
373             change_list[ev->index] = change_list[nchanges];  in ngx_kqueue_del_event()
374             e->index = ev->index;  in ngx_kqueue_del_event()
391         ev->disabled = 1;  in ngx_kqueue_del_event()
397     rc = ngx_kqueue_set_event(ev, event, flags);  in ngx_kqueue_del_event()
404 ngx_kqueue_set_event(ngx_event_t *ev, ngx_int_t filter, ngx_uint_t flags)  in ngx_kqueue_set_event()  argument
410     c = ev->data;  in ngx_kqueue_set_event()
412     ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0,  in ngx_kqueue_set_event()
417         ngx_log_error(NGX_LOG_WARN, ev->log, 0,  in ngx_kqueue_set_event()
426             ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, "kevent() failed");  in ngx_kqueue_set_event()
438     kev->udata = NGX_KQUEUE_UDATA_T ((uintptr_t) ev | ev->instance);  in ngx_kqueue_set_event()
454             kev->data = ev->available;  in ngx_kqueue_set_event()
466     ev->index = nchanges;  in ngx_kqueue_set_event()
473         ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, 0, "kevent flush");  in ngx_kqueue_set_event()
478             ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno, "kevent() failed");  in ngx_kqueue_set_event()
516     ngx_event_t      *ev;  in ngx_kqueue_process_events()  local
620         ev = (ngx_event_t *) event_list[i].udata;  in ngx_kqueue_process_events()
627             instance = (uintptr_t) ev & 1;  in ngx_kqueue_process_events()
628             ev = (ngx_event_t *) ((uintptr_t) ev & (uintptr_t) ~1);  in ngx_kqueue_process_events()
630             if (ev->closed || ev->instance != instance) {  in ngx_kqueue_process_events()
638                                "kevent: stale event %p", ev);  in ngx_kqueue_process_events()
642             if (ev->log && (ev->log->log_level & NGX_LOG_DEBUG_CONNECTION)) {  in ngx_kqueue_process_events()
643                 ngx_kqueue_dump_event(ev->log, &event_list[i]);  in ngx_kqueue_process_events()
646             if (ev->oneshot) {  in ngx_kqueue_process_events()
647                 ev->active = 0;  in ngx_kqueue_process_events()
650             ev->available = event_list[i].data;  in ngx_kqueue_process_events()
653                 ev->pending_eof = 1;  in ngx_kqueue_process_events()
654                 ev->kq_errno = event_list[i].fflags;  in ngx_kqueue_process_events()
657             ev->ready = 1;  in ngx_kqueue_process_events()
662             ev->kq_vnode = 1;  in ngx_kqueue_process_events()
667             ev->complete = 1;  in ngx_kqueue_process_events()
668             ev->ready = 1;  in ngx_kqueue_process_events()
685             queue = ev->accept ? &ngx_posted_accept_events  in ngx_kqueue_process_events()
688             ngx_post_event(ev, queue);  in ngx_kqueue_process_events()
693         ev->handler(ev);  in ngx_kqueue_process_events()