formatting

faasm · Oct 27, 2021 · b4e83f4 · b4e83f4
1 parent 59f969b
commit b4e83f4
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 11 deletions.
diff --git a/src/scheduler/Executor.cpp b/src/scheduler/Executor.cpp
@@ -11,8 +11,8 @@
 #include <faabric/util/macros.h>
 #include <faabric/util/memory.h>
 #include <faabric/util/queue.h>
-#include <faabric/util/tracing.h>
 #include <faabric/util/timing.h>
+#include <faabric/util/tracing.h>
 
 #define POOL_SHUTDOWN -1
 

diff --git a/src/scheduler/MpiWorld.cpp b/src/scheduler/MpiWorld.cpp
@@ -581,8 +581,10 @@ void MpiWorld::send(int sendRank,
     }
 
     // In non-release builds, track that we have sent this message
-    faabric::util::tracing::getCallRecords().addRecord(thisMsgId,
-        faabric::util::tracing::RecordType::MpiPerRankMessageCount, recvRank);
+    faabric::util::tracing::getCallRecords().addRecord(
+      thisMsgId,
+      faabric::util::tracing::RecordType::MpiPerRankMessageCount,
+      recvRank);
 }
 
 void MpiWorld::recv(int sendRank,

diff --git a/src/util/tracing.cpp b/src/util/tracing.cpp
@@ -6,8 +6,10 @@ void CallRecords::startRecording(const faabric::Message& msg)
 {
 #ifndef NDEBUG
     if (linkedMsg != nullptr && linkedMsg->id() != msg.id()) {
-        SPDLOG_ERROR("CallRecords already linked to a different message: (linked: {} != provided: {})",
-                     linkedMsg->id(), msg.id());
+        SPDLOG_ERROR("CallRecords already linked to a different message: "
+                     "(linked: {} != provided: {})",
+                     linkedMsg->id(),
+                     msg.id());
         throw std::runtime_error("CallRecords linked to a different message");
     } else if (linkedMsg == nullptr) {
         linkedMsg = std::make_shared<faabric::Message>(msg);
@@ -21,8 +23,10 @@ void CallRecords::stopRecording(faabric::Message& msg)
 {
 #ifndef NDEBUG
     if (linkedMsg == nullptr || linkedMsg->id() != msg.id()) {
-        SPDLOG_ERROR("CallRecords not linked to the right message: (linked: {} != provided: {})",
-                     linkedMsg->id(), msg.id());
+        SPDLOG_ERROR("CallRecords not linked to the right message: (linked: {} "
+                     "!= provided: {})",
+                     linkedMsg->id(),
+                     msg.id());
         throw std::runtime_error("CallRecords linked to a different message");
     }
 
@@ -72,14 +76,17 @@ void CallRecords::addRecord(int msgId, RecordType recordType, int idToIncrement)
 #ifndef NDEBUG
     // Check message id
     if (linkedMsg == nullptr || linkedMsg->id() != msgId) {
-        SPDLOG_ERROR("CallRecords not linked to the right message: (linked: {} != provided: {})",
-                     linkedMsg->id(), msgId);
+        SPDLOG_ERROR("CallRecords not linked to the right message: (linked: {} "
+                     "!= provided: {})",
+                     linkedMsg->id(),
+                     msgId);
         throw std::runtime_error("CallRecords linked to a different message");
     }
 
     // Add the record to the list of on going records if it is not there
     bool mustInit = false;
-    auto it = std::find(onGoingRecordings.begin(), onGoingRecordings.end(), recordType);
+    auto it =
+      std::find(onGoingRecordings.begin(), onGoingRecordings.end(), recordType);
     if (it == onGoingRecordings.end()) {
         onGoingRecordings.push_back(recordType);
         mustInit = true;
@@ -107,7 +114,6 @@ void CallRecords::addRecord(int msgId, RecordType recordType, int idToIncrement)
 #endif
 }
 
-
 CallRecords& getCallRecords()
 {
     static thread_local CallRecords callRecords;