lib/simbricks/base: Send termination message in SimbricksBaseIfClose()

2ae1ca5d · Antoine Kaufmann · b4dcbc81 · 2ae1ca5d
Commit 2ae1ca5d authored Jun 18, 2022 by Antoine Kaufmann
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 2 deletions

lib/simbricks/base/if.c lib/simbricks/base/if.c +4 -2

No files found.
--- a/lib/simbricks/base/if.c
+++ b/lib/simbricks/base/if.c
@@ -809,8 +809,10 @@ void SimbricksBaseIfClose(struct SimbricksBaseIf *base_if)
  }

  if (base_if->conn_state == kConnOpen) {
-    /* send out sync with max time stamp so no one else is stuck */
-    while (SimbricksBaseIfOutSync(base_if, UINT64_MAX) != 0);
+    // send out termination message
+    volatile union SimbricksProtoBaseMsg *msg;
+    while ((msg = SimbricksBaseIfOutAlloc(base_if, UINT64_MAX)) == NULL);
+    SimbricksBaseIfOutSend(base_if, msg, SIMBRICKS_PROTO_MSG_TYPE_TERMINATE);
  }

  close(base_if->conn_fd);