PndMvdMQFileSamplerBursts Class Reference

#include <PndMvdMQFileSamplerBursts.h>

Inheritance diagram for PndMvdMQFileSamplerBursts:

Public Types
enum	{ InputFileName = FairMQDevice::Last, Last }

Public Member Functions
	PndMvdMQFileSamplerBursts ()
virtual	~PndMvdMQFileSamplerBursts ()
void	AddInputFileName (std::string tempString)
void	AddInputChannelBranchName (std::pair< std::string, std::string > tempString)
void	SetMaxIndex (int64_t tempInt)
template<class Archive >
void	serialize (Archive &ar, const unsigned int version)

Protected Member Functions
virtual void	Run ()
virtual void	InitTask ()
virtual void	InitBurstBuilder (std::string branchName)

Private Attributes
FairRunAna *	fRunAna
FairFileSource *	fSource
std::set< std::string >	fPorts
std::multimap< std::string, std::string >	fPortBranchNameMap
std::vector< std::pair < std::string, std::string > >	fBranchNames
std::map< std::string, std::vector< std::vector < FairTimeStamp * > > >	fOutputData
std::map< std::string, TObject * >	fInputBranches
std::map< std::string, PndBurstVectorBuilderBase * >	fBurstBuilder
std::vector< FairTimeStamp * >	fHitVector
FairEventHeader *	fEventHeader
int	fNObjects
int64_t	fMaxIndex
std::vector< std::string >	fFileNames

Friends
class	boost::serialization::access

Detailed Description

Definition at line 83 of file PndMvdMQFileSamplerBursts.h.

Member Enumeration Documentation

anonymous enum

Enumerator
InputFileName
Last

Definition at line 86 of file PndMvdMQFileSamplerBursts.h.

    {
        InputFileName = FairMQDevice::Last,
        Last
    };

Constructor & Destructor Documentation

PndMvdMQFileSamplerBursts::PndMvdMQFileSamplerBursts

(

)

Definition at line 44 of file PndMvdMQFileSamplerBursts.cxx.

  : FairMQDevice()
  , fRunAna(NULL)
  , fSource(NULL)
  , fOutputData()
  , fNObjects(0)
  , fMaxIndex(-1)
  , fBranchNames()
  , fFileNames()
  , fEventHeader(0)
{
}

PndMvdMQFileSamplerBursts::~PndMvdMQFileSamplerBursts ( )

virtual

Definition at line 57 of file PndMvdMQFileSamplerBursts.cxx.

References fBurstBuilder, fRunAna, and fSource.

{
        for (auto itr : fBurstBuilder)
                delete itr.second;
        delete fSource;
        delete fRunAna;
}

Member Function Documentation

void PndMvdMQFileSamplerBursts::AddInputChannelBranchName ( std::pair< std::string, std::string >  tempString )

inline

Definition at line 96 of file PndMvdMQFileSamplerBursts.h.

References fBranchNames, fPortBranchNameMap, and fPorts.

Referenced by main().

                                                                             {
        fPortBranchNameMap.insert(std::pair<std::string, std::string>(tempString.first, tempString.second));
        fBranchNames.push_back(tempString);
        fPorts.insert(tempString.first);
    }

void PndMvdMQFileSamplerBursts::AddInputFileName ( std::string  tempString )

inline

Definition at line 95 of file PndMvdMQFileSamplerBursts.h.

References fFileNames.

Referenced by main().

{ fFileNames.push_back(tempString);}

void PndMvdMQFileSamplerBursts::InitBurstBuilder ( std::string  branchName )

protectedvirtual

Definition at line 94 of file PndMvdMQFileSamplerBursts.cxx.

References fBurstBuilder.

Referenced by InitTask().

{
        PndBurstVectorBuilderBase* tmpBuilder = 0;
        if (branchName == "MVDPixelDigis")
                tmpBuilder = new PndBurstVectorBuilderT<PndSdsDigiPixel>;
        else if (branchName == "MVDStripDigis")
                tmpBuilder = new PndBurstVectorBuilderT<PndSdsDigiStrip>;
        else if (branchName == "STTHit")
                tmpBuilder = new PndBurstVectorBuilderT<PndSttHit>;
        else if (branchName == "MVDHitsStrip")
                        tmpBuilder = new PndBurstVectorBuilderT<PndSdsHit>;

        if (tmpBuilder != 0)
                fBurstBuilder[branchName] = tmpBuilder;
}

void PndMvdMQFileSamplerBursts::InitTask ( )

protectedvirtual

Definition at line 65 of file PndMvdMQFileSamplerBursts.cxx.

References fBranchNames, fEventHeader, fFileNames, fInputBranches, fMaxIndex, fNObjects, fRunAna, fSource, and InitBurstBuilder().

