FairRoot/PandaRoot
Public Member Functions | Protected Member Functions | Private Attributes | Friends | List of all members
PndMQHitEventDevice Class Reference

#include <PndMQHitEventDevice.h>

Inheritance diagram for PndMQHitEventDevice:

Public Member Functions

 PndMQHitEventDevice ()
 
virtual ~PndMQHitEventDevice ()
 
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)
 
template<class Archive >
void serialize (Archive &ar, const unsigned int version)
 

Protected Member Functions

virtual void Run ()
 

Private Attributes

std::vector< std::vector
< PndSdsHit > > 		fHitData
 
std::vector< std::vector
< PndSdsHit > > 		fEventData
 
std::vector< std::vector
< std::vector< PndSdsHit > > > 		fDataFromChannels
 
std::vector< bool > fRunningStatus
 
bool fGlobalRunningStatus
 
std::vector< int > fSensorsInEvent
 
bool fHasBoostSerialization
 
PndMQHitsEventBuilder * fBuilder
 

Friends

class boost::serialization::access
 

Detailed Description

PndMQTopix4Sink.h

Since
2014-10-10
Author
A. Rybalchenko

Definition at line 27 of file PndMQHitEventDevice.h.

Constructor & Destructor Documentation

PndMQHitEventDevice::PndMQHitEventDevice ( )

Definition at line 33 of file PndMQHitEventDevice.cxx.

References fHasBoostSerialization.

33  : fHasBoostSerialization(false), fGlobalRunningStatus(true), fBuilder(0)
34 {
35  using namespace baseMQ::tools::resolve;
36  bool checkOutputClass = false;
37 
38  if (is_same<boost::archive::binary_oarchive, boost::archive::binary_oarchive>::value)
39  {
40  if (has_BoostSerialization<PndSdsDigiTopix4, void(boost::archive::binary_oarchive&, const unsigned int)>::value == 1)
41  {
42  checkOutputClass = true;
43  fHasBoostSerialization = true;
44  }
45  }
46  LOG(INFO) << "HasBoostSerialization: " << fHasBoostSerialization;
47 }
PndMQHitEventDevice::fBuilder
PndMQHitsEventBuilder * fBuilder
Definition: PndMQHitEventDevice.h:63
PndSdsDigiTopix4
Data class to store the digi output of a pixel module.
Definition: PndSdsDigiTopix4.h:25
PndMQHitEventDevice::~PndMQHitEventDevice ( )
virtual

Definition at line 49 of file PndMQHitEventDevice.cxx.

References fBuilder.

50 {
51  delete(fBuilder);
52 }
PndMQHitEventDevice::fBuilder
PndMQHitsEventBuilder * fBuilder
Definition: PndMQHitEventDevice.h:63

Member Function Documentation

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

Definition at line 232 of file PndMQHitEventDevice.cxx.

233 {
234  switch (key)
235  {
236  default:
237  return FairMQDevice::GetProperty(key, default_);
238  }
239 }
void PndMQHitEventDevice::Run ( )
protectedvirtual

Definition at line 55 of file PndMQHitEventDevice.cxx.

References PndMQHitsEventBuilder::AddData(), fBuilder, fDataFromChannels, fEventData, fGlobalRunningStatus, fHitData, fRunningStatus, fSensorsInEvent, PndMQHitsEventBuilder::GetEvents(), PndMQHitsEventBuilder::GetInputDataLevel(), PndMQHitsEventBuilder::GetSensorsInEvent(), i, PndMQStatus::RUNNING, status, and PndMQStatus::STOP.

