dune::HDF5RawInputDetail Class Reference

#include <HDF5RawInput.h>

Public Member Functions
	HDF5RawInputDetail (fhicl::ParameterSet const &ps, art::ProductRegistryHelper &rh, art::SourceHelper const &sh)
void	readFile (std::string const &filename, art::FileBlock *&fb)
bool	readNext (art::RunPrincipal const *const inR, art::SubRunPrincipal const *const inSR, art::RunPrincipal *&outR, art::SubRunPrincipal *&outSR, art::EventPrincipal *&outE)
void	closeCurrentFile ()

Private Attributes
std::unique_ptr< dune::HDF5Utils::HDFFileInfo >	hdf_file_
std::deque< std::string >	unprocessedEventList_
std::string	pretend_module_name
int	fLogLevel
art::SourceHelper const &	pmaker

Detailed Description

Definition at line 28 of file HDF5RawInput.h.

Constructor & Destructor Documentation

dune::HDF5RawInputDetail::HDF5RawInputDetail	(	fhicl::ParameterSet const &	ps,
		art::ProductRegistryHelper &	rh,
		art::SourceHelper const &	sh
	)

Definition at line 8 of file HDF5RawInput_source.cc.

  : pretend_module_name(ps.get<std::string>("raw_data_label", "daq")),
    fLogLevel(ps.get<int>("LogLevel", 0)),
    pmaker(sh) {
  rh.reconstitutes<raw::DUNEHDF5FileInfo, art::InEvent>(pretend_module_name); 
  rh.reconstitutes<raw::RDTimeStamp, art::InEvent>(pretend_module_name, "trigger");
}

Member Function Documentation

void dune::HDF5RawInputDetail::closeCurrentFile ( )

inline

Definition at line 42 of file HDF5RawInput.h.

                          {
    if (hdf_file_->filePtr)
      dune::HDF5Utils::closeFile(std::move(hdf_file_));
  };

void dune::HDF5RawInputDetail::readFile	(	std::string const &	filename,
		art::FileBlock *&	fb
	)

Definition at line 19 of file HDF5RawInput_source.cc.

                                                   {
  hdf_file_ = dune::HDF5Utils::openFile(filename);
  unprocessedEventList_
      = dune::HDF5Utils::getTopLevelGroupNames(hdf_file_);
  MF_LOG_INFO("HDF5")
      << "HDF5 opened HDF file with run number " <<
         hdf_file_->runNumber  << " and " <<
         unprocessedEventList_.size() << " events";
  for (const auto & e : unprocessedEventList_)
    MF_LOG_INFO("HDF5") << e;

  fb = new art::FileBlock(art::FileFormatVersion(1, "RawEvent2011"),
                          filename); 
}

bool dune::HDF5RawInputDetail::readNext	(	art::RunPrincipal const *const	inR,
		art::SubRunPrincipal const *const	inSR,
		art::RunPrincipal *&	outR,
		art::SubRunPrincipal *&	outSR,
		art::EventPrincipal *&	outE
	)

Definition at line 35 of file HDF5RawInput_source.cc.

