PndMQFileSink Class Reference

#include <PndMQFileSink.h>

Inheritance diagram for PndMQFileSink:

Public Member Functions
	PndMQFileSink ()
virtual	~PndMQFileSink ()
virtual void	InitOutputFile (TString defaultId="100")
template<class Archive >
void	serialize (Archive &ar, const unsigned int version)

Protected Member Functions
virtual void	Run ()

Private Attributes
TFile *	fOutFile
TTree *	fTree
TClonesArray *	fOutput
vector< PndSdsDigiTopix4 >	fHitVector
bool	fHasBoostSerialization

Friends
class	boost::serialization::access

Detailed Description

Definition at line 53 of file PndMQFileSink.h.

Constructor & Destructor Documentation

PndMQFileSink::PndMQFileSink ( )

inline

Definition at line 56 of file PndMQFileSink.h.

        : fOutFile(NULL)
        , fTree(NULL)
        , fOutput(NULL)
        , fHitVector()
        , fHasBoostSerialization(false)
    {
        gSystem->ResetSignal(kSigInterrupt);
        gSystem->ResetSignal(kSigTermination);

        // Check if boost serialization is available if it is chosen
        using namespace baseMQ::tools::resolve;
        // coverity[pointless_expression]: suppress coverity warnings on apparant if(const).
        if (is_same<boost::archive::binary_iarchive, boost::archive::binary_iarchive>::value || is_same<boost::archive::binary_iarchive, boost::archive::text_iarchive>::value)
        {
            if (has_BoostSerialization<PndSdsDigiTopix4, void(boost::archive::binary_iarchive&, const unsigned int)>::value == 1)
            {
                fHasBoostSerialization = true;
            }
        }
    }

virtual PndMQFileSink::~PndMQFileSink ( )

inlinevirtual

Definition at line 78 of file PndMQFileSink.h.

References fOutFile.

    {
        fTree->Write();
        fOutFile->Close();
        if (fHitVector.size() > 0)
        {
            fHitVector.clear();
        }
    }

Member Function Documentation

virtual void PndMQFileSink::InitOutputFile ( TString  defaultId = "100" )

inlinevirtual

Definition at line 88 of file PndMQFileSink.h.

References fOutFile.

Referenced by main().

    {
        fOutput = new TClonesArray("PndSdsDigiTopix4");

        fOutFile = new TFile("Filesink1.root", "recreate");
        fTree = new TTree("MQOut", "Test output");
        fTree->Branch("Output", "TClonesArray", &fOutput, 64000, 99);
    }

void PndMQFileSink::Run ( )

protectedvirtual

Definition at line 11 of file PndMQFileSink.cxx.

References fHasBoostSerialization, fHitVector, fOutput, fTree, and i.

{
    if (fHasBoostSerialization)
    {
        int receivedMsgs = 0;

        // store the channel references to avoid traversing the map on every loop iteration
        FairMQChannel& dataInChannel = fChannels.at("data-in").at(0);

        while (CheckCurrentState(RUNNING))
        {
            FairMQMessage* msg = fTransportFactory->CreateMessage();

            if (dataInChannel.Receive(msg) > 0)
            {
                receivedMsgs++;
                string msgStr(static_cast<char*>(msg->GetData()), msg->GetSize());
                istringstream ibuffer(msgStr);
                boost::archive::binary_iarchive InputArchive(ibuffer);
                LOG(INFO) << "Received Message: " << receivedMsgs;
                try
                {
                    InputArchive >> fHitVector;
                }
                catch (boost::archive::archive_exception& e)
                {
                    LOG(ERROR) << e.what();
                }

                int numInput = fHitVector.size();
                fOutput->Delete();

                for (Int_t i = 0; i < numInput; ++i)
                {
                    new ((*fOutput)[i]) PndSdsDigiTopix4(fHitVector.at(i));
 //                   LOG(INFO) << "Data: " << i << " " << fHitVector.at(i).GetTimeStamp();
                }

                if (fOutput->IsEmpty())
                {
                    LOG(ERROR) << "PndMQFileSink::Run(): No Output array!";
                }

                fTree->Fill();
            }

            delete msg;

            if (fHitVector.size() > 0)
            {
                fHitVector.clear();
            }
        }

        LOG(INFO) << "I've received " << receivedMsgs << " messages!";
    }
    else
    {
        LOG(ERROR) << " Boost Serialization not ok";
    }
}

template<class Archive >

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

inline

Definition at line 98 of file PndMQFileSink.h.

    {
        ar& fHitVector;
    }

Friends And Related Function Documentation

friend class boost::serialization::access

friend

Definition at line 112 of file PndMQFileSink.h.

Member Data Documentation

bool PndMQFileSink::fHasBoostSerialization

private

Definition at line 114 of file PndMQFileSink.h.

Referenced by Run().

vector<PndSdsDigiTopix4> PndMQFileSink::fHitVector

private

Definition at line 113 of file PndMQFileSink.h.

Referenced by Run().

TFile* PndMQFileSink::fOutFile

private

Definition at line 107 of file PndMQFileSink.h.

TClonesArray* PndMQFileSink::fOutput

private

Definition at line 109 of file PndMQFileSink.h.

Referenced by Run().

TTree* PndMQFileSink::fTree

private

Definition at line 108 of file PndMQFileSink.h.

Referenced by Run().

---

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

• PndMQFileSink.h
• PndMQFileSink.cxx