#include <PndMQHitsEventBuilder.h>

Public Member Functions
	PndMQHitsEventBuilder (int nChannels=4)

virtual	~PndMQHitsEventBuilder ()

void	AddData (vector< vector< vector< PndSdsHit > > > &data)

vector< vector< PndSdsHit > >	GetEvents ()

vector< int >	GetSensorsInEvent ()

std::vector< int >	GetInputDataLevel ()

Protected Member Functions
vector< bool >	GetChannelsInEvent (vector< vector< PndSdsHit > > &eventData)

int	FindFirstChannel (vector< vector< PndSdsHit > > &eventData)
	channel which has the oldest data More...

vector< PndSdsHit >	GetNextEvent ()

bool	HasData ()

Protected Attributes
vector< int >	fSensorsInEvent

Private Attributes
vector< vector< vector < PndSdsHit > > >	fInputData

int	fNChannels

int	fEventCounter

Detailed Description

Definition at line 18 of file PndMQHitsEventBuilder.h.

Constructor & Destructor Documentation

PndMQHitsEventBuilder::PndMQHitsEventBuilder ( int nChannels = 4 )

Definition at line 12 of file PndMQHitsEventBuilder.cxx.

References fInputData.

                                                           : fNChannels(nChannels), fEventCounter(0), fSensorsInEvent(nChannels, 0) {
          fInputData.resize(nChannels);
 
 }

PndMQHitsEventBuilder::~PndMQHitsEventBuilder ( )

virtual

Definition at line 17 of file PndMQHitsEventBuilder.cxx.

                                               {
         // TODO Auto-generated destructor stub
 }

Member Function Documentation

void PndMQHitsEventBuilder::AddData ( vector< vector< vector< PndSdsHit > > > & data )

Definition at line 21 of file PndMQHitsEventBuilder.cxx.

References fInputData.

Referenced by PndMQHitEventDevice::Run().

 {
         for (int channelNr = 0; channelNr < data.size(); channelNr++){
                 //LOG(INFO) << "PndMQHitsEventBuilder::AddData from Channel " << channelNr << " size " << data[channelNr].size();
                 fInputData[channelNr].insert(fInputData[channelNr].end(), data[channelNr].begin(), data[channelNr].end());
         }
 }

int PndMQHitsEventBuilder::FindFirstChannel ( vector< vector< PndSdsHit > > & eventData )

protected

channel which has the oldest data

Definition at line 147 of file PndMQHitsEventBuilder.cxx.

Referenced by GetChannelsInEvent().

 {
         int result = -1;
         double oldTimeStamp = -1;
         for (int channelNr = 0; channelNr < eventData.size(); channelNr++){
                 double actualTimeStamp = eventData[channelNr].front().GetTimeStamp();
                 if (actualTimeStamp < oldTimeStamp || oldTimeStamp < 0){
                         result = channelNr;
                         oldTimeStamp = actualTimeStamp;
                 }
         }
         return result;
 }

vector< bool > PndMQHitsEventBuilder::GetChannelsInEvent ( vector< vector< PndSdsHit > > & eventData )

protected

Definition at line 116 of file PndMQHitsEventBuilder.cxx.

References FindFirstChannel(), fNChannels, and offset().

Referenced by GetNextEvent().

 {
         double offset = 50;
         vector<bool> result(fNChannels, false);
 
         int firstChannel = FindFirstChannel(eventData);
 //      LOG(INFO) << "FirstChannel: " << firstChannel;
         if (firstChannel > -1){
                 double firstTimeStamp = eventData[firstChannel][0].GetTimeStamp();
                 double lastTimeStamp = eventData[firstChannel].rbegin()->GetTimeStamp() + offset;
                 result[firstChannel] = true;
 
                 for (int channelNr = 0; channelNr < eventData.size(); channelNr++){
                         if (channelNr != firstChannel){
                                 double actualFirstTS = eventData[channelNr].begin()->GetTimeStamp();
                                 double actualLastTS = eventData[channelNr].rbegin()->GetTimeStamp();
                                 if (actualFirstTS == firstTimeStamp)
                                         result[channelNr] = true;
                                 if (actualFirstTS < firstTimeStamp){
                                         if (actualLastTS >= firstTimeStamp){
                                                 result[channelNr] = true;
                                         }
                                 } else if (actualFirstTS <= lastTimeStamp) {
                                         result[channelNr] = true;
                                 }
                         }
                 }
         }
         return result;
 }

vector< vector< PndSdsHit > > PndMQHitsEventBuilder::GetEvents ( )

Definition at line 29 of file PndMQHitsEventBuilder.cxx.

References GetNextEvent(), and HasData().

Referenced by PndMQHitEventDevice::Run().

 {
         vector<vector<PndSdsHit> > result;
         while (HasData()){
                 result.push_back(GetNextEvent());
         }
         return result;
 }

std::vector<int> PndMQHitsEventBuilder::GetInputDataLevel ( )

inline

Definition at line 26 of file PndMQHitsEventBuilder.h.

Referenced by PndMQHitEventDevice::Run().

                                           {
                 std::vector<int> result;
                 for (auto& channelIter : fInputData){
                         result.push_back(channelIter.size());
                 }
                 return result;
         }

