Mercurial > hg > nginx

comparison src/event/ngx_event.h @ 143:5526213be452

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.1-2003-10-10-19:10:50 import
author Igor Sysoev <igor@sysoev.ru>
date Fri, 10 Oct 2003 15:10:50 +0000
parents 54307053f185
children ef8c87afcfc5
comparison
equal deleted inserted replaced
142:cb77c084acdb 143:5526213be452
377 #include <ngx_event_timer.h> 377 #include <ngx_event_timer.h>
378 #if (WIN32) 378 #if (WIN32)
379 #include <ngx_iocp_module.h> 379 #include <ngx_iocp_module.h>
380 #endif 380 #endif
381 381
382
383
384 ngx_inline static int ngx_handle_read_event(ngx_event_t *rev)
385 {
386 if (ngx_event_flags & (NGX_HAVE_AIO_EVENT|NGX_HAVE_EDGE_EVENT)) {
387
388 /* aio, iocp, epoll */
389
390 return NGX_OK;
391 }
392
393 if (ngx_event_flags & NGX_HAVE_CLEAR_EVENT) {
394
395 /* kqueue */
396
397 if (!rev->active && !rev->ready) {
398 if (ngx_add_event(rev, NGX_READ_EVENT, NGX_CLEAR_EVENT)
399 == NGX_ERROR) {
400 return NGX_ERROR;
401 }
402 }
403
404 return NGX_OK;
405 }
406
407 /* select, poll, /dev/poll */
408
409 if (!rev->active && !rev->ready) {
410 if (ngx_add_event(rev, NGX_READ_EVENT, NGX_LEVEL_EVENT) == NGX_ERROR) {
411 return NGX_ERROR;
412 }
413
414 return NGX_OK;
415 }
416
417 if (rev->active && rev->ready) {
418 if (ngx_del_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) {
419 return NGX_ERROR;
420 }
421
422 return NGX_OK;
423 }
424
425 return NGX_OK;
426 }
427
428
429 ngx_inline static int ngx_handle_write_event(ngx_event_t *wev, int lowat)
430 {
431 if (ngx_event_flags & (NGX_HAVE_AIO_EVENT|NGX_HAVE_EDGE_EVENT)) {
432
433 /* aio, iocp, epoll */
434
435 return NGX_OK;
436 }
437
438 if (ngx_event_flags & NGX_HAVE_CLEAR_EVENT) {
439
440 /* kqueue */
441
442 #if (HAVE_LOWAT_EVENT) /* kqueue's NOTE_LOWAT */
443
444 if (ngx_event_flags & NGX_HAVE_LOWAT_EVENT) {
445 wev->lowat = lowat;
446 }
447
448 #endif
449 if (!wev->active && !wev->ready) {
450 if (ngx_add_event(wev, NGX_WRITE_EVENT, NGX_CLEAR_EVENT)
451 == NGX_ERROR) {
452 return NGX_ERROR;
453 }
454 }
455
456 return NGX_OK;
457 }
458
459 /* select, poll, /dev/poll */
460
461 if (!wev->active && !wev->ready) {
462 if (ngx_add_event(wev, NGX_WRITE_EVENT, NGX_LEVEL_EVENT) == NGX_ERROR) {
463 return NGX_ERROR;
464 }
465
466 return NGX_OK;
467 }
468
469 if (wev->active && wev->ready) {
470 if (ngx_del_event(wev, NGX_WRITE_EVENT, 0) == NGX_ERROR) {
471 return NGX_ERROR;
472 }
473
474 return NGX_OK;
475 }
476
477 return NGX_OK;
478 }
479
480
481
382 /* ***************************** */ 482 /* ***************************** */
383 483
384 484
385 #endif /* _NGX_EVENT_H_INCLUDED_ */ 485 #endif /* _NGX_EVENT_H_INCLUDED_ */