nginx: src/event/modules/ngx_rtsig

nginx-0.0.9-2004-07-28-20:16:50 import

comparison

equal deleted inserted replaced

-:b32ca005e025
+:f209f3391020
 err = ngx_errno;
 ngx_log_error((err == NGX_EINTR) ? NGX_LOG_INFO : NGX_LOG_ALERT,
 cycle->log, 0,
 "poll() failed while the overflow recover");
-if (err != NGX_EINTR) {
+if (err == NGX_EINTR) {
-break;
+continue;
 }
 }
+break;
 }
 if (ready <= 0) {
 continue;
 }
-if (n) {
+if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) {
-if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) {
+return NGX_ERROR;
-return NGX_ERROR;
-}
 }
 for (i = 0; i < n; i++) {
 c = &cycle->connections[overflow_list[i].fd];
 wev->event_handler(wev);
 }
 }
 }
-if (n) {
+ngx_mutex_unlock(ngx_posted_events_mutex);
-ngx_mutex_unlock(ngx_posted_events_mutex);
-}
 if (tested >= rtscf->overflow_test) {
 if (ngx_linux_rtsig_max) {
 "sysctl(KERN_RTSIGNR) failed");
 return NGX_ERROR;
 }
 /*
-* drain rt signal queue if the /proc/sys/kernel/rtsig-nr
+* drain the rt signal queue if the /proc/sys/kernel/rtsig-nr
 * is bigger than
 *    /proc/sys/kernel/rtsig-max / rtsig_overflow_threshold
 */
 if (rtsig_max / rtscf->overflow_threshold < rtsig_nr) {
 } else {
 /*
 * Linux has not KERN_RTSIGMAX since 2.6.6-mm2
-* so drain rt signal queue unconditionally
+* so drain the rt signal queue unconditionally
 */
 while (ngx_rtsig_process_events(cycle) == NGX_OK) { /* void */ }
 }

Mercurial > hg > nginx