Static scheduler

core/clock.c

@@ -55,6 +55,8 @@ int lf_clock_cond_timedwait(lf_cond_t *cond, instant_t wakeup_time) {
     // Remove any clock sync offset and call the Platform API.
     clock_sync_remove_offset(&wakeup_time);
     #endif
-    return _lf_cond_timedwait(cond, wakeup_time);
+    // return _lf_cond_timedwait(cond, wakeup_time);
+    while (lf_time_physical() < wakeup_time);
+    return true;
 }
 #endif

core/lf_token.c

@@ -219,6 +219,10 @@ lf_token_t* _lf_new_token(token_type_t* type, void* value, size_t length) {
     return result;
 }
 
+// FIXME (Shaokai): The function name is probably a misnomer.
+// It should better be _lf_get_new_token.
+// I also don't get why the token isn't simply returned, and
+// _lf_free_token_value or _lf_done_using has to be called. 
 lf_token_t* _lf_get_token(token_template_t* tmplt) {
     if (tmplt->token != NULL) {
         if (tmplt->token->ref_count == 1) {

core/reactor.c

@@ -66,7 +66,9 @@ void lf_set_present(lf_port_base_t* port) {
 int wait_until(environment_t* env, instant_t wakeup_time) {
     if (!fast) {
         LF_PRINT_LOG("Waiting for elapsed logical time " PRINTF_TIME ".", wakeup_time - start_time);
-        return lf_clock_interruptable_sleep_until_locked(env, wakeup_time);
+        // return lf_clock_interruptable_sleep_until_locked(env, wakeup_time);
+        while (lf_time_physical() < wakeup_time);
+        return 0;
     }
     return 0;
 }

core/reactor_common.c

@@ -869,6 +869,8 @@ void schedule_output_reactions(environment_t *env, reaction_t* reaction, int wor
                                     downstream_reaction->is_STP_violated, downstream_reaction->name);
                         }
 #endif
+// FIXME (erj): This is super hacky and only a temporary fix. 
+#if defined REACTION_CHAIN_OPTIMIZATION
                         if (downstream_reaction != NULL && downstream_reaction != downstream_to_execute_now) {
                             num_downstream_reactions++;
                             // If there is exactly one downstream reaction that is enabled by this
@@ -897,6 +899,10 @@ void schedule_output_reactions(environment_t *env, reaction_t* reaction, int wor
                                 _lf_trigger_reaction(env, downstream_reaction, worker);
                             }
                         }
+#else
+                        // Queue the reaction.
+                        _lf_trigger_reaction(env, downstream_reaction, worker);
+#endif
                     }
                 }
             }

core/threaded/CMakeLists.txt

@@ -2,6 +2,7 @@ set(
     THREADED_SOURCES
     reactor_threaded.c
     scheduler_adaptive.c
+    scheduler_static.c
     scheduler_GEDF_NP.c
     scheduler_NP.c
     scheduler_sync_tag_advance.c