56 {
57  int numInputs = fChannels.at("data-in").size();
58 
59  // store the channel references to avoid traversing the map on every loop iteration
60  const FairMQChannel& dataOutChannel = fChannels.at("data-out").at(0);
61  const FairMQChannel& statusChannel = fChannels.at("status-out").at(0);
62  FairMQChannel* dataInChannels[fChannels.at("data-in").size()];
63  LOG(INFO) << "Number of Input Channels: " << numInputs;
64  fBuilder = new PndMQHitsEventBuilder(numInputs);
65  for (int i = 0; i < numInputs; ++i)
66  {
67  dataInChannels[i] = &(fChannels.at("data-in").at(i));
68  }
69  fDataFromChannels.resize(numInputs);
70  fRunningStatus.resize(numInputs);
71  for(int channel = 0; channel < fRunningStatus.size(); channel++)
72  fRunningStatus[channel] = true;
73 
74 // boost::this_thread::sleep(boost::posix_time::milliseconds(1000));
75 
76  std::vector<int> fillLevel(numInputs,0);
77 
78  int eventCounter = 0;
79  bool stopMessageOnce = true;
80 
81  while (CheckCurrentState(RUNNING))
82  {
83  if ( fGlobalRunningStatus == true){
84  for (int channelNr = 0; channelNr < numInputs; channelNr++){
85  // LOG(INFO) << "---- Reading channel " << channelNr << " ----";
86  if (fillLevel[channelNr] == 0 && fRunningStatus[channelNr] == true){
87 
88  std::unique_ptr<FairMQMessage> header(fTransportFactory->CreateMessage());
89  std::unique_ptr<FairMQMessage> msg(fTransportFactory->CreateMessage());
90 
91  if (dataInChannels[channelNr]->Receive(header) > 0)
92  {
93  int status = *(static_cast<int*>(header->GetData()));
94  if (status == PndMQStatus::RUNNING)
95  fRunningStatus[channelNr] = true;
96  else if (status == PndMQStatus::STOP){
97  fRunningStatus[channelNr] = false;
98  LOG(INFO) << "STOP-Status received for channel: " << channelNr;
99  }
100  if (dataInChannels[channelNr]->ExpectsAnotherPart())
101  {
102 
103  if (dataInChannels[channelNr]->Receive(msg) > 0){
104  std::string msgStr(static_cast<char*>(msg->GetData()), msg->GetSize());
105  std::istringstream ibuffer(msgStr);
106 
107  boost::archive::binary_iarchive InputArchive(ibuffer);
108 
109  try {
110  InputArchive >> fHitData;
111  }
112  catch (boost::archive::archive_exception& e)
113  {
114  LOG(ERROR) << e.what();
115  }
116  //fDataFromChannels[channelNr].push_back(fHitData);
117  fDataFromChannels[channelNr].insert(fDataFromChannels[channelNr].end(), fHitData.begin(), fHitData.end());
118  //LOG(INFO) << "Data in channel " << fDataFromChannels[channelNr].size();
119  fHitData.clear();
120  }
121  }
122  }
123  if (fillLevel[channelNr] == 0 && fRunningStatus[channelNr] == false)
124  {
125  fGlobalRunningStatus = false;
126  LOG(INFO) << "GlobarRunningStatus set to false for channel " << channelNr;
127  }
128  }
129  }
130  fBuilder->AddData(fDataFromChannels);
131  fEventData = fBuilder->GetEvents();
132 
133  if (eventCounter++ % 100 == 0){
134  LOG(INFO) << eventCounter << " nEvents: " << fEventData.size() << " hits in Event " << fEventData.front().size()
135  << " timeStamp: " << TString::Format("%12.0f",fEventData.front().front().GetTimeStamp()).Data()
136  << " sensorID " << fEventData.front().front().GetSensorID();
137  fSensorsInEvent = fBuilder->GetSensorsInEvent();
138  LOG(INFO) << "ChannelsInEvent: ";
139  for (auto data : fSensorsInEvent)
140  LOG(INFO) << data;
141 
142  std::unique_ptr<FairMQMessage> headerCopy(fTransportFactory->CreateMessage(sizeof(int)));
143  int flag = PndMQStatus::RUNNING;
144  memcpy(headerCopy->GetData(), &flag, sizeof(int));
145  statusChannel.SendPart(headerCopy);
146 
147  std::ostringstream obuffer;
148  boost::archive::binary_oarchive OutputArchive(obuffer);
149  //fPndSdsDigiTopix4Vector = frames.front();
150  OutputArchive << fSensorsInEvent;
151  int outputSize = obuffer.str().length();
152  unique_ptr<FairMQMessage> msg(fTransportFactory->CreateMessage(outputSize));
153  memcpy(msg->GetData(), obuffer.str().c_str(), outputSize);
154  //unique_ptr<FairMQMessage> msg2(fTransportFactory->CreateMessage(const_cast<char*>(obuffer.str().c_str()), outputSize, CustomCleanup, &obuffer));
155  statusChannel.Send(msg);
156 
157  }
158 
159  std::unique_ptr<FairMQMessage> headerCopy(fTransportFactory->CreateMessage(sizeof(int)));
160  int flag = PndMQStatus::RUNNING;
161  memcpy(headerCopy->GetData(), &flag, sizeof(int));
162  dataOutChannel.SendPart(headerCopy);
163 
164  std::ostringstream obuffer;
165  boost::archive::binary_oarchive OutputArchive(obuffer);
166  //fPndSdsDigiTopix4Vector = frames.front();
167  OutputArchive << fEventData;
168  int outputSize = obuffer.str().length();
169  unique_ptr<FairMQMessage> msg2(fTransportFactory->CreateMessage(outputSize));
170  memcpy(msg2->GetData(), obuffer.str().c_str(), outputSize);
171  //unique_ptr<FairMQMessage> msg2(fTransportFactory->CreateMessage(const_cast<char*>(obuffer.str().c_str()), outputSize, CustomCleanup, &obuffer));
172  dataOutChannel.Send(msg2);
173 
174  fillLevel = fBuilder->GetInputDataLevel();
175  // LOG(INFO) << "EventData.size() " << eventData.size();
176  // for (auto eventIter : eventData){
177  // LOG(INFO) << "Event";
178  // for (auto dataIter : eventIter){
179  // LOG(INFO) << dataIter.GetSensorID() << " " << dataIter.GetTimeStamp();
180  // }
181  // }
182 
183  for (int channelNr = 0; channelNr < fDataFromChannels.size(); channelNr++){
184  fDataFromChannels[channelNr].clear();
185  }
186  }
187  bool allStop = true;
188  for (auto state : fRunningStatus){
189  if (state == true)
190  allStop = false;
191  }
192  if (fGlobalRunningStatus == false && stopMessageOnce == true){
193  LOG(INFO) << "STOP-Signal received for one input";
194  std::unique_ptr<FairMQMessage> headerCopy(fTransportFactory->CreateMessage(sizeof(int)));
195  int flag = PndMQStatus::STOP;
196  memcpy(headerCopy->GetData(), &flag, sizeof(int));
197  dataOutChannel.Send(headerCopy);
198  stopMessageOnce = false;
199  }
200  }
201 }
PndMQHitsEventBuilder::AddData
void AddData(vector< vector< vector< PndSdsHit > > > &data)
Definition: PndMQHitsEventBuilder.cxx:21
PndMQHitEventDevice::fHitData
std::vector< std::vector< PndSdsHit > > fHitData
Definition: PndMQHitEventDevice.h:54
i
Int_t i
Definition: run_full.C:25
PndMQHitEventDevice::fBuilder
PndMQHitsEventBuilder * fBuilder
Definition: PndMQHitEventDevice.h:63
PndMQHitEventDevice::fSensorsInEvent
std::vector< int > fSensorsInEvent
Definition: PndMQHitEventDevice.h:60
PndMQHitsEventBuilder::GetInputDataLevel
std::vector< int > GetInputDataLevel()
Definition: PndMQHitsEventBuilder.h:26
PndMQHitEventDevice::fRunningStatus
std::vector< bool > fRunningStatus
Definition: PndMQHitEventDevice.h:58
PndMQHitEventDevice::fEventData
std::vector< std::vector< PndSdsHit > > fEventData
Definition: PndMQHitEventDevice.h:56
PndMQHitEventDevice::fDataFromChannels
std::vector< std::vector< std::vector< PndSdsHit > > > fDataFromChannels
Definition: PndMQHitEventDevice.h:57
PndMQHitsEventBuilder::GetEvents
vector< vector< PndSdsHit > > GetEvents()
Definition: PndMQHitsEventBuilder.cxx:29
PndMQHitsEventBuilder::GetSensorsInEvent
vector< int > GetSensorsInEvent()
Definition: PndMQHitsEventBuilder.h:25
status
int status[10]
Definition: f_Init.h:28
template<class Archive >
void PndMQHitEventDevice::serialize ( Archive &  ar,
const unsigned int  version 
)
inline

