170 lines
4.3 KiB
C++
170 lines
4.3 KiB
C++
#include "OnlineEventBuilder.h"
|
|
|
|
#include <algorithm>
|
|
|
|
OnlineEventBuilder::OnlineEventBuilder(Digitizer * digi){
|
|
|
|
data = digi->GetData();
|
|
nCh = digi->GetNChannels();
|
|
|
|
ClearEvents();
|
|
}
|
|
|
|
OnlineEventBuilder::~OnlineEventBuilder(){
|
|
|
|
}
|
|
|
|
void OnlineEventBuilder::ClearEvents(){
|
|
eventIndex = -1;
|
|
totalEventBuilt = 0;
|
|
for( int i = 0; i < MaxNEvent; i++ ) events[i].clear();
|
|
|
|
for( int i = 0; i < MaxNChannels; i++ ){
|
|
nextIndex[i] = -1;
|
|
loopIndex[i] = 0;
|
|
chExhaused[i] = false;
|
|
}
|
|
|
|
earlistTime = -1;
|
|
earlistCh = -1;
|
|
|
|
nExhaushedCh = 0;
|
|
}
|
|
|
|
void OnlineEventBuilder::PrintStat(){
|
|
|
|
printf("========= Total Event built : %lu, last built : %lu, index: %lu \n", totalEventBuilt, eventBuilt, eventIndex);
|
|
}
|
|
|
|
void OnlineEventBuilder::FindEarlistTimeAndCh(){
|
|
|
|
earlistTime = -1;
|
|
earlistCh = -1;
|
|
|
|
nExhaushedCh = 0;
|
|
for( int i = 0; i < MaxNChannels; i++ ){
|
|
chExhaused[i] = false;
|
|
}
|
|
|
|
for(unsigned int ch = 0; ch < nCh; ch ++){
|
|
if( data->DataIndex[ch] == -1 || loopIndex[ch] * MaxNData + nextIndex[ch] > data->LoopIndex[ch] * MaxNData + data->DataIndex[ch]) {
|
|
nExhaushedCh ++;
|
|
chExhaused[ch] = true;
|
|
continue;
|
|
}
|
|
|
|
if( nextIndex[ch] == -1 ) nextIndex[ch] = 0;
|
|
|
|
unsigned long long time = data->Timestamp[ch][nextIndex[ch]];
|
|
if( time < earlistTime ) {
|
|
earlistTime = time;
|
|
earlistCh = ch;
|
|
//printf("ch: %d , nextIndex : %d, %llu\n", ch, nextIndex[ch] , earlistTime);
|
|
}
|
|
}
|
|
|
|
// printf("%s | ch : %d, %llu\n", __func__, earlistCh, earlistTime);
|
|
}
|
|
|
|
void OnlineEventBuilder::FindLatestTime(){
|
|
latestTime = 0;
|
|
// int latestCh = -1;
|
|
for( unsigned ch = 0; ch < nCh; ch++ ){
|
|
int index = data->DataIndex[ch];
|
|
if( index == -1 ) continue;
|
|
if( data->Timestamp[ch][index] > latestTime ) {
|
|
latestTime = data->Timestamp[ch][index];
|
|
//latestCh = ch;
|
|
}
|
|
}
|
|
// printf("%s | ch : %d, %lld \n", __func__, latestCh, latestTime);
|
|
}
|
|
|
|
void OnlineEventBuilder::BuildEvents(unsigned short timeWindow, bool verbose){
|
|
|
|
this->timeWindow = timeWindow;
|
|
if( verbose ) data->PrintAllData();
|
|
|
|
FindLatestTime();
|
|
FindEarlistTimeAndCh();
|
|
|
|
if( earlistCh == -1 || nExhaushedCh == nCh) return; /// no data
|
|
|
|
eventBuilt = 0;
|
|
|
|
//======= Start building event
|
|
do{
|
|
|
|
eventIndex ++;
|
|
if( eventIndex >= MaxNEvent ) eventIndex = 0;
|
|
events[eventIndex].clear();
|
|
|
|
eventBuilt ++;
|
|
totalEventBuilt ++;
|
|
|
|
unsigned long long dT = 0;
|
|
dataPoint dp = {0, 0, 0};
|
|
for( unsigned int i = 0; i < nCh; i++){
|
|
int ch = (i + earlistCh ) % nCh;
|
|
if( chExhaused[ch] ) continue;
|
|
if( loopIndex[ch] * MaxNData + nextIndex[ch] > data->LoopIndex[ch] * MaxNData + data->DataIndex[ch]) {
|
|
nExhaushedCh ++;
|
|
chExhaused[ch] = true;
|
|
continue;
|
|
}
|
|
|
|
do {
|
|
|
|
unsigned long long time = data->Timestamp[ch][nextIndex[ch]];
|
|
|
|
if( time >= earlistTime && (time - earlistTime < timeWindow) ){
|
|
dp.ch = ch;
|
|
dp.energy = data->Energy[ch][nextIndex[ch]];
|
|
dp.timeStamp = time;
|
|
|
|
events[eventIndex].push_back(dp);
|
|
nextIndex[ch]++;
|
|
if( nextIndex[ch] >= MaxNData) {
|
|
loopIndex[ch] ++;
|
|
nextIndex[ch] = 0;
|
|
}
|
|
}else{
|
|
break;
|
|
}
|
|
|
|
}while( dT < timeWindow);
|
|
|
|
}
|
|
|
|
std::sort(events[eventIndex].begin(), events[eventIndex].end(), [](const dataPoint& a, const dataPoint& b) {
|
|
return a.timeStamp < b.timeStamp;
|
|
});
|
|
|
|
///Find the next earlist
|
|
FindEarlistTimeAndCh();
|
|
|
|
if( verbose ){
|
|
printf(">>>>>>>>>>>>>>>>> Event ID : %ld, total built: %ld, multiplicity : %ld\n", eventIndex, totalEventBuilt, events[eventIndex].size());
|
|
for( int i = 0; i <(int) events[eventIndex].size(); i++){
|
|
int chxxx = events[eventIndex][i].ch;
|
|
printf("%02d | %d | %5d %llu \n", chxxx, nextIndex[chxxx], events[eventIndex][i].energy, events[eventIndex][i].timeStamp);
|
|
}
|
|
|
|
if( nExhaushedCh == nCh ) {
|
|
printf("######################### no more event to be built\n");
|
|
break;
|
|
}
|
|
printf("----- next ch : %d, next earlist Time : %llu.\n", earlistCh, earlistTime);
|
|
|
|
}
|
|
|
|
if( latestTime - earlistTime <= timeWindow ) {
|
|
if( verbose ) {
|
|
printf("######################### left over data for next build, latesTime : %llu.\n", latestTime);
|
|
}
|
|
break;
|
|
}
|
|
|
|
}while(nExhaushedCh < nCh);
|
|
|
|
} |