In This Package:

DaqReadoutSvc.cc

Go to the documentation of this file.

/*
 *  DaqReadoutSvc.cc
 *  DaqFormatModules
 *
 *  Created by Simon Patton on 9/2/10.
 *  Copyright 2010 DayaBay Collaboration. All rights reserved.
 *
 */
#include "DaqFormatModules/DaqReadoutSvc.h"

#include <string>

#include "FileReadoutFormat/CalibrationParametersRecord.h"
#include "FileReadoutFormat/FileEndRecord.h"
#include "FileReadoutFormat/FileNameStrings.h"
#include "FileReadoutFormat/FileStartRecord.h"
#include "FileReadoutFormat/FileTraits.h"
#include "FileReadoutFormat/MetadataStrings.h"
#include "FileReadoutFormat/RunParametersRecord.h"

using DybDaq::CalibrationParametersRecord;
using DybDaq::FileBuffer;
using DybDaq::FileEndRecord;
using DybDaq::FileNameStrings;
using DybDaq::FileStartRecord;
using DybDaq::FileTraits;
using DybDaq::MetadataStrings;
using DybDaq::RunParametersRecord;



DaqReadoutSvc::DaqReadoutSvc(const std::string& name,
                             ISvcLocator *svc) :
    Service(name,
            svc),
    m_fileStartRecord(0),
    m_fileNameStrings(0),
    m_metadataStrings(0),
    m_runParametersRecord(0),
    m_calibrationParametersRecord(0),
    m_fileEndRecord(0) 
{
  declareProperty("RunNumber",m_runNumber=0,
                  "The run number to be stamped in generated DAQ format data for the supplied detector");
  declareProperty("FirstEventNumber",m_nextEventNumber=1,
                  "The event number to be stamped into the next DAQ format event for the supplied detector");
  declareProperty("Generating",m_generating=false,
                  "True if DAQ formated data  should be generated");
}

DaqReadoutSvc::~DaqReadoutSvc() {
    if (0 != m_fileEndRecord) {
        delete m_fileEndRecord;
    }
    if (0 != m_calibrationParametersRecord) {
        delete m_calibrationParametersRecord;
    }
    if (0 != m_runParametersRecord) {
        delete m_runParametersRecord;
    }
    if (0 != m_metadataStrings) {
        delete m_metadataStrings;
    }
    if (0 != m_fileNameStrings) {
        delete m_fileNameStrings;
    }
    if (0 != m_fileStartRecord) {
        delete m_fileStartRecord;
    }
}

StatusCode DaqReadoutSvc::queryInterface(const InterfaceID& id, 
                                      void** interface) {
    if (IDaqReadoutSvc::interfaceID().versionMatch(id)) {
        // Good enough. Return this object
        *interface = dynamic_cast<IDaqReadoutSvc*>(this);
        addRef();
        return StatusCode::SUCCESS;
    }
    // Try base class
    return Service::queryInterface(id,
                                   interface);
}

bool DaqReadoutSvc::isGenerating() const {
    return m_generating;
}

unsigned int DaqReadoutSvc::ltbSlot(const DayaBay::Detector& /* detector */) const {
    return 3;
}

unsigned int DaqReadoutSvc::runNumber(const DayaBay::Detector& /* detector */) const {
    return m_runNumber;
}

unsigned int DaqReadoutSvc::nextEventNumber(const DayaBay::Detector& /* detector */) {
    return m_nextEventNumber++;
}

bool DaqReadoutSvc::hasFileStartRecord() const {
    return 0 != m_fileStartRecord;
}

const FileStartRecord& DaqReadoutSvc::fileStartRecord() const {
    return *m_fileStartRecord;
}

bool DaqReadoutSvc::hasFileNameStrings() const {
    return 0 != m_fileNameStrings;
}

const FileNameStrings& DaqReadoutSvc::fileNameStrings() const {
    return *m_fileNameStrings;
}

bool DaqReadoutSvc::hasMetadataStrings() const {
    return 0 != m_metadataStrings;
}

const MetadataStrings& DaqReadoutSvc::metadataStrings() const {
    return *m_metadataStrings;
}

bool DaqReadoutSvc::hasRunParametersRecord() const {
    return 0 != m_runParametersRecord;
}

const RunParametersRecord& DaqReadoutSvc::runParametersRecord() const {
    return *m_runParametersRecord;
}

bool DaqReadoutSvc::hasCalibrationParametersRecord() const {
    return 0 != m_calibrationParametersRecord;
}

const CalibrationParametersRecord& DaqReadoutSvc::calibrationParametersRecord() const {
    return *m_calibrationParametersRecord;
}

bool DaqReadoutSvc::hasFileEndRecord() const {
    return 0 != m_fileEndRecord;
}

const FileEndRecord& DaqReadoutSvc::fileEndRecord() const {
    return *m_fileEndRecord;
}

void DaqReadoutSvc::setFileRecord(const FileBuffer* record) {
    if (record->isMarked(FileTraits::kFileStartRecord)) {
        const FileStartRecord* fileRecord = dynamic_cast<const FileStartRecord*>(record);
        setFileRecord(fileRecord);
    } else if (record->isMarked(FileTraits::kFileNameStrings)) {
        const FileNameStrings* fileRecord = dynamic_cast<const FileNameStrings*>(record);
        setFileRecord(fileRecord);
    } else if (record->isMarked(FileTraits::kMetadataStrings)) {
        const MetadataStrings* fileRecord = dynamic_cast<const MetadataStrings*>(record);
        setFileRecord(fileRecord);
    } else if (record->isMarked(FileTraits::kRunParametersRecord)) {
        const RunParametersRecord* fileRecord = dynamic_cast<const RunParametersRecord*>(record);
        setFileRecord(fileRecord);
    } else if (record->isMarked(FileTraits::kCalibrationParametersRecord)) {
        const CalibrationParametersRecord* fileRecord = dynamic_cast<const CalibrationParametersRecord*>(record);
        setFileRecord(fileRecord);
    } else if (record->isMarked(FileTraits::kFileEndRecord)) {
        const FileEndRecord* fileRecord = dynamic_cast<const FileEndRecord*>(record);
        setFileRecord(fileRecord);
    }
}

void DaqReadoutSvc::setFileRecord(const FileStartRecord* record) {
    if (0 != m_fileStartRecord) {
        delete m_fileStartRecord;
    }
    m_fileStartRecord = record;
}

void DaqReadoutSvc::setFileRecord(const FileNameStrings* record) {
    if (0 != m_fileNameStrings) {
        delete m_fileNameStrings;
    }
    m_fileNameStrings = record;
}

void DaqReadoutSvc::setFileRecord(const MetadataStrings* record) {
    if (0 != m_metadataStrings) {
        delete m_metadataStrings;
    }
    m_metadataStrings = record;
}

void DaqReadoutSvc::setFileRecord(const RunParametersRecord* record) {
    if (0 != m_runParametersRecord) {
        delete m_runParametersRecord;
    }
    m_runParametersRecord = record;
}

void DaqReadoutSvc::setFileRecord(const CalibrationParametersRecord* record) {
    if (0 != m_calibrationParametersRecord) {
        delete m_calibrationParametersRecord;
    }
    m_calibrationParametersRecord = record;
}

void DaqReadoutSvc::setFileRecord(const FileEndRecord* record) {
    if (0 != m_fileEndRecord) {
        delete m_fileEndRecord;
    }
    m_fileEndRecord = record;
}

---