ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/libev/ev.c
(Generate patch)

Comparing libev/ev.c (file contents):
Revision 1.32 by root, Thu Nov 1 09:21:51 2007 UTC vs.
Revision 1.85 by root, Sat Nov 10 03:13:50 2007 UTC

1/* 1/*
2 * libev event processing core, watcher management
3 *
2 * Copyright (c) 2007 Marc Alexander Lehmann <libev@schmorp.de> 4 * Copyright (c) 2007 Marc Alexander Lehmann <libev@schmorp.de>
3 * All rights reserved. 5 * All rights reserved.
4 * 6 *
5 * Redistribution and use in source and binary forms, with or without 7 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are 8 * modification, are permitted provided that the following conditions are
24 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 26 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
25 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 27 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
26 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 28 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
27 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 29 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28 */ 30 */
29#if EV_USE_CONFIG_H 31#ifndef EV_STANDALONE
30# include "config.h" 32# include "config.h"
33
34# if HAVE_CLOCK_GETTIME
35# define EV_USE_MONOTONIC 1
36# define EV_USE_REALTIME 1
37# endif
38
39# if HAVE_SELECT && HAVE_SYS_SELECT_H
40# define EV_USE_SELECT 1
41# endif
42
43# if HAVE_POLL && HAVE_POLL_H
44# define EV_USE_POLL 1
45# endif
46
47# if HAVE_EPOLL && HAVE_EPOLL_CTL && HAVE_SYS_EPOLL_H
48# define EV_USE_EPOLL 1
49# endif
50
51# if HAVE_KQUEUE && HAVE_WORKING_KQUEUE && HAVE_SYS_EVENT_H && HAVE_SYS_QUEUE_H
52# define EV_USE_KQUEUE 1
53# endif
54
31#endif 55#endif
32 56
33#include <math.h> 57#include <math.h>
34#include <stdlib.h> 58#include <stdlib.h>
35#include <unistd.h>
36#include <fcntl.h> 59#include <fcntl.h>
37#include <signal.h>
38#include <stddef.h> 60#include <stddef.h>
39 61
40#include <stdio.h> 62#include <stdio.h>
41 63
42#include <assert.h> 64#include <assert.h>
43#include <errno.h> 65#include <errno.h>
44#include <sys/types.h> 66#include <sys/types.h>
45#include <sys/wait.h>
46#include <sys/time.h>
47#include <time.h> 67#include <time.h>
48 68
69#include <signal.h>
70
71#ifndef WIN32
72# include <unistd.h>
73# include <sys/time.h>
74# include <sys/wait.h>
75#endif
76/**/
77
49#ifndef EV_USE_MONOTONIC 78#ifndef EV_USE_MONOTONIC
50# ifdef CLOCK_MONOTONIC
51# define EV_USE_MONOTONIC 1 79# define EV_USE_MONOTONIC 1
52# endif
53#endif 80#endif
54 81
55#ifndef EV_USE_SELECT 82#ifndef EV_USE_SELECT
56# define EV_USE_SELECT 1 83# define EV_USE_SELECT 1
57#endif 84#endif
58 85
86#ifndef EV_USE_POLL
87# define EV_USE_POLL 0 /* poll is usually slower than select, and not as well tested */
88#endif
89
59#ifndef EV_USE_EPOLL 90#ifndef EV_USE_EPOLL
60# define EV_USE_EPOLL 0 91# define EV_USE_EPOLL 0
61#endif 92#endif
62 93
94#ifndef EV_USE_KQUEUE
95# define EV_USE_KQUEUE 0
96#endif
97
98#ifndef EV_USE_WIN32
99# ifdef WIN32
100# define EV_USE_WIN32 0 /* it does not exist, use select */
101# undef EV_USE_SELECT
102# define EV_USE_SELECT 1
103# else
104# define EV_USE_WIN32 0
105# endif
106#endif
107
108#ifndef EV_USE_REALTIME
109# define EV_USE_REALTIME 1
110#endif
111
112/**/
113
114#ifndef CLOCK_MONOTONIC
115# undef EV_USE_MONOTONIC
116# define EV_USE_MONOTONIC 0
117#endif
118
63#ifndef CLOCK_REALTIME 119#ifndef CLOCK_REALTIME
120# undef EV_USE_REALTIME
64# define EV_USE_REALTIME 0 121# define EV_USE_REALTIME 0
65#endif 122#endif
66#ifndef EV_USE_REALTIME 123
67# define EV_USE_REALTIME 1 /* posix requirement, but might be slower */ 124/**/
68#endif
69 125
70#define MIN_TIMEJUMP 1. /* minimum timejump that gets detected (if monotonic clock available) */ 126#define MIN_TIMEJUMP 1. /* minimum timejump that gets detected (if monotonic clock available) */
71#define MAX_BLOCKTIME 59.731 /* never wait longer than this time (to detetc time jumps) */ 127#define MAX_BLOCKTIME 59.731 /* never wait longer than this time (to detect time jumps) */
72#define PID_HASHSIZE 16 /* size of pid hash table, must be power of two */ 128#define PID_HASHSIZE 16 /* size of pid hash table, must be power of two */
73#define CLEANUP_INTERVAL (MAX_BLOCKTIME * 5.) /* how often to try to free memory and re-check fds */ 129/*#define CLEANUP_INTERVAL 300. /* how often to try to free memory and re-check fds */
74 130
131#ifdef EV_H
132# include EV_H
133#else
75#include "ev.h" 134# include "ev.h"
135#endif
136
137#if __GNUC__ >= 3
138# define expect(expr,value) __builtin_expect ((expr),(value))
139# define inline inline
140#else
141# define expect(expr,value) (expr)
142# define inline static
143#endif
144
145#define expect_false(expr) expect ((expr) != 0, 0)
146#define expect_true(expr) expect ((expr) != 0, 1)
147
148#define NUMPRI (EV_MAXPRI - EV_MINPRI + 1)
149#define ABSPRI(w) ((w)->priority - EV_MINPRI)
76 150
77typedef struct ev_watcher *W; 151typedef struct ev_watcher *W;
78typedef struct ev_watcher_list *WL; 152typedef struct ev_watcher_list *WL;
79typedef struct ev_watcher_time *WT; 153typedef struct ev_watcher_time *WT;
80 154
81static ev_tstamp now, diff; /* monotonic clock */ 155static int have_monotonic; /* did clock_gettime (CLOCK_MONOTONIC) work? */
82ev_tstamp ev_now;
83int ev_method;
84 156
85static int have_monotonic; /* runtime */ 157#include "ev_win32.c"
86
87static ev_tstamp method_fudge; /* stupid epoll-returns-early bug */
88static void (*method_modify)(int fd, int oev, int nev);
89static void (*method_poll)(ev_tstamp timeout);
90 158
91/*****************************************************************************/ 159/*****************************************************************************/
92 160
93ev_tstamp 161static void (*syserr_cb)(const char *msg);
162
163void ev_set_syserr_cb (void (*cb)(const char *msg))
164{
165 syserr_cb = cb;
166}
167
168static void
169syserr (const char *msg)
170{
171 if (!msg)
172 msg = "(libev) system error";
173
174 if (syserr_cb)
175 syserr_cb (msg);
176 else
177 {
178 perror (msg);
179 abort ();
180 }
181}
182
183static void *(*alloc)(void *ptr, long size);
184
185void ev_set_allocator (void *(*cb)(void *ptr, long size))
186{
187 alloc = cb;
188}
189
190static void *
191ev_realloc (void *ptr, long size)
192{
193 ptr = alloc ? alloc (ptr, size) : realloc (ptr, size);
194
195 if (!ptr && size)
196 {
197 fprintf (stderr, "libev: cannot allocate %ld bytes, aborting.", size);
198 abort ();
199 }
200
201 return ptr;
202}
203
204#define ev_malloc(size) ev_realloc (0, (size))
205#define ev_free(ptr) ev_realloc ((ptr), 0)
206
207/*****************************************************************************/
208
209typedef struct
210{
211 WL head;
212 unsigned char events;
213 unsigned char reify;
214} ANFD;
215
216typedef struct
217{
218 W w;
219 int events;
220} ANPENDING;
221
222#if EV_MULTIPLICITY
223
224 struct ev_loop
225 {
226 #define VAR(name,decl) decl;
227 #include "ev_vars.h"
228 #undef VAR
229 };
230 #include "ev_wrap.h"
231
232 struct ev_loop default_loop_struct;
233 static struct ev_loop *default_loop;
234
235#else
236
237 #define VAR(name,decl) static decl;
238 #include "ev_vars.h"
239 #undef VAR
240
241 static int default_loop;
242
243#endif
244
245/*****************************************************************************/
246
247inline ev_tstamp
94ev_time (void) 248ev_time (void)
95{ 249{
96#if EV_USE_REALTIME 250#if EV_USE_REALTIME
97 struct timespec ts; 251 struct timespec ts;
98 clock_gettime (CLOCK_REALTIME, &ts); 252 clock_gettime (CLOCK_REALTIME, &ts);
102 gettimeofday (&tv, 0); 256 gettimeofday (&tv, 0);
103 return tv.tv_sec + tv.tv_usec * 1e-6; 257 return tv.tv_sec + tv.tv_usec * 1e-6;
104#endif 258#endif
105} 259}
106 260
107static ev_tstamp 261inline ev_tstamp
108get_clock (void) 262get_clock (void)
109{ 263{
110#if EV_USE_MONOTONIC 264#if EV_USE_MONOTONIC
111 if (have_monotonic) 265 if (expect_true (have_monotonic))
112 { 266 {
113 struct timespec ts; 267 struct timespec ts;
114 clock_gettime (CLOCK_MONOTONIC, &ts); 268 clock_gettime (CLOCK_MONOTONIC, &ts);
115 return ts.tv_sec + ts.tv_nsec * 1e-9; 269 return ts.tv_sec + ts.tv_nsec * 1e-9;
116 } 270 }
117#endif 271#endif
118 272
119 return ev_time (); 273 return ev_time ();
120} 274}
121 275
276#if EV_MULTIPLICITY
277ev_tstamp
278ev_now (EV_P)
279{
280 return ev_rt_now;
281}
282#endif
283
122#define array_roundsize(base,n) ((n) | 4 & ~3) 284#define array_roundsize(type,n) ((n) | 4 & ~3)
123 285
124#define array_needsize(base,cur,cnt,init) \ 286#define array_needsize(type,base,cur,cnt,init) \
125 if ((cnt) > cur) \ 287 if (expect_false ((cnt) > cur)) \
126 { \ 288 { \
127 int newcnt = cur; \ 289 int newcnt = cur; \
128 do \ 290 do \
129 { \ 291 { \
130 newcnt = array_roundsize (base, newcnt << 1); \ 292 newcnt = array_roundsize (type, newcnt << 1); \
131 } \ 293 } \
132 while ((cnt) > newcnt); \ 294 while ((cnt) > newcnt); \
133 \ 295 \
134 base = realloc (base, sizeof (*base) * (newcnt)); \ 296 base = (type *)ev_realloc (base, sizeof (type) * (newcnt));\
135 init (base + cur, newcnt - cur); \ 297 init (base + cur, newcnt - cur); \
136 cur = newcnt; \ 298 cur = newcnt; \
137 } 299 }
300
301#define array_slim(type,stem) \
302 if (stem ## max < array_roundsize (stem ## cnt >> 2)) \
303 { \
304 stem ## max = array_roundsize (stem ## cnt >> 1); \
305 base = (type *)ev_realloc (base, sizeof (type) * (stem ## max));\
306 fprintf (stderr, "slimmed down " # stem " to %d\n", stem ## max);/*D*/\
307 }
308
309/* microsoft's pseudo-c is quite far from C as the rest of the world and the standard knows it */
310/* bringing us everlasting joy in form of stupid extra macros that are not required in C */
311#define array_free_microshit(stem) \
312 ev_free (stem ## s); stem ## cnt = stem ## max = 0;
313
314#define array_free(stem, idx) \
315 ev_free (stem ## s idx); stem ## cnt idx = stem ## max idx = 0;
138 316
139/*****************************************************************************/ 317/*****************************************************************************/
140
141typedef struct
142{
143 struct ev_io *head;
144 int events;
145} ANFD;
146
147static ANFD *anfds;
148static int anfdmax;
149 318
150static void 319static void
151anfds_init (ANFD *base, int count) 320anfds_init (ANFD *base, int count)
152{ 321{
153 while (count--) 322 while (count--)
154 { 323 {
155 base->head = 0; 324 base->head = 0;
156 base->events = EV_NONE; 325 base->events = EV_NONE;
326 base->reify = 0;
327
157 ++base; 328 ++base;
158 } 329 }
159} 330}
160 331
161typedef struct 332void
333ev_feed_event (EV_P_ void *w, int revents)
162{ 334{
163 W w; 335 W w_ = (W)w;
164 int events;
165} ANPENDING;
166 336
167static ANPENDING *pendings;
168static int pendingmax, pendingcnt;
169
170static void
171event (W w, int events)
172{
173 if (w->pending) 337 if (w_->pending)
174 { 338 {
175 pendings [w->pending - 1].events |= events; 339 pendings [ABSPRI (w_)][w_->pending - 1].events |= revents;
176 return; 340 return;
177 } 341 }
178 342
179 w->pending = ++pendingcnt; 343 w_->pending = ++pendingcnt [ABSPRI (w_)];
180 array_needsize (pendings, pendingmax, pendingcnt, ); 344 array_needsize (ANPENDING, pendings [ABSPRI (w_)], pendingmax [ABSPRI (w_)], pendingcnt [ABSPRI (w_)], (void));
181 pendings [pendingcnt - 1].w = w; 345 pendings [ABSPRI (w_)][w_->pending - 1].w = w_;
182 pendings [pendingcnt - 1].events = events; 346 pendings [ABSPRI (w_)][w_->pending - 1].events = revents;
183} 347}
184 348
185static void 349static void
186queue_events (W *events, int eventcnt, int type) 350queue_events (EV_P_ W *events, int eventcnt, int type)
187{ 351{
188 int i; 352 int i;
189 353
190 for (i = 0; i < eventcnt; ++i) 354 for (i = 0; i < eventcnt; ++i)
191 event (events [i], type); 355 ev_feed_event (EV_A_ events [i], type);
192} 356}
193 357
194static void 358inline void
195fd_event (int fd, int events) 359fd_event (EV_P_ int fd, int revents)
196{ 360{
197 ANFD *anfd = anfds + fd; 361 ANFD *anfd = anfds + fd;
198 struct ev_io *w; 362 struct ev_io *w;
199 363
200 for (w = anfd->head; w; w = w->next) 364 for (w = (struct ev_io *)anfd->head; w; w = (struct ev_io *)((WL)w)->next)
201 { 365 {
202 int ev = w->events & events; 366 int ev = w->events & revents;
203 367
204 if (ev) 368 if (ev)
205 event ((W)w, ev); 369 ev_feed_event (EV_A_ (W)w, ev);
206 } 370 }
371}
372
373void
374ev_feed_fd_event (EV_P_ int fd, int revents)
375{
376 fd_event (EV_A_ fd, revents);
207} 377}
208 378
209/*****************************************************************************/ 379/*****************************************************************************/
210 380
211static int *fdchanges;
212static int fdchangemax, fdchangecnt;
213
214static void 381static void
215fd_reify (void) 382fd_reify (EV_P)
216{ 383{
217 int i; 384 int i;
218 385
219 for (i = 0; i < fdchangecnt; ++i) 386 for (i = 0; i < fdchangecnt; ++i)
220 { 387 {
222 ANFD *anfd = anfds + fd; 389 ANFD *anfd = anfds + fd;
223 struct ev_io *w; 390 struct ev_io *w;
224 391
225 int events = 0; 392 int events = 0;
226 393
227 for (w = anfd->head; w; w = w->next) 394 for (w = (struct ev_io *)anfd->head; w; w = (struct ev_io *)((WL)w)->next)
228 events |= w->events; 395 events |= w->events;
229 396
230 anfd->events &= ~EV_REIFY; 397 anfd->reify = 0;
231 398
232 if (anfd->events != events)
233 {
234 method_modify (fd, anfd->events, events); 399 method_modify (EV_A_ fd, anfd->events, events);
235 anfd->events = events; 400 anfd->events = events;
236 }
237 } 401 }
238 402
239 fdchangecnt = 0; 403 fdchangecnt = 0;
240} 404}
241 405
242static void 406static void
243fd_change (int fd) 407fd_change (EV_P_ int fd)
244{ 408{
245 if (anfds [fd].events & EV_REIFY || fdchangecnt < 0) 409 if (anfds [fd].reify)
246 return; 410 return;
247 411
248 anfds [fd].events |= EV_REIFY; 412 anfds [fd].reify = 1;
249 413
250 ++fdchangecnt; 414 ++fdchangecnt;
251 array_needsize (fdchanges, fdchangemax, fdchangecnt, ); 415 array_needsize (int, fdchanges, fdchangemax, fdchangecnt, (void));
252 fdchanges [fdchangecnt - 1] = fd; 416 fdchanges [fdchangecnt - 1] = fd;
253} 417}
254 418
419static void
420fd_kill (EV_P_ int fd)
421{
422 struct ev_io *w;
423
424 while ((w = (struct ev_io *)anfds [fd].head))
425 {
426 ev_io_stop (EV_A_ w);
427 ev_feed_event (EV_A_ (W)w, EV_ERROR | EV_READ | EV_WRITE);
428 }
429}
430
431static int
432fd_valid (int fd)
433{
434#ifdef WIN32
435 return !!win32_get_osfhandle (fd);
436#else
437 return fcntl (fd, F_GETFD) != -1;
438#endif
439}
440
255/* called on EBADF to verify fds */ 441/* called on EBADF to verify fds */
256static void 442static void
257fd_recheck (void) 443fd_ebadf (EV_P)
258{ 444{
259 int fd; 445 int fd;
260 446
261 for (fd = 0; fd < anfdmax; ++fd) 447 for (fd = 0; fd < anfdmax; ++fd)
262 if (anfds [fd].events) 448 if (anfds [fd].events)
263 if (fcntl (fd, F_GETFD) == -1 && errno == EBADF) 449 if (!fd_valid (fd) == -1 && errno == EBADF)
264 while (anfds [fd].head) 450 fd_kill (EV_A_ fd);
451}
452
453/* called on ENOMEM in select/poll to kill some fds and retry */
454static void
455fd_enomem (EV_P)
456{
457 int fd;
458
459 for (fd = anfdmax; fd--; )
460 if (anfds [fd].events)
265 { 461 {
266 ev_io_stop (anfds [fd].head); 462 fd_kill (EV_A_ fd);
267 event ((W)anfds [fd].head, EV_ERROR | EV_READ | EV_WRITE | EV_TIMEOUT); 463 return;
268 } 464 }
465}
466
467/* usually called after fork if method needs to re-arm all fds from scratch */
468static void
469fd_rearm_all (EV_P)
470{
471 int fd;
472
473 /* this should be highly optimised to not do anything but set a flag */
474 for (fd = 0; fd < anfdmax; ++fd)
475 if (anfds [fd].events)
476 {
477 anfds [fd].events = 0;
478 fd_change (EV_A_ fd);
479 }
269} 480}
270 481
271/*****************************************************************************/ 482/*****************************************************************************/
272 483
273static struct ev_timer **timers;
274static int timermax, timercnt;
275
276static struct ev_periodic **periodics;
277static int periodicmax, periodiccnt;
278
279static void 484static void
280upheap (WT *timers, int k) 485upheap (WT *heap, int k)
281{ 486{
282 WT w = timers [k]; 487 WT w = heap [k];
283 488
284 while (k && timers [k >> 1]->at > w->at) 489 while (k && heap [k >> 1]->at > w->at)
285 { 490 {
286 timers [k] = timers [k >> 1]; 491 heap [k] = heap [k >> 1];
287 timers [k]->active = k + 1; 492 ((W)heap [k])->active = k + 1;
288 k >>= 1; 493 k >>= 1;
289 } 494 }
290 495
291 timers [k] = w; 496 heap [k] = w;
292 timers [k]->active = k + 1; 497 ((W)heap [k])->active = k + 1;
293 498
294} 499}
295 500
296static void 501static void
297downheap (WT *timers, int N, int k) 502downheap (WT *heap, int N, int k)
298{ 503{
299 WT w = timers [k]; 504 WT w = heap [k];
300 505
301 while (k < (N >> 1)) 506 while (k < (N >> 1))
302 { 507 {
303 int j = k << 1; 508 int j = k << 1;
304 509
305 if (j + 1 < N && timers [j]->at > timers [j + 1]->at) 510 if (j + 1 < N && heap [j]->at > heap [j + 1]->at)
306 ++j; 511 ++j;
307 512
308 if (w->at <= timers [j]->at) 513 if (w->at <= heap [j]->at)
309 break; 514 break;
310 515
311 timers [k] = timers [j]; 516 heap [k] = heap [j];
312 timers [k]->active = k + 1; 517 ((W)heap [k])->active = k + 1;
313 k = j; 518 k = j;
314 } 519 }
315 520
316 timers [k] = w; 521 heap [k] = w;
317 timers [k]->active = k + 1; 522 ((W)heap [k])->active = k + 1;
523}
524
525inline void
526adjustheap (WT *heap, int N, int k, ev_tstamp at)
527{
528 ev_tstamp old_at = heap [k]->at;
529 heap [k]->at = at;
530
531 if (old_at < at)
532 downheap (heap, N, k);
533 else
534 upheap (heap, k);
318} 535}
319 536
320/*****************************************************************************/ 537/*****************************************************************************/
321 538
322typedef struct 539typedef struct
323{ 540{
324 struct ev_signal *head; 541 WL head;
325 sig_atomic_t gotsig; 542 sig_atomic_t volatile gotsig;
326} ANSIG; 543} ANSIG;
327 544
328static ANSIG *signals; 545static ANSIG *signals;
329static int signalmax; 546static int signalmax;
330 547
331static int sigpipe [2]; 548static int sigpipe [2];
332static sig_atomic_t gotsig; 549static sig_atomic_t volatile gotsig;
333static struct ev_io sigev; 550static struct ev_io sigev;
334 551
335static void 552static void
336signals_init (ANSIG *base, int count) 553signals_init (ANSIG *base, int count)
337{ 554{
338 while (count--) 555 while (count--)
339 { 556 {
340 base->head = 0; 557 base->head = 0;
341 base->gotsig = 0; 558 base->gotsig = 0;
559
342 ++base; 560 ++base;
343 } 561 }
344} 562}
345 563
346static void 564static void
347sighandler (int signum) 565sighandler (int signum)
348{ 566{
567#if WIN32
568 signal (signum, sighandler);
569#endif
570
349 signals [signum - 1].gotsig = 1; 571 signals [signum - 1].gotsig = 1;
350 572
351 if (!gotsig) 573 if (!gotsig)
352 { 574 {
575 int old_errno = errno;
353 gotsig = 1; 576 gotsig = 1;
577#ifdef WIN32
578 send (sigpipe [1], &signum, 1, MSG_DONTWAIT);
579#else
354 write (sigpipe [1], &gotsig, 1); 580 write (sigpipe [1], &signum, 1);
581#endif
582 errno = old_errno;
355 } 583 }
356} 584}
357 585
586void
587ev_feed_signal_event (EV_P_ int signum)
588{
589 WL w;
590
591#if EV_MULTIPLICITY
592 assert (("feeding signal events is only supported in the default loop", loop == default_loop));
593#endif
594
595 --signum;
596
597 if (signum < 0 || signum >= signalmax)
598 return;
599
600 signals [signum].gotsig = 0;
601
602 for (w = signals [signum].head; w; w = w->next)
603 ev_feed_event (EV_A_ (W)w, EV_SIGNAL);
604}
605
358static void 606static void
359sigcb (struct ev_io *iow, int revents) 607sigcb (EV_P_ struct ev_io *iow, int revents)
360{ 608{
361 struct ev_signal *w;
362 int sig; 609 int signum;
363 610
611#ifdef WIN32
612 recv (sigpipe [0], &revents, 1, MSG_DONTWAIT);
613#else
614 read (sigpipe [0], &revents, 1);
615#endif
364 gotsig = 0; 616 gotsig = 0;
365 read (sigpipe [0], &revents, 1);
366 617
367 for (sig = signalmax; sig--; ) 618 for (signum = signalmax; signum--; )
368 if (signals [sig].gotsig) 619 if (signals [signum].gotsig)
369 { 620 ev_feed_signal_event (EV_A_ signum + 1);
370 signals [sig].gotsig = 0;
371
372 for (w = signals [sig].head; w; w = w->next)
373 event ((W)w, EV_SIGNAL);
374 }
375} 621}
376 622
377static void 623static void
378siginit (void) 624siginit (EV_P)
379{ 625{
626#ifndef WIN32
380 fcntl (sigpipe [0], F_SETFD, FD_CLOEXEC); 627 fcntl (sigpipe [0], F_SETFD, FD_CLOEXEC);
381 fcntl (sigpipe [1], F_SETFD, FD_CLOEXEC); 628 fcntl (sigpipe [1], F_SETFD, FD_CLOEXEC);
382 629
383 /* rather than sort out wether we really need nb, set it */ 630 /* rather than sort out wether we really need nb, set it */
384 fcntl (sigpipe [0], F_SETFL, O_NONBLOCK); 631 fcntl (sigpipe [0], F_SETFL, O_NONBLOCK);
385 fcntl (sigpipe [1], F_SETFL, O_NONBLOCK); 632 fcntl (sigpipe [1], F_SETFL, O_NONBLOCK);
633#endif
386 634
387 ev_io_set (&sigev, sigpipe [0], EV_READ); 635 ev_io_set (&sigev, sigpipe [0], EV_READ);
388 ev_io_start (&sigev); 636 ev_io_start (EV_A_ &sigev);
637 ev_unref (EV_A); /* child watcher should not keep loop alive */
389} 638}
390 639
391/*****************************************************************************/ 640/*****************************************************************************/
392 641
393static struct ev_idle **idles;
394static int idlemax, idlecnt;
395
396static struct ev_prepare **prepares;
397static int preparemax, preparecnt;
398
399static struct ev_check **checks;
400static int checkmax, checkcnt;
401
402/*****************************************************************************/
403
404static struct ev_child *childs [PID_HASHSIZE]; 642static struct ev_child *childs [PID_HASHSIZE];
643
644#ifndef WIN32
645
405static struct ev_signal childev; 646static struct ev_signal childev;
406 647
407#ifndef WCONTINUED 648#ifndef WCONTINUED
408# define WCONTINUED 0 649# define WCONTINUED 0
409#endif 650#endif
410 651
411static void 652static void
412childcb (struct ev_signal *sw, int revents) 653child_reap (EV_P_ struct ev_signal *sw, int chain, int pid, int status)
413{ 654{
414 struct ev_child *w; 655 struct ev_child *w;
656
657 for (w = (struct ev_child *)childs [chain & (PID_HASHSIZE - 1)]; w; w = (struct ev_child *)((WL)w)->next)
658 if (w->pid == pid || !w->pid)
659 {
660 ev_priority (w) = ev_priority (sw); /* need to do it *now* */
661 w->rpid = pid;
662 w->rstatus = status;
663 ev_feed_event (EV_A_ (W)w, EV_CHILD);
664 }
665}
666
667static void
668childcb (EV_P_ struct ev_signal *sw, int revents)
669{
415 int pid, status; 670 int pid, status;
416 671
417 while ((pid = waitpid (-1, &status, WNOHANG | WUNTRACED | WCONTINUED)) != -1) 672 if (0 < (pid = waitpid (-1, &status, WNOHANG | WUNTRACED | WCONTINUED)))
418 for (w = childs [pid & (PID_HASHSIZE - 1)]; w; w = w->next) 673 {
419 if (w->pid == pid || w->pid == -1) 674 /* make sure we are called again until all childs have been reaped */
420 { 675 ev_feed_event (EV_A_ (W)sw, EV_SIGNAL);
421 w->status = status; 676
422 event ((W)w, EV_CHILD); 677 child_reap (EV_A_ sw, pid, pid, status);
423 } 678 child_reap (EV_A_ sw, 0, pid, status); /* this might trigger a watcher twice, but event catches that */
679 }
424} 680}
681
682#endif
425 683
426/*****************************************************************************/ 684/*****************************************************************************/
427 685
686#if EV_USE_KQUEUE
687# include "ev_kqueue.c"
688#endif
428#if EV_USE_EPOLL 689#if EV_USE_EPOLL
429# include "ev_epoll.c" 690# include "ev_epoll.c"
430#endif 691#endif
692#if EV_USE_POLL
693# include "ev_poll.c"
694#endif
431#if EV_USE_SELECT 695#if EV_USE_SELECT
432# include "ev_select.c" 696# include "ev_select.c"
433#endif 697#endif
434 698
435int 699int
442ev_version_minor (void) 706ev_version_minor (void)
443{ 707{
444 return EV_VERSION_MINOR; 708 return EV_VERSION_MINOR;
445} 709}
446 710
447int ev_init (int flags) 711/* return true if we are running with elevated privileges and should ignore env variables */
712static int
713enable_secure (void)
448{ 714{
715#ifdef WIN32
716 return 0;
717#else
718 return getuid () != geteuid ()
719 || getgid () != getegid ();
720#endif
721}
722
723int
724ev_method (EV_P)
725{
726 return method;
727}
728
729static void
730loop_init (EV_P_ int methods)
731{
449 if (!ev_method) 732 if (!method)
450 { 733 {
451#if EV_USE_MONOTONIC 734#if EV_USE_MONOTONIC
452 { 735 {
453 struct timespec ts; 736 struct timespec ts;
454 if (!clock_gettime (CLOCK_MONOTONIC, &ts)) 737 if (!clock_gettime (CLOCK_MONOTONIC, &ts))
455 have_monotonic = 1; 738 have_monotonic = 1;
456 } 739 }
457#endif 740#endif
458 741
459 ev_now = ev_time (); 742 ev_rt_now = ev_time ();
460 now = get_clock (); 743 mn_now = get_clock ();
744 now_floor = mn_now;
461 diff = ev_now - now; 745 rtmn_diff = ev_rt_now - mn_now;
462 746
463 if (pipe (sigpipe)) 747 if (methods == EVMETHOD_AUTO)
464 return 0; 748 if (!enable_secure () && getenv ("LIBEV_METHODS"))
465 749 methods = atoi (getenv ("LIBEV_METHODS"));
750 else
466 ev_method = EVMETHOD_NONE; 751 methods = EVMETHOD_ANY;
752
753 method = 0;
754#if EV_USE_WIN32
755 if (!method && (methods & EVMETHOD_WIN32 )) method = win32_init (EV_A_ methods);
756#endif
757#if EV_USE_KQUEUE
758 if (!method && (methods & EVMETHOD_KQUEUE)) method = kqueue_init (EV_A_ methods);
759#endif
467#if EV_USE_EPOLL 760#if EV_USE_EPOLL
468 if (ev_method == EVMETHOD_NONE) epoll_init (flags); 761 if (!method && (methods & EVMETHOD_EPOLL )) method = epoll_init (EV_A_ methods);
762#endif
763#if EV_USE_POLL
764 if (!method && (methods & EVMETHOD_POLL )) method = poll_init (EV_A_ methods);
469#endif 765#endif
470#if EV_USE_SELECT 766#if EV_USE_SELECT
471 if (ev_method == EVMETHOD_NONE) select_init (flags); 767 if (!method && (methods & EVMETHOD_SELECT)) method = select_init (EV_A_ methods);
472#endif 768#endif
473 769
770 ev_init (&sigev, sigcb);
771 ev_set_priority (&sigev, EV_MAXPRI);
772 }
773}
774
775void
776loop_destroy (EV_P)
777{
778 int i;
779
780#if EV_USE_WIN32
781 if (method == EVMETHOD_WIN32 ) win32_destroy (EV_A);
782#endif
783#if EV_USE_KQUEUE
784 if (method == EVMETHOD_KQUEUE) kqueue_destroy (EV_A);
785#endif
786#if EV_USE_EPOLL
787 if (method == EVMETHOD_EPOLL ) epoll_destroy (EV_A);
788#endif
789#if EV_USE_POLL
790 if (method == EVMETHOD_POLL ) poll_destroy (EV_A);
791#endif
792#if EV_USE_SELECT
793 if (method == EVMETHOD_SELECT) select_destroy (EV_A);
794#endif
795
796 for (i = NUMPRI; i--; )
797 array_free (pending, [i]);
798
799 /* have to use the microsoft-never-gets-it-right macro */
800 array_free_microshit (fdchange);
801 array_free_microshit (timer);
802 array_free_microshit (periodic);
803 array_free_microshit (idle);
804 array_free_microshit (prepare);
805 array_free_microshit (check);
806
807 method = 0;
808}
809
810static void
811loop_fork (EV_P)
812{
813#if EV_USE_EPOLL
814 if (method == EVMETHOD_EPOLL ) epoll_fork (EV_A);
815#endif
816#if EV_USE_KQUEUE
817 if (method == EVMETHOD_KQUEUE) kqueue_fork (EV_A);
818#endif
819
820 if (ev_is_active (&sigev))
821 {
822 /* default loop */
823
824 ev_ref (EV_A);
825 ev_io_stop (EV_A_ &sigev);
826 close (sigpipe [0]);
827 close (sigpipe [1]);
828
829 while (pipe (sigpipe))
830 syserr ("(libev) error creating pipe");
831
832 siginit (EV_A);
833 }
834
835 postfork = 0;
836}
837
838#if EV_MULTIPLICITY
839struct ev_loop *
840ev_loop_new (int methods)
841{
842 struct ev_loop *loop = (struct ev_loop *)ev_malloc (sizeof (struct ev_loop));
843
844 memset (loop, 0, sizeof (struct ev_loop));
845
846 loop_init (EV_A_ methods);
847
848 if (ev_method (EV_A))
849 return loop;
850
851 return 0;
852}
853
854void
855ev_loop_destroy (EV_P)
856{
857 loop_destroy (EV_A);
858 ev_free (loop);
859}
860
861void
862ev_loop_fork (EV_P)
863{
864 postfork = 1;
865}
866
867#endif
868
869#if EV_MULTIPLICITY
870struct ev_loop *
871#else
872int
873#endif
874ev_default_loop (int methods)
875{
876 if (sigpipe [0] == sigpipe [1])
877 if (pipe (sigpipe))
878 return 0;
879
880 if (!default_loop)
881 {
882#if EV_MULTIPLICITY
883 struct ev_loop *loop = default_loop = &default_loop_struct;
884#else
885 default_loop = 1;
886#endif
887
888 loop_init (EV_A_ methods);
889
474 if (ev_method) 890 if (ev_method (EV_A))
475 { 891 {
476 ev_watcher_init (&sigev, sigcb);
477 siginit (); 892 siginit (EV_A);
478 893
894#ifndef WIN32
479 ev_signal_init (&childev, childcb, SIGCHLD); 895 ev_signal_init (&childev, childcb, SIGCHLD);
896 ev_set_priority (&childev, EV_MAXPRI);
480 ev_signal_start (&childev); 897 ev_signal_start (EV_A_ &childev);
898 ev_unref (EV_A); /* child watcher should not keep loop alive */
899#endif
481 } 900 }
901 else
902 default_loop = 0;
482 } 903 }
483 904
484 return ev_method; 905 return default_loop;
906}
907
908void
909ev_default_destroy (void)
910{
911#if EV_MULTIPLICITY
912 struct ev_loop *loop = default_loop;
913#endif
914
915#ifndef WIN32
916 ev_ref (EV_A); /* child watcher */
917 ev_signal_stop (EV_A_ &childev);
918#endif
919
920 ev_ref (EV_A); /* signal watcher */
921 ev_io_stop (EV_A_ &sigev);
922
923 close (sigpipe [0]); sigpipe [0] = 0;
924 close (sigpipe [1]); sigpipe [1] = 0;
925
926 loop_destroy (EV_A);
927}
928
929void
930ev_default_fork (void)
931{
932#if EV_MULTIPLICITY
933 struct ev_loop *loop = default_loop;
934#endif
935
936 if (method)
937 postfork = 1;
485} 938}
486 939
487/*****************************************************************************/ 940/*****************************************************************************/
488 941
489void
490ev_prefork (void)
491{
492 /* nop */
493}
494
495void
496ev_postfork_parent (void)
497{
498 /* nop */
499}
500
501void
502ev_postfork_child (void)
503{
504#if EV_USE_EPOLL
505 if (ev_method == EVMETHOD_EPOLL)
506 epoll_postfork_child ();
507#endif
508
509 ev_io_stop (&sigev);
510 close (sigpipe [0]);
511 close (sigpipe [1]);
512 pipe (sigpipe);
513 siginit ();
514}
515
516/*****************************************************************************/
517
518static void 942static int
943any_pending (EV_P)
944{
945 int pri;
946
947 for (pri = NUMPRI; pri--; )
948 if (pendingcnt [pri])
949 return 1;
950
951 return 0;
952}
953
954static void
519call_pending (void) 955call_pending (EV_P)
520{ 956{
957 int pri;
958
959 for (pri = NUMPRI; pri--; )
521 while (pendingcnt) 960 while (pendingcnt [pri])
522 { 961 {
523 ANPENDING *p = pendings + --pendingcnt; 962 ANPENDING *p = pendings [pri] + --pendingcnt [pri];
524 963
525 if (p->w) 964 if (p->w)
526 { 965 {
527 p->w->pending = 0; 966 p->w->pending = 0;
528 p->w->cb (p->w, p->events); 967 EV_CB_INVOKE (p->w, p->events);
529 } 968 }
530 } 969 }
531} 970}
532 971
533static void 972static void
534timers_reify (void) 973timers_reify (EV_P)
535{ 974{
536 while (timercnt && timers [0]->at <= now) 975 while (timercnt && ((WT)timers [0])->at <= mn_now)
537 { 976 {
538 struct ev_timer *w = timers [0]; 977 struct ev_timer *w = timers [0];
978
979 assert (("inactive timer on timer heap detected", ev_is_active (w)));
539 980
540 /* first reschedule or stop timer */ 981 /* first reschedule or stop timer */
541 if (w->repeat) 982 if (w->repeat)
542 { 983 {
984 assert (("negative ev_timer repeat value found while processing timers", w->repeat > 0.));
543 w->at = now + w->repeat; 985 ((WT)w)->at = mn_now + w->repeat;
544 assert (("timer timeout in the past, negative repeat?", w->at > now));
545 downheap ((WT *)timers, timercnt, 0); 986 downheap ((WT *)timers, timercnt, 0);
546 } 987 }
547 else 988 else
548 ev_timer_stop (w); /* nonrepeating: stop timer */ 989 ev_timer_stop (EV_A_ w); /* nonrepeating: stop timer */
549 990
550 event ((W)w, EV_TIMEOUT); 991 ev_feed_event (EV_A_ (W)w, EV_TIMEOUT);
551 } 992 }
552} 993}
553 994
554static void 995static void
555periodics_reify (void) 996periodics_reify (EV_P)
556{ 997{
557 while (periodiccnt && periodics [0]->at <= ev_now) 998 while (periodiccnt && ((WT)periodics [0])->at <= ev_rt_now)
558 { 999 {
559 struct ev_periodic *w = periodics [0]; 1000 struct ev_periodic *w = periodics [0];
560 1001
1002 assert (("inactive timer on periodic heap detected", ev_is_active (w)));
1003
561 /* first reschedule or stop timer */ 1004 /* first reschedule or stop timer */
562 if (w->interval) 1005 if (w->reschedule_cb)
563 { 1006 {
1007 ev_tstamp at = ((WT)w)->at = w->reschedule_cb (w, ev_rt_now + 0.0001);
1008
1009 assert (("ev_periodic reschedule callback returned time in the past", ((WT)w)->at > ev_rt_now));
1010 downheap ((WT *)periodics, periodiccnt, 0);
1011 }
1012 else if (w->interval)
1013 {
564 w->at += floor ((ev_now - w->at) / w->interval + 1.) * w->interval; 1014 ((WT)w)->at += floor ((ev_rt_now - ((WT)w)->at) / w->interval + 1.) * w->interval;
565 assert (("periodic timeout in the past, negative interval?", w->at > ev_now)); 1015 assert (("ev_periodic timeout in the past detected while processing timers, negative interval?", ((WT)w)->at > ev_rt_now));
566 downheap ((WT *)periodics, periodiccnt, 0); 1016 downheap ((WT *)periodics, periodiccnt, 0);
567 } 1017 }
568 else 1018 else
569 ev_periodic_stop (w); /* nonrepeating: stop timer */ 1019 ev_periodic_stop (EV_A_ w); /* nonrepeating: stop timer */
570 1020
571 event ((W)w, EV_TIMEOUT); 1021 ev_feed_event (EV_A_ (W)w, EV_PERIODIC);
572 } 1022 }
573} 1023}
574 1024
575static void 1025static void
576periodics_reschedule (ev_tstamp diff) 1026periodics_reschedule (EV_P)
577{ 1027{
578 int i; 1028 int i;
579 1029
580 /* adjust periodics after time jump */ 1030 /* adjust periodics after time jump */
581 for (i = 0; i < periodiccnt; ++i) 1031 for (i = 0; i < periodiccnt; ++i)
582 { 1032 {
583 struct ev_periodic *w = periodics [i]; 1033 struct ev_periodic *w = periodics [i];
584 1034
1035 if (w->reschedule_cb)
1036 ((WT)w)->at = w->reschedule_cb (w, ev_rt_now);
585 if (w->interval) 1037 else if (w->interval)
1038 ((WT)w)->at += ceil ((ev_rt_now - ((WT)w)->at) / w->interval) * w->interval;
1039 }
1040
1041 /* now rebuild the heap */
1042 for (i = periodiccnt >> 1; i--; )
1043 downheap ((WT *)periodics, periodiccnt, i);
1044}
1045
1046inline int
1047time_update_monotonic (EV_P)
1048{
1049 mn_now = get_clock ();
1050
1051 if (expect_true (mn_now - now_floor < MIN_TIMEJUMP * .5))
1052 {
1053 ev_rt_now = rtmn_diff + mn_now;
1054 return 0;
1055 }
1056 else
1057 {
1058 now_floor = mn_now;
1059 ev_rt_now = ev_time ();
1060 return 1;
1061 }
1062}
1063
1064static void
1065time_update (EV_P)
1066{
1067 int i;
1068
1069#if EV_USE_MONOTONIC
1070 if (expect_true (have_monotonic))
1071 {
1072 if (time_update_monotonic (EV_A))
586 { 1073 {
587 ev_tstamp diff = ceil ((ev_now - w->at) / w->interval) * w->interval; 1074 ev_tstamp odiff = rtmn_diff;
588 1075
589 if (fabs (diff) >= 1e-4) 1076 for (i = 4; --i; ) /* loop a few times, before making important decisions */
590 { 1077 {
591 ev_periodic_stop (w); 1078 rtmn_diff = ev_rt_now - mn_now;
592 ev_periodic_start (w);
593 1079
594 i = 0; /* restart loop, inefficient, but time jumps should be rare */ 1080 if (fabs (odiff - rtmn_diff) < MIN_TIMEJUMP)
1081 return; /* all is well */
1082
1083 ev_rt_now = ev_time ();
1084 mn_now = get_clock ();
1085 now_floor = mn_now;
595 } 1086 }
1087
1088 periodics_reschedule (EV_A);
1089 /* no timer adjustment, as the monotonic clock doesn't jump */
1090 /* timers_reschedule (EV_A_ rtmn_diff - odiff) */
596 } 1091 }
597 } 1092 }
598} 1093 else
599 1094#endif
600static void 1095 {
601time_update (void)
602{
603 int i;
604
605 ev_now = ev_time (); 1096 ev_rt_now = ev_time ();
606 1097
607 if (have_monotonic) 1098 if (expect_false (mn_now > ev_rt_now || mn_now < ev_rt_now - MAX_BLOCKTIME - MIN_TIMEJUMP))
608 {
609 ev_tstamp odiff = diff;
610
611 for (i = 4; --i; ) /* loop a few times, before making important decisions */
612 { 1099 {
613 now = get_clock ();
614 diff = ev_now - now;
615
616 if (fabs (odiff - diff) < MIN_TIMEJUMP)
617 return; /* all is well */
618
619 ev_now = ev_time ();
620 }
621
622 periodics_reschedule (diff - odiff);
623 /* no timer adjustment, as the monotonic clock doesn't jump */
624 }
625 else
626 {
627 if (now > ev_now || now < ev_now - MAX_BLOCKTIME - MIN_TIMEJUMP)
628 {
629 periodics_reschedule (ev_now - now); 1100 periodics_reschedule (EV_A);
630 1101
631 /* adjust timers. this is easy, as the offset is the same for all */ 1102 /* adjust timers. this is easy, as the offset is the same for all */
632 for (i = 0; i < timercnt; ++i) 1103 for (i = 0; i < timercnt; ++i)
633 timers [i]->at += diff; 1104 ((WT)timers [i])->at += ev_rt_now - mn_now;
634 } 1105 }
635 1106
636 now = ev_now; 1107 mn_now = ev_rt_now;
637 } 1108 }
638} 1109}
639 1110
640int ev_loop_done; 1111void
1112ev_ref (EV_P)
1113{
1114 ++activecnt;
1115}
641 1116
1117void
1118ev_unref (EV_P)
1119{
1120 --activecnt;
1121}
1122
1123static int loop_done;
1124
1125void
642void ev_loop (int flags) 1126ev_loop (EV_P_ int flags)
643{ 1127{
644 double block; 1128 double block;
645 ev_loop_done = flags & (EVLOOP_ONESHOT | EVLOOP_NONBLOCK) ? 1 : 0; 1129 loop_done = flags & (EVLOOP_ONESHOT | EVLOOP_NONBLOCK) ? 1 : 0;
646 1130
647 do 1131 do
648 { 1132 {
649 /* queue check watchers (and execute them) */ 1133 /* queue check watchers (and execute them) */
650 if (preparecnt) 1134 if (expect_false (preparecnt))
651 { 1135 {
652 queue_events ((W *)prepares, preparecnt, EV_PREPARE); 1136 queue_events (EV_A_ (W *)prepares, preparecnt, EV_PREPARE);
653 call_pending (); 1137 call_pending (EV_A);
654 } 1138 }
655 1139
1140 /* we might have forked, so reify kernel state if necessary */
1141 if (expect_false (postfork))
1142 loop_fork (EV_A);
1143
656 /* update fd-related kernel structures */ 1144 /* update fd-related kernel structures */
657 fd_reify (); 1145 fd_reify (EV_A);
658 1146
659 /* calculate blocking time */ 1147 /* calculate blocking time */
660 1148
661 /* we only need this for !monotonic clockor timers, but as we basically 1149 /* we only need this for !monotonic clock or timers, but as we basically
662 always have timers, we just calculate it always */ 1150 always have timers, we just calculate it always */
1151#if EV_USE_MONOTONIC
1152 if (expect_true (have_monotonic))
1153 time_update_monotonic (EV_A);
1154 else
1155#endif
1156 {
663 ev_now = ev_time (); 1157 ev_rt_now = ev_time ();
1158 mn_now = ev_rt_now;
1159 }
664 1160
665 if (flags & EVLOOP_NONBLOCK || idlecnt) 1161 if (flags & EVLOOP_NONBLOCK || idlecnt)
666 block = 0.; 1162 block = 0.;
667 else 1163 else
668 { 1164 {
669 block = MAX_BLOCKTIME; 1165 block = MAX_BLOCKTIME;
670 1166
671 if (timercnt) 1167 if (timercnt)
672 { 1168 {
673 ev_tstamp to = timers [0]->at - (have_monotonic ? get_clock () : ev_now) + method_fudge; 1169 ev_tstamp to = ((WT)timers [0])->at - mn_now + method_fudge;
674 if (block > to) block = to; 1170 if (block > to) block = to;
675 } 1171 }
676 1172
677 if (periodiccnt) 1173 if (periodiccnt)
678 { 1174 {
679 ev_tstamp to = periodics [0]->at - ev_now + method_fudge; 1175 ev_tstamp to = ((WT)periodics [0])->at - ev_rt_now + method_fudge;
680 if (block > to) block = to; 1176 if (block > to) block = to;
681 } 1177 }
682 1178
683 if (block < 0.) block = 0.; 1179 if (block < 0.) block = 0.;
684 } 1180 }
685 1181
686 method_poll (block); 1182 method_poll (EV_A_ block);
687 1183
688 /* update ev_now, do magic */ 1184 /* update ev_rt_now, do magic */
689 time_update (); 1185 time_update (EV_A);
690 1186
691 /* queue pending timers and reschedule them */ 1187 /* queue pending timers and reschedule them */
692 timers_reify (); /* relative timers called last */ 1188 timers_reify (EV_A); /* relative timers called last */
693 periodics_reify (); /* absolute timers called first */ 1189 periodics_reify (EV_A); /* absolute timers called first */
694 1190
695 /* queue idle watchers unless io or timers are pending */ 1191 /* queue idle watchers unless io or timers are pending */
696 if (!pendingcnt) 1192 if (idlecnt && !any_pending (EV_A))
697 queue_events ((W *)idles, idlecnt, EV_IDLE); 1193 queue_events (EV_A_ (W *)idles, idlecnt, EV_IDLE);
698 1194
699 /* queue check watchers, to be executed first */ 1195 /* queue check watchers, to be executed first */
700 if (checkcnt) 1196 if (checkcnt)
701 queue_events ((W *)checks, checkcnt, EV_CHECK); 1197 queue_events (EV_A_ (W *)checks, checkcnt, EV_CHECK);
702 1198
703 call_pending (); 1199 call_pending (EV_A);
704 } 1200 }
705 while (!ev_loop_done); 1201 while (activecnt && !loop_done);
706 1202
707 if (ev_loop_done != 2) 1203 if (loop_done != 2)
708 ev_loop_done = 0; 1204 loop_done = 0;
1205}
1206
1207void
1208ev_unloop (EV_P_ int how)
1209{
1210 loop_done = how;
709} 1211}
710 1212
711/*****************************************************************************/ 1213/*****************************************************************************/
712 1214
713static void 1215inline void
714wlist_add (WL *head, WL elem) 1216wlist_add (WL *head, WL elem)
715{ 1217{
716 elem->next = *head; 1218 elem->next = *head;
717 *head = elem; 1219 *head = elem;
718} 1220}
719 1221
720static void 1222inline void
721wlist_del (WL *head, WL elem) 1223wlist_del (WL *head, WL elem)
722{ 1224{
723 while (*head) 1225 while (*head)
724 { 1226 {
725 if (*head == elem) 1227 if (*head == elem)
730 1232
731 head = &(*head)->next; 1233 head = &(*head)->next;
732 } 1234 }
733} 1235}
734 1236
735static void 1237inline void
736ev_clear (W w) 1238ev_clear_pending (EV_P_ W w)
737{ 1239{
738 if (w->pending) 1240 if (w->pending)
739 { 1241 {
740 pendings [w->pending - 1].w = 0; 1242 pendings [ABSPRI (w)][w->pending - 1].w = 0;
741 w->pending = 0; 1243 w->pending = 0;
742 } 1244 }
743} 1245}
744 1246
745static void 1247inline void
746ev_start (W w, int active) 1248ev_start (EV_P_ W w, int active)
747{ 1249{
1250 if (w->priority < EV_MINPRI) w->priority = EV_MINPRI;
1251 if (w->priority > EV_MAXPRI) w->priority = EV_MAXPRI;
1252
748 w->active = active; 1253 w->active = active;
1254 ev_ref (EV_A);
749} 1255}
750 1256
751static void 1257inline void
752ev_stop (W w) 1258ev_stop (EV_P_ W w)
753{ 1259{
1260 ev_unref (EV_A);
754 w->active = 0; 1261 w->active = 0;
755} 1262}
756 1263
757/*****************************************************************************/ 1264/*****************************************************************************/
758 1265
759void 1266void
760ev_io_start (struct ev_io *w) 1267ev_io_start (EV_P_ struct ev_io *w)
761{ 1268{
1269 int fd = w->fd;
1270
762 if (ev_is_active (w)) 1271 if (ev_is_active (w))
763 return; 1272 return;
764 1273
765 int fd = w->fd; 1274 assert (("ev_io_start called with negative fd", fd >= 0));
766 1275
767 ev_start ((W)w, 1); 1276 ev_start (EV_A_ (W)w, 1);
768 array_needsize (anfds, anfdmax, fd + 1, anfds_init); 1277 array_needsize (ANFD, anfds, anfdmax, fd + 1, anfds_init);
769 wlist_add ((WL *)&anfds[fd].head, (WL)w); 1278 wlist_add ((WL *)&anfds[fd].head, (WL)w);
770 1279
771 fd_change (fd); 1280 fd_change (EV_A_ fd);
772} 1281}
773 1282
774void 1283void
775ev_io_stop (struct ev_io *w) 1284ev_io_stop (EV_P_ struct ev_io *w)
776{ 1285{
777 ev_clear ((W)w); 1286 ev_clear_pending (EV_A_ (W)w);
778 if (!ev_is_active (w)) 1287 if (!ev_is_active (w))
779 return; 1288 return;
780 1289
781 wlist_del ((WL *)&anfds[w->fd].head, (WL)w); 1290 wlist_del ((WL *)&anfds[w->fd].head, (WL)w);
782 ev_stop ((W)w); 1291 ev_stop (EV_A_ (W)w);
783 1292
784 fd_change (w->fd); 1293 fd_change (EV_A_ w->fd);
785} 1294}
786 1295
787void 1296void
788ev_timer_start (struct ev_timer *w) 1297ev_timer_start (EV_P_ struct ev_timer *w)
789{ 1298{
790 if (ev_is_active (w)) 1299 if (ev_is_active (w))
791 return; 1300 return;
792 1301
793 w->at += now; 1302 ((WT)w)->at += mn_now;
794 1303
795 assert (("timer repeat value less than zero not allowed", w->repeat >= 0.)); 1304 assert (("ev_timer_start called with negative timer repeat value", w->repeat >= 0.));
796 1305
797 ev_start ((W)w, ++timercnt); 1306 ev_start (EV_A_ (W)w, ++timercnt);
798 array_needsize (timers, timermax, timercnt, ); 1307 array_needsize (struct ev_timer *, timers, timermax, timercnt, (void));
799 timers [timercnt - 1] = w; 1308 timers [timercnt - 1] = w;
800 upheap ((WT *)timers, timercnt - 1); 1309 upheap ((WT *)timers, timercnt - 1);
801}
802 1310
1311 assert (("internal timer heap corruption", timers [((W)w)->active - 1] == w));
1312}
1313
803void 1314void
804ev_timer_stop (struct ev_timer *w) 1315ev_timer_stop (EV_P_ struct ev_timer *w)
805{ 1316{
806 ev_clear ((W)w); 1317 ev_clear_pending (EV_A_ (W)w);
807 if (!ev_is_active (w)) 1318 if (!ev_is_active (w))
808 return; 1319 return;
809 1320
1321 assert (("internal timer heap corruption", timers [((W)w)->active - 1] == w));
1322
810 if (w->active < timercnt--) 1323 if (((W)w)->active < timercnt--)
811 { 1324 {
812 timers [w->active - 1] = timers [timercnt]; 1325 timers [((W)w)->active - 1] = timers [timercnt];
813 downheap ((WT *)timers, timercnt, w->active - 1); 1326 downheap ((WT *)timers, timercnt, ((W)w)->active - 1);
814 } 1327 }
815 1328
816 w->at = w->repeat; 1329 ((WT)w)->at = w->repeat;
817 1330
818 ev_stop ((W)w); 1331 ev_stop (EV_A_ (W)w);
819} 1332}
820 1333
821void 1334void
822ev_timer_again (struct ev_timer *w) 1335ev_timer_again (EV_P_ struct ev_timer *w)
823{ 1336{
824 if (ev_is_active (w)) 1337 if (ev_is_active (w))
825 { 1338 {
826 if (w->repeat) 1339 if (w->repeat)
827 {
828 w->at = now + w->repeat;
829 downheap ((WT *)timers, timercnt, w->active - 1); 1340 adjustheap ((WT *)timers, timercnt, ((W)w)->active - 1, mn_now + w->repeat);
830 }
831 else 1341 else
832 ev_timer_stop (w); 1342 ev_timer_stop (EV_A_ w);
833 } 1343 }
834 else if (w->repeat) 1344 else if (w->repeat)
835 ev_timer_start (w); 1345 ev_timer_start (EV_A_ w);
836} 1346}
837 1347
838void 1348void
839ev_periodic_start (struct ev_periodic *w) 1349ev_periodic_start (EV_P_ struct ev_periodic *w)
840{ 1350{
841 if (ev_is_active (w)) 1351 if (ev_is_active (w))
842 return; 1352 return;
843 1353
844 assert (("periodic interval value less than zero not allowed", w->interval >= 0.)); 1354 if (w->reschedule_cb)
845 1355 ((WT)w)->at = w->reschedule_cb (w, ev_rt_now);
1356 else if (w->interval)
1357 {
1358 assert (("ev_periodic_start called with negative interval value", w->interval >= 0.));
846 /* this formula differs from the one in periodic_reify because we do not always round up */ 1359 /* this formula differs from the one in periodic_reify because we do not always round up */
847 if (w->interval)
848 w->at += ceil ((ev_now - w->at) / w->interval) * w->interval; 1360 ((WT)w)->at += ceil ((ev_rt_now - ((WT)w)->at) / w->interval) * w->interval;
1361 }
849 1362
850 ev_start ((W)w, ++periodiccnt); 1363 ev_start (EV_A_ (W)w, ++periodiccnt);
851 array_needsize (periodics, periodicmax, periodiccnt, ); 1364 array_needsize (struct ev_periodic *, periodics, periodicmax, periodiccnt, (void));
852 periodics [periodiccnt - 1] = w; 1365 periodics [periodiccnt - 1] = w;
853 upheap ((WT *)periodics, periodiccnt - 1); 1366 upheap ((WT *)periodics, periodiccnt - 1);
854}
855 1367
1368 assert (("internal periodic heap corruption", periodics [((W)w)->active - 1] == w));
1369}
1370
856void 1371void
857ev_periodic_stop (struct ev_periodic *w) 1372ev_periodic_stop (EV_P_ struct ev_periodic *w)
858{ 1373{
859 ev_clear ((W)w); 1374 ev_clear_pending (EV_A_ (W)w);
860 if (!ev_is_active (w)) 1375 if (!ev_is_active (w))
861 return; 1376 return;
862 1377
1378 assert (("internal periodic heap corruption", periodics [((W)w)->active - 1] == w));
1379
863 if (w->active < periodiccnt--) 1380 if (((W)w)->active < periodiccnt--)
864 { 1381 {
865 periodics [w->active - 1] = periodics [periodiccnt]; 1382 periodics [((W)w)->active - 1] = periodics [periodiccnt];
866 downheap ((WT *)periodics, periodiccnt, w->active - 1); 1383 downheap ((WT *)periodics, periodiccnt, ((W)w)->active - 1);
867 } 1384 }
868 1385
869 ev_stop ((W)w); 1386 ev_stop (EV_A_ (W)w);
870} 1387}
871 1388
872void 1389void
1390ev_periodic_again (EV_P_ struct ev_periodic *w)
1391{
1392 /* TODO: use adjustheap and recalculation */
1393 ev_periodic_stop (EV_A_ w);
1394 ev_periodic_start (EV_A_ w);
1395}
1396
1397void
873ev_signal_start (struct ev_signal *w) 1398ev_idle_start (EV_P_ struct ev_idle *w)
874{ 1399{
875 if (ev_is_active (w)) 1400 if (ev_is_active (w))
876 return; 1401 return;
877 1402
1403 ev_start (EV_A_ (W)w, ++idlecnt);
1404 array_needsize (struct ev_idle *, idles, idlemax, idlecnt, (void));
1405 idles [idlecnt - 1] = w;
1406}
1407
1408void
1409ev_idle_stop (EV_P_ struct ev_idle *w)
1410{
1411 ev_clear_pending (EV_A_ (W)w);
1412 if (ev_is_active (w))
1413 return;
1414
1415 idles [((W)w)->active - 1] = idles [--idlecnt];
1416 ev_stop (EV_A_ (W)w);
1417}
1418
1419void
1420ev_prepare_start (EV_P_ struct ev_prepare *w)
1421{
1422 if (ev_is_active (w))
1423 return;
1424
1425 ev_start (EV_A_ (W)w, ++preparecnt);
1426 array_needsize (struct ev_prepare *, prepares, preparemax, preparecnt, (void));
1427 prepares [preparecnt - 1] = w;
1428}
1429
1430void
1431ev_prepare_stop (EV_P_ struct ev_prepare *w)
1432{
1433 ev_clear_pending (EV_A_ (W)w);
1434 if (ev_is_active (w))
1435 return;
1436
1437 prepares [((W)w)->active - 1] = prepares [--preparecnt];
1438 ev_stop (EV_A_ (W)w);
1439}
1440
1441void
1442ev_check_start (EV_P_ struct ev_check *w)
1443{
1444 if (ev_is_active (w))
1445 return;
1446
1447 ev_start (EV_A_ (W)w, ++checkcnt);
1448 array_needsize (struct ev_check *, checks, checkmax, checkcnt, (void));
1449 checks [checkcnt - 1] = w;
1450}
1451
1452void
1453ev_check_stop (EV_P_ struct ev_check *w)
1454{
1455 ev_clear_pending (EV_A_ (W)w);
1456 if (ev_is_active (w))
1457 return;
1458
1459 checks [((W)w)->active - 1] = checks [--checkcnt];
1460 ev_stop (EV_A_ (W)w);
1461}
1462
1463#ifndef SA_RESTART
1464# define SA_RESTART 0
1465#endif
1466
1467void
1468ev_signal_start (EV_P_ struct ev_signal *w)
1469{
1470#if EV_MULTIPLICITY
1471 assert (("signal watchers are only supported in the default loop", loop == default_loop));
1472#endif
1473 if (ev_is_active (w))
1474 return;
1475
1476 assert (("ev_signal_start called with illegal signal number", w->signum > 0));
1477
878 ev_start ((W)w, 1); 1478 ev_start (EV_A_ (W)w, 1);
879 array_needsize (signals, signalmax, w->signum, signals_init); 1479 array_needsize (ANSIG, signals, signalmax, w->signum, signals_init);
880 wlist_add ((WL *)&signals [w->signum - 1].head, (WL)w); 1480 wlist_add ((WL *)&signals [w->signum - 1].head, (WL)w);
881 1481
882 if (!w->next) 1482 if (!((WL)w)->next)
883 { 1483 {
1484#if WIN32
1485 signal (w->signum, sighandler);
1486#else
884 struct sigaction sa; 1487 struct sigaction sa;
885 sa.sa_handler = sighandler; 1488 sa.sa_handler = sighandler;
886 sigfillset (&sa.sa_mask); 1489 sigfillset (&sa.sa_mask);
887 sa.sa_flags = 0; 1490 sa.sa_flags = SA_RESTART; /* if restarting works we save one iteration */
888 sigaction (w->signum, &sa, 0); 1491 sigaction (w->signum, &sa, 0);
1492#endif
889 } 1493 }
890} 1494}
891 1495
892void 1496void
893ev_signal_stop (struct ev_signal *w) 1497ev_signal_stop (EV_P_ struct ev_signal *w)
894{ 1498{
895 ev_clear ((W)w); 1499 ev_clear_pending (EV_A_ (W)w);
896 if (!ev_is_active (w)) 1500 if (!ev_is_active (w))
897 return; 1501 return;
898 1502
899 wlist_del ((WL *)&signals [w->signum - 1].head, (WL)w); 1503 wlist_del ((WL *)&signals [w->signum - 1].head, (WL)w);
900 ev_stop ((W)w); 1504 ev_stop (EV_A_ (W)w);
901 1505
902 if (!signals [w->signum - 1].head) 1506 if (!signals [w->signum - 1].head)
903 signal (w->signum, SIG_DFL); 1507 signal (w->signum, SIG_DFL);
904} 1508}
905 1509
906void 1510void
907ev_idle_start (struct ev_idle *w) 1511ev_child_start (EV_P_ struct ev_child *w)
908{ 1512{
1513#if EV_MULTIPLICITY
1514 assert (("child watchers are only supported in the default loop", loop == default_loop));
1515#endif
909 if (ev_is_active (w)) 1516 if (ev_is_active (w))
910 return; 1517 return;
911 1518
912 ev_start ((W)w, ++idlecnt); 1519 ev_start (EV_A_ (W)w, 1);
913 array_needsize (idles, idlemax, idlecnt, ); 1520 wlist_add ((WL *)&childs [w->pid & (PID_HASHSIZE - 1)], (WL)w);
914 idles [idlecnt - 1] = w;
915} 1521}
916 1522
917void 1523void
918ev_idle_stop (struct ev_idle *w) 1524ev_child_stop (EV_P_ struct ev_child *w)
919{ 1525{
920 ev_clear ((W)w); 1526 ev_clear_pending (EV_A_ (W)w);
921 if (ev_is_active (w)) 1527 if (ev_is_active (w))
922 return; 1528 return;
923 1529
924 idles [w->active - 1] = idles [--idlecnt];
925 ev_stop ((W)w);
926}
927
928void
929ev_prepare_start (struct ev_prepare *w)
930{
931 if (ev_is_active (w))
932 return;
933
934 ev_start ((W)w, ++preparecnt);
935 array_needsize (prepares, preparemax, preparecnt, );
936 prepares [preparecnt - 1] = w;
937}
938
939void
940ev_prepare_stop (struct ev_prepare *w)
941{
942 ev_clear ((W)w);
943 if (ev_is_active (w))
944 return;
945
946 prepares [w->active - 1] = prepares [--preparecnt];
947 ev_stop ((W)w);
948}
949
950void
951ev_check_start (struct ev_check *w)
952{
953 if (ev_is_active (w))
954 return;
955
956 ev_start ((W)w, ++checkcnt);
957 array_needsize (checks, checkmax, checkcnt, );
958 checks [checkcnt - 1] = w;
959}
960
961void
962ev_check_stop (struct ev_check *w)
963{
964 ev_clear ((W)w);
965 if (ev_is_active (w))
966 return;
967
968 checks [w->active - 1] = checks [--checkcnt];
969 ev_stop ((W)w);
970}
971
972void
973ev_child_start (struct ev_child *w)
974{
975 if (ev_is_active (w))
976 return;
977
978 ev_start ((W)w, 1);
979 wlist_add ((WL *)&childs [w->pid & (PID_HASHSIZE - 1)], (WL)w);
980}
981
982void
983ev_child_stop (struct ev_child *w)
984{
985 ev_clear ((W)w);
986 if (ev_is_active (w))
987 return;
988
989 wlist_del ((WL *)&childs [w->pid & (PID_HASHSIZE - 1)], (WL)w); 1530 wlist_del ((WL *)&childs [w->pid & (PID_HASHSIZE - 1)], (WL)w);
990 ev_stop ((W)w); 1531 ev_stop (EV_A_ (W)w);
991} 1532}
992 1533
993/*****************************************************************************/ 1534/*****************************************************************************/
994 1535
995struct ev_once 1536struct ev_once
999 void (*cb)(int revents, void *arg); 1540 void (*cb)(int revents, void *arg);
1000 void *arg; 1541 void *arg;
1001}; 1542};
1002 1543
1003static void 1544static void
1004once_cb (struct ev_once *once, int revents) 1545once_cb (EV_P_ struct ev_once *once, int revents)
1005{ 1546{
1006 void (*cb)(int revents, void *arg) = once->cb; 1547 void (*cb)(int revents, void *arg) = once->cb;
1007 void *arg = once->arg; 1548 void *arg = once->arg;
1008 1549
1009 ev_io_stop (&once->io); 1550 ev_io_stop (EV_A_ &once->io);
1010 ev_timer_stop (&once->to); 1551 ev_timer_stop (EV_A_ &once->to);
1011 free (once); 1552 ev_free (once);
1012 1553
1013 cb (revents, arg); 1554 cb (revents, arg);
1014} 1555}
1015 1556
1016static void 1557static void
1017once_cb_io (struct ev_io *w, int revents) 1558once_cb_io (EV_P_ struct ev_io *w, int revents)
1018{ 1559{
1019 once_cb ((struct ev_once *)(((char *)w) - offsetof (struct ev_once, io)), revents); 1560 once_cb (EV_A_ (struct ev_once *)(((char *)w) - offsetof (struct ev_once, io)), revents);
1020} 1561}
1021 1562
1022static void 1563static void
1023once_cb_to (struct ev_timer *w, int revents) 1564once_cb_to (EV_P_ struct ev_timer *w, int revents)
1024{ 1565{
1025 once_cb ((struct ev_once *)(((char *)w) - offsetof (struct ev_once, to)), revents); 1566 once_cb (EV_A_ (struct ev_once *)(((char *)w) - offsetof (struct ev_once, to)), revents);
1026} 1567}
1027 1568
1028void 1569void
1029ev_once (int fd, int events, ev_tstamp timeout, void (*cb)(int revents, void *arg), void *arg) 1570ev_once (EV_P_ int fd, int events, ev_tstamp timeout, void (*cb)(int revents, void *arg), void *arg)
1030{ 1571{
1031 struct ev_once *once = malloc (sizeof (struct ev_once)); 1572 struct ev_once *once = (struct ev_once *)ev_malloc (sizeof (struct ev_once));
1032 1573
1033 if (!once) 1574 if (!once)
1034 cb (EV_ERROR | EV_READ | EV_WRITE | EV_TIMEOUT, arg); 1575 cb (EV_ERROR | EV_READ | EV_WRITE | EV_TIMEOUT, arg);
1035 else 1576 else
1036 { 1577 {
1037 once->cb = cb; 1578 once->cb = cb;
1038 once->arg = arg; 1579 once->arg = arg;
1039 1580
1040 ev_watcher_init (&once->io, once_cb_io); 1581 ev_init (&once->io, once_cb_io);
1041 if (fd >= 0) 1582 if (fd >= 0)
1042 { 1583 {
1043 ev_io_set (&once->io, fd, events); 1584 ev_io_set (&once->io, fd, events);
1044 ev_io_start (&once->io); 1585 ev_io_start (EV_A_ &once->io);
1045 } 1586 }
1046 1587
1047 ev_watcher_init (&once->to, once_cb_to); 1588 ev_init (&once->to, once_cb_to);
1048 if (timeout >= 0.) 1589 if (timeout >= 0.)
1049 { 1590 {
1050 ev_timer_set (&once->to, timeout, 0.); 1591 ev_timer_set (&once->to, timeout, 0.);
1051 ev_timer_start (&once->to); 1592 ev_timer_start (EV_A_ &once->to);
1052 } 1593 }
1053 } 1594 }
1054} 1595}
1055 1596
1056/*****************************************************************************/
1057
1058#if 0
1059
1060struct ev_io wio;
1061
1062static void
1063sin_cb (struct ev_io *w, int revents)
1064{
1065 fprintf (stderr, "sin %d, revents %d\n", w->fd, revents);
1066}
1067
1068static void
1069ocb (struct ev_timer *w, int revents)
1070{
1071 //fprintf (stderr, "timer %f,%f (%x) (%f) d%p\n", w->at, w->repeat, revents, w->at - ev_time (), w->data);
1072 ev_timer_stop (w);
1073 ev_timer_start (w);
1074}
1075
1076static void
1077scb (struct ev_signal *w, int revents)
1078{
1079 fprintf (stderr, "signal %x,%d\n", revents, w->signum);
1080 ev_io_stop (&wio);
1081 ev_io_start (&wio);
1082}
1083
1084static void
1085gcb (struct ev_signal *w, int revents)
1086{
1087 fprintf (stderr, "generic %x\n", revents);
1088
1089}
1090
1091int main (void)
1092{
1093 ev_init (0);
1094
1095 ev_io_init (&wio, sin_cb, 0, EV_READ);
1096 ev_io_start (&wio);
1097
1098 struct ev_timer t[10000];
1099
1100#if 0
1101 int i;
1102 for (i = 0; i < 10000; ++i)
1103 {
1104 struct ev_timer *w = t + i;
1105 ev_watcher_init (w, ocb, i);
1106 ev_timer_init_abs (w, ocb, drand48 (), 0.99775533);
1107 ev_timer_start (w);
1108 if (drand48 () < 0.5)
1109 ev_timer_stop (w);
1110 }
1111#endif
1112
1113 struct ev_timer t1;
1114 ev_timer_init (&t1, ocb, 5, 10);
1115 ev_timer_start (&t1);
1116
1117 struct ev_signal sig;
1118 ev_signal_init (&sig, scb, SIGQUIT);
1119 ev_signal_start (&sig);
1120
1121 struct ev_check cw;
1122 ev_check_init (&cw, gcb);
1123 ev_check_start (&cw);
1124
1125 struct ev_idle iw;
1126 ev_idle_init (&iw, gcb);
1127 ev_idle_start (&iw);
1128
1129 ev_loop (0);
1130
1131 return 0;
1132}
1133
1134#endif
1135
1136
1137
1138

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines