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

Comparing libev/ev.c (file contents):
Revision 1.193 by root, Sat Dec 22 05:47:58 2007 UTC vs.
Revision 1.208 by root, Fri Feb 1 13:22:48 2008 UTC

 /*
  * libev event processing core, watcher management
  *
- * Copyright (c) 2007 Marc Alexander Lehmann <libev@schmorp.de>
+ * Copyright (c) 2007,2008 Marc Alexander Lehmann <libev@schmorp.de>
  * All rights reserved.
  *
- * Redistribution and use in source and binary forms, with or without
+ * Redistribution and use in source and binary forms, with or without modifica-
- * modification, are permitted provided that the following conditions are
+ * tion, are permitted provided that the following conditions are met:
- * met:
+ *
+ *   1.  Redistributions of source code must retain the above copyright notice,
+ *       this list of conditions and the following disclaimer.
+ *
+ *   2.  Redistributions in binary form must reproduce the above copyright
+ *       notice, this list of conditions and the following disclaimer in the
+ *       documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
+ * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MER-
+ * CHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.  IN NO
+ * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPE-
+ * CIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
+ * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
+ * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
+ * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTH-
+ * ERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE.
  *
- *     * Redistributions of source code must retain the above copyright
+ * Alternatively, the contents of this file may be used under the terms of
- *       notice, this list of conditions and the following disclaimer.
+ * the GNU General Public License ("GPL") version 2 or any later version,
- *
+ * in which case the provisions of the GPL are applicable instead of
- *     * Redistributions in binary form must reproduce the above
+ * the above. If you wish to allow the use of your version of this file
- *       copyright notice, this list of conditions and the following
+ * only under the terms of the GPL and not to allow others to use your
- *       disclaimer in the documentation and/or other materials provided
+ * version of this file under the BSD license, indicate your decision
- *       with the distribution.
+ * by deleting the provisions above and replace them with the notice
- *
+ * and other provisions required by the GPL. If you do not delete the
- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * provisions above, a recipient may use your version of this file under
- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * either the BSD or the GPL.
- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
 #ifdef __cplusplus
 extern "C" {
 #endif
 typedef ev_watcher *W;
 typedef ev_watcher_list *WL;
 typedef ev_watcher_time *WT;
+#if EV_USE_MONOTONIC
+/* sig_atomic_t is used to avoid per-thread variables or locking but still */
+/* giving it a reasonably high chance of working on typical architetcures */
-static int have_monotonic; /* did clock_gettime (CLOCK_MONOTONIC) work? */
+static EV_ATOMIC_T have_monotonic; /* did clock_gettime (CLOCK_MONOTONIC) work? */
+#endif
 #ifdef _WIN32
 # include "ev_win32.c"
 #endif
 #if EV_SELECT_IS_WINSOCKET
       if (events)
         {
           unsigned long argp;
+          #ifdef EV_FD_TO_WIN32_HANDLE
+            anfd->handle = EV_FD_TO_WIN32_HANDLE (fd);
+          #else
-          anfd->handle = _get_osfhandle (fd);
+            anfd->handle = _get_osfhandle (fd);
+          #endif
           assert (("libev only supports socket fds in this configuration", ioctlsocket (anfd->handle, FIONREAD, &argp) == 0));
         }
 #endif
       {
 /*****************************************************************************/
 typedef struct
 {
   WL head;
-  sig_atomic_t volatile gotsig;
+  EV_ATOMIC_T gotsig;
 } ANSIG;
 static ANSIG *signals;
 static int signalmax;
-static int sigpipe [2];
+static EV_ATOMIC_T gotsig;
-static sig_atomic_t volatile gotsig;
-static ev_io sigev;
 void inline_size
 signals_init (ANSIG *base, int count)
 {
   while (count--)
       ++base;
     }
 }
