RecordParser.cc

Go to the documentation of this file.

#include "RawRecordPool/DaqRawEvent.h"
#include "RawRecordPool/TShiftProxy.h"
#include "RawRecordPool/RecordParser.h"
#include "RawRecordPool/RecordBuffer.h"
#include "RawRecordPool/RawRecordPoolUtil.h"

using DybDaq::RecordParser;
using DybDaq::RecordBuffer;

RecordParser::RecordParser()
    : m_site(-1),
      m_nPmtDet(0),
      m_hasRpc(0),
      m_mask(0),
      m_ready(false)
{
}

RecordParser::~RecordParser()
{
}

bool RecordParser::getRunParams(RecordBuffer* record, bool timeAlignment)
{
    if ( record != 0 &&
         marker(record) == DybDaq::RawRecordPoolUtil::RunParametersMarker ) {

        m_run = ((uint32_t*)record->data())[2];

        uint32_t detMask = ((uint32_t*)record->data())[5];

        for ( m_site = 0; m_site < 3; ++m_site ) {
            m_mask = ((detMask>>(8*m_site)) & 0xFF);
            if ( m_mask != 0 ) {
                for ( int i = 1; i < 7; ++i ) {
                    if ( (m_mask & (1<<i)) != 0 ) ++m_nPmtDet;
                }

                if ( (m_mask&0x80) != 0 ) m_hasRpc = 1;
                break;
            }
        }

        if ( timeAlignment ) initTimeShift();

        m_ready = true;

        return true;
    }
    return false;
}

bool RecordParser::isPmtEvent(RecordBuffer* record)
{
    if ( record != 0 &&
         marker(record) == DybDaq::RawRecordPoolUtil::DataSeparatorMarker ) {

        uint32_t* event = (uint32_t*)(record->data() + 16);
        uint32_t  srcId = event[3];

        if ( (srcId&0xF0000) != 0x70000 ) {
            return true;
        }
    }
    return false;
}

bool RecordParser::isRpcEvent(RecordBuffer* record)
{
    if ( record != 0 &&
         marker(record) == DybDaq::RawRecordPoolUtil::DataSeparatorMarker ) {

        uint32_t* event = (uint32_t*)(record->data() + 16);
        uint32_t  srcId = event[3];

        if ( (srcId&0xF0000) == 0x70000 ) {
            return true;
        }
    }
    return false;
}

int RecordParser::recordType(RecordBuffer* record)
{
    // 0: not a DAQ event, 1:AD1,2:AD2,3:AD3,4:AD4,5:IWP,6:OWP,7:RPC
    int result = 0;
    if ( record != 0 &&
         marker(record) == DybDaq::RawRecordPoolUtil::DataSeparatorMarker ) {

        uint32_t* event = (uint32_t*)(record->data() + 16);
        uint32_t  srcId = event[3];

        // 0: not a DAQ event, 1: PMT event, 2: RPC event
        //result = ( (srcId&0xF0000) != 0x70000 ) ? 1 : 2;
        result = ((srcId>>16)&0xF);
    }
    return result;
}

bool RecordParser::earlier(RecordBuffer* r1, RecordBuffer* r2)
{
    bool result = false;

    DaqRawEvent* evt1 = ( r1 != 0 ) ? r1->timeRevisedEvent() : 0;
    DaqRawEvent* evt2 = ( r2 != 0 ) ? r2->timeRevisedEvent() : 0;

    if ( r1 != 0 && r2 != 0 ) {
        if ( evt1->second() == evt2->second() ) {
            result = evt1->nanoSecond() < evt2->nanoSecond();
        }
        else {
            result = evt1->second() < evt2->second();
        }
    }
    else if ( r2 == 0 ) {
        result = true;
    }

    return result;
}

uint32_t RecordParser::marker(RecordBuffer* record)
{
    return ((uint32_t*)record->data())[0];
}

void  RecordParser::initTimeShift()
{
    TShiftProxy  tProxy(m_run, m_site);

    for ( int detId = 0; detId < 7; ++detId ) {
        DybDaq::RawRecordPoolUtil::EVENT_TIME_REVISE[m_site][detId] = tProxy.time_shift(detId);
    }
}