PndMQTopix4Sampler Class Reference

#include <PndMQTopix4Sampler.h>

Inheritance diagram for PndMQTopix4Sampler:

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

Public Member Functions
	PndMQTopix4Sampler ()
virtual	~PndMQTopix4Sampler ()
virtual void	SetProperty (const int key, const std::string &value)
virtual std::string	GetProperty (const int key, const std::string &default_="")
virtual void	SetProperty (const int key, const int value)
virtual int	GetProperty (const int key, const int default_=0)
virtual void	Init ()

Static Public Member Functions
static void	CustomCleanup (void *data, void *hint)

Protected Member Functions
virtual void	Run ()

Protected Attributes
std::string	fFileName
int	fFE
PndMvdReadInToPix4TBData	fTopixDataReader

Detailed Description

PndMQTopix4Sampler.h

Since

2014-10-10

Author

A. Rybalchenko

Definition at line 23 of file PndMQTopix4Sampler.h.

Member Enumeration Documentation

anonymous enum

Enumerator
FileName
Last

Definition at line 26 of file PndMQTopix4Sampler.h.

    {
        FileName = FairMQDevice::Last,
        Last
    };

Constructor & Destructor Documentation

PndMQTopix4Sampler::PndMQTopix4Sampler

(

)

Definition at line 27 of file PndMQTopix4Sampler.cxx.

    : fFileName()
{
}

PndMQTopix4Sampler::~PndMQTopix4Sampler ( )

virtual

Definition at line 73 of file PndMQTopix4Sampler.cxx.

{
}

Member Function Documentation

void PndMQTopix4Sampler::CustomCleanup ( void *  data, void *  hint  )

static

Definition at line 32 of file PndMQTopix4Sampler.cxx.

Referenced by Run().

{
    delete (TMrfData_8b*)object;
}

virtual std::string PndMQTopix4Sampler::GetProperty ( const int  key, const std::string &  default_ = ""  )

virtual

int PndMQTopix4Sampler::GetProperty ( const int  key, const int  default_ = 0  )

virtual

Definition at line 113 of file PndMQTopix4Sampler.cxx.

{
    switch (key)
    {
        default:
            return FairMQDevice::GetProperty(key, default_);
    }
}

void PndMQTopix4Sampler::Init ( )

virtual

Definition at line 37 of file PndMQTopix4Sampler.cxx.

References fTopixDataReader, and PndMvdReadInToPix4TBData::Init().

{
    fTopixDataReader.Init();
}

void PndMQTopix4Sampler::Run ( )

protectedvirtual

Definition at line 42 of file PndMQTopix4Sampler.cxx.

References CustomCleanup(), fTopixDataReader, TMrfData_8b::getNumWords(), PndMvdReadInToPix4TBData::ReadInDataFromFile(), TMrfData_8b::regdata, PndMQStatus::RUNNING, and PndMQStatus::STOP.

{
        bool stop = false;

    while (CheckCurrentState(RUNNING) && stop == false)
    {
        //boost::this_thread::sleep(boost::posix_time::milliseconds(1000));

        TMrfData_8b* data = 0;
        stop = fTopixDataReader.ReadInDataFromFile(data);

        unique_ptr<FairMQMessage> header(fTransportFactory->CreateMessage(sizeof(int)));

        int flag = -1;
        if (stop == false){
                flag = PndMQStatus::RUNNING;
                        memcpy(header->GetData(), &flag, sizeof(int));
                        unique_ptr<FairMQMessage> msg(fTransportFactory->CreateMessage(reinterpret_cast<u_int8_t*>(&data->regdata[0]),data->getNumWords(),CustomCleanup,data));
         //       LOG(INFO) << "Sending Words\"" << data->getNumWords() << "\"" << " Bits: " << data->getNumBits();
                        fChannels.at("data-out").at(0).SendPart(header);
                        fChannels.at("data-out").at(0).Send(msg);
        }
        else
        {
                flag = PndMQStatus::STOP;
                memcpy(header->GetData(), &flag, sizeof(int));
                fChannels.at("data-out").at(0).Send(header);
        }
    }
}

virtual void PndMQTopix4Sampler::SetProperty ( const int  key, const std::string &  value  )

virtual

Referenced by main().

void PndMQTopix4Sampler::SetProperty ( const int  key, const int  value  )

virtual

Definition at line 103 of file PndMQTopix4Sampler.cxx.

{
    switch (key)
    {
        default:
                FairMQDevice::SetProperty(key, value);
                break;
    }
}

Member Data Documentation

int PndMQTopix4Sampler::fFE

protected

Definition at line 45 of file PndMQTopix4Sampler.h.

std::string PndMQTopix4Sampler::fFileName

protected

Definition at line 44 of file PndMQTopix4Sampler.h.

PndMvdReadInToPix4TBData PndMQTopix4Sampler::fTopixDataReader

protected

Definition at line 46 of file PndMQTopix4Sampler.h.

Referenced by Init(), and Run().

---

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

• PndMQTopix4Sampler.h
• PndMQTopix4Sampler.cxx