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

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

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines