Mercurial > hg > nginx

comparison src/os/unix/ngx_process_cycle.c @ 371:780e93985b93

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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;