handling joining time announcement

Author: tanneberger

src/federated.c

@@ -139,8 +139,7 @@ void FederatedInputConnection_ctor(FederatedInputConnection *self, Reactor *pare
   self->max_wait = max_wait;
 }
 
-// Callback registered with the NetworkChannel. Is called asynchronously when there is a
-// a TaggedMessage available.
+// Callback registered with the NetworkChannel. Is called asynchronously when there is a TaggedMessage available.
 void FederatedConnectionBundle_handle_tagged_msg(FederatedConnectionBundle *self, const FederateMessage *_msg) {
   const TaggedMessage *msg = &_msg->message.tagged_message;
   LF_DEBUG(FED, "Callback on FedConnBundle %p for message of size=%u with tag:" PRINTF_TAG, self, msg->payload.size,
@@ -222,16 +221,16 @@ void FederatedConnectionBundle_msg_received_cb(FederatedConnectionBundle *self,
   FederatedEnvironment *env_fed = (FederatedEnvironment *)self->parent->env;
   switch (msg->which_message) {
   case FederateMessage_tagged_message_tag:
-    LF_DEBUG(FED, "Handeling tagged message");
+    LF_DEBUG(FED, "Handling tagged message");
     FederatedConnectionBundle_handle_tagged_msg(self, msg);
     break;
   case FederateMessage_startup_coordination_tag:
-    LF_DEBUG(FED, "Handeling start up message");
+    LF_DEBUG(FED, "Handling start up message");
     env_fed->startup_coordinator->handle_message_callback(env_fed->startup_coordinator,
                                                           &msg->message.startup_coordination, self->index);
     break;
   case FederateMessage_clock_sync_msg_tag:
-    LF_DEBUG(FED, "Handeling clock sync message");
+    LF_DEBUG(FED, "Handling clock sync message");
     if (env_fed->do_clock_sync) {
       env_fed->clock_sync->handle_message_callback(env_fed->clock_sync, &msg->message.clock_sync_msg, self->index);
     } else {

src/startup_coordinator.c

@@ -456,6 +456,25 @@ static void StartupCoordinator_handle_start_time_response(StartupCoordinator *se
   }
 }
 
+static void StartupCoordinator_handle_join_time_announcement(const StartupCoordinator *self,
+                                                             const StartupEvent *payload) {
+  if (payload->neighbor_index != NEIGHBOR_INDEX_SELF) {
+
+    const FederatedEnvironment *env = (FederatedEnvironment *)self->env;
+    for (size_t i = 0; i < env->net_bundles_size; i++) {
+      if (env->net_bundles[i]->index == (size_t)payload->neighbor_index) {
+
+        // we found the correct connection bundle to this federate now we set last known tag to the joining time.
+        const FederatedConnectionBundle *bundle = env->net_bundles[i];
+        for (size_t j = 0; j < bundle->inputs_size; j++) {
+          tag_t joining_time = {.time = payload->msg.message.joining_time_announcement.joining_time, .microstep = 0};
+          bundle->inputs[i]->last_known_tag = joining_time;
+        }
+      }
+    }
+  }
+}
+
 /** Invoked by scheduler when handling any system event destined for StartupCoordinator. */
 static void StartupCoordinator_handle_system_event(SystemEventHandler *_self, SystemEvent *event) {
   StartupCoordinator *self = (StartupCoordinator *)_self;
@@ -487,8 +506,8 @@ static void StartupCoordinator_handle_system_event(SystemEventHandler *_self, Sy
     break;
 
   case StartupCoordination_joining_time_announcement_tag:
-    LF_INFO(FED, "Handle: Announcement of Joining Tag");
-    // TODO: here we then need to set the last message tag on all input ports connected to this transient federate
+    LF_INFO(FED, "Handle: Joining Time Announcement");
+    StartupCoordinator_handle_join_time_announcement(self, payload);
     break;
   }