{
  fRunAna = new FairRunAna();
  if ( fFileNames.size() > 0 ) {
    fSource = new FairFileSource(fFileNames.at(0).c_str());
    for ( unsigned int ifile = 1 ; ifile < fFileNames.size() ; ifile++ ) 
      fSource->AddFile(fFileNames.at(ifile));
  }
  fSource->Init();
  LOG(INFO) << "Going to request " << fBranchNames.size() << "  branches:";

  fSource->ActivateObject((TObject**)&fEventHeader, "EventHeader.");

   for ( unsigned int ibrn = 0 ; ibrn < fBranchNames.size() ; ibrn++ ) {

    LOG(INFO) << " requesting branch \"" << fBranchNames[ibrn].second << "\"";
    std::string branchName = fBranchNames[ibrn].second;
        int branchStat = fSource->ActivateObject((TObject**)&fInputBranches[branchName], branchName.c_str()); // should check the status...
        LOG(INFO) << "BranchStat: " << branchStat;
    InitBurstBuilder(branchName);
    LOG(INFO) << "Activated object \"" << fInputBranches[branchName] << "\" with name \"" << fBranchNames[ibrn].second << " for channel " << fBranchNames[ibrn].first <<"/ (" << branchStat << ")";
    fNObjects++;
  }

  if ( fMaxIndex < 0 )
    fMaxIndex = fSource->CheckMaxEventNo();
  LOG(INFO) << "Input source has " << fMaxIndex << " events.";
}

void PndMvdMQFileSamplerBursts::Run ( )

protectedvirtual

Definition at line 126 of file PndMvdMQFileSamplerBursts.cxx.

References BurstHeader::fBranchName, fBurstBuilder, BurstHeader::fBurstID, BurstData::fData, fEventHeader, BurstData::fHeader, fInputBranches, fMaxIndex, fOutputData, fPortBranchNameMap, fPorts, free_string(), BurstHeader::fRunID, fSource, and if().

                                    {
        int eventCounter = 0;

        // Check if we are still in the RUNNING state.
//      boost::this_thread::sleep(boost::posix_time::milliseconds(100000));
        while (CheckCurrentState(RUNNING)) {
                if (eventCounter != fMaxIndex){

                        Int_t readEventReturn = fSource->ReadEvent(eventCounter);

                        if (readEventReturn != 0)
                                break;

//                      if (fEventHeader != 0)
//                              LOG(INFO) << "EventHeader: " << fEventHeader->GetRunId() << " " << fEventHeader->GetEventTime() << std::endl;

                        for (auto branchItr : fInputBranches){
                                if (branchItr.first.find(".") == std::string::npos){
                                        std::vector<std::vector< FairTimeStamp* > > data;
                                        TClonesArray* tmpArray = (TClonesArray*)branchItr.second;

                                        if (fBurstBuilder.count(branchItr.first) > 0){
                                                fOutputData[branchItr.first] = fBurstBuilder[branchItr.first]->ProcessData(tmpArray);
                //                              LOG(INFO) << branchItr.first << " has " << fOutputData[branchItr.first].size() << " bursts! ";
                                        }
                                }
                        }
                } else {
                        LOG(INFO) << "FinishRun";
                        for (auto branchItr : fInputBranches){
                                if (branchItr.first.find(".") == std::string::npos){
                                        if (fBurstBuilder.count(branchItr.first) > 0){
                                                fOutputData[branchItr.first] = fBurstBuilder[branchItr.first]->GetLastData();
                //                              LOG(INFO) << branchItr.first << " has " << fOutputData[branchItr.first].size() << " last bursts! ";
                //                              for (auto dataItr : fOutputData[branchItr.first]){
                //                                      LOG(INFO) << branchItr.first << " has data: " << dataItr.size();
                //                              }
                                        }
                                }
                        }
                }

                for (auto portIt = fPorts.begin(); portIt != fPorts.end(); portIt++){
                        for (auto branchIt = fPortBranchNameMap.lower_bound(*portIt); branchIt != fPortBranchNameMap.upper_bound(*portIt); ++branchIt){
//                              LOG(INFO) << branchIt->second << " burstSize " << fOutputData[branchIt->second].size();
                                for (auto dataIt = fOutputData[branchIt->second].begin(); dataIt != fOutputData[branchIt->second].end(); ++dataIt){
//                                      LOG(INFO) << branchIt->second << " dataSize " << dataIt->size();
                                        if (dataIt->size() > 0){
                                                BurstData bData;// = new BurstData;
                                                std::vector<std::vector<FairTimeStamp*> > dataVector;
                                                dataVector.push_back(*dataIt);
                                                bData.fData = dataVector;
                                                bData.fHeader.fBranchName = branchIt->second;
                                                bData.fHeader.fRunID = fEventHeader->GetRunId();
                                                bData.fHeader.fBurstID = fBurstBuilder[branchIt->second]->GetBurstId(dataVector[0][0]);
                                                std::ostringstream obuffer;
                                                boost::archive::binary_oarchive OutputArchive(obuffer);
                                                OutputArchive << bData;
                                                std::string* strMsg = new std::string(obuffer.str());
                                                unique_ptr<FairMQMessage> msg(NewMessage(const_cast<char*>(strMsg->c_str()), strMsg->length(), free_string, strMsg));
                                                LOG(INFO) << "Send message: " << bData.fHeader.fBranchName << " " << bData.fHeader.fBurstID << " size: " << msg->GetSize();
                                                //LOG(INFO) << obuffer.str();
                                                Send(msg, *portIt);
                                        }
                                }
                        }
                }
                if (eventCounter != fMaxIndex){
                        eventCounter++;
                }
                else
                        break;
        }
        LOG(INFO) << "Going out of RUNNING state.";
}

