[ViewVC] Diff of: cvs/libev/ev.c

Comparing libev/ev.c (file contents):
Revision 1.66 by root, Sun Nov 4 23:30:53 2007 UTC vs.
Revision 1.69 by root, Tue Nov 6 00:10:04 2007 UTC

 typedef struct ev_watcher_list *WL;
 typedef struct ev_watcher_time *WT;
 static int have_monotonic; /* did clock_gettime (CLOCK_MONOTONIC) work? */
+#if WIN32
+/* note: the comment below could not be substantiated, but what would I care */
+/* MSDN says this is required to handle SIGFPE */
+volatile double SIGFPE_REQ = 0.0f;
+#endif
 /*****************************************************************************/
+static void (*syserr_cb)(void);
+void ev_set_syserr_cb (void (*cb)(void))
+{
+  syserr_cb = cb;
+}
+static void
+syserr (void)
+{
+  if (syserr_cb)
+    syserr_cb ();
+  else
+    {
+      perror ("libev");
+      abort ();
+    }
+}
+static void *(*alloc)(void *ptr, long size);
+void ev_set_allocator (void *(*cb)(void *ptr, long size))
+{
+  alloc = cb;
+}
+static void *
+ev_realloc (void *ptr, long size)
+{
+  ptr = alloc ? alloc (ptr, size) : realloc (ptr, size);
+  if (!ptr && size)
+    {
+      fprintf (stderr, "libev: cannot allocate %ld bytes, aborting.", size);
+      abort ();
+    }
+  return ptr;
+}
+#define ev_malloc(size) ev_realloc (0, (size))
+#define ev_free(ptr)    ev_realloc ((ptr), 0)
+/*****************************************************************************/
 typedef struct
 {
-  struct ev_watcher_list *head;
+  WL head;
   unsigned char events;
   unsigned char reify;
 } ANFD;
 typedef struct
   return rt_now;
 }
 #define array_roundsize(base,n) ((n) | 4 & ~3)
-#define array_needsize(base,cur,cnt,init)		\
+#define array_needsize(base,cur,cnt,init)			\
-  if (expect_false ((cnt) > cur))			\
+  if (expect_false ((cnt) > cur))				\
-    {							\
+    {								\
-      int newcnt = cur;					\
+      int newcnt = cur;						\
-      do						\
+      do							\
-        {						\
+        {							\
-          newcnt = array_roundsize (base, newcnt << 1);	\
+          newcnt = array_roundsize (base, newcnt << 1);		\
-        }						\
+        }							\
-      while ((cnt) > newcnt);				\
+      while ((cnt) > newcnt);					\
-      							\
+      								\
-      base = realloc (base, sizeof (*base) * (newcnt));	\
+      base = ev_realloc (base, sizeof (*base) * (newcnt));	\
-      init (base + cur, newcnt - cur);			\
+      init (base + cur, newcnt - cur);				\
-      cur = newcnt;					\
+      cur = newcnt;						\
+    }
+#define array_slim(stem)					\
+  if (stem ## max < array_roundsize (stem ## cnt >> 2))		\
+    {								\
+      stem ## max = array_roundsize (stem ## cnt >> 1);		\
+      base = ev_realloc (base, sizeof (*base) * (stem ## max));	\
+      fprintf (stderr, "slimmed down " # stem " to %d\n", stem ## max);/*D*/\
     }
 #define array_free(stem, idx) \
-  free (stem ## s idx); stem ## cnt idx = stem ## max idx = 0;
+  ev_free (stem ## s idx); stem ## cnt idx = stem ## max idx = 0;
 /*****************************************************************************/
 static void
 anfds_init (ANFD *base, int count)
   int fd;
   for (fd = anfdmax; fd--; )
     if (anfds [fd].events)
       {
-        close (fd);
         fd_kill (EV_A_ fd);
         return;
       }
 }
 /*****************************************************************************/
 typedef struct
 {
-  struct ev_watcher_list *head;
+  WL head;
   sig_atomic_t volatile gotsig;
 } ANSIG;
 static ANSIG *signals;
 static int signalmax;
 }
 static void
 sighandler (int signum)
 {
+#if WIN32
+  signal (signum, sighandler);
+#endif
   signals [signum - 1].gotsig = 1;
   if (!gotsig)
     {
       int old_errno = errno;
 }
 static void
 sigcb (EV_P_ struct ev_io *iow, int revents)
 {
-  struct ev_watcher_list *w;
+  WL w;
   int signum;
   read (sigpipe [0], &revents, 1);
   gotsig = 0;
 #if EV_MULTIPLICITY
 struct ev_loop *
 ev_loop_new (int methods)
 {
-  struct ev_loop *loop = (struct ev_loop *)calloc (1, sizeof (struct ev_loop));
+  struct ev_loop *loop = (struct ev_loop *)ev_malloc (sizeof (struct ev_loop));
+  memset (loop, 0, sizeof (struct ev_loop));
   loop_init (EV_A_ methods);
   if (ev_method (EV_A))
     return loop;
 void
 ev_loop_destroy (EV_P)
 {
   loop_destroy (EV_A);
-  free (loop);
+  ev_free (loop);
 }
 void
 ev_loop_fork (EV_P)
 {
   array_needsize (signals, signalmax, w->signum, signals_init);
   wlist_add ((WL *)&signals [w->signum - 1].head, (WL)w);
   if (!((WL)w)->next)
     {
+#if WIN32
+      signal (w->signum, sighandler);
+#else
       struct sigaction sa;
       sa.sa_handler = sighandler;
       sigfillset (&sa.sa_mask);
       sa.sa_flags = SA_RESTART; /* if restarting works we save one iteration */
       sigaction (w->signum, &sa, 0);
+#endif
     }
 }
 void
 ev_signal_stop (EV_P_ struct ev_signal *w)
   void (*cb)(int revents, void *arg) = once->cb;
   void *arg = once->arg;
   ev_io_stop (EV_A_ &once->io);
   ev_timer_stop (EV_A_ &once->to);
-  free (once);
+  ev_free (once);
   cb (revents, arg);
 }
 static void
 }
 void
 ev_once (EV_P_ int fd, int events, ev_tstamp timeout, void (*cb)(int revents, void *arg), void *arg)
 {
-  struct ev_once *once = malloc (sizeof (struct ev_once));
+  struct ev_once *once = ev_malloc (sizeof (struct ev_once));
   if (!once)
     cb (EV_ERROR | EV_READ | EV_WRITE | EV_TIMEOUT, arg);
   else
     {

Diff Legend

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

Comparing libev/ev.c (file contents): Revision 1.66 by root, Sun Nov 4 23:30:53 2007 UTC vs. Revision 1.69 by root, Tue Nov 6 00:10:04 2007 UTC

Diff Legend

Comparing libev/ev.c (file contents):
Revision 1.66 by root, Sun Nov 4 23:30:53 2007 UTC vs.
Revision 1.69 by root, Tue Nov 6 00:10:04 2007 UTC