DaqFormatSelector.cc

Go to the documentation of this file.

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

#include "DaqFormatContext.h"
#include "StructureConverter.h"

#include "DaqReadoutSvc/IDaqReadoutSvc.h"

using DybDaq::DaqFormatContext;
using DybDaq::DaqFormatSelector;
using DybDaq::StructureConverter;
using std::vector;
using std::string;

DaqFormatSelector::DaqFormatSelector(const std::string& name,
                                     ISvcLocator* svc) :
Service(name,
            svc),
m_inputFiles(new vector<string>()) {
    declareProperty("InputFiles",
                    *m_inputFiles,
                    "List of input data files");
}

DaqFormatSelector::~DaqFormatSelector() {
    if (0 != m_inputFiles) {
        delete m_inputFiles;
    }
}

StatusCode DaqFormatSelector::initialize() {
    StatusCode status = Service::initialize();
    if (status.isFailure()) {
        return status;
    }
    return service("DaqReadoutSvc",
                     "DaqReadoutSvc",
                     m_daqSvc);
}

StatusCode DaqFormatSelector::finalize()
{
    if (0 != m_daqSvc) {
        m_daqSvc->release();
    }
    return Service::finalize();
}

StatusCode DaqFormatSelector::createContext(Context*& context) const {
    context = new DaqFormatContext(*m_inputFiles,
                                   *msgSvc(),
                                   *m_daqSvc);
    return StatusCode::SUCCESS;
}

StatusCode DaqFormatSelector::next(Context& context) const {
    return next(context,
                m_daqSvc->samplingInterval());
}


StatusCode DaqFormatSelector::next(Context& context,
                                   int jump) const {
    DaqFormatContext* ctxt = dynamic_cast<DaqFormatContext*>(&context);
    return ctxt->jump(jump);
}


StatusCode DaqFormatSelector::createAddress(const Context& context,
                                            IOpaqueAddress*& iop) const {
    const DaqFormatContext* ctxt = dynamic_cast<const DaqFormatContext*>(&context);
    StatusCode status = ctxt->isGoodEvent();
    if (status.isFailure()) {
        return status;
    }
    iop = new StructureConverter::Address(*ctxt,
                                          StructureConverter::kEvent);
    return StatusCode::SUCCESS;
}


StatusCode DaqFormatSelector::releaseContext(Context*& context) const {
    if (0 != context) {
        delete context;
    }
    return StatusCode::SUCCESS;
}


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

StatusCode DaqFormatSelector::previous(Context& /* context */) const {
    return StatusCode::FAILURE;
}

StatusCode DaqFormatSelector::previous(Context& /* context */,
                                       int /* jump */) const {
    return StatusCode::FAILURE;
}

StatusCode DaqFormatSelector::last(Context& /* context */) const {
    return StatusCode::FAILURE;
}

StatusCode DaqFormatSelector::rewind(Context& /* context */) const {
    return StatusCode::FAILURE;
}

StatusCode DaqFormatSelector::resetCriteria(const std::string& /* criteria */,
                                            Context& /* context */) const {
    return StatusCode::FAILURE;
}