Include in the JSON filename the hostname and pid of the workflow

Author: pnwkw

EventVisualisation/Workflow/include/EveWorkflow/FileProducer.h

@@ -34,12 +34,12 @@ class FileProducer
 
  public:
   explicit FileProducer(const std::string& path, int filesInFolder = 10,
-                        const std::string& name = "tracks{}.json");
+                        const std::string& name = "tracks_{hostname}_{pid}_{timestamp}.json");
 
   [[nodiscard]] std::string newFileName() const;
 };
 
 } // namespace event_visualisation
 } // namespace o2
 
-#endif //ALICE_O2_EVENTVISUALISATION_WORKFLOW_FILEPRODUCER_H
+#endif // ALICE_O2_EVENTVISUALISATION_WORKFLOW_FILEPRODUCER_H

EventVisualisation/Workflow/src/FileProducer.cxx

@@ -17,25 +17,21 @@
 #include "CommonUtils/FileSystemUtils.h"
 
 #include <deque>
-#include <iostream>
 #include <chrono>
-#include <cstdio>
 #include <filesystem>
 #include <algorithm>
+#include <climits>
+#include <fmt/core.h>
 
-using namespace std;
 using namespace o2::event_visualisation;
 
-using std::cout;
-using std::endl;
 using std::chrono::duration_cast;
 using std::chrono::milliseconds;
-using std::chrono::seconds;
 using std::chrono::system_clock;
 
 std::deque<std::string> FileProducer::load(const std::string& path)
 {
-  deque<string> result;
+  std::deque<std::string> result;
 
   for (const auto& entry : std::filesystem::directory_iterator(path)) {
     if (entry.path().extension() == ".json") {
@@ -55,15 +51,20 @@ FileProducer::FileProducer(const std::string& path, int filesInFolder, const std
 
 std::string FileProducer::newFileName() const
 {
-  string pholder = "{}";
-  string result = this->mName;
   auto millisec_since_epoch = duration_cast<milliseconds>(system_clock::now().time_since_epoch()).count();
-  string stamp = std::to_string(millisec_since_epoch);
-  result.replace(result.find(pholder), pholder.length(), stamp);
+
+  char hostname[_POSIX_HOST_NAME_MAX];
+  gethostname(hostname, _POSIX_HOST_NAME_MAX);
+
+  auto pid = getpid();
+
+  auto result = fmt::format(this->mName, fmt::arg("hostname", hostname), fmt::arg("pid", pid), fmt::arg("timestamp", millisec_since_epoch));
+
   auto files = this->load(this->mPath);
   std::sort(files.begin(), files.end());
+
   while (files.size() >= this->mFilesInFolder) {
-    string front = files.front();
+    auto front = files.front();
     files.pop_front();
     std::remove((this->mPath + "/" + front).c_str()); // delete file
   }