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

Comparing libev/ev.c (file contents):
Revision 1.292 by root, Mon Jun 29 07:22:56 2009 UTC vs.
Revision 1.296 by root, Thu Jul 9 09:11:20 2009 UTC

 # define inline_speed      static noinline
 #else
 # define inline_speed      static inline
 #endif
-#define NUMPRI    (EV_MAXPRI - EV_MINPRI + 1)
+#define NUMPRI (EV_MAXPRI - EV_MINPRI + 1)
+#if EV_MINPRI == EV_MAXPRI
+# define ABSPRI(w) (((W)w), 0)
+#else
-#define ABSPRI(w) (((W)w)->priority - EV_MINPRI)
+# define ABSPRI(w) (((W)w)->priority - EV_MINPRI)
+#endif
 #define EMPTY       /* required for microsofts broken pseudo-c compiler */
 #define EMPTY2(a,b) /* used to suppress some warnings */
 typedef ev_watcher *W;
       tv.tv_sec  = (time_t)delay;
       tv.tv_usec = (long)((delay - (ev_tstamp)(tv.tv_sec)) * 1e6);
       /* here we rely on sys/time.h + sys/types.h + unistd.h providing select */
-      /* somehting nto guaranteed by newer posix versions, but guaranteed */
+      /* somehting not guaranteed by newer posix versions, but guaranteed */
       /* by older ones */
       select (0, 0, 0, 0, &tv);
 #endif
     }
 }
 ev_loop_count (EV_P)
 {
   return loop_count;
 }
+unsigned int
+ev_loop_depth (EV_P)
+{
+  return loop_depth;
+}
 void
 ev_set_io_collect_interval (EV_P_ ev_tstamp interval)
 {
   io_blocktime = interval;
 }
       ev_rt_now         = ev_time ();
       mn_now            = get_clock ();
       now_floor         = mn_now;
       rtmn_diff         = ev_rt_now - mn_now;
+      invoke_cb         = ev_invoke_pending;
       io_blocktime      = 0.;
       timeout_blocktime = 0.;
       backend           = 0;
       backend_fd        = -1;
 ev_invoke (EV_P_ void *w, int revents)
 {
   EV_CB_INVOKE ((W)w, revents);
 }
-inline_speed void
+void
-call_pending (EV_P)
+ev_invoke_pending (EV_P)
 {
   int pri;
   for (pri = NUMPRI; pri--; )
     while (pendingcnt [pri])
       mn_now = ev_rt_now;
     }
 }
-static int loop_done;
 void
 ev_loop (EV_P_ int flags)
 {
+  ++loop_depth;
   loop_done = EVUNLOOP_CANCEL;
-  call_pending (EV_A); /* in case we recurse, ensure ordering stays nice and clean */
+  invoke_cb (EV_A); /* in case we recurse, ensure ordering stays nice and clean */
   do
     {
 #if EV_VERIFY >= 2
       ev_loop_verify (EV_A);
       /* we might have forked, so queue fork handlers */
       if (expect_false (postfork))
         if (forkcnt)
           {
             queue_events (EV_A_ (W *)forks, forkcnt, EV_FORK);
-            call_pending (EV_A);
+            invoke_cb (EV_A);
           }
 #endif
       /* queue prepare watchers (and execute them) */
       if (expect_false (preparecnt))
         {
           queue_events (EV_A_ (W *)prepares, preparecnt, EV_PREPARE);
-          call_pending (EV_A);
+          invoke_cb (EV_A);
         }
       /* we might have forked, so reify kernel state if necessary */
       if (expect_false (postfork))
         loop_fork (EV_A);
         ev_tstamp waittime  = 0.;
         ev_tstamp sleeptime = 0.;
         if (expect_true (!(flags & EVLOOP_NONBLOCK || idleall || !activecnt)))
           {
+            /* remember old timestamp for io_blocktime calculation */
+            ev_tstamp prev_mn_now = mn_now;
             /* update time to cancel out callback processing overhead */
             time_update (EV_A_ 1e100);
             waittime = MAX_BLOCKTIME;
                 ev_tstamp to = ANHE_at (periodics [HEAP0]) - ev_rt_now + backend_fudge;
                 if (waittime > to) waittime = to;
               }
 #endif
+            /* don't let timeouts decrease the waittime below timeout_blocktime */
             if (expect_false (waittime < timeout_blocktime))
               waittime = timeout_blocktime;
-            sleeptime = waittime - backend_fudge;
+            /* extra check because io_blocktime is commonly 0 */
-            if (expect_true (sleeptime > io_blocktime))
+            if (expect_false (io_blocktime))
-              sleeptime = io_blocktime;
-            if (sleeptime)
               {
+                sleeptime = io_blocktime - (mn_now - prev_mn_now);
+                if (sleeptime > waittime - backend_fudge)
+                  sleeptime = waittime - backend_fudge;
+                if (expect_true (sleeptime > 0.))
+                  {
-                ev_sleep (sleeptime);
+                    ev_sleep (sleeptime);
-                waittime -= sleeptime;
+                    waittime -= sleeptime;
+                  }
               }
           }
         ++loop_count;
         backend_poll (EV_A_ waittime);
       /* queue check watchers, to be executed first */
       if (expect_false (checkcnt))
         queue_events (EV_A_ (W *)checks, checkcnt, EV_CHECK);
-      call_pending (EV_A);
+      invoke_cb (EV_A);
     }
   while (expect_true (
     activecnt
     && !loop_done
     && !(flags & (EVLOOP_ONESHOT | EVLOOP_NONBLOCK))
   ));
   if (loop_done == EVUNLOOP_ONE)
     loop_done = EVUNLOOP_CANCEL;
+  --loop_depth;
 }
 void
 ev_unloop (EV_P_ int how)
 {
 }
 inline_size void
 pri_adjust (EV_P_ W w)
 {
-  int pri = w->priority;
+  int pri = ev_priority (w);
   pri = pri < EV_MINPRI ? EV_MINPRI : pri;
   pri = pri > EV_MAXPRI ? EV_MAXPRI : pri;
-  w->priority = pri;
+  ev_set_priority (w, pri);
 }
 inline_speed void
 ev_start (EV_P_ W w, int active)
 {

Diff Legend

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

Comparing libev/ev.c (file contents): Revision 1.292 by root, Mon Jun 29 07:22:56 2009 UTC vs. Revision 1.296 by root, Thu Jul 9 09:11:20 2009 UTC

Diff Legend

Comparing libev/ev.c (file contents):
Revision 1.292 by root, Mon Jun 29 07:22:56 2009 UTC vs.
Revision 1.296 by root, Thu Jul 9 09:11:20 2009 UTC