Mercurial > hg > nginx

comparison src/event/modules/ngx_poll_module.c @ 59:e8cdc2989cee

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.1-2003-02-06-20:21:13 import
author Igor Sysoev <igor@sysoev.ru>
date Thu, 06 Feb 2003 17:21:13 +0000
parents d1e42f1b8fd4
children 50186b49f2ad
comparison
equal deleted inserted replaced
58:6b13b1cadabe 59:e8cdc2989cee
11 #include <ngx_poll_module.h> 11 #include <ngx_poll_module.h>
12 12
13 13
14 /* should be per-thread */ 14 /* should be per-thread */
15 static struct pollfd *event_list; 15 static struct pollfd *event_list;
16 static unsigned int nevents; 16 static u_int nevents;
17 17
18 static ngx_event_t **event_index; 18 static ngx_event_t **event_index;
19 static ngx_event_t **ready_index; 19 static ngx_event_t **ready_index;
20 static ngx_event_t *timer_queue; 20 static ngx_event_t *timer_queue;
21 /* */ 21 /* */
138 return NGX_OK; 138 return NGX_OK;
139 } 139 }
140 140
141 int ngx_poll_process_events(ngx_log_t *log) 141 int ngx_poll_process_events(ngx_log_t *log)
142 { 142 {
143 int i, ready, nready, found; 143 int ready, found;
144 u_int i, nready;
144 ngx_msec_t timer, delta; 145 ngx_msec_t timer, delta;
145 ngx_err_t err; 146 ngx_err_t err;
146 ngx_event_t *ev; 147 ngx_event_t *ev;
147 ngx_connection_t *c; 148 ngx_connection_t *c;
148 149
170 return NGX_ERROR; 171 return NGX_ERROR;
171 } 172 }
172 173
173 ngx_log_debug(log, "poll ready %d" _ ready); 174 ngx_log_debug(log, "poll ready %d" _ ready);
174 175
175 if (timer != INFTIM) { 176 if ((int) timer != INFTIM) {
176 delta = ngx_msec() - delta; 177 delta = ngx_msec() - delta;
177 178
178 } else { 179 } else {
179 if (ready == 0) { 180 if (ready == 0) {
180 ngx_log_error(NGX_LOG_ALERT, log, 0, 181 ngx_log_error(NGX_LOG_ALERT, log, 0,
254 255
255 if (ready != 0) { 256 if (ready != 0) {
256 ngx_log_error(NGX_LOG_ALERT, log, 0, "poll ready != events"); 257 ngx_log_error(NGX_LOG_ALERT, log, 0, "poll ready != events");
257 } 258 }
258 259
259 if (timer != INFTIM) { 260 if ((int) timer != INFTIM) {
260 ngx_event_expire_timers(delta); 261 ngx_event_expire_timers(delta);
261 } 262 }
262 263
263 return NGX_OK; 264 return NGX_OK;
264 } 265 }