Mercurial > hg > nginx
view src/event/ngx_event_posted.c @ 376:d0451e402e27
nginx-0.0.7-2004-07-05-10:55:54 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Mon, 05 Jul 2004 06:55:54 +0000 |
parents | 744ccb59062d |
children | 41437e4fd9b4 |
line wrap: on
line source
#include <ngx_config.h> #include <ngx_core.h> #include <ngx_event.h> ngx_thread_volatile ngx_event_t *ngx_posted_events; #if (NGX_THREADS) ngx_mutex_t *ngx_posted_events_mutex; #endif void ngx_event_process_posted(ngx_cycle_t *cycle) { ngx_event_t *ev; for ( ;; ) { ev = (ngx_event_t *) ngx_posted_events; ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "posted event " PTR_FMT, ev); if (ev == NULL) { return; } ngx_delete_posted_event(ev); #if 0 /* do not check instance ??? */ if (ev->accept) { continue; } #endif if (ev->closed || (ev->use_instance && ev->instance != ev->returned_instance)) { /* * the stale event from a file descriptor * that was just closed in this iteration */ ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "stale posted event " PTR_FMT, ev); continue; } ev->event_handler(ev); } } #if (NGX_THREADS) void ngx_wakeup_worker_thread(ngx_cycle_t *cycle) { ngx_int_t i; for (i = 0; i < ngx_threads_n; i++) { if (ngx_threads[i].state == NGX_THREAD_FREE) { ngx_cond_signal(ngx_threads[i].cv); return; } } } ngx_int_t ngx_event_thread_process_posted(ngx_cycle_t *cycle) { ngx_event_t *ev; for ( ;; ) { ev = (ngx_event_t *) ngx_posted_events; for ( ;; ) { ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "posted event " PTR_FMT, ev); if (ev == NULL) { return NGX_OK; } if (ngx_trylock(ev->lock) == 0) { ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "posted event " PTR_FMT " is busy", ev); ev = ev->next; continue; } ngx_delete_posted_event(ev); ngx_log_debug3(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "event instance: c:%d i:%d r:%d", ev->closed, ev->instance, ev->returned_instance); if (ev->closed || (ev->use_instance && ev->instance != ev->returned_instance)) { /* * The stale event from a file descriptor that was just * closed in this iteration. We use ngx_cycle->log * because ev->log may be already destoyed. */ ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ngx_cycle->log, 0, "stale posted event " PTR_FMT, ev); ngx_unlock(ev->lock); ev = ev->next; continue; } ev->locked = 1; ev->ready |= ev->posted_ready; ev->timedout |= ev->posted_timedout; ev->available |= ev->posted_available; ev->pending_eof |= ev->posted_eof; #if (HAVE_KQUEUE) ev->kq_errno |= ev->posted_errno; #endif ev->posted_ready = 0; ev->posted_timedout = 0; ev->posted_available = 0; ev->posted_eof = 0; #if (HAVE_KQUEUE) ev->posted_errno = 0; #endif ngx_mutex_unlock(ngx_posted_events_mutex); ev->event_handler(ev); if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) { return NGX_ERROR; } if (ev->locked) { ngx_unlock(ev->lock); } break; } } } #else void ngx_wakeup_worker_thread(ngx_cycle_t *cycle) { } #endif