Merge pull request #1892 from corrodis/LumiStream

Online work: Lumi stream

Author: oksuzian

DAQ/src/EventHeaderFromCFOFragment_module.cc

@@ -21,6 +21,7 @@
 
 // Offline
 #include "Offline/DataProducts/inc/EventWindowMarker.hh"
+#include "Offline/RecoDataProducts/inc/ProtonBunchTime.hh"
 
 // C++
 #include <iostream>
@@ -84,6 +85,7 @@ art::EventHeaderFromCFOFragment::EventHeaderFromCFOFragment(
   if(ewm_) {
     TLOG(TLVL_DEBUG + 2) << "Producing EventWindowMarker";
     produces<mu2e::EventWindowMarker>();
+    produces<mu2e::ProtonBunchTime>();
   }
   if(isSim_) TLOG(TLVL_DEBUG + 2) << "Assuming simulation inputs!";
 }
@@ -95,6 +97,7 @@ void art::EventHeaderFromCFOFragment::produce(Event& event) {
   // Collection of CaloHits for the event
   std::unique_ptr<mu2e::EventHeader>       evtHdr(new mu2e::EventHeader);
   std::unique_ptr<mu2e::EventWindowMarker> ewm((ewm_) ? new mu2e::EventWindowMarker : nullptr);
+  std::unique_ptr<mu2e::ProtonBunchTime>   pbt((ewm_) ? new mu2e::ProtonBunchTime   : nullptr);
   art::Handle<artdaq::Fragments>           cfoFragmentHandle;
 
   // Set values that are useful in simulations
@@ -106,7 +109,10 @@ void art::EventHeaderFromCFOFragment::produce(Event& event) {
   // Check for the CFO fragment list
   if(!event.getByLabel(cfoFragmentTag_, cfoFragmentHandle)) {
     event.put(std::move(evtHdr));
-    if(ewm_) event.put(std::move(ewm));
+    if(ewm_) {
+      event.put(std::move(ewm));
+      event.put(std::move(pbt));
+    }
     TLOG(TLVL_DEBUG + 1) << "No CFO fragments found";
     return;
   }
@@ -118,24 +124,30 @@ void art::EventHeaderFromCFOFragment::produce(Event& event) {
     const mu2e::CFOEventFragment   cfoFrag(frag);
     const CFOLib::CFO_Event        cfo       = cfoFrag.getData();
     const CFOLib::CFO_EventRecord& cfoRecord = cfo.GetEventRecord();
-    evtHdr->mode          = 0;//cfo.GetEventMode();
+    evtHdr->mode          = cfoRecord.event_mode; //cfo.GetEventMode();
     evtHdr->ewt           = static_cast<long unsigned int>(cfo.GetEventWindowTag().GetEventWindowTag().to_ullong());
     evtHdr->flags         = cfo.GetEventMode().isOnSpillFlagSet();
     evtHdr->eventDuration = cfoRecord.event_duration;
-    TLOG(TLVL_DEBUG + 20) << "mode = " << evtHdr->mode << " ewt  = "<< evtHdr->ewt << " flags = " << evtHdr->flags
+    TLOG(TLVL_DEBUG + 20) << "mode = " << evtHdr->mode << " (" << cfoRecord.event_mode << ")"
+			  << " ewt  = "<< evtHdr->ewt << " flags = " << int(evtHdr->flags)
                           << " onspill = " << evtHdr->isOnSpill() << " duration = " << evtHdr->eventDuration;
     if(ewm_) {
       constexpr double tick = 25.; // clock ticks -> ns
-      ewm->_spillType   = (evtHdr->isOnSpill()) ? mu2e::EventWindowMarker::SpillType::onspill : mu2e::EventWindowMarker::SpillType::offspill;
+      ewm->_spillType   = (cfo.GetEventMode().isOnSpillFlagSet()) ? mu2e::EventWindowMarker::SpillType::onspill : mu2e::EventWindowMarker::SpillType::offspill;
       ewm->_eventLength = tick * evtHdr->eventDuration;
+      pbt->pbtime_ = 0.f; // FIXME
+      pbt->pbterr_ = 1.f;
     }
 
   } else {
     TLOG(TLVL_DEBUG + 3) << "No CFO fragments found in the event";
   }
 
   event.put(std::move(evtHdr));
-  if(ewm_) event.put(std::move(ewm));
+  if(ewm_) {
+    event.put(std::move(ewm));
+    event.put(std::move(pbt));
+  }
 } // produce()
 
 // ======================================================================