EV first rough cut

diff --git a/ev.c b/ev.c
index 1e54f21b7b54296f806f8a256a813b8c1474c0d3..a038613087c6da2e2839771cce12ded5df737832 100644 (file)
--- a/ev.c
+++ b/ev.c
@@ -36,18 +36,6 @@
 
 #include "ev.h"
 
 
 #include "ev.h"
 

-struct ev_watcher {
-  EV_WATCHER (ev_watcher);
-};
-
-struct ev_watcher_list {
-  EV_WATCHER_LIST (ev_watcher_list);
-};
-
-struct ev_watcher_time {
-  EV_WATCHER_TIME (ev_watcher_time);
-};
-

 typedef struct ev_watcher *W;
 typedef struct ev_watcher_list *WL;
 typedef struct ev_watcher_time *WT;
 typedef struct ev_watcher *W;
 typedef struct ev_watcher_list *WL;
 typedef struct ev_watcher_time *WT;


@@ -457,11 +445,11 @@ periodics_reify ()
 }
 
 static void
 }
 
 static void

-time_jump (ev_tstamp diff)
+periodics_reschedule (ev_tstamp diff)

 {
   int i;
 
 {
   int i;
 

-  /* adjust periodics */
+  /* adjust periodics after time jump */

   for (i = 0; i < periodiccnt; ++i)
     {
       struct ev_periodic *w = periodics [i];
   for (i = 0; i < periodiccnt; ++i)
     {
       struct ev_periodic *w = periodics [i];


@@ -479,10 +467,6 @@ time_jump (ev_tstamp diff)
             }
         }
     }
             }
         }
     }

-
-  /* adjust timers. this is easy, as the offset is the same for all */
-  for (i = 0; i < timercnt; ++i)
-    timers [i]->at += diff;

 }
 
 static void
 }
 
 static void


@@ -507,12 +491,19 @@ time_update ()
           ev_now = ev_time ();
         }
 
           ev_now = ev_time ();
         }
 

-      time_jump (diff - odiff);
+      periodics_reschedule (diff - odiff);
+      /* no timer adjustment, as the monotonic clock doesn't jump */

     }
   else
     {
       if (now > ev_now || now < ev_now - MAX_BLOCKTIME - MIN_TIMEJUMP)
     }
   else
     {
       if (now > ev_now || now < ev_now - MAX_BLOCKTIME - MIN_TIMEJUMP)

-        time_jump (ev_now - now);
+        {
+          periodics_reschedule (ev_now - now);
+
+          /* adjust timers. this is easy, as the offset is the same for all */
+          for (i = 0; i < timercnt; ++i)
+            timers [i]->at += diff;
+        }

 
       now = ev_now;
     }
 
       now = ev_now;
     }


@@ -523,7 +514,7 @@ int ev_loop_done;
 void ev_loop (int flags)
 {
   double block;
 void ev_loop (int flags)
 {
   double block;

-  ev_loop_done = flags & EVLOOP_ONESHOT;
+  ev_loop_done = flags & EVLOOP_ONESHOT ? 1 : 0;

 
   if (checkcnt)
     {
 
   if (checkcnt)
     {


@@ -581,6 +572,9 @@ void ev_loop (int flags)
       call_pending ();
     }
   while (!ev_loop_done);
       call_pending ();
     }
   while (!ev_loop_done);

+
+  if (ev_loop_done != 2)
+    ev_loop_done = 0;

 }
 
 /*****************************************************************************/
 }
 
 /*****************************************************************************/


@@ -665,6 +659,8 @@ evtimer_start (struct ev_timer *w)
 
   w->at += now;
 
 
   w->at += now;
 

+  assert (("timer repeat value less than zero not allowed", w->repeat >= 0.));
+

   ev_start ((W)w, ++timercnt);
   array_needsize (timers, timermax, timercnt, );
   timers [timercnt - 1] = w;
   ev_start ((W)w, ++timercnt);
   array_needsize (timers, timermax, timercnt, );
   timers [timercnt - 1] = w;


@@ -692,6 +688,8 @@ evperiodic_start (struct ev_periodic *w)
   if (ev_is_active (w))
     return;
 
   if (ev_is_active (w))
     return;
 

+  assert (("periodic interval value less than zero not allowed", w->interval >= 0.));
+

   /* this formula differs from the one in periodic_reify because we do not always round up */
   if (w->interval)
     w->at += ceil ((ev_now - w->at) / w->interval) * w->interval;
   /* this formula differs from the one in periodic_reify because we do not always round up */
   if (w->interval)
     w->at += ceil ((ev_now - w->at) / w->interval) * w->interval;


@@ -784,7 +782,7 @@ void evcheck_stop (struct ev_check *w)
 
 /*****************************************************************************/
 
 
 /*****************************************************************************/
 

-#if 1
+#if 0

 
 struct ev_io wio;
 
 
 struct ev_io wio;
 

diff --git a/ev.h b/ev.h
index 9d2b2e9cc56c677cf2f23950999b75c4fdaa45b5..7236712c97ede0736a0e795077d614794bbf9c5a 100644 (file)
--- a/ev.h
+++ b/ev.h
@@ -40,6 +40,21 @@ typedef double ev_tstamp;
   EV_WATCHER (type);                           \
   ev_tstamp at     /* private */
 
   EV_WATCHER (type);                           \
   ev_tstamp at     /* private */
 

+/* base class, nothing to see here unless you subclass */
+struct ev_watcher {
+  EV_WATCHER (ev_watcher);
+};
+
+/* base class, nothing to see here unless you subclass */
+struct ev_watcher_list {
+  EV_WATCHER_LIST (ev_watcher_list);
+};
+
+/* base class, nothing to see here unless you subclass */
+struct ev_watcher_time {
+  EV_WATCHER_TIME (ev_watcher_time);
+};
+

 /* invoked after a specific time, repeatable (based on monotonic clock) */
 struct ev_timer
 {
 /* invoked after a specific time, repeatable (based on monotonic clock) */
 struct ev_timer
 {


@@ -102,7 +117,7 @@ ev_tstamp ev_time (void);
 #define EVLOOP_NONBLOCK        1 /* do not block/wait */
 #define EVLOOP_ONESHOT 2 /* block *once* only */
 void ev_loop (int flags);
 #define EVLOOP_NONBLOCK        1 /* do not block/wait */
 #define EVLOOP_ONESHOT 2 /* block *once* only */
 void ev_loop (int flags);

-extern int ev_loop_done; /* set to 1 to break out of event loop */
+extern int ev_loop_done; /* set to 1 to break out of event loop, set to 2 to break out of all event loops */

 
 /* these may evaluate ev multiple times, and the other arguments at most once */
 /* either use evw_init + evXXX_set, or the evXXX_init macro, below, to first initialise a watcher */
 
 /* these may evaluate ev multiple times, and the other arguments at most once */
 /* either use evw_init + evXXX_set, or the evXXX_init macro, below, to first initialise a watcher */