PndMQTopix4Sink Class Reference

#include <PndMQTopix4Sink.h>

Inheritance diagram for PndMQTopix4Sink:

Public Member Functions
	PndMQTopix4Sink ()
virtual	~PndMQTopix4Sink ()
template<class Archive >
void	serialize (Archive &ar, const unsigned int version)

Protected Member Functions
virtual void	Run ()

Protected Attributes
bool	fHasBoostSerialization
std::vector< PndSdsDigiTopix4 >	fTopixData
PndMvdReadInToPix4TBData	fTopixDataReader

Friends
class	boost::serialization::access

Detailed Description

PndMQTopix4Sink.h

Since

2014-10-10

Author

A. Rybalchenko

Definition at line 28 of file PndMQTopix4Sink.h.

Constructor & Destructor Documentation

PndMQTopix4Sink::PndMQTopix4Sink

(

)

Definition at line 32 of file PndMQTopix4Sink.cxx.

References fHasBoostSerialization.

                                 : fHasBoostSerialization(false)
{
        //gSystem->ResetSignal(kSigInterrupt);
        //gSystem->ResetSignal(kSigTermination);

        using namespace baseMQ::tools::resolve;
        // coverity[pointless_expression]: suppress coverity warnings on apparant if(const).
        if (has_BoostSerialization<PndSdsDigiTopix4, void(boost::archive::binary_iarchive&, const unsigned int)>::value == 1)
                fHasBoostSerialization = true;
}

PndMQTopix4Sink::~PndMQTopix4Sink ( )

virtual

Definition at line 99 of file PndMQTopix4Sink.cxx.

{
}

Member Function Documentation

void PndMQTopix4Sink::Run ( )

protectedvirtual

Definition at line 48 of file PndMQTopix4Sink.cxx.

References fHasBoostSerialization, and fTopixData.

{
        LOG(INFO) << "Boost Serialization "<< fHasBoostSerialization;
        if (fHasBoostSerialization){
                FairMQChannel& dataInChannel = fChannels.at("data-in").at(0);
                int receivedMsgs = 0;

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

                        if (dataInChannel.Receive(msg) > 0)
                        {
                                LOG(INFO) << "Received Message: ";
                                LOG(INFO) << receivedMsgs++;
                                LOG(INFO) << msg->GetSize();

                                string msgStr(static_cast<char*>(msg->GetData()), msg->GetSize());
                                istringstream ibuffer(msgStr);

                                boost::archive::binary_iarchive InputArchive(ibuffer);

                                try {
                                        InputArchive >> fTopixData;
                                }
                                catch (boost::archive::archive_exception& e)
                                {
                                        LOG(ERROR) << e.what();
                                }

                                LOG(INFO) << "TopixData: " << fTopixData.size();

                                if (fTopixData.size() > 0){
        //              ostringstream obuffer;
        //              boost::archive::binary_oarchive OutputArchive(obuffer);
        //              OutputArchive << frames.front();
        //              int outputSize = obuffer.str().length();
        //              unique_ptr<FairMQMessage> msg2(fTransportFactory->CreateMessage(const_cast<char*>(obuffer.str().c_str()), outputSize, CustomCleanup, &obuffer));
        //              fChannels.at("data-out").at(0).Send(msg);
                                        LOG(INFO) << "Data: " << fTopixData.size() << " " << fTopixData.front() <<  std::endl;
                                }
                                delete(msg);


                                if (fTopixData.size() > 0)
                                        fTopixData.clear();
                        }
                }
        }
}

template<class Archive >

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

inline

Definition at line 37 of file PndMQTopix4Sink.h.

References fTopixData.

        {
                ar& fTopixData;
        }

Friends And Related Function Documentation

friend class boost::serialization::access

friend

Definition at line 46 of file PndMQTopix4Sink.h.

Member Data Documentation

bool PndMQTopix4Sink::fHasBoostSerialization

protected

Definition at line 47 of file PndMQTopix4Sink.h.

Referenced by PndMQTopix4Sink(), and Run().

std::vector<PndSdsDigiTopix4> PndMQTopix4Sink::fTopixData

protected

Definition at line 50 of file PndMQTopix4Sink.h.

Referenced by Run(), and serialize().

PndMvdReadInToPix4TBData PndMQTopix4Sink::fTopixDataReader

protected

Definition at line 52 of file PndMQTopix4Sink.h.

---

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

• PndMQTopix4Sink.h
• PndMQTopix4Sink.cxx