-static void
+/*****************************************************************************/
-sighandler (int signum)
-{
-#if _WIN32
-  signal (signum, sighandler);
-#endif
-  signals [signum - 1].gotsig = 1;
-  if (!gotsig)
-    {
-      int old_errno = errno;
-      gotsig = 1;
-      write (sigpipe [1], &signum, 1);
-      errno = old_errno;
-    }
-}
-void noinline
-ev_feed_signal_event (EV_P_ int signum)
-{
-  WL w;
-#if EV_MULTIPLICITY
-  assert (("feeding signal events is only supported in the default loop", loop == ev_default_loop_ptr));
-#endif
-  --signum;
-  if (signum < 0 || signum >= signalmax)
-    return;
-  signals [signum].gotsig = 0;
-  for (w = signals [signum].head; w; w = w->next)
-    ev_feed_event (EV_A_ (W)w, EV_SIGNAL);
-}
-static void
-sigcb (EV_P_ ev_io *iow, int revents)
-{
-  int signum;
-  read (sigpipe [0], &revents, 1);
-  gotsig = 0;
-  for (signum = signalmax; signum--; )
-    if (signals [signum].gotsig)
-      ev_feed_signal_event (EV_A_ signum + 1);
-}
 void inline_speed
 fd_intern (int fd)
 {
 #ifdef _WIN32
   fcntl (fd, F_SETFL, O_NONBLOCK);
 #endif
 }
 static void noinline
-siginit (EV_P)
+evpipe_init (EV_P)
 {
+  if (!ev_is_active (&pipeev))
+    {
+      while (pipe (evpipe))
+        syserr ("(libev) error creating signal/async pipe");
-  fd_intern (sigpipe [0]);
+      fd_intern (evpipe [0]);
-  fd_intern (sigpipe [1]);
+      fd_intern (evpipe [1]);
-  ev_io_set (&sigev, sigpipe [0], EV_READ);
+      ev_io_set (&pipeev, evpipe [0], EV_READ);
-  ev_io_start (EV_A_ &sigev);
+      ev_io_start (EV_A_ &pipeev);
-  ev_unref (EV_A); /* child watcher should not keep loop alive */
+      ev_unref (EV_A); /* child watcher should not keep loop alive */
+    }
+}
+void inline_size
+evpipe_write (EV_P_ int sig, int async)
+{
+  if (!(gotasync || gotsig))
+    {
+      int old_errno = errno;
+      if (sig)   gotsig   = 1;
+      if (async) gotasync = 1;
+      write (evpipe [1], &old_errno, 1);
+      errno = old_errno;
+    }
+}
+static void
+pipecb (EV_P_ ev_io *iow, int revents)
+{
+  {
+    int dummy;
+    read (evpipe [0], &dummy, 1);
+  }
+  if (gotsig)
+    {
+      int signum;
+      gotsig = 0;
+      for (signum = signalmax; signum--; )
+        if (signals [signum].gotsig)
+          ev_feed_signal_event (EV_A_ signum + 1);
+    }
+  if (gotasync)
+    {
+      int i;
+      gotasync = 0;
+      for (i = asynccnt; i--; )
+        if (asyncs [i]->sent)
+          {
+            asyncs [i]->sent = 0;
+            ev_feed_event (EV_A_ asyncs [i], EV_ASYNC);
+          }
+    }
 }
 /*****************************************************************************/
+static void
+sighandler (int signum)
+{
+#if EV_MULTIPLICITY
+  struct ev_loop *loop = &default_loop_struct;
+#endif
+#if _WIN32
+  signal (signum, sighandler);
+#endif
+  signals [signum - 1].gotsig = 1;
+  evpipe_write (EV_A_ 1, 0);
+}
+void noinline
+ev_feed_signal_event (EV_P_ int signum)
+{
+  WL w;
+#if EV_MULTIPLICITY
+  assert (("feeding signal events is only supported in the default loop", loop == ev_default_loop_ptr));
+#endif
+  --signum;
+  if (signum < 0 || signum >= signalmax)
+    return;
+  signals [signum].gotsig = 0;
+  for (w = signals [signum].head; w; w = w->next)
+    ev_feed_event (EV_A_ (W)w, EV_SIGNAL);
+}
+/*****************************************************************************/
 static WL childs [EV_PID_HASHSIZE];
 #ifndef _WIN32
 static ev_signal childev;
