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

Comparing libev/ev.c (file contents):
Revision 1.284 by root, Wed Apr 15 17:49:26 2009 UTC vs.
Revision 1.287 by root, Mon Apr 20 19:45:58 2009 UTC

   reheap (periodics, periodiccnt);
 }
 #endif
+static void noinline
+timers_reschedule (EV_P_ ev_tstamp adjust)
+{
+  int i;
+  for (i = 0; i < timercnt; ++i)
+    {
+      ANHE *he = timers + i + HEAP0;
+      ANHE_w (*he)->at += adjust;
+      ANHE_at_cache (*he);
+    }
+}
 inline_speed void
 time_update (EV_P_ ev_tstamp max_block)
 {
   int i;
           ev_rt_now = ev_time ();
           mn_now    = get_clock ();
           now_floor = mn_now;
         }
+      /* no timer adjustment, as the monotonic clock doesn't jump */
+      /* timers_reschedule (EV_A_ rtmn_diff - odiff) */
 # if EV_PERIODIC_ENABLE
       periodics_reschedule (EV_A);
 # endif
-      /* no timer adjustment, as the monotonic clock doesn't jump */
-      /* timers_reschedule (EV_A_ rtmn_diff - odiff) */
     }
   else
 #endif
     {
       ev_rt_now = ev_time ();
       if (expect_false (mn_now > ev_rt_now || ev_rt_now > mn_now + max_block + MIN_TIMEJUMP))
         {
+          /* adjust timers. this is easy, as the offset is the same for all of them */
+          timers_reschedule (EV_A_ ev_rt_now - mn_now);
 #if EV_PERIODIC_ENABLE
           periodics_reschedule (EV_A);
 #endif
-          /* adjust timers. this is easy, as the offset is the same for all of them */
-          for (i = 0; i < timercnt; ++i)
-            {
-              ANHE *he = timers + i + HEAP0;
-              ANHE_w (*he)->at += ev_rt_now - mn_now;
-              ANHE_at_cache (*he);
-            }
         }
       mn_now = ev_rt_now;
     }
-}
-void
-ev_ref (EV_P)
-{
-  ++activecnt;
-}
-void
-ev_unref (EV_P)
-{
-  --activecnt;
-}
-void
-ev_now_update (EV_P)
-{
-  time_update (EV_A_ 1e100);
 }
 static int loop_done;
 void
         if (expect_true (!(flags & EVLOOP_NONBLOCK || idleall || !activecnt)))
           {
             /* update time to cancel out callback processing overhead */
             time_update (EV_A_ 1e100);
+            waittime = MAX_BLOCKTIME;
             if (timercnt)
               {
                 ev_tstamp to = ANHE_at (timers [HEAP0]) - mn_now + backend_fudge;
                 if (waittime > to) waittime = to;
               }
 void
 ev_unloop (EV_P_ int how)
 {
   loop_done = how;
+}
+void
+ev_ref (EV_P)
+{
+  ++activecnt;
+}
+void
+ev_unref (EV_P)
+{
+  --activecnt;
+}
+void
+ev_now_update (EV_P)
+{
+  time_update (EV_A_ 1e100);
+}
+void
+ev_suspend (EV_P)
+{
+  ev_now_update (EV_A);
+}
+void
+ev_resume (EV_P)
+{
+  ev_tstamp mn_prev = mn_now;
+  ev_now_update (EV_A);
+  timers_reschedule (EV_A_ mn_now - mn_prev);
+#if EV_PERIODIC_ENABLE
+  periodics_reschedule (EV_A);
+#endif
 }
 /*****************************************************************************/
 inline_size void

Diff Legend

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

Comparing libev/ev.c (file contents): Revision 1.284 by root, Wed Apr 15 17:49:26 2009 UTC vs. Revision 1.287 by root, Mon Apr 20 19:45:58 2009 UTC

Diff Legend

Comparing libev/ev.c (file contents):
Revision 1.284 by root, Wed Apr 15 17:49:26 2009 UTC vs.
Revision 1.287 by root, Mon Apr 20 19:45:58 2009 UTC