In This Package:

ArchiveTrimSvc.cpp

Go to the documentation of this file.

#include "ArchiveTrimSvc.h"
#include "TrimmingAgent.h"

#include "GaudiKernel/GaudiException.h"
#include "GaudiKernel/IDataManagerSvc.h"
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/SystemOfUnits.h"

ArchiveTrimSvc::ArchiveTrimSvc(const std::string& name,
                               ISvcLocator* svc) :
                                 Service(name,
                                         svc),
                                 m_agent(0) {
  declareProperty("DefaultWindowSeconds",
                  m_defaultWindowSeconds=0,
                  "The default length of the trim window in seconds.");
  m_defaultWindowSeconds.declareUpdateHandler(&ArchiveTrimSvc::updateWindow,
                                              this);
}

StatusCode ArchiveTrimSvc::queryInterface(const InterfaceID& id,
                                          void** interface) {
  if (IArchiveTrimSvc::interfaceID().versionMatch(id)) {
    // If good enough match return this object.
    *interface = (IArchiveTrimSvc*)this;
    addRef();
  } else {
    // Interface is not directly available: try out a base class.
    return Service::queryInterface(id,
                                   interface);
  }

  return StatusCode::SUCCESS;
}

StatusCode ArchiveTrimSvc::initialize() {
  StatusCode status = Service::initialize();
  if (status.isFailure()) {
    throw GaudiException("Could not initialize super class",
                         name(),
                         status);
  }

  m_agent = new TrimmingAgent(new MsgStream(msgSvc(),
                                            name()));
  this->_update();
  return StatusCode::SUCCESS;
}

StatusCode ArchiveTrimSvc::finalize() {
  if (0 != m_agent) {
    delete m_agent;
  }
  
  return Service::finalize();
}

void ArchiveTrimSvc::updateWindow(Property& ) {
    if (! m_agent) return;
    this->_update();
}

void ArchiveTrimSvc::_update() 
{
    MsgStream log(msgSvc(), name());

    TimeStamp dt(m_defaultWindowSeconds);

    log << MSG::INFO
        << "Setting default AES window to "
        << double(dt)
        << " seconds" << endreq;
    
    m_agent->setWindow(dt);
}

StatusCode ArchiveTrimSvc::trim(IDataManagerSvc* dataStore,
                                TimeStamp latest) {
  m_agent->setLatest(latest);
  return dataStore->traverseTree(m_agent);
}

const TimeStamp& ArchiveTrimSvc::window(const std::string& path) {
  if ( 0 == m_agent) {
    throw GaudiException("Service not yet initialized",
                         name(),
                         StatusCode::FAILURE);
  }
  return m_agent->window(path);
}

---