Mercurial > hg > nginx
comparison src/os/unix/ngx_process_cycle.c @ 371:780e93985b93
nginx-0.0.7-2004-06-28-20:05:02 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Mon, 28 Jun 2004 16:05:02 +0000 |
parents | 54f76b0b8dca |
children | 744ccb59062d |
comparison
equal
deleted
inserted
replaced
370:54f76b0b8dca | 371:780e93985b93 |
---|---|
623 if (ngx_init_threads(5, 128 * 1024 * 1024, cycle) == NGX_ERROR) { | 623 if (ngx_init_threads(5, 128 * 1024 * 1024, cycle) == NGX_ERROR) { |
624 /* fatal */ | 624 /* fatal */ |
625 exit(2); | 625 exit(2); |
626 } | 626 } |
627 | 627 |
628 if (!(ngx_posted_events_cv = ngx_cv_init(cycle->log))) { | 628 if (!(ngx_posted_events_cv = ngx_cond_init(cycle->log))) { |
629 /* fatal */ | 629 /* fatal */ |
630 exit(2); | 630 exit(2); |
631 } | 631 } |
632 | 632 |
633 ngx_posted_events_mutex = &ngx_posted_events_cv->mutex; | 633 for (i = 0; i < 2; i++) { |
634 | |
635 for (i = 0; i < 1; i++) { | |
636 if (ngx_create_thread(&tid, ngx_worker_thread_cycle, | 634 if (ngx_create_thread(&tid, ngx_worker_thread_cycle, |
637 cycle, cycle->log) != 0) | 635 cycle, cycle->log) != 0) |
638 { | 636 { |
639 /* fatal */ | 637 /* fatal */ |
640 exit(2); | 638 exit(2); |
778 "thread %d started", ngx_thread_self()); | 776 "thread %d started", ngx_thread_self()); |
779 | 777 |
780 ngx_setproctitle("worker thread"); | 778 ngx_setproctitle("worker thread"); |
781 | 779 |
782 for ( ;; ) { | 780 for ( ;; ) { |
783 if (ngx_cv_wait(ngx_posted_events_cv) == NGX_ERROR) { | 781 if (ngx_cond_wait(ngx_posted_events_cv, ngx_posted_events_mutex) |
782 == NGX_ERROR) | |
783 { | |
784 return 1; | 784 return 1; |
785 } | 785 } |
786 | 786 |
787 if (ngx_event_thread_process_posted(cycle) == NGX_ERROR) { | 787 if (ngx_event_thread_process_posted(cycle) == NGX_ERROR) { |
788 return 1; | 788 return 1; |