cbmreco: Add child-id flag.

algo/base/Options.cxx

@@ -79,6 +79,7 @@ Options::Options(int argc, char** argv)
       "comma seperated list of reconstruction steps (upack, digitrigger, localreco, ...)")
     ("systems,s", po::value(&fDetectors)->multitoken()->default_value({Subsystem::STS, Subsystem::TOF, Subsystem::BMON, Subsystem::MUCH, Subsystem::RICH})->value_name("<detectors>"),
       "comma seperated list of detectors to process (sts, mvd, ...)")
+    ("child-id,c", po::value(&fChildId)->default_value("00")->value_name("<id>"), "online process id on node")
     ("num-ts,n", po::value(&fNumTimeslices)->default_value(-1)->value_name("<num>"),
       "Stop after <num> timeslices (-1 = all)")
     ("skip-ts", po::value(&fSkipTimeslices)->default_value(0)->value_name("<num>"),

algo/base/Options.h

@@ -35,6 +35,7 @@ namespace cbm::algo
     bool CollectKernelTimes() const { return fCollectKernelTimes; }
     int NumTimeslices() const { return fNumTimeslices; }
     int SkipTimeslices() const { return fSkipTimeslices; }
+    const std::string& ChildId() const { return fChildId; }
 
     const std::vector<Step>& Steps() const { return fRecoSteps; }
     bool HasStep(Step step) const { return std::find(fRecoSteps.begin(), fRecoSteps.end(), step) != fRecoSteps.end(); }
@@ -66,6 +67,7 @@ namespace cbm::algo
     std::vector<Step> fRecoSteps;
     std::vector<RecoData> fOutputTypes;
     std::vector<fles::Subsystem> fDetectors;
+    std::string fChildId = "00";
 
   private:  // serialization
     friend class boost::serialization::access;

algo/global/Reco.cxx

@@ -185,7 +185,7 @@ void Reco::QueueUnpackerMetrics(const fles::Timeslice& ts, const UnpackMonitorDa
 
   double totalExpansionFactor = static_cast<double>(nDigisTotal) / monitor.fNumBytes;
 
-  GetMonitor().QueueMetric("cbmreco", {{"hostname", fles::system::current_hostname()}},
+  GetMonitor().QueueMetric("cbmreco", {{"hostname", fles::system::current_hostname()}, {"child", Opts().ChildId()}},
                            {
                              {"unpackTimeTotal", monitor.fTimeUnpack},
                              {"unpackBytesInSts", monitor.fNumBytesInSts},
@@ -220,7 +220,7 @@ void Reco::QueueStsRecoMetrics(const sts::HitfinderMonitor& monitor)
 {
   if (!HasMonitor()) return;
 
-  GetMonitor().QueueMetric("cbmreco", {{"hostname", fles::system::current_hostname()}},
+  GetMonitor().QueueMetric("cbmreco", {{"hostname", fles::system::current_hostname()}, {"child", Opts().ChildId()}},
                            {
                              {"stsRecoTimeTotal", monitor.fTimeTotal},
                              {"stsRecoNumClusters", monitor.fNumClusterTotal},