Mercurial > hg > nginx

comparison src/event/modules/ngx_kqueue_module.c @ 377:41437e4fd9b4

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.7-2004-07-05-19:08:23 import
author Igor Sysoev <igor@sysoev.ru>
date Mon, 05 Jul 2004 15:08:23 +0000
parents d0451e402e27
children b7d3625c9336
comparison
equal deleted inserted replaced
376:d0451e402e27 377:41437e4fd9b4
155 |NGX_USE_LEVEL_EVENT 155 |NGX_USE_LEVEL_EVENT
156 #endif 156 #endif
157 #if (HAVE_LOWAT_EVENT) 157 #if (HAVE_LOWAT_EVENT)
158 |NGX_HAVE_LOWAT_EVENT 158 |NGX_HAVE_LOWAT_EVENT
159 #endif 159 #endif
160 |NGX_HAVE_INSTANCE_EVENT
161 |NGX_HAVE_KQUEUE_EVENT; 160 |NGX_HAVE_KQUEUE_EVENT;
162 161
163 return NGX_OK; 162 return NGX_OK;
164 } 163 }
165 164
368 struct timespec ts, *tp; 367 struct timespec ts, *tp;
369 368
370 for ( ;; ) { 369 for ( ;; ) {
371 timer = ngx_event_find_timer(); 370 timer = ngx_event_find_timer();
372 371
373 #if (NGX_THREADS0) 372 #if (NGX_THREADS)
374 if (timer == NGX_TIMER_ERROR) { 373 if (timer == NGX_TIMER_ERROR) {
375 return NGX_ERROR; 374 return NGX_ERROR;
376 } 375 }
377 376
378 if (timer == NGX_TIMER_INFINITE || timer > 500) { 377 if (timer == NGX_TIMER_INFINITE || timer > 500) {
520 519
521 if (ev->log && (ev->log->log_level & NGX_LOG_DEBUG_CONNECTION)) { 520 if (ev->log && (ev->log->log_level & NGX_LOG_DEBUG_CONNECTION)) {
522 ngx_kqueue_dump_event(ev->log, &event_list[i]); 521 ngx_kqueue_dump_event(ev->log, &event_list[i]);
523 } 522 }
524 523
525 ev->returned_instance = instance;
526
527 #if (NGX_THREADS) 524 #if (NGX_THREADS)
528 525
529 if (ngx_threaded && !ev->accept) { 526 if (ngx_threaded && !ev->accept) {
530 ev->posted_ready = 1; 527 ev->posted_ready = 1;
531 ev->posted_available += event_list[i].data; 528 ev->posted_available = event_list[i].data;
532 529
533 if (event_list[i].flags & EV_EOF) { 530 if (event_list[i].flags & EV_EOF) {
534 ev->posted_eof = 1; 531 ev->posted_eof = 1;
535 ev->posted_errno = event_list[i].fflags; 532 ev->posted_errno = event_list[i].fflags;
536 } 533 }