Formatting

lf-lang · Feb 11, 2025 · 4549e05 · 4549e05
1 parent c9030d4
commit 4549e05
Show file tree

Hide file tree

Showing 24 changed files with 62 additions and 30 deletions.
diff --git a/examples/posix/federated/receiver.c b/examples/posix/federated/receiver.c
@@ -67,12 +67,16 @@ LF_FEDERATED_CONNECTION_BUNDLE_CTOR_SIGNATURE(Receiver, Sender) {
   LF_INITIALIZE_FEDERATED_INPUT_CONNECTION(Receiver, in, deserialize_msg_t);
 }
 
+LF_DEFINE_STARTUP_COORDINATOR_STRUCT(Federate, 1);
+LF_DEFINE_STARTUP_COORDINATOR_CTOR(Federate, 1, 1);
+
 typedef struct {
   Reactor super;
   LF_CHILD_REACTOR_INSTANCE(Receiver, receiver, 1);
   LF_FEDERATED_CONNECTION_BUNDLE_INSTANCE(Receiver, Sender);
   LF_FEDERATE_BOOKKEEPING_INSTANCES(1);
   LF_CHILD_INPUT_SOURCES(receiver, in, 1, 1, 0);
+  FederateStartupCoordinator startup_coordinator;
 } MainRecv;
 
 LF_REACTOR_CTOR_SIGNATURE(MainRecv) {
@@ -81,6 +85,7 @@ LF_REACTOR_CTOR_SIGNATURE(MainRecv) {
   LF_DEFINE_CHILD_INPUT_ARGS(receiver, in, 1, 1);
   LF_INITIALIZE_CHILD_REACTOR_WITH_PARAMETERS(Receiver, receiver, 1, _receiver_in_args[i]);
   LF_INITIALIZE_FEDERATED_CONNECTION_BUNDLE(Receiver, Sender);
+  LF_INITIALIZE_STARTUP_COORDINATOR(Federate);
   lf_connect_federated_input(&self->Receiver_Sender_bundle.inputs[0]->super, &self->receiver->in[0].super);
 }
 

diff --git a/examples/posix/federated/sender.c b/examples/posix/federated/sender.c
@@ -78,6 +78,9 @@ LF_FEDERATED_CONNECTION_BUNDLE_CTOR_SIGNATURE(Sender, Receiver) {
   LF_INITIALIZE_FEDERATED_OUTPUT_CONNECTION(Sender, out, serialize_msg_t);
 }
 
+LF_DEFINE_STARTUP_COORDINATOR_STRUCT(Federate, 1);
+LF_DEFINE_STARTUP_COORDINATOR_CTOR(Federate, 1, 1);
+
 // Reactor main
 typedef struct {
   Reactor super;
@@ -87,6 +90,7 @@ typedef struct {
   LF_CHILD_OUTPUT_CONNECTIONS(sender, out, 1, 1, 1);
   LF_CHILD_OUTPUT_EFFECTS(sender, out, 1, 1, 0);
   LF_CHILD_OUTPUT_OBSERVERS(sender, out, 1, 1, 0);
+  FederateStartupCoordinator startup_coordinator;
 } MainSender;
 
 LF_REACTOR_CTOR_SIGNATURE(MainSender) {
@@ -96,6 +100,7 @@ LF_REACTOR_CTOR_SIGNATURE(MainSender) {
   LF_INITIALIZE_CHILD_REACTOR_WITH_PARAMETERS(Sender, sender, 1, _sender_out_args[i]);
   LF_INITIALIZE_FEDERATED_CONNECTION_BUNDLE(Sender, Receiver);
   lf_connect_federated_output(self->Sender_Receiver_bundle.outputs[0], self->sender->out);
+  LF_INITIALIZE_STARTUP_COORDINATOR(Federate);
 }
 
 LF_ENTRY_POINT_FEDERATED(MainSender, SEC(1), true, 1, true)

diff --git a/examples/riot/coap_federated/receiver/main.c b/examples/riot/coap_federated/receiver/main.c
@@ -66,12 +66,15 @@ LF_FEDERATED_CONNECTION_BUNDLE_CTOR_SIGNATURE(Receiver, Sender) {
   LF_INITIALIZE_FEDERATED_INPUT_CONNECTION(Receiver, in, deserialize_msg_t);
 }
 
+LF_DEFINE_STARTUP_COORDINATOR_STRUCT(Federate, 1);
+LF_DEFINE_STARTUP_COORDINATOR_CTOR(Federate, 1, 1);
 typedef struct {
   Reactor super;
   LF_CHILD_REACTOR_INSTANCE(Receiver, receiver, 1);
   LF_FEDERATED_CONNECTION_BUNDLE_INSTANCE(Receiver, Sender);
   LF_FEDERATE_BOOKKEEPING_INSTANCES(1);
   LF_CHILD_INPUT_SOURCES(receiver, in, 1, 1, 0);
+  FederateStartupCoordinator startup_coordinator;
 } MainRecv;
 
 LF_REACTOR_CTOR_SIGNATURE(MainRecv) {
@@ -80,6 +83,7 @@ LF_REACTOR_CTOR_SIGNATURE(MainRecv) {
   LF_DEFINE_CHILD_INPUT_ARGS(receiver, in, 1, 1);
   LF_INITIALIZE_CHILD_REACTOR_WITH_PARAMETERS(Receiver, receiver, 1, _receiver_in_args[i]);
   LF_INITIALIZE_FEDERATED_CONNECTION_BUNDLE(Receiver, Sender);
+  LF_INITIALIZE_STARTUP_COORDINATOR(Federate);
   lf_connect_federated_input(&self->Receiver_Sender_bundle.inputs[0]->super, &self->receiver->in[0].super);
 }
 

diff --git a/examples/riot/coap_federated/sender/main.c b/examples/riot/coap_federated/sender/main.c
@@ -73,6 +73,8 @@ LF_FEDERATED_CONNECTION_BUNDLE_CTOR_SIGNATURE(Sender, Receiver) {
   LF_INITIALIZE_FEDERATED_OUTPUT_CONNECTION(Sender, out, serialize_msg_t);
 }
 
+LF_DEFINE_STARTUP_COORDINATOR_STRUCT(Federate, 1);
+LF_DEFINE_STARTUP_COORDINATOR_CTOR(Federate, 1, 1);
 // Reactor main
 typedef struct {
   Reactor super;
@@ -82,6 +84,7 @@ typedef struct {
   LF_CHILD_OUTPUT_CONNECTIONS(sender, out, 1, 1, 1);
   LF_CHILD_OUTPUT_EFFECTS(sender, out, 1, 1, 0);
   LF_CHILD_OUTPUT_OBSERVERS(sender, out, 1, 1, 0);
+  FederateStartupCoordinator startup_coordinator;
 } MainSender;
 
 LF_REACTOR_CTOR_SIGNATURE(MainSender) {
@@ -91,6 +94,7 @@ LF_REACTOR_CTOR_SIGNATURE(MainSender) {
   LF_INITIALIZE_CHILD_REACTOR_WITH_PARAMETERS(Sender, sender, 1, _sender_out_args[i]);
   LF_INITIALIZE_FEDERATED_CONNECTION_BUNDLE(Sender, Receiver);
   lf_connect_federated_output((Connection *)self->Sender_Receiver_bundle.outputs[0], (Port *)self->sender->out);
+  LF_INITIALIZE_STARTUP_COORDINATOR(Federate);
 }
 
 LF_ENTRY_POINT_FEDERATED(MainSender, SEC(1), true, 1, true)

diff --git a/examples/zephyr/basic_federated/common/receiver.h b/examples/zephyr/basic_federated/common/receiver.h
@@ -81,12 +81,15 @@ LF_FEDERATED_CONNECTION_BUNDLE_CTOR_SIGNATURE(Receiver, Sender) {
   LF_INITIALIZE_FEDERATED_INPUT_CONNECTION(Receiver, in, deserialize_payload_default);
 }
 
+LF_DEFINE_STARTUP_COORDINATOR_STRUCT(Federate, 1);
+LF_DEFINE_STARTUP_COORDINATOR_CTOR(Federate, 1, 1);
 typedef struct {
   Reactor super;
   LF_CHILD_REACTOR_INSTANCE(Receiver, receiver, 1);
   LF_FEDERATED_CONNECTION_BUNDLE_INSTANCE(Receiver, Sender);
   LF_FEDERATE_BOOKKEEPING_INSTANCES(1);
   LF_CHILD_INPUT_SOURCES(receiver, in, 1, 1, 0);
+  FederateStartupCoordinator startup_coordinator;
 } MainRecv;
 
 LF_REACTOR_CTOR_SIGNATURE(MainRecv) {
@@ -95,6 +98,7 @@ LF_REACTOR_CTOR_SIGNATURE(MainRecv) {
   LF_DEFINE_CHILD_INPUT_ARGS(receiver, in, 1, 1);
   LF_INITIALIZE_CHILD_REACTOR_WITH_PARAMETERS(Receiver, receiver, 1, _receiver_in_args[i]);
   LF_INITIALIZE_FEDERATED_CONNECTION_BUNDLE(Receiver, Sender);
+  LF_INITIALIZE_STARTUP_COORDINATOR(Federate);
   lf_connect_federated_input(&self->Receiver_Sender_bundle.inputs[0]->super, &self->receiver->in[0].super);
 }
 LF_ENTRY_POINT_FEDERATED(MainRecv, FOREVER, true, 1, false)
diff --git a/examples/zephyr/basic_federated/federated_sender/src/sender.c b/examples/zephyr/basic_federated/federated_sender/src/sender.c
@@ -132,6 +132,8 @@ LF_FEDERATED_CONNECTION_BUNDLE_CTOR_SIGNATURE(Sender, Receiver2) {
   LF_INITIALIZE_FEDERATED_OUTPUT_CONNECTION(Sender, out, serialize_payload_default);
 }
 
+LF_DEFINE_STARTUP_COORDINATOR_STRUCT(Federate, 2);
+LF_DEFINE_STARTUP_COORDINATOR_CTOR(Federate, 2, 1);
 // Reactor main
 typedef struct {
   Reactor super;
@@ -142,6 +144,7 @@ typedef struct {
   LF_CHILD_OUTPUT_EFFECTS(sender, out, 1, 1, 0);
   LF_CHILD_OUTPUT_OBSERVERS(sender, out,1, 1, 0);
   LF_FEDERATE_BOOKKEEPING_INSTANCES(2);
+  FederateStartupCoordinator startup_coordinator;
 } MainSender;
 
 LF_REACTOR_CTOR_SIGNATURE(MainSender) {
@@ -152,6 +155,7 @@ LF_REACTOR_CTOR_SIGNATURE(MainSender) {
   LF_INITIALIZE_CHILD_REACTOR_WITH_PARAMETERS(Sender, sender, 1, _sender_out_args[i]);
   LF_INITIALIZE_FEDERATED_CONNECTION_BUNDLE(Sender, Receiver1);
   LF_INITIALIZE_FEDERATED_CONNECTION_BUNDLE(Sender, Receiver2);
+  LF_INITIALIZE_STARTUP_COORDINATOR(Federate);
 
   lf_connect_federated_output(self->Sender_Receiver1_bundle.outputs[0], self->sender->out);
   lf_connect_federated_output(self->Sender_Receiver2_bundle.outputs[0], self->sender->out);

diff --git a/include/reactor-uc/federated.h b/include/reactor-uc/federated.h
@@ -54,7 +54,7 @@ struct FederatedConnectionBundle {
   FederatedOutputConnection **outputs;
   serialize_hook *serialize_hooks;
   size_t outputs_size;
-  bool server; // Does this federate work as server or client
+  bool server;  // Does this federate work as server or client
   size_t index; // Index of this FederatedConnectionBundle in the Environment's net_bundles array
 };
 

diff --git a/include/reactor-uc/macros_internal.h b/include/reactor-uc/macros_internal.h
@@ -520,7 +520,7 @@ typedef struct FederatedInputConnection FederatedInputConnection;
   } ReactorName##StartupCoordinator;
 
 #define LF_DEFINE_STARTUP_COORDINATOR_CTOR(ReactorName, NumFederates, LongestPath)                                     \
-  void ReactorName##StartupCoordinator_ctor(ReactorName##StartupCoordinator *self, Environment *env) {               \
+  void ReactorName##StartupCoordinator_ctor(ReactorName##StartupCoordinator *self, Environment *env) {                 \
     StartupCoordinator_ctor(&self->super, env, self->neighbors, NumFederates, LongestPath);                            \
   }
 
@@ -566,7 +566,7 @@ typedef struct FederatedInputConnection FederatedInputConnection;
   Environment *_lf_environment = &env;                                                                                 \
   void lf_exit(void) { Environment_free(&env); }                                                                       \
   void lf_start() {                                                                                                    \
-    Environment_ctor(&env, (Reactor *)&main_reactor, Timeout, KeepAlive, false, Fast, NULL, 0, 0, NULL);               \
+    Environment_ctor(&env, (Reactor *)&main_reactor, Timeout, KeepAlive, false, Fast, NULL, 0, NULL);                  \
     MainReactorName##_ctor(&main_reactor, NULL, &env);                                                                 \
     env.scheduler->duration = Timeout;                                                                                 \
     env.scheduler->keep_alive = KeepAlive;                                                                             \
@@ -576,15 +576,15 @@ typedef struct FederatedInputConnection FederatedInputConnection;
     lf_exit();                                                                                                         \
   }
 
-#define LF_ENTRY_POINT_FEDERATED(FederateName, Timeout, KeepAlive, NumBundles, IsLeader, Length)                       \
+#define LF_ENTRY_POINT_FEDERATED(FederateName, Timeout, KeepAlive, NumBundles, IsLeader)                               \
   FederateName main_reactor;                                                                                           \
   Environment env;                                                                                                     \
   Environment *_lf_environment = &env;                                                                                 \
   StartupCoordinator startup_coordinator;                                                                              \
   void lf_exit(void) { Environment_free(&env); }                                                                       \
   void lf_start() {                                                                                                    \
     Environment_ctor(&env, (Reactor *)&main_reactor, Timeout, KeepAlive, true, false, &main_reactor._bundles,          \
-                     NumBundles, Length, &startup_coordinator);                                                        \
+                     NumBundles, &main_reactor.startup_coordinator);                                                   \
     env.scheduler->leader = IsLeader;                                                                                  \
     FederateName##_ctor(&main_reactor, NULL, &env);                                                                    \
     env.net_bundles_size = NumBundles;                                                                                 \

diff --git a/lfc/core/src/main/kotlin/org/lflang/generator/uc/UcConnectionGenerator.kt b/lfc/core/src/main/kotlin/org/lflang/generator/uc/UcConnectionGenerator.kt
@@ -1,14 +1,13 @@
 package org.lflang.generator.uc
 
+import java.util.*
+import kotlin.collections.HashSet
 import org.lflang.*
 import org.lflang.generator.PrependOperator
 import org.lflang.generator.orNever
 import org.lflang.generator.uc.UcInstanceGenerator.Companion.isAFederate
 import org.lflang.generator.uc.UcReactorGenerator.Companion.codeType
 import org.lflang.lf.*
-import java.util.*
-import kotlin.collections.ArrayDeque
-import kotlin.collections.HashSet
 
 /**
  * This generator creates code for configuring the connections between reactors. This is perhaps the
@@ -494,7 +493,6 @@ class UcConnectionGenerator(
           .distinctBy { it.networkChannel.type }
           .joinWithLn { it.networkChannel.src.iface.includeHeaders }
 
-
   // Finds the longest path through the federation. Performs
   // two breadt-first-searches looking for the longest path.
   // see: https://www.geeksforgeeks.org/longest-path-undirected-tree/
@@ -503,14 +501,14 @@ class UcConnectionGenerator(
 
     // Return the furthest node and its distance from u
     fun breadthFirstSearch(u: Int, graph: Graph): Pair<Int, Int> {
-      val visited = allFederates.map{false}.toMutableList()
-      val distance = allFederates.map{-1}.toMutableList()
+      val visited = allFederates.map { false }.toMutableList()
+      val distance = allFederates.map { -1 }.toMutableList()
       distance[u] = 0
       visited[u] = true
       val queue: Queue<Int> = LinkedList<Int>()
       queue.add(u)
 
-      while(queue.isNotEmpty()) {
+      while (queue.isNotEmpty()) {
         val front = queue.poll()
         for (i in graph.adj[front]) {
           if (!visited[i]) {
@@ -522,7 +520,7 @@ class UcConnectionGenerator(
       }
       var maxDist = -1
       var nodeIdx = -1
-      for (i in 0..< graph.nodes) {
+      for (i in 0..<graph.nodes) {
         if (distance[i] > maxDist) {
           maxDist = distance[i]
           nodeIdx = i
@@ -531,7 +529,7 @@ class UcConnectionGenerator(
       return Pair(nodeIdx, maxDist)
     }
     // Build adjacency matrix
-    val adjacency = allFederates.map{ mutableSetOf<Int>() }
+    val adjacency = allFederates.map { mutableSetOf<Int>() }
     for (bundle in allFederatedConnectionBundles) {
       val src = allFederates.indexOf(bundle.src)
       val dest = allFederates.indexOf(bundle.dest)

diff --git a/src/federated.c b/src/federated.c
@@ -224,8 +224,8 @@ void FederatedConnectionBundle_msg_received_cb(FederatedConnectionBundle *self,
     FederatedConnectionBundle_handle_tagged_msg(self, msg);
     break;
   case FederateMessage_startup_coordination_tag:
-    self->parent->env->startup_coordinator->handle_message_callback(self->parent->env->startup_coordinator, &msg->message.startup_coordination,
-                                                                    self->index);
+    self->parent->env->startup_coordinator->handle_message_callback(self->parent->env->startup_coordinator,
+                                                                    &msg->message.startup_coordination, self->index);
     break;
   default:
     LF_ERR(FED, "Unknown message type %d", msg->which_message);

diff --git a/src/schedulers/dynamic/scheduler.c b/src/schedulers/dynamic/scheduler.c
@@ -267,7 +267,7 @@ void Scheduler_set_and_schedule_start_tag(Scheduler *untyped_self, instant_t sta
   tag_t start_tag = {.time = start_time, .microstep = 0};
   untyped_self->start_time = start_time;
   self->stop_tag = lf_delay_tag(start_tag, untyped_self->duration);
-  
+
   // Schedule the initial events
   Scheduler_schedule_startups(untyped_self, start_tag);
   Scheduler_schedule_timers(untyped_self, env->main, start_tag);

diff --git a/test/lf/src/FederatedBank.lf b/test/lf/src/FederatedBank.lf
@@ -1,6 +1,5 @@
 target uC {
   platform: Native,
-  logging: Debug
 }
 
 

diff --git a/test/lf/src/FederatedConnection.lf b/test/lf/src/FederatedConnection.lf
@@ -1,6 +1,5 @@
 target uC {
   platform: Native,
-  logging: Debug
 }
 
 reactor Src(id: int = 0) {

diff --git a/test/lf/src/FederatedUnconnected2.lf b/test/lf/src/FederatedUnconnected2.lf
@@ -1,14 +1,13 @@
 target uC {
   platform: Native,
-  timeout: 1sec,
-  logging: Debug
 }
 
 reactor Src(id: int = 0) {
   output out: int
   reaction(startup) -> out{=
     printf("Hello from Src!\n");
     lf_set(out, self->id);
+    env->request_shutdown(env);
   =}
 }
 

diff --git a/test/platform/riot/coap_channel_federated_test/receiver/main.c b/test/platform/riot/coap_channel_federated_test/receiver/main.c
@@ -73,12 +73,16 @@ LF_FEDERATED_CONNECTION_BUNDLE_CTOR_SIGNATURE(Receiver, Sender) {
   LF_INITIALIZE_FEDERATED_INPUT_CONNECTION(Receiver, in, deserialize_msg_t);
 }
 
+LF_DEFINE_STARTUP_COORDINATOR_STRUCT(Federate, 1);
+LF_DEFINE_STARTUP_COORDINATOR_CTOR(Federate, 1, 1);
+
 typedef struct {
   Reactor super;
   LF_CHILD_REACTOR_INSTANCE(Receiver, receiver, 1);
   LF_FEDERATED_CONNECTION_BUNDLE_INSTANCE(Receiver, Sender);
   LF_FEDERATE_BOOKKEEPING_INSTANCES(1);
   LF_CHILD_INPUT_SOURCES(receiver, in, 1, 1, 0);
+  FederateStartupCoordinator startup_coordinator;
 } MainRecv;
 
 LF_REACTOR_CTOR_SIGNATURE(MainRecv) {
@@ -88,6 +92,7 @@ LF_REACTOR_CTOR_SIGNATURE(MainRecv) {
   LF_INITIALIZE_CHILD_REACTOR_WITH_PARAMETERS(Receiver, receiver, 1, _receiver_in_args[i]);
   LF_INITIALIZE_FEDERATED_CONNECTION_BUNDLE(Receiver, Sender);
   lf_connect_federated_input(&self->Receiver_Sender_bundle.inputs[0]->super, &self->receiver->in[0].super);
+  LF_INITIALIZE_STARTUP_COORDINATOR(Federate);
 }
 
 LF_ENTRY_POINT_FEDERATED(MainRecv, SEC(1), true, 1, false)

diff --git a/test/platform/riot/coap_channel_federated_test/sender/main.c b/test/platform/riot/coap_channel_federated_test/sender/main.c
@@ -73,6 +73,9 @@ LF_FEDERATED_CONNECTION_BUNDLE_CTOR_SIGNATURE(Sender, Receiver) {
   LF_INITIALIZE_FEDERATED_OUTPUT_CONNECTION(Sender, out, serialize_msg_t);
 }
 
+LF_DEFINE_STARTUP_COORDINATOR_STRUCT(Federate, 1);
+LF_DEFINE_STARTUP_COORDINATOR_CTOR(Federate, 1, 1);
+
 // Reactor main
 typedef struct {
   Reactor super;
@@ -82,6 +85,7 @@ typedef struct {
   LF_CHILD_OUTPUT_CONNECTIONS(sender, out, 1, 1, 1);
   LF_CHILD_OUTPUT_EFFECTS(sender, out, 1, 1, 0);
   LF_CHILD_OUTPUT_OBSERVERS(sender, out, 1, 1, 0);
+  FederateStartupCoordinator startup_coordinator;
 } MainSender;
 
 LF_REACTOR_CTOR_SIGNATURE(MainSender) {
@@ -90,6 +94,7 @@ LF_REACTOR_CTOR_SIGNATURE(MainSender) {
   LF_DEFINE_CHILD_OUTPUT_ARGS(sender, out, 1, 1);
   LF_INITIALIZE_CHILD_REACTOR_WITH_PARAMETERS(Sender, sender, 1, _sender_out_args[i]);
   LF_INITIALIZE_FEDERATED_CONNECTION_BUNDLE(Sender, Receiver);
+  LF_INITIALIZE_STARTUP_COORDINATOR(Federate);
   lf_connect_federated_output((Connection *)self->Sender_Receiver_bundle.outputs[0], (Port *)self->sender->out);
 }
 

diff --git a/test/platform/riot/coap_channel_test/main.c b/test/platform/riot/coap_channel_test/main.c
@@ -27,7 +27,7 @@ bool client_callback_called = false;
 
 void setUp(void) {
   /* init environment */
-  Environment_ctor(&env, NULL, FOREVER, false, true, false, net_bundles, 1, 2, &startup_coordinator);
+  Environment_ctor(&env, NULL, FOREVER, false, true, false, net_bundles, 1, &startup_coordinator);
 
   /* init channel */
   CoapUdpIpChannel_ctor(&_coap_channel, REMOTE_ADDRESS, REMOTE_PROTOCOL_FAMILY);

diff --git a/test/platform/riot/uart_channel_test/main.c b/test/platform/riot/uart_channel_test/main.c
@@ -34,7 +34,7 @@ void receive_callback(FederatedConnectionBundle *conn, const FederateMessage *me
 }
 
 int main(void) {
-  Environment_ctor(&env, NULL, FOREVER, false, false, false, NULL, 0,0, NULL);
+  Environment_ctor(&env, NULL, FOREVER, false, false, false, NULL, 0, NULL);
   _lf_environment = &env;
 
   UartPolledChannel_ctor(&channel_1, 0, 9600, UC_UART_DATA_BITS_8, UC_UART_PARITY_EVEN, UC_UART_STOP_BITS_2);

diff --git a/test/unit/action_lib.h b/test/unit/action_lib.h
@@ -53,8 +53,9 @@ Environment env;
 Environment *_lf_environment = &env;
 
 void action_lib_start(interval_t duration) {
-  Environment_ctor(&env, (Reactor *)&my_reactor, duration, false, false, false, NULL, 0, 0, NULL);
+  Environment_ctor(&env, (Reactor *)&my_reactor, duration, false, false, false, NULL, 0, NULL);
   ActionLib_ctor(&my_reactor, NULL, &env);
+  env.assemble(&env);
   env.start(&env);
   Environment_free(&env);
 }

diff --git a/test/unit/deadline_test.c b/test/unit/deadline_test.c
@@ -48,7 +48,7 @@ Environment env;
 Environment* _lf_environment = &env;
 
 void test_simple() {
-  Environment_ctor(&env, (Reactor *)&my_reactor, MSEC(100), false, false, false, NULL, 0, 0, NULL);
+  Environment_ctor(&env, (Reactor *)&my_reactor, MSEC(100), false, false, false, NULL, 0, NULL);
   TimerTest_ctor(&my_reactor, NULL, &env);
   env.assemble(&env);
   env.start(&env);