{
  using namespace dune::HDF5Utils;
  
  // Establish default 'results'
  outR = 0;
  outSR = 0;
  outE = 0;

  if (unprocessedEventList_.empty()) {return false;}
  std::string nextEventGroupName = unprocessedEventList_.front();
  unprocessedEventList_.pop_front();

  size_t run_id = 999; //runNumber can be 0,
                      //but this seems like an issue
                      //with art

  //Accessing run number
  hid_t the_group = getGroupFromPath (hdf_file_->filePtr, nextEventGroupName);
  HeaderInfo header_info;
  std::string det_type = "TriggerRecordHeader";

  getHeaderInfo(the_group, det_type, header_info);
  if (fLogLevel > 0) {
    std::cout << "   Magic word: 0x" << std::hex << header_info.magicWord <<
                 std::dec << std::endl;
    std::cout << "   Version: " << std::dec << header_info.version <<
                 std::dec << std::endl;
    std::cout << "   Trig Num: " << std::dec << header_info.trigNum <<
                 std::dec << std::endl;
    std::cout << "   Trig Timestamp: " << std::dec <<
                 header_info.trigTimestamp << std::dec << std::endl;
    std::cout << "   No. of requested components:   " << std::dec <<
                 header_info.nReq << std::dec << std::endl;
    std::cout << "   Run Number: " << std::dec << header_info.runNum <<
                 std::endl;
    std::cout << "   Error bits: " << std::dec << header_info.errBits <<
                 std::endl;
    std::cout << "   Trigger type: " << std::dec << header_info.triggerType <<
                 std::endl;
  }
   MF_LOG_INFO("HDF5") << "header_info.trigTimestamp :" << header_info.trigTimestamp << std::endl;

   // trigTimeStamp is NOT time but Clock-tick since the epoch.
   uint64_t trigTimeStamp = header_info.trigTimestamp;
    
   uint64_t getTrigTime = formatTrigTimeStamp (trigTimeStamp);
   // std::cout << "getTrigTime :" << getTrigTime << std::endl;
  
   art::Timestamp artTrigStamp (getTrigTime);
   // std::cout << "artTrigStamp :" << artTrigStamp.value() << std::endl;

  run_id = header_info.runNum;
  std::unique_ptr<raw::RDTimeStamp> rd_timestamp(
    new raw::RDTimeStamp(header_info.trigTimestamp));

  // make new run if inR is 0 or if the run has changed
  if (inR == 0 || inR->run() != run_id) {
    outR = pmaker.makeRunPrincipal(run_id,artTrigStamp);
  }

  // make new subrun if inSR is 0 or if the subrun has changed
  art::SubRunID subrun_check(run_id, 1);
  if (inSR == 0 || subrun_check != inSR->subRunID()) {
    outSR = pmaker.makeSubRunPrincipal(run_id, 1, artTrigStamp);
  }

  //Where to get event number?
  //For now -- parse from input record
  std::string event_str = nextEventGroupName;
  std::string trig = "TriggerRecord";
  auto pos = event_str.begin() + event_str.find(trig);
  event_str.erase(pos, pos + trig.size());
  int event = std::stoi(event_str);
  outE = pmaker.makeEventPrincipal(run_id, 1, event, artTrigStamp);
  //std::cout << "Event Time Stamp :" << event.time() << std::endl;
 
  std::unique_ptr<raw::DUNEHDF5FileInfo> the_info(
      new raw::DUNEHDF5FileInfo(hdf_file_->fileName, hdf_file_->filePtr,
                           0, nextEventGroupName));

  put_product_in_principal(std::move(the_info), *outE, pretend_module_name,
                           "");
  put_product_in_principal(std::move(rd_timestamp), *outE, pretend_module_name,
                           "trigger");

  return true;
}

Member Data Documentation

int dune::HDF5RawInputDetail::fLogLevel

private

Definition at line 51 of file HDF5RawInput.h.

std::unique_ptr<dune::HDF5Utils::HDFFileInfo> dune::HDF5RawInputDetail::hdf_file_

private

Definition at line 45 of file HDF5RawInput.h.

art::SourceHelper const& dune::HDF5RawInputDetail::pmaker

private

Definition at line 52 of file HDF5RawInput.h.

std::string dune::HDF5RawInputDetail::pretend_module_name

private

Definition at line 50 of file HDF5RawInput.h.

std::deque<std::string> dune::HDF5RawInputDetail::unprocessedEventList_

private

Definition at line 49 of file HDF5RawInput.h.

---

The documentation for this class was generated from the following files:

• dunecore/dunecore/HDF5Utils/HDF5RawInput.h
• dunecore/dunecore/HDF5Utils/HDF5RawInput_source.cc