Definition at line 41 of file PndMQHitEventDevice.h.

References fEventData, fHitData, and fSensorsInEvent.

42  {
43  ar& fHitData;
44  ar& fEventData;
45  ar& fSensorsInEvent;
46  }
PndMQHitEventDevice::fHitData
std::vector< std::vector< PndSdsHit > > fHitData
Definition: PndMQHitEventDevice.h:54
PndMQHitEventDevice::fSensorsInEvent
std::vector< int > fSensorsInEvent
Definition: PndMQHitEventDevice.h:60
PndMQHitEventDevice::fEventData
std::vector< std::vector< PndSdsHit > > fEventData
Definition: PndMQHitEventDevice.h:56
virtual void PndMQHitEventDevice::SetProperty ( const int  key,
const std::string &  value 
)
virtual

Referenced by main().

void PndMQHitEventDevice::SetProperty ( const int  key,
const int  value 
)
virtual

Definition at line 222 of file PndMQHitEventDevice.cxx.

223 {
224  switch (key)
225  {
226  default:
227  FairMQDevice::SetProperty(key, value);
228  break;
229  }
230 }

Friends And Related Function Documentation

friend class boost::serialization::access
friend

Definition at line 52 of file PndMQHitEventDevice.h.

Member Data Documentation

PndMQHitsEventBuilder* PndMQHitEventDevice::fBuilder
private

