PndMvdMQFileSampler Class Reference

#include <PndMvdMQFileSampler.h>

Inheritance diagram for PndMvdMQFileSampler:

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

Public Member Functions
	PndMvdMQFileSampler ()
virtual	~PndMvdMQFileSampler ()
void	AddInputFileName (std::string tempString)
void	AddInputChannelBranchName (std::pair< std::string, std::string > tempString)
void	SetMaxIndex (int64_t tempInt)
	PndMvdMQFileSampler ()
virtual	~PndMvdMQFileSampler ()
void	AddInputFileName (std::string tempString)
void	AddInputBranchName (std::string tempString)
void	SetMaxIndex (int64_t tempInt)

Protected Member Functions
virtual void	Run ()
virtual void	InitTask ()
virtual void	Run ()
virtual void	InitTask ()

Private Attributes
FairRunAna *	fRunAna
FairFileSource *	fSource
std::multimap< std::string, TObject * >	fInputObjects
std::map< std::string, TObject * >	fInputBranches
TObject *	fEventHeaderPointer
std::set< std::string >	fPorts
int	fNObjects
int64_t	fMaxIndex
std::vector< std::pair < std::string, std::string > >	fBranchNames
std::vector< std::string >	fFileNames
TObject *	fInputObjects [100]
std::vector< std::string >	fBranchNames

Detailed Description

FairMQEx9Sampler.h

Since

2016-03-08

Author

R. Karabowicz

Definition at line 27 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

Member Enumeration Documentation

anonymous enum

Enumerator
InputFileName
Last

Definition at line 30 of file MvdOfflineTBAnalysis_Topix4/MQ/PndMvdMQFileSampler.h.

    {
        InputFileName = FairMQDevice::Last,
        Last
    };

anonymous enum

Enumerator
InputFileName
Last

Definition at line 30 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

    {
        InputFileName = FairMQDevice::Last,
        Last
    };

Constructor & Destructor Documentation

PndMvdMQFileSampler::PndMvdMQFileSampler

(

)

Definition at line 28 of file MvdMQ/src/devices/PndMvdMQFileSampler.cxx.

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

PndMvdMQFileSampler::~PndMvdMQFileSampler ( )

virtual

Definition at line 108 of file MvdMQ/src/devices/PndMvdMQFileSampler.cxx.

{
}

PndMvdMQFileSampler::PndMvdMQFileSampler

(

)

virtual PndMvdMQFileSampler::~PndMvdMQFileSampler ( )

virtual

Member Function Documentation

void PndMvdMQFileSampler::AddInputBranchName ( std::string  tempString )

inline

Definition at line 40 of file MvdOfflineTBAnalysis_Topix4/MQ/PndMvdMQFileSampler.h.

References fBranchNames.

Referenced by main().

{ fBranchNames.push_back(tempString); }

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

inline

Definition at line 40 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

References fBranchNames, and fPorts.

Referenced by main().

                                                                             {
        fBranchNames.push_back(tempString);
        fPorts.insert(tempString.first);
    }

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

inline

Definition at line 39 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

References fFileNames.

Referenced by main().

{ fFileNames  .push_back(tempString);}

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

inline

Definition at line 39 of file MvdOfflineTBAnalysis_Topix4/MQ/PndMvdMQFileSampler.h.

References fFileNames.

{ fFileNames  .push_back(tempString); }

virtual void PndMvdMQFileSampler::InitTask ( )

protectedvirtual

void PndMvdMQFileSampler::InitTask ( )

protectedvirtual

Definition at line 40 of file MvdMQ/src/devices/PndMvdMQFileSampler.cxx.

References fBranchNames, fFileNames, fInputBranches, fInputObjects, fMaxIndex, fNObjects, fRunAna, and fSource.

