1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
volitile int ngx_last_posted_event;
typedef struct {
ngx_tid_t tid;
ngx_cv_t cv;
} ngx_thread_data_t;
static ngx_thread_data_t *threead_data;
{
err = ngx_thread_cond_wait(ngx_thread_data_cv, ngx_thread_data_mutex);
tid = ngx_thread_self();
for (i = 0; i < thread_data_n; i++) {
if (thread_data[i].tid == tid) {
cv = thread_data[i].cv;
break;
}
}
if (i == thread_data_n) {
error
return
}
for ( ;; ) {
err = ngx_thread_cond_wait(cv, ngx_posted_events_mutex);
if (err) {
ngx_log_error(NGX_ALERT, log, err,
ngx_thread_cond_wait_n " failed, thread is exiting");
return;
}
for ( ;; ) {
ev = NULL;
for (i = ngx_last_posted_event; i > 0; i--) {
ev = ngx_posted_events[i];
if (ev == NULL) {
continue;
}
err = ngx_thread_mutex_trylock(ev->mutex);
if (err == 0) {
ngx_posted_events[i] = NULL;
while (ngx_posted_events[ngx_last_posted_event] == NULL) {
ngx_last_posted_event--;
}
break;
}
if (err == NGX_EBUSY) {
ev = NULL;
continue;
}
ngx_log_error(NGX_ALERT, log, err,
ngx_thread_mutex_unlock_n " failed,
thread is exiting");
ngx_worker_thread_error();
return;
}
err = ngx_thread_mutex_unlock(ngx_posted_events_mutex);
if (err) {
ngx_log_error(NGX_ALERT, log, err,
ngx_thread_mutex_unlock_n
" failed, thread exiting");
return;
}
if (ev == NULL) {
break;
}
ngx_event_handle_event(ev);
err = ngx_thread_mutex_unlock(ev->mutex);
if (err) {
ngx_log_error(NGX_ALERT, log, err,
ngx_thread_mutex_unlock_n
" failed, thread exiting");
ngx_worker_thread_error();
return;
}
err = ngx_thread_mutex_lock(ngx_posted_events_mutex);
if (err) {
ngx_log_error(NGX_ALERT, log, err,
ngx_thread_mutex_lock_n
" failed, thread exiting");
return;
}
}
if (restart) {
ngx_log_error(NGX_INFO, log, 0, "thread is exiting");
return;
}
}
}
ngx_worker_thread_error()
{
ngx_err_t err;
err = ngx_thread_mutex_unlock(ngx_posted_events_mutex);
if (err) {
ngx_log_error(NGX_ALERT, log, err,
ngx_thread_mutex_unlock_n
" failed, thread exiting");
}
}
|
