Mercurial > hg > nginx

comparison src/event/modules/ngx_devpoll_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 e43f406e4525
comparison
equal deleted inserted replaced
58:6b13b1cadabe 59:e8cdc2989cee
14 14
15 #if (USE_DEVPOLL) && !(HAVE_DEVPOLL) 15 #if (USE_DEVPOLL) && !(HAVE_DEVPOLL)
16 #error "/dev/poll is not supported on this platform" 16 #error "/dev/poll is not supported on this platform"
17 #endif 17 #endif
18 18
19 static int ngx_devpoll_set_event(ngx_event_t *ev, int event, u_int flags);
19 20
20 /* STUB */ 21 /* STUB */
21 #define DEVPOLL_NCHANGES 512 22 #define DEVPOLL_NCHANGES 512
22 #define DEVPOLL_NEVENTS 512 23 #define DEVPOLL_NEVENTS 512
23 24
135 136
136 return NGX_OK; 137 return NGX_OK;
137 } 138 }
138 139
139 140
140 int ngx_devpoll_set_event(ngx_event_t *ev, int event, u_int flags) 141 static int ngx_devpoll_set_event(ngx_event_t *ev, int event, u_int flags)
141 { 142 {
142 int n; 143 int n;
143 ngx_connection_t *c; 144 ngx_connection_t *c;
144 145
145 c = (ngx_connection_t *) ev->data; 146 c = (ngx_connection_t *) ev->data;
190 int ngx_devpoll_process_events(ngx_log_t *log) 191 int ngx_devpoll_process_events(ngx_log_t *log)
191 { 192 {
192 int events, n, i; 193 int events, n, i;
193 ngx_msec_t timer, delta; 194 ngx_msec_t timer, delta;
194 ngx_err_t err; 195 ngx_err_t err;
195 ngx_event_t *ev;
196 ngx_connection_t *c; 196 ngx_connection_t *c;
197 struct dvpoll dvp; 197 struct dvpoll dvp;
198 struct timeval tv; 198 struct timeval tv;
199 199
200 timer = ngx_event_find_timer(); 200 timer = ngx_event_find_timer();
231 return NGX_ERROR; 231 return NGX_ERROR;
232 } 232 }
233 233
234 nchanges = 0; 234 nchanges = 0;
235 235
236 if (timer != INFTIM) { 236 if ((int) timer != INFTIM) {
237 gettimeofday(&tv, NULL); 237 gettimeofday(&tv, NULL);
238 delta = tv.tv_sec * 1000 + tv.tv_usec / 1000 - delta; 238 delta = tv.tv_sec * 1000 + tv.tv_usec / 1000 - delta;
239 239
240 } else { 240 } else {
241 if (events == 0) { 241 if (events == 0) {
303 "ioctl(DP_POLL) error on %d:%d", 303 "ioctl(DP_POLL) error on %d:%d",
304 event_list[i].fd, event_list[i].revents); 304 event_list[i].fd, event_list[i].revents);
305 } 305 }
306 } 306 }
307 307
308 if (timer != INFTIM) { 308 if ((int) timer != INFTIM) {
309 ngx_event_expire_timers(delta); 309 ngx_event_expire_timers(delta);
310 } 310 }
311 311
312 return NGX_OK; 312 return NGX_OK;
313 } 313 }