diff options
| author | Igor Sysoev <igor@sysoev.ru> | 2004-07-07 15:01:00 +0000 |
|---|---|---|
| committer | Igor Sysoev <igor@sysoev.ru> | 2004-07-07 15:01:00 +0000 |
| commit | 2b97993c7a6525bf41c694414450943d39605757 (patch) | |
| tree | b3b3870575cd65e64ef59de5359bfdd3695bc77c /src/event/modules/ngx_kqueue_module.c | |
| parent | c78c41cefcf1e1fa8005f81b7c6cc0c857bcf46f (diff) | |
| download | nginx-2b97993c7a6525bf41c694414450943d39605757.tar.gz nginx-2b97993c7a6525bf41c694414450943d39605757.tar.bz2 | |
nginx-0.0.7-2004-07-07-19:01:00 import
Diffstat (limited to 'src/event/modules/ngx_kqueue_module.c')
| -rw-r--r-- | src/event/modules/ngx_kqueue_module.c | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/event/modules/ngx_kqueue_module.c b/src/event/modules/ngx_kqueue_module.c index 2f722f781..99fffefee 100644 --- a/src/event/modules/ngx_kqueue_module.c +++ b/src/event/modules/ngx_kqueue_module.c @@ -421,6 +421,7 @@ static ngx_int_t ngx_kqueue_process_events(ngx_cycle_t *cycle) timer = ngx_event_find_timer(); #if (NGX_THREADS) + if (timer == NGX_TIMER_ERROR) { return NGX_ERROR; } @@ -442,7 +443,9 @@ static ngx_int_t ngx_kqueue_process_events(ngx_cycle_t *cycle) ngx_event_expire_timers((ngx_msec_t) (ngx_elapsed_msec - ngx_old_elapsed_msec)); - /* TODO: if ngx_threaded then wake up the worker thread */ + if (ngx_posted_events && ngx_threaded) { + ngx_wakeup_worker_thread(cycle); + } } ngx_old_elapsed_msec = ngx_elapsed_msec; |