template<class Archive >

void PndMvdMQFileSamplerBursts::serialize ( Archive &  ar, const unsigned int  version  )

inline

Definition at line 105 of file PndMvdMQFileSamplerBursts.h.

References fHitVector.

        {
                ar & fHitVector;
        }

void PndMvdMQFileSamplerBursts::SetMaxIndex ( int64_t  tempInt )

inline

Definition at line 102 of file PndMvdMQFileSamplerBursts.h.

References fMaxIndex.

Referenced by main().

{fMaxIndex=tempInt;}

Friends And Related Function Documentation

friend class boost::serialization::access

friend

Definition at line 111 of file PndMvdMQFileSamplerBursts.h.

Member Data Documentation

std::vector<std::pair<std::string, std::string> > PndMvdMQFileSamplerBursts::fBranchNames

private

Definition at line 125 of file PndMvdMQFileSamplerBursts.h.

Referenced by AddInputChannelBranchName(), and InitTask().

std::map<std::string, PndBurstVectorBuilderBase*> PndMvdMQFileSamplerBursts::fBurstBuilder

private

Definition at line 128 of file PndMvdMQFileSamplerBursts.h.

Referenced by InitBurstBuilder(), Run(), and ~PndMvdMQFileSamplerBursts().

FairEventHeader* PndMvdMQFileSamplerBursts::fEventHeader

private

Definition at line 130 of file PndMvdMQFileSamplerBursts.h.

Referenced by InitTask(), and Run().

std::vector<std::string> PndMvdMQFileSamplerBursts::fFileNames

private

Definition at line 136 of file PndMvdMQFileSamplerBursts.h.

Referenced by AddInputFileName(), and InitTask().

std::vector<FairTimeStamp*> PndMvdMQFileSamplerBursts::fHitVector

private

Definition at line 129 of file PndMvdMQFileSamplerBursts.h.

Referenced by serialize().

std::map<std::string, TObject* > PndMvdMQFileSamplerBursts::fInputBranches

private

Definition at line 127 of file PndMvdMQFileSamplerBursts.h.

Referenced by InitTask(), and Run().

int64_t PndMvdMQFileSamplerBursts::fMaxIndex

private

Definition at line 134 of file PndMvdMQFileSamplerBursts.h.

Referenced by InitTask(), Run(), and SetMaxIndex().

int PndMvdMQFileSamplerBursts::fNObjects

private

Definition at line 133 of file PndMvdMQFileSamplerBursts.h.

Referenced by InitTask().

std::map<std::string, std::vector< std::vector<FairTimeStamp*> > > PndMvdMQFileSamplerBursts::fOutputData

private

Definition at line 126 of file PndMvdMQFileSamplerBursts.h.

Referenced by Run().

std::multimap<std::string, std::string> PndMvdMQFileSamplerBursts::fPortBranchNameMap

private

Definition at line 124 of file PndMvdMQFileSamplerBursts.h.

Referenced by AddInputChannelBranchName(), and Run().

std::set<std::string> PndMvdMQFileSamplerBursts::fPorts

private

Definition at line 123 of file PndMvdMQFileSamplerBursts.h.

Referenced by AddInputChannelBranchName(), and Run().

FairRunAna* PndMvdMQFileSamplerBursts::fRunAna

private

Definition at line 121 of file PndMvdMQFileSamplerBursts.h.

Referenced by InitTask(), and ~PndMvdMQFileSamplerBursts().

FairFileSource* PndMvdMQFileSamplerBursts::fSource

private

Definition at line 122 of file PndMvdMQFileSamplerBursts.h.

Referenced by InitTask(), Run(), and ~PndMvdMQFileSamplerBursts().

---

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

• PndMvdMQFileSamplerBursts.h
• PndMvdMQFileSamplerBursts.cxx