+#ifndef WIFCONTINUED
+# define WIFCONTINUED(status) 0
+#endif
 void inline_speed
 child_reap (EV_P_ ev_signal *sw, int chain, int pid, int status)
 {
   ev_child *w;
+  int traced = WIFSTOPPED (status) || WIFCONTINUED (status);
   for (w = (ev_child *)childs [chain & (EV_PID_HASHSIZE - 1)]; w; w = (ev_child *)((WL)w)->next)
+    {
-    if (w->pid == pid || !w->pid)
+      if ((w->pid == pid || !w->pid)
+          && (!traced || (w->flags & 1)))
-      {
+        {
-        ev_set_priority (w, ev_priority (sw)); /* need to do it *now* */
+          ev_set_priority (w, ev_priority (sw)); /* need to do it *now* */
-        w->rpid    = pid;
+          w->rpid    = pid;
-        w->rstatus = status;
+          w->rstatus = status;
-        ev_feed_event (EV_A_ (W)w, EV_CHILD);
+          ev_feed_event (EV_A_ (W)w, EV_CHILD);
-      }
+        }
+    }
 }
 #ifndef WCONTINUED
 # define WCONTINUED 0
 #endif
 }
 unsigned int
 ev_embeddable_backends (void)
 {
+  int flags = EVBACKEND_EPOLL | EVBACKEND_KQUEUE | EVBACKEND_PORT;
   /* epoll embeddability broken on all linux versions up to at least 2.6.23 */
-  return EVBACKEND_KQUEUE
+  /* please fix it and tell me how to detect the fix */
-       | EVBACKEND_PORT;
+  flags &= ~EVBACKEND_EPOLL;
+  return flags;
 }
 unsigned int
 ev_backend (EV_P)
 {
 #endif
 #if EV_USE_SELECT
       if (!backend && (flags & EVBACKEND_SELECT)) backend = select_init (EV_A_ flags);
 #endif
-      ev_init (&sigev, sigcb);
+      ev_init (&pipeev, pipecb);
-      ev_set_priority (&sigev, EV_MAXPRI);
+      ev_set_priority (&pipeev, EV_MAXPRI);
     }
 }
 static void noinline
 loop_destroy (EV_P)
 {
   int i;
+  if (ev_is_active (&pipeev))
+    {
+      ev_ref (EV_A); /* signal watcher */
+      ev_io_stop (EV_A_ &pipeev);
+      close (evpipe [0]); evpipe [0] = 0;
+      close (evpipe [1]); evpipe [1] = 0;
+    }
 #if EV_USE_INOTIFY
   if (fs_fd >= 0)
     close (fs_fd);
 #endif
 #endif
 #if EV_USE_INOTIFY
   infy_fork (EV_A);
 #endif
-  if (ev_is_active (&sigev))
+  if (ev_is_active (&pipeev))
     {
-      /* default loop */
+      /* this "locks" the handlers against writing to the pipe */
+      gotsig = gotasync = 1;
       ev_ref (EV_A);
-      ev_io_stop (EV_A_ &sigev);
+      ev_io_stop (EV_A_ &pipeev);
-      close (sigpipe [0]);
+      close (evpipe [0]);
-      close (sigpipe [1]);
+      close (evpipe [1]);
-      while (pipe (sigpipe))
-        syserr ("(libev) error creating pipe");
-      siginit (EV_A);
+      evpipe_init (EV_A);
+      /* now iterate over everything, in case we missed something */
+      pipecb (EV_A_ &pipeev, EV_READ);
     }
   postfork = 0;
 }
 }
 void
 ev_loop_fork (EV_P)
 {
-  postfork = 1;
+  postfork = 1; /* must be in line with ev_default_fork */
 }
 #endif
 #if EV_MULTIPLICITY
 #else
 int
 ev_default_loop (unsigned int flags)
 #endif
 {
-  if (sigpipe [0] == sigpipe [1])
-    if (pipe (sigpipe))
-      return 0;
   if (!ev_default_loop_ptr)
     {
 #if EV_MULTIPLICITY
       struct ev_loop *loop = ev_default_loop_ptr = &default_loop_struct;
 #else
       loop_init (EV_A_ flags);
       if (ev_backend (EV_A))
         {
-          siginit (EV_A);
 #ifndef _WIN32
           ev_signal_init (&childev, childcb, SIGCHLD);
           ev_set_priority (&childev, EV_MAXPRI);
           ev_signal_start (EV_A_ &childev);
           ev_unref (EV_A); /* child watcher should not keep loop alive */
 #ifndef _WIN32
   ev_ref (EV_A); /* child watcher */
   ev_signal_stop (EV_A_ &childev);
 #endif
-  ev_ref (EV_A); /* signal watcher */
-  ev_io_stop (EV_A_ &sigev);
-  close (sigpipe [0]); sigpipe [0] = 0;
-  close (sigpipe [1]); sigpipe [1] = 0;
   loop_destroy (EV_A);
 }
 void
 ev_default_fork (void)
 #if EV_MULTIPLICITY
   struct ev_loop *loop = ev_default_loop_ptr;
 #endif
   if (backend)
-    postfork = 1;
+    postfork = 1; /* must be in line with ev_loop_fork */
 }
 /*****************************************************************************/
 void
 #endif
   if (expect_false (ev_is_active (w)))
     return;
   assert (("ev_signal_start called with illegal signal number", w->signum > 0));
+  evpipe_init (EV_A);
   {
 #ifndef _WIN32
     sigset_t full, prev;
     sigfillset (&full);
   ev_embed *w = (ev_embed *)(((char *)io) - offsetof (ev_embed, io));
   if (ev_cb (w))
     ev_feed_event (EV_A_ (W)w, EV_EMBED);
   else
-    ev_embed_sweep (loop, w);
+    ev_loop (w->other, EVLOOP_NONBLOCK);
 }
 static void
 embed_prepare_cb (EV_P_ ev_prepare *prepare, int revents)
 {
   ev_embed *w = (ev_embed *)(((char *)prepare) - offsetof (ev_embed, prepare));
-  fd_reify (w->other);
+  {
+    struct ev_loop *loop = w->other;
+    while (fdchangecnt)
+      {
+        fd_reify (EV_A);
+        ev_loop (EV_A_ EVLOOP_NONBLOCK);
+      }
+  }
 }
+#if 0
+static void
+embed_idle_cb (EV_P_ ev_idle *idle, int revents)
+{
+  ev_idle_stop (EV_A_ idle);
+}
+#endif
 void
 ev_embed_start (EV_P_ ev_embed *w)
 {
   if (expect_false (ev_is_active (w)))
   ev_prepare_init (&w->prepare, embed_prepare_cb);
   ev_set_priority (&w->prepare, EV_MINPRI);
   ev_prepare_start (EV_A_ &w->prepare);
+  /*ev_idle_init (&w->idle, e,bed_idle_cb);*/
   ev_start (EV_A_ (W)w, 1);
 }
 void
 ev_embed_stop (EV_P_ ev_embed *w)
   ev_stop (EV_A_ (W)w);
 }
 #endif
