PndMQTopix4OnlineHisto Class Reference

#include <PndMQTopix4OnlineHisto.h>

Inheritance diagram for PndMQTopix4OnlineHisto:

Public Member Functions
	PndMQTopix4OnlineHisto ()
virtual	~PndMQTopix4OnlineHisto ()
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

PndMQTopix4OnlineHisto.h

Since

2014-10-10

Author

A. Rybalchenko

Definition at line 28 of file PndMQTopix4OnlineHisto.h.

Constructor & Destructor Documentation

PndMQTopix4OnlineHisto::PndMQTopix4OnlineHisto

(

)

Definition at line 33 of file PndMQTopix4OnlineHisto.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;
}

PndMQTopix4OnlineHisto::~PndMQTopix4OnlineHisto ( )

virtual

Definition at line 105 of file PndMQTopix4OnlineHisto.cxx.

{
}

Member Function Documentation

void PndMQTopix4OnlineHisto::Run ( )

protectedvirtual

Definition at line 49 of file PndMQTopix4OnlineHisto.cxx.

References c1, fHasBoostSerialization, fTopixData, and h2.

Referenced by main().

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

                TH2* h2 = new TH2D("h2","h2", 21, -0.5, 20.5, 33, -0.5, 32.5);
                TCanvas *c1 = new TCanvas("c1", "Dynamic Filling Example", 500, 100, 700, 500);
                c1->Show();
                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){
                                        for (auto itr : fTopixData){
                                                h2->Fill(itr.GetPixelColumn(), itr.GetPixelRow());
                                        }
                                }
                                delete(msg);

                                const int kUPDATE = 100;
                                if (receivedMsgs){
                                        if (receivedMsgs == kUPDATE) h2->Draw("colz");
                                        c1->Modified();
                                        c1->Update();
                                }

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

template<class Archive >

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

inline

Definition at line 37 of file PndMQTopix4OnlineHisto.h.

References fTopixData.

        {
                ar& fTopixData;
        }

Friends And Related Function Documentation

friend class boost::serialization::access

friend

Definition at line 46 of file PndMQTopix4OnlineHisto.h.

Member Data Documentation

bool PndMQTopix4OnlineHisto::fHasBoostSerialization

protected

Definition at line 47 of file PndMQTopix4OnlineHisto.h.

Referenced by PndMQTopix4OnlineHisto(), and Run().

std::vector<PndSdsDigiTopix4> PndMQTopix4OnlineHisto::fTopixData

protected

Definition at line 50 of file PndMQTopix4OnlineHisto.h.

Referenced by Run(), and serialize().

PndMvdReadInToPix4TBData PndMQTopix4OnlineHisto::fTopixDataReader

protected

Definition at line 52 of file PndMQTopix4OnlineHisto.h.

---

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

• PndMQTopix4OnlineHisto.h
• PndMQTopix4OnlineHisto.cxx