comparison src/os/unix/ngx_process_cycle.c @ 379:73688d5d7fc3

nginx-0.0.7-2004-07-06-20:12:16 import
author Igor Sysoev <igor@sysoev.ru>
date Tue, 06 Jul 2004 16:12:16 +0000
parents 41437e4fd9b4
children 5ce6561246a5
comparison
equal deleted inserted replaced
378:b7d3625c9336 379:73688d5d7fc3
824 824
825 static void* ngx_worker_thread_cycle(void *data) 825 static void* ngx_worker_thread_cycle(void *data)
826 { 826 {
827 ngx_thread_t *thr = data; 827 ngx_thread_t *thr = data;
828 828
829 sigset_t set; 829 sigset_t set;
830 ngx_err_t err; 830 ngx_err_t err;
831 struct timeval tv; 831 ngx_tls_t *tls;
832 struct timeval tv;
832 833
833 thr->cv->tid = ngx_thread_self(); 834 thr->cv->tid = ngx_thread_self();
834 835
835 sigemptyset(&set); 836 sigemptyset(&set);
836 sigaddset(&set, ngx_signal_value(NGX_RECONFIGURE_SIGNAL)); 837 sigaddset(&set, ngx_signal_value(NGX_RECONFIGURE_SIGNAL));
847 ngx_log_debug1(NGX_LOG_DEBUG_CORE, ngx_cycle->log, ngx_errno, 848 ngx_log_debug1(NGX_LOG_DEBUG_CORE, ngx_cycle->log, ngx_errno,
848 "thread " TID_T_FMT " started", ngx_thread_self()); 849 "thread " TID_T_FMT " started", ngx_thread_self());
849 850
850 ngx_setthrtitle("worker thread"); 851 ngx_setthrtitle("worker thread");
851 852
853 if (!(tls = ngx_calloc(sizeof(ngx_tls_t), ngx_cycle->log))) {
854 return (void *) 1;
855 }
856
857 err = ngx_thread_create_tls();
858 if (err != 0) {
859 ngx_log_error(NGX_LOG_ALERT, ngx_cycle->log, err,
860 ngx_thread_create_tls_n " failed");
861 return (void *) 1;
862 }
863
864 ngx_thread_set_tls(tls);
865
852 if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) { 866 if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) {
853 return (void *) 1; 867 return (void *) 1;
854 } 868 }
855 869
856 for ( ;; ) { 870 for ( ;; ) {