CheckTimeOrder.cc

Go to the documentation of this file.

#include "CheckTimeOrder.h"
#include "Context/Context.h"
#include "Context/TimeStamp.h"
#include "Event/HeaderObject.h"
#include "Event/ReadoutHeader.h"

using namespace DayaBay;
using namespace std;


CheckTimeOrder::CheckTimeOrder(const std::string& name, ISvcLocator* pSvcLocator)
    : GaudiAlgorithm(name,pSvcLocator)
    , m_lastTimeStamp(0)
{
}

CheckTimeOrder::~CheckTimeOrder()
{
}
    
StatusCode CheckTimeOrder::initialize()
{
    return StatusCode::SUCCESS;
}

StatusCode CheckTimeOrder::execute()
{
    ReadoutHeader* roh = get<ReadoutHeader>("/Event/Readout/ReadoutHeader");
    if ( !roh ) {
        error() << "Cannot find ReadoutHeader" << endreq;
        return StatusCode::FAILURE;
    } 
   
    TimeStamp ts = roh->context().GetTimeStamp();
    DetectorId::DetectorId_t detectorId = roh->context().GetDetId();

    if (detectorId == DetectorId::kRPC) {
        return StatusCode::SUCCESS; // skip RPC triggers
    } 
    
    // double dt = (ts - m_lastTimeStamp).GetSeconds();
    // 
    // if (dt>=0) {
    //     m_lastTimeStamp = ts;
    //     info() << "Timestamp order: #" << roh->execNumber() << ": dt:" << dt << " sec" << endreq;
    //     return StatusCode::SUCCESS;
    // }
    // else {
    //     error() << "Timestamp Disorder: #" << roh->execNumber() << ": dt:" << dt << " sec" << endreq;
    //     return StatusCode::FAILURE;
    // }
    
    long ts_sec = ts.GetSec();
    long ts_nsec = ts.GetNanoSec();
    long last_ts_sec = m_lastTimeStamp.GetSec();
    long last_ts_nsec = m_lastTimeStamp.GetNanoSec();
    
    
    bool inorder = false;
    if (ts_sec == last_ts_sec) {
        if (ts_nsec >= last_ts_nsec) inorder = true;
    }
    else if (ts_sec > last_ts_sec) inorder = true;
    
    if (inorder) {
        m_lastTimeStamp = ts;
        // info() << "Timestamp Inorder: #" << roh->execNumber() 
        //     << ": this: " << ts_sec << "+" << ts_nsec 
        //     << ": last: " << last_ts_sec << "+" << last_ts_nsec << endreq;
        return StatusCode::SUCCESS;
    }
    else {
        error() << "Timestamp Disorder: #" << roh->execNumber()
            << ": this: " << ts_sec << "+" << ts_nsec 
            << ": last: " << last_ts_sec << "+" << last_ts_nsec << endreq;
        return StatusCode::FAILURE;
    }
    return StatusCode::SUCCESS;
}

StatusCode CheckTimeOrder::finalize()
{
    return StatusCode::SUCCESS;
}