Apply code formatting

Author: sbgaia

include/reactor-uc/queues.h

@@ -37,7 +37,7 @@ struct EventQueue {
   void (*heapify)(EventQueue* self, size_t idx);
   /** @brief Find an event with the same tag and trigger as @p event, or NULL if not found. */
   ArbitraryEvent* (*find_equal_same_tag)(EventQueue* self, AbstractEvent* event);
-  /** @brief Remove the event equal to @p event from the queue. Returns 
+  /** @brief Remove the event equal to @p event from the queue. Returns
    * LF_NOT_FOUND if no such event exists, LF_OK otherwise.
    */
   lf_ret_t (*remove)(EventQueue* self, AbstractEvent* event);

include/reactor-uc/scheduler.h

@@ -59,13 +59,13 @@ struct Scheduler {
   void (*prepare_timestep)(Scheduler* self, tag_t tag);
 
   /**
-   * @brief Cancel a pending event for a `trigger` at `event_time`. Returns 
+   * @brief Cancel a pending event for a `trigger` at `event_time`. Returns
    * LF_NOT_FOUND if no matching event exists.
    */
   lf_ret_t (*cancel_event)(Scheduler* self, Trigger* trigger, instant_t event_time);
 
   /**
-   * @brief Replace the payload of a pending event for a `trigger` at 
+   * @brief Replace the payload of a pending event for a `trigger` at
    * `event_time`. Returns LF_NOT_FOUND if no matching event exists.
    */
   lf_ret_t (*replace_event_payload)(Scheduler* self, Trigger* trigger, instant_t event_time, const void* new_value);

src/action.c

@@ -75,8 +75,7 @@ lf_ret_t Action_schedule(Action* self, interval_t offset, const void* value) {
       break;
 
     case replace:
-      if (sched->replace_event_payload(sched, (Trigger*)self,
-                                      self->last_event_time, value) == LF_OK) {
+      if (sched->replace_event_payload(sched, (Trigger*)self, self->last_event_time, value) == LF_OK) {
         return LF_OK;
       }
     /* fallthrough - no existing event, defer to earliest_time */
@@ -90,13 +89,15 @@ lf_ret_t Action_schedule(Action* self, interval_t offset, const void* value) {
     }
   }
 
-  // If the event is scheduled at the current tag, we need to increment the microstep to ensure that the event is scheduled after the currently executing reactions.
+  // If the event is scheduled at the current tag, we need to increment the microstep to ensure that the event is
+  // scheduled after the currently executing reactions.
   if (lf_tag_compare(tag, base_tag) <= 0) {
     tag.time = base_tag.time;
     tag.microstep = base_tag.microstep + 1;
   }
 
-  // Only allocate and copy payload if a new event is actually being scheduled. In the case of "drop" and "replace" policies we don't want to allocate a new payload.
+  // Only allocate and copy payload if a new event is actually being scheduled. In the case of "drop" and "replace"
+  // policies we don't want to allocate a new payload.
   if (value != NULL) {
     ret = self->payload_pool.allocate(&self->payload_pool, &payload);
     validate(ret == LF_OK);

src/schedulers/dynamic/scheduler.c

@@ -520,10 +520,11 @@ lf_ret_t Scheduler_cancel_event(Scheduler* self, Trigger* trigger, instant_t eve
   return LF_OK;
 }
 
-lf_ret_t Scheduler_replace_event_payload(Scheduler* self, Trigger* trigger, instant_t event_time, const void* new_value) {
+lf_ret_t Scheduler_replace_event_payload(Scheduler* self, Trigger* trigger, instant_t event_time,
+                                         const void* new_value) {
   DynamicScheduler* scheduler = (DynamicScheduler*)self;
   Event* found = find_event(scheduler, trigger, event_time);
-  
+
   if (found == NULL) {
     LF_DEBUG(SCHED, "Could not find event to replace payload for trigger %p at time " PRINTF_TIME, trigger, event_time);
     return LF_NOT_FOUND;

test/unit/action_defer_test.c

@@ -17,14 +17,12 @@ LF_DEFINE_REACTION_BODY(ActionLib, reaction) {
   } else if (self->cnt == 1) {
     // First event fires at MSEC(1) with value 41
     TEST_ASSERT_EQUAL(true, lf_is_present(act));
-    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(1),
-                      env->scheduler->current_tag(env->scheduler).time);
+    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(1), env->scheduler->current_tag(env->scheduler).time);
     TEST_ASSERT_EQUAL(41, act->value);
   } else if (self->cnt == 2) {
     // Deferred event fires at MSEC(6) with value 42
     TEST_ASSERT_EQUAL(true, lf_is_present(act));
-    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(6),
-                      env->scheduler->current_tag(env->scheduler).time);
+    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(6), env->scheduler->current_tag(env->scheduler).time);
     TEST_ASSERT_EQUAL(42, act->value);
   }
   self->cnt++;

test/unit/action_drop_test.c

@@ -17,8 +17,7 @@ LF_DEFINE_REACTION_BODY(ActionLib, reaction) {
   } else if (self->cnt >= 1) {
     // Only the first event fires at MSEC(1) with value 41
     TEST_ASSERT_EQUAL(true, lf_is_present(act));
-    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(1),
-                      env->scheduler->current_tag(env->scheduler).time);
+    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(1), env->scheduler->current_tag(env->scheduler).time);
     TEST_ASSERT_EQUAL(41, act->value);
   }
   self->cnt++;

test/unit/action_replace_test.c

@@ -17,8 +17,7 @@ LF_DEFINE_REACTION_BODY(ActionLib, reaction) {
   } else if (self->cnt >= 1) {
     // Event fires at MSEC(1) but with replaced value 42
     TEST_ASSERT_EQUAL(true, lf_is_present(act));
-    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(1),
-                      env->scheduler->current_tag(env->scheduler).time);
+    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(1), env->scheduler->current_tag(env->scheduler).time);
     TEST_ASSERT_EQUAL(42, act->value);
   }
   self->cnt++;

test/unit/action_update_test.c

@@ -8,7 +8,8 @@ LF_DEFINE_REACTION_BODY(ActionLib, reaction) {
   LF_SCOPE_SELF(ActionLib);
   LF_SCOPE_ENV();
   LF_SCOPE_ACTION(ActionLib, act);
-  printf("Reaction executed at time " PRINTF_TIME ", with value %i\n", env->scheduler->current_tag(env->scheduler).time, act->value);
+  printf("Reaction executed at time " PRINTF_TIME ", with value %i\n", env->scheduler->current_tag(env->scheduler).time,
+         act->value);
 
   if (self->cnt == 0) {
     // Startup: schedule two events that will violate min_spacing
@@ -18,8 +19,7 @@ LF_DEFINE_REACTION_BODY(ActionLib, reaction) {
   } else if (self->cnt >= 1) {
     // Event fires at MSEC(2) with value 42 (old event cancelled)
     TEST_ASSERT_EQUAL(true, lf_is_present(act));
-    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(2),
-                      env->scheduler->current_tag(env->scheduler).time);
+    TEST_ASSERT_EQUAL(env->scheduler->start_time + MSEC(2), env->scheduler->current_tag(env->scheduler).time);
     TEST_ASSERT_EQUAL(42, act->value);
   }
   self->cnt++;