SegMemSvc.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#include "StoreGate/SegMemSvc.h"
 
#include "GaudiKernel/ISvcLocator.h"
#include "GaudiKernel/IIncidentSvc.h"
#include "GaudiKernel/Incident.h"
 
using namespace std;
 
 
//
//
 
SegMemSvc::SegMemSvc( const std::string& name, ISvcLocator* svc )
  : base_class( name, svc ), p_incSvc("IncidentSvc",name),
    m_arena_job("sms_job",&m_ahead_job), 
    m_arena_evt("sms_evt",&m_ahead_evt), 
    m_arena_inc("sms_inc",&m_ahead_inc) 
{
 
}
 
 
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 
SegMemSvc::~SegMemSvc() {
 
}
 
 
 
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 
StatusCode
SegMemSvc::initialize() {
 
  SG::Arena::Push push(m_arena_job);
  SG::Arena::Push push2(m_arena_evt);
  SG::Arena::Push push3(m_arena_inc);
 
  //   m_ahead.addArena(&m_arena);
 
  
  p_incSvc->addListener( this, "EndEvent" );
  p_incSvc->addListener( this, "DefragMemory" );
 
  return StatusCode::SUCCESS;
 
}
 
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 
void 
SegMemSvc::handle(const Incident& inc) {
 
  if (inc.type() == "EndEvent") {
    if (msgStream().level() <= MSG::DEBUG) {
      std::ostringstream ost;
      m_ahead_evt.report(ost);
      debug() << "Running report for " << m_arena_evt.name()
              << ost.str() << endmsg;
    }
 
    debug() << "freeing all memory allocated for Event" << endmsg;
    m_arena_evt.reset();
    m_ahead_evt.reset();
 
  } else if ( inc.type() == "DefragMemory") {
 
    if (msgStream().level() <= MSG::DEBUG) {
      debug() << "defragmenting memory" << endmsg;
    }
    debug() << "freeing all memory allocated associated with "
            << "DefragMemory incident" << endmsg;
    m_arena_inc.reset();
    m_ahead_inc.reset();
  }
 
}