+#if EV_ASYNC_ENABLE
+void
+ev_async_start (EV_P_ ev_async *w)
+{
+  if (expect_false (ev_is_active (w)))
+    return;
+  evpipe_init (EV_A);
+  ev_start (EV_A_ (W)w, ++asynccnt);
+  array_needsize (ev_async *, asyncs, asyncmax, asynccnt, EMPTY2);
+  asyncs [asynccnt - 1] = w;
+}
+void
+ev_async_stop (EV_P_ ev_async *w)
+{
+  clear_pending (EV_A_ (W)w);
+  if (expect_false (!ev_is_active (w)))
+    return;
+  {
+    int active = ((W)w)->active;
+    asyncs [active - 1] = asyncs [--asynccnt];
+    ((W)asyncs [active - 1])->active = active;
+  }
+  ev_stop (EV_A_ (W)w);
+}
+void
+ev_async_send (EV_P_ ev_async *w)
+{
+  w->sent = 1;
+  evpipe_write (EV_A_ 0, 1);
+}
+#endif
 /*****************************************************************************/
 struct ev_once
 {
   ev_io io;

Diff Legend

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

Comparing libev/ev.c (file contents): Revision 1.193 by root, Sat Dec 22 05:47:58 2007 UTC vs. Revision 1.208 by root, Fri Feb 1 13:22:48 2008 UTC

Diff Legend

Comparing libev/ev.c (file contents):
Revision 1.193 by root, Sat Dec 22 05:47:58 2007 UTC vs.
Revision 1.208 by root, Fri Feb 1 13:22:48 2008 UTC