Fix a trace point for DNET

lf-lang · Apr 23, 2024 · 4ebd09e · 4ebd09e
1 parent 1c2777d
commit 4ebd09e
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/core/federated/RTI/rti_remote.c b/core/federated/RTI/rti_remote.c
@@ -273,6 +273,15 @@ void notify_provisional_tag_advance_grant(scheduling_node_t* e, tag_t tag) {
 }
 
 void send_downstream_next_event_tag(scheduling_node_t* e, tag_t tag) {
+  if (e->state == NOT_CONNECTED) {
+    return;
+  }
+  // Need to make sure that the destination federate's thread has already
+  // sent the starting MSG_TYPE_TIMESTAMP message.
+  while (e->state == PENDING) {
+    // Need to wait here.
+    lf_cond_wait(&sent_start_time);
+  }
   size_t message_length = 1 + sizeof(int64_t) + sizeof(uint32_t);
   unsigned char buffer[message_length];
   buffer[0] = MSG_TYPE_DOWNSTREAM_NEXT_EVENT_TAG;

diff --git a/util/tracing/trace_util.c b/util/tracing/trace_util.c
@@ -96,6 +96,7 @@ const char* trace_event_names[] = {
     "Sending P2P_MSG",
     "Sending ADR_AD",
     "Sending ADR_QR",
+    "Sending DNET",
     // Receiving messages
     "Receiving ACK",
     "Receiving FAILED",
@@ -118,6 +119,7 @@ const char* trace_event_names[] = {
     "Receiving P2P_MSG",
     "Receiving ADR_AD",
     "Receiving ADR_QR",
+    "Receiving DNET",
     "Receiving UNIDENTIFIED",
 };