{
  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:";
  for ( unsigned int ibrn = 0 ; ibrn < fBranchNames.size() ; ibrn++ ) {
    LOG(INFO) << " requesting branch \"" << fBranchNames[ibrn].second << "\"";
    int branchStat = fSource->ActivateObject((TObject**)&fInputBranches[fBranchNames[ibrn].second],fBranchNames[ibrn].second.c_str()); // should check the status...
    LOG(INFO) << "BranchStat: " << branchStat;
    if ( fInputBranches[fBranchNames[ibrn].second] ) {
      fInputObjects.insert(std::pair<std::string, TObject*>(fBranchNames[ibrn].first, fInputBranches[fBranchNames[ibrn].second]));
      LOG(INFO) << "Activated object \"" << fInputBranches[fBranchNames[ibrn].second] << "\" 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.";
}

virtual void PndMvdMQFileSampler::Run ( )

protectedvirtual

void PndMvdMQFileSampler::Run ( )

protectedvirtual

Definition at line 71 of file MvdMQ/src/devices/PndMvdMQFileSampler.cxx.

References fInputObjects, fMaxIndex, fPorts, free_tmessage2(), and fSource.

                              {
        int eventCounter = 0;

        // Check if we are still in the RUNNING state.
        while (CheckCurrentState(RUNNING)) {
                if (eventCounter == fMaxIndex)
                        break;

                Int_t readEventReturn = fSource->ReadEvent(eventCounter);

                if (readEventReturn != 0)
                        break;

                int messageIter = 0;
                for (std::set<std::string>::iterator portIt = fPorts.begin(); portIt != fPorts.end(); portIt++){
                        FairMQParts parts;
                        TMessage* message[1000];
                        for (std::multimap<std::string, TObject*>::iterator dataIt = fInputObjects.lower_bound(*portIt); dataIt != fInputObjects.upper_bound(*portIt); ++dataIt){
                                TNamed* data = (TNamed*)(dataIt->second);
                                LOG(INFO) << *portIt << " : " << dataIt->second << " " << dataIt->second->ClassName() << " " << dataIt->second->GetName();
                                if ( strcmp(dataIt->second->ClassName(),"FairEventHeader") == 0 )
                                        LOG(INFO) << "RunNumber: " << ((FairEventHeader*)dataIt->second)->GetRunId();
                                message[messageIter] = new TMessage(kMESS_OBJECT);
                                message[messageIter]->WriteObject(dataIt->second);
                                parts.AddPart(NewMessage(message[messageIter]->Buffer(), message[messageIter]->BufferSize(), free_tmessage2, message[messageIter]));
                                messageIter++;
                        }
                        LOG(INFO) << "Send!";
                        Send(parts, *portIt);
                }

                eventCounter++;
        }

        LOG(INFO) << "Going out of RUNNING state.";
}

void PndMvdMQFileSampler::SetMaxIndex ( int64_t  tempInt )

inline

Definition at line 42 of file MvdOfflineTBAnalysis_Topix4/MQ/PndMvdMQFileSampler.h.

References fMaxIndex.

{fMaxIndex=tempInt;}

void PndMvdMQFileSampler::SetMaxIndex ( int64_t  tempInt )

inline

Definition at line 45 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

References fMaxIndex.

Referenced by main().

{fMaxIndex=tempInt;}

Member Data Documentation

std::vector<std::string> PndMvdMQFileSampler::fBranchNames

private

Definition at line 54 of file MvdOfflineTBAnalysis_Topix4/MQ/PndMvdMQFileSampler.h.

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

private

Definition at line 60 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

Referenced by AddInputBranchName(), AddInputChannelBranchName(), and InitTask().

TObject* PndMvdMQFileSampler::fEventHeaderPointer

private

Definition at line 56 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

std::vector< std::string > PndMvdMQFileSampler::fFileNames

private

Definition at line 61 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

Referenced by AddInputFileName(), and InitTask().

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

private

Definition at line 55 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

Referenced by InitTask().

TObject* PndMvdMQFileSampler::fInputObjects[100]

private

Definition at line 51 of file MvdOfflineTBAnalysis_Topix4/MQ/PndMvdMQFileSampler.h.

std::multimap<std::string, TObject*> PndMvdMQFileSampler::fInputObjects

private

Definition at line 54 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

Referenced by InitTask(), and Run().

int64_t PndMvdMQFileSampler::fMaxIndex

private

Definition at line 59 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

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

int PndMvdMQFileSampler::fNObjects

private

Definition at line 58 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

Referenced by InitTask().

std::set<std::string> PndMvdMQFileSampler::fPorts

private

Definition at line 57 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

Referenced by AddInputChannelBranchName(), and Run().

FairRunAna * PndMvdMQFileSampler::fRunAna

private

Definition at line 52 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

Referenced by InitTask().

FairFileSource * PndMvdMQFileSampler::fSource

private

Definition at line 53 of file MvdMQ/src/devices/PndMvdMQFileSampler.h.

Referenced by InitTask(), and Run().

---

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

• MvdMQ/src/devices/PndMvdMQFileSampler.h
• MvdOfflineTBAnalysis_Topix4/MQ/PndMvdMQFileSampler.h
• MvdMQ/src/devices/PndMvdMQFileSampler.cxx
• MvdOfflineTBAnalysis_Topix4/MQ/PndMvdMQFileSampler.cxx