Mercurial > hg > nginx

comparison src/event/modules/ngx_kqueue_module.c @ 270:7bb9562216ce

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.2-2004-02-25-23:16:15 import
author Igor Sysoev <igor@sysoev.ru>
date Wed, 25 Feb 2004 20:16:15 +0000
parents d30f2c39caae
children e16dfb9b9afa
comparison
equal deleted inserted replaced
269:f082cb6bcdd7 270:7bb9562216ce
335 335
336 return NGX_OK; 336 return NGX_OK;
337 } 337 }
338 338
339 339
340 static int ngx_kqueue_process_events(ngx_log_t *log) 340 static ngx_int_t ngx_kqueue_process_events(ngx_log_t *log)
341 { 341 {
342 int events; 342 int events;
343 ngx_int_t instance, i; 343 ngx_int_t instance, i;
344 ngx_err_t err; 344 ngx_err_t err;
345 ngx_msec_t timer; 345 ngx_msec_t timer;
347 ngx_epoch_msec_t delta; 347 ngx_epoch_msec_t delta;
348 struct timeval tv; 348 struct timeval tv;
349 struct timespec ts, *tp; 349 struct timespec ts, *tp;
350 350
351 timer = ngx_event_find_timer(); 351 timer = ngx_event_find_timer();
352
353 #if (NGX_THREADS)
354 if (timer == NGX_TIMER_ERROR) {
355 return NGX_ERROR;
356 }
357
358 /*
359 * TODO: if timer is 0 and any worker thread is still busy
360 * then set 1 second timeout
361 */
362
363 #endif
364
352 ngx_old_elapsed_msec = ngx_elapsed_msec; 365 ngx_old_elapsed_msec = ngx_elapsed_msec;
353 366
354 if (timer) { 367 if (timer) {
355 ts.tv_sec = timer / 1000; 368 ts.tv_sec = timer / 1000;
356 ts.tv_nsec = (timer % 1000) * 1000000; 369 ts.tv_nsec = (timer % 1000) * 1000000;