Handle unconnected inputs and add test (#204)

* Handle unconnected inputs and add test

* Format

Author: erlingrj

src/schedulers/dynamic/scheduler.c

@@ -60,6 +60,11 @@ static lf_ret_t Scheduler_federated_acquire_tag(Scheduler *untyped_self, tag_t n
   instant_t additional_sleep = 0;
   for (size_t i = 0; i < env->net_bundles_size; i++) {
     FederatedConnectionBundle *bundle = env->net_bundles[i];
+
+    if (!bundle->net_channel->is_connected(bundle->net_channel)) {
+      continue;
+    }
+
     for (size_t j = 0; j < bundle->inputs_size; j++) {
       FederatedInputConnection *input = bundle->inputs[j];
       // Find the max safe-to-assume-absent value and go to sleep waiting for this.

test/lf/src/FederatedUnconnected.lf

@@ -0,0 +1,27 @@
+target uC {
+  platform: Native,
+  timeout: 1sec
+}
+
+
+reactor Dst {
+  input in: int
+  state check: bool = false
+  reaction(startup) {=
+    printf("Hello from Dst!\n");
+    self->check = true;
+  =}
+  reaction(in) {=
+    printf("Received %d from Src\n", in->value);
+    validate(in->value == 42);
+    env->request_shutdown(env);
+  =}
+
+  reaction(shutdown) {=
+    validate(self->check);
+  =}
+}
+
+federated reactor {
+  r2 = new Dst()
+}

test/lf/src/FederatedUnconnected2.lf

@@ -0,0 +1,42 @@
+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);
+  =}
+}
+
+reactor Dst {
+  input in: int
+  input in2: int
+  state check: bool = false
+  
+  reaction(in) {=
+    printf("Received %d from Src\n", in->value);
+    validate(in->value == 42);
+    self->check = true;
+    env->request_shutdown(env);
+  =}
+
+  reaction(startup) {=
+    printf("Hello from Dst!\n");
+  =}
+
+
+  reaction(shutdown) {=
+    validate(self->check);
+  =}
+
+}
+
+federated reactor {
+  r1 = new Src(id=42)
+  r2 = new Dst()
+  r1.out -> r2.in 
+}