In This Package:

TestIOIncidentAlg.cc

Go to the documentation of this file.

#include "TestIOIncidentAlg.h"
#include "RootIOSvc/RootIOIncident.h"

#include "GaudiKernel/IIncidentSvc.h"

TestIOIncidentAlg::TestIOIncidentAlg(const std::string& name,
                                     ISvcLocator*  pSvcLocator)
    : GaudiAlgorithm(name,pSvcLocator)
{
}

TestIOIncidentAlg::~TestIOIncidentAlg()
{
}

StatusCode TestIOIncidentAlg::initialize()
{
    StatusCode sc = GaudiAlgorithm::initialize();
    if (sc.isFailure()) return sc;

    // Get and hold on to the incident service and add ourself.
    m_incsvc = svc<IIncidentSvc>("IncidentSvc",true);
    m_incsvc->addListener(this,"RootIOIncident");

    info() << "initialize()" << endreq;

    return StatusCode::SUCCESS;
}

StatusCode TestIOIncidentAlg::execute()
{
    info() << "execute()" << endreq;

    return StatusCode::SUCCESS;
}

StatusCode TestIOIncidentAlg::finalize()
{
    info() << "finalize()" << endreq;

    // Must remove self.  O.w. we may finalize before RootIOSvc and
    // leave beind a dangling handler.
    m_incsvc->removeListener(this,"RootIOIncident");
    m_incsvc->release();

    return GaudiAlgorithm::finalize();
}

void TestIOIncidentAlg::handle(const Incident& incident)
{
    // Handle the incident in a trivial manner

    info() << "Got incident from \"" << incident.source()
           << "\" and type \"" << incident.type() << "\"" << endreq;
    const RootIOIncident* rioinc = dynamic_cast<const RootIOIncident*>(&incident);
    if (!rioinc) {
        warning() 
            << "Ignoring unexpected incident not of class RootIOIncident" 
            << endreq;
        return;
    }
    info () << "File name: \"" << rioinc->filename() 
            << "\" file state: \"" << rioinc->state() << "\"" 
            << endreq;
}

---