PndMQTopix4ProcessorTask Class Reference

#include <PndMQTopix4ProcessorTask.h>

Inheritance diagram for PndMQTopix4ProcessorTask:

Public Member Functions
	PndMQTopix4ProcessorTask ()
virtual	~PndMQTopix4ProcessorTask ()
virtual InitStatus	Init ()
virtual void	Exec (Option_t *opt="0")
template<class Archive >
void	serialize (Archive &ar, const unsigned int version)

Private Attributes
std::vector< PndSdsDigiTopix4 >	fPndSdsDigiTopix4Vector
bool	fHasBoostSerialization
PndMvdReadInToPix4TBData	fTopixDataReader

Friends
class	boost::serialization::access

Detailed Description

PndMQTopix4Sink.h

Since

2014-10-10

Author

A. Rybalchenko

Definition at line 26 of file PndMQTopix4ProcessorTask.h.

Constructor & Destructor Documentation

PndMQTopix4ProcessorTask::PndMQTopix4ProcessorTask

(

)

Definition at line 30 of file PndMQTopix4ProcessorTask.cxx.

References fHasBoostSerialization.

                                                   : fHasBoostSerialization(false)
{
        using namespace baseMQ::tools::resolve;
        bool checkOutputClass = false;

        if (is_same<boost::archive::binary_oarchive, boost::archive::binary_oarchive>::value)
        {
                if (has_BoostSerialization<PndSdsDigiTopix4, void(boost::archive::binary_oarchive&, const unsigned int)>::value == 1)
                {
                        checkOutputClass = true;
                        fHasBoostSerialization = true;
                }
        }
        LOG(INFO) << "HasBoostSerialization: " << fHasBoostSerialization;
}

PndMQTopix4ProcessorTask::~PndMQTopix4ProcessorTask ( )

virtual

Definition at line 77 of file PndMQTopix4ProcessorTask.cxx.

{
}

Member Function Documentation

void PndMQTopix4ProcessorTask::Exec ( Option_t *  opt = "0" )

virtual

Definition at line 47 of file PndMQTopix4ProcessorTask.cxx.

References PndMvdReadInToPix4TBData::AnalyzeData(), fPndSdsDigiTopix4Vector, fTopixDataReader, PndTopix4::GetRawData(), TMrfData_8b::regdata, and TMrfData_8b::setNumWords().

{
        TMrfData_8b* message = new TMrfData_8b();
        message->setNumWords(fPayload->GetSize());
        memcpy(reinterpret_cast<u_int8_t*>(&message->regdata[0]),fPayload->GetData(), fPayload->GetSize());
//           LOG(INFO) << "Received message: \""
//                     << message->getNumWords() << " " << message->getNumBits()
//                     << "\"";
        std::vector<ULong64_t> rawArray;
        PndTopix4 topix;
        rawArray = topix.GetRawData(message);
        std::vector<std::vector<PndSdsDigiTopix4> > frames = fTopixDataReader.AnalyzeData(rawArray, 50);

        LOG(INFO) << "Frames.size " << frames.size();
        if (frames.size() > 0)
                LOG(INFO) << "Frames.front().size() " << frames.front().size();
        if (frames.size() > 0){
                ostringstream obuffer;
                boost::archive::binary_oarchive OutputArchive(obuffer);
                fPndSdsDigiTopix4Vector = frames.front();
                OutputArchive << fPndSdsDigiTopix4Vector;
                int outputSize = obuffer.str().length();
                fPayload->Rebuild(outputSize);
                memcpy(fPayload->GetData(), obuffer.str().c_str(), outputSize);
                //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: " << frames.front().size();
        }
}

virtual InitStatus PndMQTopix4ProcessorTask::Init ( )

inlinevirtual

Definition at line 32 of file PndMQTopix4ProcessorTask.h.

{ return kSUCCESS; };

template<class Archive >

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

inline

Definition at line 37 of file PndMQTopix4ProcessorTask.h.

References fPndSdsDigiTopix4Vector.

        {
        ar& fPndSdsDigiTopix4Vector;
        }

Friends And Related Function Documentation

friend class boost::serialization::access

friend

Definition at line 44 of file PndMQTopix4ProcessorTask.h.

Member Data Documentation

bool PndMQTopix4ProcessorTask::fHasBoostSerialization

private

Definition at line 48 of file PndMQTopix4ProcessorTask.h.

Referenced by PndMQTopix4ProcessorTask().

std::vector<PndSdsDigiTopix4> PndMQTopix4ProcessorTask::fPndSdsDigiTopix4Vector

private

Definition at line 46 of file PndMQTopix4ProcessorTask.h.

Referenced by Exec(), and serialize().

PndMvdReadInToPix4TBData PndMQTopix4ProcessorTask::fTopixDataReader

private

Definition at line 50 of file PndMQTopix4ProcessorTask.h.

Referenced by Exec().

---

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

• PndMQTopix4ProcessorTask.h
• PndMQTopix4ProcessorTask.cxx