aboutsummaryrefslogtreecommitdiff
path: root/src/event/modules/ngx_kqueue_module.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/event/modules/ngx_kqueue_module.c')
-rw-r--r--src/event/modules/ngx_kqueue_module.c47
1 files changed, 6 insertions, 41 deletions
diff --git a/src/event/modules/ngx_kqueue_module.c b/src/event/modules/ngx_kqueue_module.c
index b261e1be6..7e1cfa295 100644
--- a/src/event/modules/ngx_kqueue_module.c
+++ b/src/event/modules/ngx_kqueue_module.c
@@ -339,7 +339,8 @@ static int ngx_kqueue_set_event(ngx_event_t *ev, int filter, u_int flags)
static int ngx_kqueue_process_events(ngx_log_t *log)
{
- ngx_int_t events, instance, i;
+ int events;
+ ngx_int_t instance, i;
ngx_err_t err;
ngx_msec_t timer;
ngx_event_t *ev;
@@ -355,13 +356,7 @@ static int ngx_kqueue_process_events(ngx_log_t *log)
ts.tv_nsec = (timer % 1000) * 1000000;
tp = &ts;
-#if 0
- ngx_gettimeofday(&tv);
- delta = tv.tv_sec * 1000 + tv.tv_usec / 1000;
-#endif
-
} else {
- delta = 0;
tp = NULL;
}
@@ -378,17 +373,17 @@ static int ngx_kqueue_process_events(ngx_log_t *log)
nchanges = 0;
ngx_gettimeofday(&tv);
+ ngx_time_update(tv.tv_sec);
-#if 1
delta = ngx_elapsed_msec;
-#endif
ngx_elapsed_msec = tv.tv_sec * 1000 + tv.tv_usec / 1000 - ngx_start_msec;
- ngx_time_update(tv.tv_sec);
-
if (timer) {
delta = ngx_elapsed_msec - delta;
+ ngx_log_debug2(NGX_LOG_DEBUG_EVENT, log, 0,
+ "kevent timer: %d, delta: %d", timer, (int) delta);
+
} else {
if (events == 0) {
ngx_log_error(NGX_LOG_ALERT, log, 0,
@@ -397,9 +392,6 @@ static int ngx_kqueue_process_events(ngx_log_t *log)
}
}
- ngx_log_debug2(NGX_LOG_DEBUG_EVENT, log, 0,
- "kevent timer: %d, delta: %d", timer, (int) delta);
-
if (err) {
ngx_log_error((err == NGX_EINTR) ? NGX_LOG_INFO : NGX_LOG_ALERT,
log, err, "kevent() failed");
@@ -496,33 +488,6 @@ static int ngx_kqueue_process_events(ngx_log_t *log)
}
-#if 0
-
-static void ngx_kqueue_thread_handler(ngx_event_t *ev, ngx_log_t *log)
-{
- ngx_int_t instance;
-
- instance = (uintptr_t) ev & 1;
- ev = (ngx_event_t *) ((uintptr_t) ev & (uintptr_t) ~1);
-
- if (ev->active && ev->instance == instance) {
- ev->event_handler(ev);
- return;
- }
-
- /*
- * it's a stale event from a file descriptor
- * that was just closed in this iteration
- */
-
- ngx_log_debug1(NGX_LOG_DEBUG_EVENT, log, 0,
- "kevent: stale event " PTR_FMT, ev);
-
-}
-
-#endif
-
-
static void *ngx_kqueue_create_conf(ngx_cycle_t *cycle)
{
ngx_kqueue_conf_t *kcf;