Definition at line 63 of file PndMQHitEventDevice.h.

Referenced by Run(), and ~PndMQHitEventDevice().

std::vector<std::vector<std::vector<PndSdsHit> > > PndMQHitEventDevice::fDataFromChannels
private

Definition at line 57 of file PndMQHitEventDevice.h.

Referenced by Run().

std::vector<std::vector<PndSdsHit> > PndMQHitEventDevice::fEventData
private

Definition at line 56 of file PndMQHitEventDevice.h.

Referenced by Run(), and serialize().

bool PndMQHitEventDevice::fGlobalRunningStatus
private

Definition at line 59 of file PndMQHitEventDevice.h.

Referenced by Run().

bool PndMQHitEventDevice::fHasBoostSerialization
private

Definition at line 62 of file PndMQHitEventDevice.h.

Referenced by PndMQHitEventDevice().

std::vector< std::vector<PndSdsHit> > PndMQHitEventDevice::fHitData
private

Definition at line 54 of file PndMQHitEventDevice.h.

Referenced by Run(), and serialize().

std::vector<bool> PndMQHitEventDevice::fRunningStatus
private

Definition at line 58 of file PndMQHitEventDevice.h.

Referenced by Run().

std::vector<int> PndMQHitEventDevice::fSensorsInEvent
private

Definition at line 60 of file PndMQHitEventDevice.h.

Referenced by Run(), and serialize().

The documentation for this class was generated from the following files:
Generated on Wed Apr 3 2019 08:44:40 for FairRoot/PandaRoot by   doxygen 1.8.5