From 184b55f0b5a846ae839f57bc4e3e319268eeb15a Mon Sep 17 00:00:00 2001 From: Byeonggil Jun Date: Wed, 29 Jan 2025 09:04:17 -0700 Subject: [PATCH] Do not check MIN_SLEEP_DURATION when waiting for the physical time to exceed the next tag --- core/threaded/reactor_threaded.c | 8 -------- include/core/threaded/reactor_threaded.h | 4 +--- 2 files changed, 1 insertion(+), 11 deletions(-) diff --git a/core/threaded/reactor_threaded.c b/core/threaded/reactor_threaded.c index 61c771118..9f6f8cd35 100644 --- a/core/threaded/reactor_threaded.c +++ b/core/threaded/reactor_threaded.c @@ -199,14 +199,6 @@ bool wait_until(instant_t wait_until_time, lf_cond_t* condition) { LF_PRINT_DEBUG("-------- Waiting until physical time " PRINTF_TIME, wait_until_time - start_time); // Check whether we actually need to wait, or if we have already passed the timepoint. interval_t wait_duration = wait_until_time - lf_time_physical(); - if (wait_duration < MIN_SLEEP_DURATION) { - LF_PRINT_DEBUG("Wait time " PRINTF_TIME " is less than lf_min_sleep_duration " PRINTF_TIME - ". Performing busy wait.", - wait_duration, MIN_SLEEP_DURATION); - while (lf_time_physical() < wait_until_time) { - // Busy wait - } - } // We do the sleep on the cond var so we can be awakened by the // asynchronous scheduling of a physical action. lf_clock_cond_timedwait diff --git a/include/core/threaded/reactor_threaded.h b/include/core/threaded/reactor_threaded.h index e8b0cd0c6..fe14beb8e 100644 --- a/include/core/threaded/reactor_threaded.h +++ b/include/core/threaded/reactor_threaded.h @@ -93,9 +93,7 @@ void lf_synchronize_with_other_federates(void); * if that event time matches or exceeds the specified time. * * The mutex lock associated with the condition argument is assumed to be held by - * the calling thread. This mutex is released while waiting. If the wait time is - * too small (less than MIN_SLEEP_DURATION) to wait using lf_clock_cond_timedwait, - * then this function performs busy wait and the mutex is not released. + * the calling thread. * * @param env Environment within which we are executing. * @param wait_until_time The time to wait until physical time matches it.