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

Comparing libev/ev.c (file contents):
Revision 1.78 by root, Thu Nov 8 21:08:56 2007 UTC vs.
Revision 1.81 by root, Fri Nov 9 17:07:59 2007 UTC

… …
126#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) */
127#define MAX_BLOCKTIME 59.731 /* never wait longer than this time (to detect time jumps) */ 127#define MAX_BLOCKTIME 59.731 /* never wait longer than this time (to detect time jumps) */
128#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 */
129/*#define CLEANUP_INTERVAL 300. /* 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 */
130 130
131#ifdef EV_H
132# include EV_H
133#else
131#include "ev.h" 134# include "ev.h"
135#endif
132 136
133#if __GNUC__ >= 3 137#if __GNUC__ >= 3
134# define expect(expr,value) __builtin_expect ((expr),(value)) 138# define expect(expr,value) __builtin_expect ((expr),(value))
135# define inline inline 139# define inline inline
136#else 140#else
… …
215 int events; 219 int events;
216} ANPENDING; 220} ANPENDING;
217 221
218#if EV_MULTIPLICITY 222#if EV_MULTIPLICITY
219 223
220struct ev_loop 224 struct ev_loop
221{ 225 {
222# define VAR(name,decl) decl; 226 #define VAR(name,decl) decl;
223# include "ev_vars.h" 227 #include "ev_vars.h"
224};
225# undef VAR 228 #undef VAR
229 };
226# include "ev_wrap.h" 230 #include "ev_wrap.h"
231
232 struct ev_loop default_loop_struct;
233 static struct ev_loop *default_loop;
227 234
228#else 235#else
229 236
230# define VAR(name,decl) static decl; 237 #define VAR(name,decl) static decl;
231# include "ev_vars.h" 238 #include "ev_vars.h"
232# undef VAR 239 #undef VAR
240
241 static int default_loop;
233 242
234#endif 243#endif
235 244
236/*****************************************************************************/ 245/*****************************************************************************/
237 246
… …
342 351
343 for (i = 0; i < eventcnt; ++i) 352 for (i = 0; i < eventcnt; ++i)
344 ev_feed_event (EV_A_ events [i], type); 353 ev_feed_event (EV_A_ events [i], type);
345} 354}
346 355
347static void 356inline void
348fd_event (EV_P_ int fd, int events) 357fd_event (EV_P_ int fd, int revents)
349{ 358{
350 ANFD *anfd = anfds + fd; 359 ANFD *anfd = anfds + fd;
351 struct ev_io *w; 360 struct ev_io *w;
352 361
353 for (w = (struct ev_io *)anfd->head; w; w = (struct ev_io *)((WL)w)->next) 362 for (w = (struct ev_io *)anfd->head; w; w = (struct ev_io *)((WL)w)->next)
354 { 363 {
355 int ev = w->events & events; 364 int ev = w->events & revents;
356 365
357 if (ev) 366 if (ev)
358 ev_feed_event (EV_A_ (W)w, ev); 367 ev_feed_event (EV_A_ (W)w, ev);
359 } 368 }
369}
370
371void
372ev_feed_fd_event (EV_P_ int fd, int revents)
373{
374 fd_event (EV_A_ fd, revents);
360} 375}
361 376
362/*****************************************************************************/ 377/*****************************************************************************/
363 378
364static void 379static void
… …
552#endif 567#endif
553 errno = old_errno; 568 errno = old_errno;
554 } 569 }
555} 570}
556 571
572void
573ev_feed_signal_event (EV_P_ int signum)
574{
575 WL w;
576
577#if EV_MULTIPLICITY
578 assert (("feeding signal events is only supported in the default loop", loop == default_loop));
579#endif
580
581 --signum;
582
583 if (signum < 0 || signum >= signalmax)
584 return;
585
586 signals [signum].gotsig = 0;
587
588 for (w = signals [signum].head; w; w = w->next)
589 ev_feed_event (EV_A_ (W)w, EV_SIGNAL);
590}
591
557static void 592static void
558sigcb (EV_P_ struct ev_io *iow, int revents) 593sigcb (EV_P_ struct ev_io *iow, int revents)
559{ 594{
560 WL w;
561 int signum; 595 int signum;
562 596
563#ifdef WIN32 597#ifdef WIN32
564 recv (sigpipe [0], &revents, 1, MSG_DONTWAIT); 598 recv (sigpipe [0], &revents, 1, MSG_DONTWAIT);
565#else 599#else
… …
567#endif 601#endif
568 gotsig = 0; 602 gotsig = 0;
569 603
570 for (signum = signalmax; signum--; ) 604 for (signum = signalmax; signum--; )
571 if (signals [signum].gotsig) 605 if (signals [signum].gotsig)
572 { 606 ev_feed_signal_event (EV_A_ signum + 1);
573 signals [signum].gotsig = 0;
574
575 for (w = signals [signum].head; w; w = w->next)
576 ev_feed_event (EV_A_ (W)w, EV_SIGNAL);
577 }
578} 607}
579 608
580static void 609static void
581siginit (EV_P) 610siginit (EV_P)
582{ 611{
… …
822} 851}
823 852
824#endif 853#endif
825 854
826#if EV_MULTIPLICITY 855#if EV_MULTIPLICITY
827struct ev_loop default_loop_struct;
828static struct ev_loop *default_loop;
829
830struct ev_loop * 856struct ev_loop *
831#else 857#else
832static int default_loop;
833
834int 858int
835#endif 859#endif
836ev_default_loop (int methods) 860ev_default_loop (int methods)
837{ 861{
838 if (sigpipe [0] == sigpipe [1]) 862 if (sigpipe [0] == sigpipe [1])

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines