nginx: src/event/modules/ngx_rtsig

comparison src/event/modules/ngx_rtsig_module.c @ 316:a0beefedaf94

nginx-0.0.3-2004-04-15-00:34:05 import

author	Igor Sysoev <igor@sysoev.ru>
date	Wed, 14 Apr 2004 20:34:05 +0000
parents	6b91bfbc4123
children	1308b98496a2

comparison

equal deleted inserted replaced

-:39b6f2df45c0
+:a0beefedaf94
 int ngx_rtsig_process_events(ngx_cycle_t *cycle)
 {
 int                 signo;
 ngx_int_t           instance, i;
+ngx_uint_t          expire;
 size_t              n;
 ngx_msec_t          timer;
 ngx_err_t           err;
 siginfo_t           si;
 struct timeval      tv;
 struct timespec     ts, *tp;
 struct sigaction    sa;
+ngx_epoch_msec_t    delta;
 ngx_connection_t   *c;
-ngx_epoch_msec_t    delta;
 ngx_rtsig_conf_t   *rtscf;
-timer = ngx_event_find_timer();
+for ( ;; ) {
-ngx_old_elapsed_msec = ngx_elapsed_msec;
+timer = ngx_event_find_timer();
-if (timer) {
+if (timer != 0) {
+break;
+}
+ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
+"rtsig expired timer");
+ngx_event_expire_timers(0);
+}
+expire = 1;
+if (ngx_accept_mutex) {
+if (ngx_trylock_accept_mutex(cycle) == NGX_ERROR) {
+return NGX_ERROR;
+}
+if (ngx_accept_mutex_held == 0
+&& (timer == NGX_TIMER_INFINITE || timer > ngx_accept_mutex_delay))
+{
+timer = ngx_accept_mutex_delay;
+expire = 0;
+}
+}
+if (timer == NGX_TIMER_INFINITE) {
+tp = NULL;
+expire = 0;
+} else {
 ts.tv_sec = timer / 1000;
 ts.tv_nsec = (timer % 1000) * 1000000;
 tp = &ts;
+}
-} else {
-tp = NULL;
+ngx_old_elapsed_msec = ngx_elapsed_msec;
-}
 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
 "rtsig timer: %d", timer);
 /* Linux sigwaitinfo() is sigtimedwait() with the NULL timeout pointer */
 ngx_elapsed_msec = tv.tv_sec * 1000 + tv.tv_usec / 1000 - ngx_start_msec;
 if (err) {
 ngx_log_error((err == NGX_EINTR) ? NGX_LOG_INFO : NGX_LOG_ALERT,
 cycle->log, err, "sigtimedwait() failed");
-return NGX_ERROR;
+ngx_accept_mutex_unlock();
-}
+return NGX_ERROR;
+}
-if (timer) {
+if (timer != NGX_TIMER_INFINITE) {
 delta = ngx_elapsed_msec - delta;
 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
 "rtsig timer: %d, delta: %d", timer, (int) delta);
 }
 /* TODO: stale signals */
 if (si.si_band & (POLLIN|POLLHUP|POLLERR)) {
 if (c->read->active) {
 c->read->ready = 1;
-c->read->event_handler(c->read);
+if (!ngx_threaded && !ngx_accept_mutex_held) {
+c->read->event_handler(c->read);
+} else if (c->read->accept) {
+c->read->event_handler(c->read);
+} else {
+if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) {
+ngx_accept_mutex_unlock();
+return NGX_ERROR;
+}
+ngx_post_event(c->read);
+ngx_mutex_unlock(ngx_posted_events_mutex);
+}
 }
 }
 if (si.si_band & (POLLOUT|POLLHUP|POLLERR)) {
 if (c->write->active) {
 c->write->ready = 1;
-c->write->event_handler(c->write);
+if (!ngx_threaded && !ngx_accept_mutex_held) {
+c->write->event_handler(c->write);
+} else {
+if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) {
+ngx_accept_mutex_unlock();
+return NGX_ERROR;
+}
+ngx_post_event(c->write);
+ngx_mutex_unlock(ngx_posted_events_mutex);
+}
 }
 }
 } else if (signo == SIGIO) {
+ngx_accept_mutex_unlock();
 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
 "signal queue overflowed: "
 "SIGIO, fd:%d, band:%X", si.si_fd, si.si_band);
 /* TODO: flush all the used RT signals */
 } else {
 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0,
 "sigtimedwait() returned unexpected signal: %d", signo);
-return NGX_ERROR;
+ngx_accept_mutex_unlock();
-}
+return NGX_ERROR;
+}
-if (timer != (ngx_msec_t) -1 && delta) {
+ngx_accept_mutex_unlock();
+if (expire && delta) {
 ngx_event_expire_timers((ngx_msec_t) delta);
+}
+if (!ngx_threaded) {
+ngx_event_process_posted(cycle);
 }
 return NGX_OK;
 }

Mercurial > hg > nginx

comparison src/event/modules/ngx_rtsig_module.c @ 316:a0beefedaf94