vector< PndSdsHit > PndMQHitsEventBuilder::GetNextEvent ( )

protected

Definition at line 51 of file PndMQHitsEventBuilder.cxx.

References fInputData, fNChannels, fSensorsInEvent, and GetChannelsInEvent().

Referenced by GetEvents().

 {
         vector<PndSdsHit> result;
 //      if (fEventCounter % 1000 == 0){
 //              LOG(INFO) << fEventCounter;
 //              for (int channelNr = 0; channelNr < fNChannels; channelNr++){
 //                      LOG(INFO) << channelNr << " : " << fInputData[channelNr].size();
 //              }
 //      }
 //      fEventCounter++;
 //      LOG(INFO) << "Data in channels";
 //      for (auto channelIter: fInputData){
 //              LOG(INFO) << "Channel size: " << channelIter.size();
 //              for (auto eventIter : channelIter)
 //                      for (auto dataIter : eventIter)
 //                              LOG(INFO) << dataIter.GetSensorID() << " " << dataIter.GetTimeStamp();
 //      }
 
         vector<vector<PndSdsHit> > firstDataInChannels;
         firstDataInChannels.resize(fNChannels);
         for (int channelNr = 0; channelNr < fInputData.size(); channelNr++){
                 if (fInputData[channelNr].size() > 0){
                         if (fInputData[channelNr][0].size() > 0)
                                 firstDataInChannels[channelNr] = fInputData[channelNr][0];
                         else
                                 return result;
                 }
         }
 //      LOG(INFO) << "FirstDataInChannel:";
 //      for (int channel = 0; channel < firstDataInChannels.size(); channel++){
 //              //LOG(INFO) << "Channel: " << channel << " : ";
 //              for (auto data : firstDataInChannels[channel]){
 //                      LOG(INFO) << channel << " : " << TString::Format("%12.0f", data.GetTimeStamp()).Data();
 //              }
 //      }
         vector<bool> channelInEvent = GetChannelsInEvent(firstDataInChannels);
 
         int nSensorsInEvent = 0;
 //      LOG(INFO) << "ChannelMatch:";
         for (auto inEvent : channelInEvent){
                 //LOG(INFO) << inEvent;
                 nSensorsInEvent += inEvent;
         }
 
         if (nSensorsInEvent > 0)
                 fSensorsInEvent[nSensorsInEvent - 1]++;
 
 //      LOG(INFO) << "channelInEvent.size " << channelInEvent.size();
         for(int channelNr = 0; channelNr < fNChannels; channelNr++){
                 if (channelInEvent[channelNr] == true){
                         //LOG(INFO) << "Add Data to result from: " << channelNr;
                         result.insert(result.end(), firstDataInChannels[channelNr].begin(), firstDataInChannels[channelNr].end());
                         //LOG(INFO) << "DataInserted: " << result.size();
                         fInputData[channelNr].erase(fInputData[channelNr].begin());
 //                      LOG(INFO) << "Delete data from InputData " << channelNr << " " << fInputData[channelNr].size();
                 }
         }
         //if (nChannelsInEvent > 2){
         //      LOG(INFO) << "Data in Result: ";
         //      for (auto data : result)
         //              LOG(INFO) << data.GetSensorID() << " : " << data.GetTimeStamp();
         //}
         return result;
 }

vector<int> PndMQHitsEventBuilder::GetSensorsInEvent ( )

inline

Definition at line 25 of file PndMQHitsEventBuilder.h.

Referenced by PndMQHitEventDevice::Run().

25 { return fSensorsInEvent;}

PndMQHitsEventBuilder::fSensorsInEvent

vector< int > fSensorsInEvent

Definition: PndMQHitsEventBuilder.h:38

bool PndMQHitsEventBuilder::HasData ( )

protected

Definition at line 38 of file PndMQHitsEventBuilder.cxx.

References fInputData.

Referenced by GetEvents().

 {
         bool result = true;
         for (int channelIter = 0; channelIter < fInputData.size(); channelIter++){
                 if (fInputData[channelIter].size() == 0){
                         result = false;
                 }
         }
 //      if (result == false)
 //              LOG(INFO) << "HasData " << result;
         return result;
 }

Member Data Documentation

int PndMQHitsEventBuilder::fEventCounter

private

Definition at line 47 of file PndMQHitsEventBuilder.h.

vector<vector<vector<PndSdsHit> > > PndMQHitsEventBuilder::fInputData

private

Definition at line 45 of file PndMQHitsEventBuilder.h.

Referenced by AddData(), GetNextEvent(), HasData(), and PndMQHitsEventBuilder().

int PndMQHitsEventBuilder::fNChannels

private

Definition at line 46 of file PndMQHitsEventBuilder.h.

Referenced by GetChannelsInEvent(), and GetNextEvent().

vector<int> PndMQHitsEventBuilder::fSensorsInEvent

protected

Definition at line 38 of file PndMQHitsEventBuilder.h.

Referenced by GetNextEvent().

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

Public Member Functions

Protected Member Functions

Protected Attributes

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation