Mercurial > hg > nginx
comparison src/event/ngx_event.c @ 345:fade4edd61f8
nginx-0.0.3-2004-06-04-18:57:33 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Fri, 04 Jun 2004 14:57:33 +0000 |
parents | e366ba5db8f8 |
children | 55e496a8ece3 |
comparison
equal
deleted
inserted
replaced
344:e366ba5db8f8 | 345:fade4edd61f8 |
---|---|
221 ecf = ngx_event_get_conf(cycle->conf_ctx, ngx_event_core_module); | 221 ecf = ngx_event_get_conf(cycle->conf_ctx, ngx_event_core_module); |
222 | 222 |
223 if (ngx_accept_mutex_ptr && ccf->worker_processes > 1 && ecf->accept_mutex) | 223 if (ngx_accept_mutex_ptr && ccf->worker_processes > 1 && ecf->accept_mutex) |
224 { | 224 { |
225 ngx_accept_mutex = ngx_accept_mutex_ptr; | 225 ngx_accept_mutex = ngx_accept_mutex_ptr; |
226 ngx_accept_mutex_held = 1; | 226 ngx_accept_mutex_held = 0; |
227 ngx_accept_mutex_delay = ecf->accept_mutex_delay; | 227 ngx_accept_mutex_delay = ecf->accept_mutex_delay; |
228 } | 228 } |
229 | 229 |
230 #if (NGX_THREADS) | 230 #if (NGX_THREADS) |
231 if (!(ngx_posted_events_mutex = ngx_mutex_init(cycle->log, 0))) { | 231 if (!(ngx_posted_events_mutex = ngx_mutex_init(cycle->log, 0))) { |
369 | 369 |
370 #else | 370 #else |
371 | 371 |
372 rev->event_handler = &ngx_event_accept; | 372 rev->event_handler = &ngx_event_accept; |
373 | 373 |
374 if (ngx_accept_mutex) { | |
375 continue; | |
376 } | |
377 | |
374 if (ngx_event_flags & NGX_USE_SIGIO_EVENT) { | 378 if (ngx_event_flags & NGX_USE_SIGIO_EVENT) { |
375 | 379 if (ngx_add_conn(c) == NGX_ERROR) { |
376 if (ngx_accept_mutex) { | 380 return NGX_ERROR; |
377 ngx_accept_mutex_held = 0; | |
378 | |
379 } else { | |
380 if (ngx_add_conn(c) == NGX_ERROR) { | |
381 return NGX_ERROR; | |
382 } | |
383 } | 381 } |
384 | 382 |
385 } else { | 383 } else { |
386 if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { | 384 if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { |
387 return NGX_ERROR; | 385 return NGX_ERROR; |