HiveSlimEventLoopMgr Class Reference

#include <GaudiHive/HiveSlimEventLoopMgr.h>

Inheritance diagram for HiveSlimEventLoopMgr:

Collaboration diagram for HiveSlimEventLoopMgr:

Public Member Functions
	HiveSlimEventLoopMgr (const std::string &nam, ISvcLocator *svcLoc)
	Standard Constructor. More...
virtual	~HiveSlimEventLoopMgr ()
	Standard Destructor. More...
StatusCode	getEventRoot (IOpaqueAddress *&refpAddr)
	Create event address using event selector. More...
virtual StatusCode	initialize ()
	implementation of IService::initialize More...
virtual StatusCode	reinitialize ()
	implementation of IService::reinitialize More...
virtual StatusCode	stop ()
	implementation of IService::stop More...
virtual StatusCode	finalize ()
	implementation of IService::finalize More...
virtual StatusCode	nextEvent (int maxevt)
	implementation of IService::nextEvent More...
virtual StatusCode	executeEvent (void *par)
	implementation of IEventProcessor::executeEvent(void* par) More...
virtual StatusCode	executeRun (int maxevt)
	implementation of IEventProcessor::executeRun() More...
virtual StatusCode	stopRun ()
	implementation of IEventProcessor::stopRun() More...
Public Member Functions inherited from extends< BASE, Interfaces >
void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...
StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...
std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...
	~extends () override=default
	Virtual destructor. More...
void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...
StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...
std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...
	~extends () override=default
	Virtual destructor. More...
Public Member Functions inherited from extend_interfaces< Interfaces...>
	~extend_interfaces () override=default
	Virtual destructor. More...
	~extend_interfaces () override=default
	Virtual destructor. More...

Protected Member Functions
StatusCode	clearWBSlot (int evtSlot)
	Clear a slot in the WB. More...
StatusCode	declareEventRootAddress ()
	Declare the root address of the event. More...
StatusCode	createEventContext (EventContext *&eventContext, int createdEvents)
	Create event context. More...
StatusCode	drainScheduler (int &finishedEvents)
	Drain the scheduler from all actions that may be queued. More...

Protected Attributes
SmartIF< IDataManagerSvc >	m_evtDataMgrSvc
	Reference to the Event Data Service's IDataManagerSvc interface. More...
SmartIF< IEvtSelector >	m_evtSelector
	Reference to the Event Selector. More...
IEvtSelector::Context *	m_evtContext
	Event Iterator. More...
std::string	m_evtsel
	Event selector. More...
SmartIF< IDataManagerSvc >	m_histoDataMgrSvc
	Reference to the Histogram Data Service. More...
SmartIF< IConversionSvc >	m_histoPersSvc
	Reference to the Histogram Persistency Service. More...
SmartIF< IHiveWhiteBoard >	m_whiteboard
	Reference to the Whiteboard. More...
SmartIF< IAlgResourcePool >	m_algResourcePool
	Reference to the Algorithm resource pool. More...
std::string	m_histPersName
	Name of the Hist Pers type. More...
SmartIF< IProperty >	m_appMgrProperty
	Property interface of ApplicationMgr. More...
bool	m_endEventFired
	Flag to avoid to fire the EnvEvent incident twice in a row (and also not before the first event) More...
bool	m_warnings
	Flag to disable warning messages when using external input. More...
SmartIF< IScheduler >	m_schedulerSvc
	A shortcut for the scheduler. More...
SmartIF< IIncidentListener >	m_abortEventListener
	Instance of the incident listener waiting for AbortEvent. More...
std::string	m_schedulerName
	Name of the scheduler to be used. More...
bool	m_scheduledStop
	Scheduled stop of event processing. More...
SmartIF< IAppMgrUI >	m_appMgrUI
	Reference to the IAppMgrUI interface of the application manager. More...
SmartIF< IIncidentSvc >	m_incidentSvc
	Reference to the incident service. More...
std::vector< unsigned int >	m_eventNumberBlacklist
	List of events to be skipped. The number is the number in the job. More...
boost::dynamic_bitset *	m_blackListBS

Additional Inherited Members
Public Types inherited from extends< BASE, Interfaces >
using	base_class = extends
	Typedef to this class. More...
using	extend_interfaces_base = extend_interfaces< Interfaces...>
	Typedef to the base of this class. More...
using	base_class = extends
	Typedef to this class. More...
using	extend_interfaces_base = extend_interfaces< Interfaces...>
	Typedef to the base of this class. More...
Public Types inherited from extend_interfaces< Interfaces...>
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...

Detailed Description

Definition at line 25 of file HiveSlimEventLoopMgr.h.

Constructor & Destructor Documentation

HiveSlimEventLoopMgr::HiveSlimEventLoopMgr	(	const std::string &	nam,
		ISvcLocator *	svcLoc
	)

Standard Constructor.

Definition at line 47 of file HiveSlimEventLoopMgr.cpp.

:  base_class(name, svcLoc), m_appMgrUI(svcLoc)
{
  m_histoDataMgrSvc   = 0;
  m_histoPersSvc      = 0;
  m_evtDataMgrSvc     = 0;
  m_whiteboard        = 0;
  m_evtSelector       = 0;
  m_evtContext        = 0;
  m_blackListBS  = nullptr;

  // Declare properties
  declareProperty("HistogramPersistency", m_histPersName = "");
  declareProperty("EvtSel", m_evtsel );
  declareProperty("Warnings",m_warnings=true,
      "Set this property to false to suppress warning messages");
  declareProperty("SchedulerName", m_schedulerName="ForwardSchedulerSvc",
                  "Name of the scheduler to be used");
  declareProperty("EventNumberBlackList", m_eventNumberBlacklist);

  m_scheduledStop = false;

}

HiveSlimEventLoopMgr::~HiveSlimEventLoopMgr ( )

virtual

Standard Destructor.

Definition at line 74 of file HiveSlimEventLoopMgr.cpp.

                                              {
  if( m_histoDataMgrSvc ) m_histoDataMgrSvc->release();
  if( m_histoPersSvc ) m_histoPersSvc->release();
  if( m_evtDataMgrSvc ) m_evtDataMgrSvc->release();
  if( m_whiteboard ) m_whiteboard->release();
  if( m_evtSelector ) m_evtSelector->release();
  if( m_evtContext ) delete m_evtContext;
}

Member Function Documentation

StatusCode HiveSlimEventLoopMgr::clearWBSlot ( int  evtSlot )

protected

Clear a slot in the WB.

Definition at line 673 of file HiveSlimEventLoopMgr.cpp.

                                                         {
  StatusCode sc = m_whiteboard->clearStore(evtSlot);
  if( !sc.isSuccess() )  {
    warning() << "Clear of Event data store failed" << endmsg;
  }
  return m_whiteboard->freeStore(evtSlot);
}

StatusCode HiveSlimEventLoopMgr::createEventContext ( EventContext *&  eventContext, int  createdEvents  )

protected

Create event context.

Definition at line 594 of file HiveSlimEventLoopMgr.cpp.

                                                                                              {
  evtContext = new EventContext;

  evtContext->set(createdEvts, m_whiteboard->allocateStore(createdEvts));

  StatusCode sc = m_whiteboard->selectStore(evtContext->slot());
  if (sc.isFailure()){
    warning() << "Slot " << evtContext->slot()
              << " could not be selected for the WhiteBoard" << endmsg;
  }
  return sc;
}

StatusCode HiveSlimEventLoopMgr::declareEventRootAddress ( )

protected

Declare the root address of the event.

Definition at line 566 of file HiveSlimEventLoopMgr.cpp.

                                                        {

  StatusCode sc;
  if( m_evtContext ) {
      //---This is the "event iterator" context from EventSelector
      IOpaqueAddress* pAddr = 0;
      sc = getEventRoot(pAddr);
      if( !sc.isSuccess() )  {
          info() << "No more events in event selection " << endmsg;
          return StatusCode::FAILURE;
      }
      sc = m_evtDataMgrSvc->setRoot ("/Event", pAddr);
      if( !sc.isSuccess() )  {
          warning() << "Error declaring event root address." << endmsg;
      }
  }
  else {
      //---In case of no event selector----------------
      sc = m_evtDataMgrSvc->setRoot ("/Event", new DataObject());
      if( !sc.isSuccess() )  {
          warning() << "Error declaring event root DataObject" << endmsg;
      }
  }
  return StatusCode::SUCCESS;
}

StatusCode HiveSlimEventLoopMgr::drainScheduler ( int &  finishedEvents )

protected

Drain the scheduler from all actions that may be queued.

Definition at line 609 of file HiveSlimEventLoopMgr.cpp.

                                                                {

  StatusCode sc(StatusCode::SUCCESS);

  // maybe we can do better
  std::vector<EventContext*> finishedEvtContexts;

  EventContext* finishedEvtContext(nullptr);

  // Here we wait not to loose cpu resources
  debug() << "Waiting for a context" << endmsg;
  sc = m_schedulerSvc->popFinishedEvent(finishedEvtContext);

  // We got past it: cache the pointer
  if (sc.isSuccess()){
    debug() << "Context obtained" << endmsg;
  } else{
    // A problem occurred.
    debug() << "Context not obtained: a problem in the scheduling?" << endmsg;
//     return StatusCode::FAILURE;
  }
  finishedEvtContexts.push_back(finishedEvtContext);

  // Let's see if we can pop other event contexts
  while (m_schedulerSvc->tryPopFinishedEvent(finishedEvtContext).isSuccess()){
    finishedEvtContexts.push_back(finishedEvtContext);
  }

  // Now we flush them
  StatusCode finalSC;
  for (auto& thisFinishedEvtContext : finishedEvtContexts){
    if (nullptr == thisFinishedEvtContext){
      error() << "Detected nullptr ctxt before clearing WB!"<< endmsg;
      finalSC = StatusCode::FAILURE;
      continue;
    }
    if (thisFinishedEvtContext->evtFail()){
      fatal() << "Failed event detected"<< endmsg;
      finalSC = StatusCode::FAILURE;
    }

    m_incidentSvc->fireIncident(Incident(name(), IncidentType::EndProcessing));
    m_incidentSvc->fireIncident(Incident(name(),IncidentType::EndEvent));

    debug() << "Clearing slot " << thisFinishedEvtContext->slot()
        << " (event " << thisFinishedEvtContext->evt()
          << ") of the whiteboard" << endmsg;

    StatusCode sc = clearWBSlot(thisFinishedEvtContext->slot());
    if (!sc.isSuccess())
      error() << "Whiteboard slot " << thisFinishedEvtContext->slot()
                << " could not be properly cleared";


    delete thisFinishedEvtContext;

    finishedEvts++;

  }
  return finalSC;
}

StatusCode HiveSlimEventLoopMgr::executeEvent ( void *  par )

virtual

implementation of IEventProcessor::executeEvent(void* par)

Definition at line 334 of file HiveSlimEventLoopMgr.cpp.

                                                                         {

  // Leave the interface intact and swallow this C trick.
  int& createdEvts = *((int*)createdEvts_IntPtr);

  EventContext* evtContext(nullptr);

  // Check if event number is in blacklist
  if(LIKELY(m_blackListBS != nullptr)){ //we are processing a finite number of events, use bitset blacklist
      if(m_blackListBS->test(createdEvts)){
          verbose() << "Event " << createdEvts  << " on black list" << endmsg;
          return StatusCode::RECOVERABLE;
      }
  } else  if(std::binary_search(m_eventNumberBlacklist.begin(),m_eventNumberBlacklist.end(),createdEvts)){

      verbose() << "Event " << createdEvts  << " on black list" << endmsg;
      return StatusCode::RECOVERABLE;
  }

  if ( createEventContext(evtContext,createdEvts).isFailure() ){
    fatal() << "Impossible to create event context" << endmsg;
    return StatusCode::FAILURE;
  }

  verbose() << "Beginning to process event " <<  createdEvts << endmsg;

  // An incident may schedule a stop, in which case is better to exit before the actual execution.
  // DP have to find out who shoots this
/*  if ( m_scheduledStop ) {
    always() << "Terminating event processing loop due to a stop scheduled by an incident listener" << endmsg;
    return StatusCode::SUCCESS;
  }*/


  StatusCode declEvtRootSc = declareEventRootAddress();
  if (declEvtRootSc.isFailure()) { // We ran out of events!
    createdEvts = -1;  // Set created event to a negative value: we finished!
    return StatusCode::SUCCESS;
    }

  // Fire BeginEvent "Incident"
  m_incidentSvc->fireIncident(Incident(name(),IncidentType::BeginEvent));

  // Now add event to the scheduler
  verbose() << "Adding event " << evtContext->evt()
     << ", slot " << evtContext->slot()
          << " to the scheduler" << endmsg;

  m_incidentSvc->fireIncident(Incident(name(), IncidentType::BeginProcessing));

  StatusCode addEventStatus = m_schedulerSvc->pushNewEvent(evtContext);

  // If this fails, we need to wait for something to complete
  if (!addEventStatus.isSuccess()){
      fatal() << "An event processing slot should be now free in the scheduler, but it appears not to be the case." << endmsg;
  }

  createdEvts++;
  return StatusCode::SUCCESS;

}

StatusCode HiveSlimEventLoopMgr::executeRun ( int  maxevt )

virtual

implementation of IEventProcessor::executeRun()

Definition at line 399 of file HiveSlimEventLoopMgr.cpp.

                                                           {
  StatusCode  sc;
  bool eventfailed = false;

  if(maxevt > 0){ //finite number of events to process
    const unsigned int umaxevt = static_cast<unsigned int>(maxevt);
    m_blackListBS = new boost::dynamic_bitset<>(maxevt); //all initialized to zero
    for(unsigned int i = 0; i < m_eventNumberBlacklist.size() && m_eventNumberBlacklist[i] <= umaxevt; ++i ){ //black list is sorted in init
      m_blackListBS->set(m_eventNumberBlacklist[i], true);
    }
  }

  sc = m_algResourcePool->beginRun();
  if (sc.isFailure())
    eventfailed=true;

  // Call now the nextEvent(...)
  sc = nextEvent(maxevt);
  if (!sc.isSuccess())
    eventfailed = true;

  sc = m_algResourcePool->endRun();
  if (sc.isFailure())
    eventfailed=true;

  if(m_blackListBS != nullptr)
      delete m_blackListBS;

  if (eventfailed)
    return StatusCode::FAILURE;
  else
    return StatusCode::SUCCESS;
}

StatusCode HiveSlimEventLoopMgr::finalize ( )

virtual

implementation of IService::finalize

Definition at line 260 of file HiveSlimEventLoopMgr.cpp.

                                             {

  StatusCode scRet;
  StatusCode sc = Service::finalize();

  if (sc.isFailure()) {
    scRet = StatusCode::FAILURE;
    error() << "Problems finalizing Service base class" << endmsg;
  }

  // Save Histograms Now
  if ( m_histoPersSvc != 0 )    {
    HistogramAgent agent;
    sc = m_histoDataMgrSvc->traverseTree( &agent );
    if( sc.isSuccess() )   {
      IDataSelector* objects = agent.selectedObjects();
      // skip /stat entry!
      if ( objects->size() > 0 )    {
        IDataSelector::iterator i;
        for ( i = objects->begin(); i != objects->end(); i++ )    {
          IOpaqueAddress* pAddr = 0;
          StatusCode iret = m_histoPersSvc->createRep(*i, pAddr);
          if ( iret.isSuccess() )     {
            (*i)->registry()->setAddress(pAddr);
          }
          else  {
            sc = iret;
          }
        }
        for ( i = objects->begin(); i != objects->end(); i++ )    {
          IRegistry* reg = (*i)->registry();
          StatusCode iret = m_histoPersSvc->fillRepRefs(reg->address(), *i);
          if ( !iret.isSuccess() )    {
            sc = iret;
          }
        }
      }
      if ( sc.isSuccess() )    {
        info() << "Histograms converted successfully according to request." << endmsg;
      }
      else  {
        error() << "Error while saving Histograms." << endmsg;
      }
    }
    else {
      error() << "Error while traversing Histogram data store" << endmsg;
    }
  }

  scRet=sc;

  // Release event selector context
  if ( m_evtSelector && m_evtContext )   {
    m_evtSelector->releaseContext(m_evtContext).ignore();
    m_evtContext = 0;
  }

  m_incidentSvc = 0; // release
  m_appMgrUI = 0; // release

  // Release all interfaces...
  m_histoDataMgrSvc = 0;
  m_histoPersSvc    = 0;

  m_evtSelector     = 0;
  m_whiteboard      = 0;
  m_evtDataMgrSvc   = 0;

  return scRet;
}

StatusCode HiveSlimEventLoopMgr::getEventRoot

(

IOpaqueAddress *&

refpAddr

)

Create event address using event selector.

Definition at line 544 of file HiveSlimEventLoopMgr.cpp.

                                                                        {
  refpAddr = 0;
  StatusCode sc = m_evtSelector->next(*m_evtContext);
  if ( !sc.isSuccess() )  {
    return sc;
  }
  // Create root address and assign address to data service
  sc = m_evtSelector->createAddress(*m_evtContext,refpAddr);
  if( !sc.isSuccess() )  {
    sc = m_evtSelector->next(*m_evtContext);
    if ( sc.isSuccess() )  {
      sc = m_evtSelector->createAddress(*m_evtContext,refpAddr);
      if ( !sc.isSuccess() )  {
        warning() << "Error creating IOpaqueAddress." << endmsg;
      }
    }
  }
  return sc;
}

StatusCode HiveSlimEventLoopMgr::initialize ( )

virtual

implementation of IService::initialize

Definition at line 86 of file HiveSlimEventLoopMgr.cpp.

                                               {

    if ( !m_appMgrUI.isValid() ) {
        return StatusCode::FAILURE;
    }

    StatusCode sc = Service::initialize();
    if ( !sc.isSuccess() )   {
        error() << "Failed to initialize Service Base class." << endmsg;
        return StatusCode::FAILURE;
    }

    // Get the references to the services that are needed by the ApplicationMgr itself
    m_incidentSvc = serviceLocator()->service("IncidentSvc");
    if( !m_incidentSvc.isValid() )  {
        fatal() << "Error retrieving IncidentSvc." << endmsg;
        return StatusCode::FAILURE;
    }

    // Setup access to event data services
    m_evtDataMgrSvc = serviceLocator()->service("EventDataSvc");
    if( !m_evtDataMgrSvc.isValid() )  {
        fatal() << "Error retrieving EventDataSvc interface IDataManagerSvc." << endmsg;
        return StatusCode::FAILURE;
    }
    m_whiteboard = serviceLocator()->service("EventDataSvc");
    if( !m_whiteboard.isValid() )  {
        fatal() << "Error retrieving EventDataSvc interface IHiveWhiteBoard." << endmsg;
        return StatusCode::FAILURE;
    }
    m_schedulerSvc = serviceLocator()->service(m_schedulerName);
    if ( !m_schedulerSvc.isValid()){
        fatal() << "Error retrieving SchedulerSvc interface ISchedulerSvc." << endmsg;
        return StatusCode::FAILURE;
    }
    // Obtain the IProperty of the ApplicationMgr
    m_appMgrProperty = serviceLocator();
    if ( ! m_appMgrProperty.isValid() )   {
        fatal() << "IProperty interface not found in ApplicationMgr." << endmsg;
        return StatusCode::FAILURE;
    }

    // We do not expect a Event Selector necessarily being declared
    setProperty(m_appMgrProperty->getProperty("EvtSel")).ignore();

    if( m_evtsel != "NONE" || m_evtsel.length() == 0) {
        m_evtSelector = serviceLocator()->service("EventSelector");
        if( m_evtSelector.isValid() ) {
            // Setup Event Selector
            sc=m_evtSelector->createContext(m_evtContext);
            if( !sc.isSuccess() )   {
                fatal() << "Can not create the event selector Context." << endmsg;
                return sc;
            }
        }
        else {
            fatal() << "EventSelector not found." << endmsg;
            return sc;
        }
    }
    else {
        m_evtSelector = 0;
        m_evtContext = 0;
        if ( m_warnings ) {
            warning() << "Unable to locate service \"EventSelector\" " << endmsg;
            warning() << "No events will be processed from external input." << endmsg;
        }
    }

    // Setup access to histogramming services
    m_histoDataMgrSvc = serviceLocator()->service("HistogramDataSvc");
    if( !m_histoDataMgrSvc.isValid() )  {
        fatal() << "Error retrieving HistogramDataSvc." << endmsg;
        return sc;
    }
    // Setup histogram persistency
    m_histoPersSvc = serviceLocator()->service("HistogramPersistencySvc");
    if( !m_histoPersSvc.isValid() ) {
        warning() << "Histograms cannot not be saved - though required." << endmsg;
        return sc;
    }

    // Setup algorithm resource pool
    m_algResourcePool = serviceLocator()->service("AlgResourcePool");
    if( !m_algResourcePool.isValid() ) {
        fatal() << "Error retrieving AlgResourcePool" << endmsg;
        return StatusCode::FAILURE;
    }

    std::sort(m_eventNumberBlacklist.begin(), m_eventNumberBlacklist.end());
    info() << "Found " << m_eventNumberBlacklist.size() << " events in black list" << endmsg;

    return StatusCode::SUCCESS;
}

StatusCode HiveSlimEventLoopMgr::nextEvent ( int  maxevt )

virtual

implementation of IService::nextEvent

Definition at line 454 of file HiveSlimEventLoopMgr.cpp.

                                                       {

  // Calculate runtime
  typedef std::chrono::high_resolution_clock Clock;
  typedef Clock::time_point time_point;

  // Reset the application return code.
  Gaudi::setAppReturnCode(m_appMgrProperty, Gaudi::ReturnCode::Success, true).ignore();

  int finishedEvts =0;
  int createdEvts =0;
  int skippedEvts = 0;
  info() << "Starting loop on events" << endmsg;
  // Loop until the finished events did not reach the maxevt number
  bool loop_ended = false;
  // Run the first event before spilling more than one
  bool newEvtAllowed = false ;

  constexpr double oneOver1204 = 1./1024.;

  uint iteration = 0;
  time_point start_time = Clock::now();
  while ( !loop_ended and (maxevt < 0 or (finishedEvts+skippedEvts) < maxevt)){
      debug() << "work loop iteration " << iteration++ << endmsg;
    // if the created events did not reach maxevt, create an event
    if ((newEvtAllowed or createdEvts == 0 ) && // Launch the first event alone
        createdEvts >= 0 && // The events are not finished with an unlimited number of events
        (createdEvts < maxevt or maxevt<0) &&  // The events are not finished with a limited number of events
        m_schedulerSvc->freeSlots()>0){ // There are still free slots in the scheduler

      if (1==createdEvts) // reset counter to count from event 1
        start_time = Clock::now();

      debug() << "createdEvts: " << createdEvts << ", freeslots: " << m_schedulerSvc->freeSlots() << endmsg;
//  DP remove to remove the syscalls...
//      if (0!=createdEvts){
//        info()   << "Event Number = " << createdEvts
//                 << " WSS (MB) = " << System::mappedMemory(System::MemoryUnit::kByte)*oneOver1204
//                << " Time (s) = " << secsFromStart(start_time) << endmsg;
//        }

      //TODO can we adapt the interface of executeEvent for a nicer solution?
      StatusCode sc = StatusCode::RECOVERABLE;
      while(!sc.isSuccess() //we haven't created an event yet
              && (createdEvts < maxevt or maxevt<0)){ //redunant check for maxEvts, can we do better?
          sc = executeEvent(&createdEvts);

          if (sc.isRecoverable()){ //we skipped an event

              //this is all to skip the event
              size_t slot = m_whiteboard->allocateStore(createdEvts); //we need a new store, not to change the previous event
              m_whiteboard->selectStore(slot);
              declareEventRootAddress(); //actually skip over the event
              m_whiteboard->freeStore(slot); // delete the store

              ++createdEvts;
              ++skippedEvts;
          } else if (sc.isRecoverable()){ //exit immediatly
              return StatusCode::FAILURE;
          } // else we have an success --> exit loop
      }

    } // end if condition createdEvts < maxevt
    else{
      // all the events were created but not all finished or the slots were
      // all busy: the scheduler should finish its job

      debug() << "Draining the scheduler" << endmsg;

      // Pull out of the scheduler the finished events
      if (drainScheduler(finishedEvts).isFailure()){
        loop_ended = true;
      }
      newEvtAllowed = true;
    }
  } // end main loop on finished events
  time_point end_time = Clock::now();

  info() << "---> Loop Finished (skipping 1st evt) - "
         << " WSS " << System::mappedMemory(System::MemoryUnit::kByte)*oneOver1204
         << " total time " << std::chrono::duration_cast < std::chrono::nanoseconds > (end_time - start_time).count() <<endmsg;
  info() << skippedEvts << " events were SKIPed" << endmsg;

  return StatusCode::SUCCESS;

}

StatusCode HiveSlimEventLoopMgr::reinitialize ( )

virtual

implementation of IService::reinitialize

Definition at line 183 of file HiveSlimEventLoopMgr.cpp.

                                              {


  // Check to see whether a new Event Selector has been specified
  setProperty(m_appMgrProperty->getProperty("EvtSel"));
  if( m_evtsel != "NONE" || m_evtsel.length() == 0) {
    SmartIF<IService> theSvc(serviceLocator()->service("EventSelector"));
    SmartIF<IEvtSelector> theEvtSel(theSvc);
    StatusCode sc;
    if( theEvtSel.isValid() && ( theEvtSel.get() != m_evtSelector.get() ) ) {
      // Setup Event Selector
      if ( m_evtSelector.get() && m_evtContext ) {
        // Need to release context before switching to new event selector
        m_evtSelector->releaseContext(m_evtContext);
        m_evtContext = 0;
      }
      m_evtSelector = theEvtSel;
      if (theSvc->FSMState() == Gaudi::StateMachine::INITIALIZED) {
        sc = theSvc->reinitialize();
        if( !sc.isSuccess() ) {
          error() << "Failure Reinitializing EventSelector "
              << theSvc->name( ) << endmsg;
          return sc;
        }
      }
      else {
        sc = theSvc->sysInitialize();
        if( !sc.isSuccess() ) {
          error() << "Failure Initializing EventSelector "
              << theSvc->name( ) << endmsg;
          return sc;
        }
      }
      sc = m_evtSelector->createContext(m_evtContext);
      if( !sc.isSuccess() ) {
        error() << "Can not create Context " << theSvc->name( ) << endmsg;
        return sc;
      }

    }
    else if ( m_evtSelector.isValid() ) {
      if ( m_evtContext ) {
        m_evtSelector->releaseContext(m_evtContext);
        m_evtContext = 0;
      }
      sc = m_evtSelector->createContext(m_evtContext);
      if( !sc.isSuccess() ) {
        error() << "Can not create Context " << theSvc->name( ) << endmsg;
        return sc;
      }
    }
  }
  else if ( m_evtSelector.isValid() && m_evtContext ) {
    m_evtSelector->releaseContext(m_evtContext);
    m_evtSelector = 0;
    m_evtContext = 0;
  }
  return StatusCode::SUCCESS;
}

StatusCode HiveSlimEventLoopMgr::stop ( )

virtual

implementation of IService::stop

Definition at line 247 of file HiveSlimEventLoopMgr.cpp.

                                         {
  if ( ! m_endEventFired ) {
    // Fire pending EndEvent incident
    m_incidentSvc->fireIncident(Incident(name(),IncidentType::EndEvent));
    m_endEventFired = true;
  }
  return StatusCode::SUCCESS;
}

StatusCode HiveSlimEventLoopMgr::stopRun ( )

virtual

implementation of IEventProcessor::stopRun()

Definition at line 436 of file HiveSlimEventLoopMgr.cpp.

                                         {
  // Set the application return code
  SmartIF<IProperty> appmgr(serviceLocator());
  if(Gaudi::setAppReturnCode(appmgr, Gaudi::ReturnCode::ScheduledStop).isFailure()) {
    error() << "Could not set return code of the application ("
            << Gaudi::ReturnCode::ScheduledStop << ")" << endmsg;
  }
  m_scheduledStop = true;
  return StatusCode::SUCCESS;
}

Member Data Documentation

SmartIF< IIncidentListener > HiveSlimEventLoopMgr::m_abortEventListener

protected

Instance of the incident listener waiting for AbortEvent.

Definition at line 64 of file HiveSlimEventLoopMgr.h.

SmartIF<IAlgResourcePool> HiveSlimEventLoopMgr::m_algResourcePool

protected

Reference to the Algorithm resource pool.

Definition at line 43 of file HiveSlimEventLoopMgr.h.

SmartIF<IProperty> HiveSlimEventLoopMgr::m_appMgrProperty

protected

Property interface of ApplicationMgr.

Definition at line 47 of file HiveSlimEventLoopMgr.h.

SmartIF<IAppMgrUI> HiveSlimEventLoopMgr::m_appMgrUI

protected

Reference to the IAppMgrUI interface of the application manager.

Definition at line 70 of file HiveSlimEventLoopMgr.h.

boost::dynamic_bitset* HiveSlimEventLoopMgr::m_blackListBS

protected

Definition at line 78 of file HiveSlimEventLoopMgr.h.

bool HiveSlimEventLoopMgr::m_endEventFired

protected

Flag to avoid to fire the EnvEvent incident twice in a row (and also not before the first event)

Definition at line 50 of file HiveSlimEventLoopMgr.h.

std::vector<unsigned int> HiveSlimEventLoopMgr::m_eventNumberBlacklist

protected

List of events to be skipped. The number is the number in the job.

Definition at line 75 of file HiveSlimEventLoopMgr.h.

IEvtSelector::Context* HiveSlimEventLoopMgr::m_evtContext

protected

Event Iterator.

Definition at line 33 of file HiveSlimEventLoopMgr.h.

SmartIF<IDataManagerSvc> HiveSlimEventLoopMgr::m_evtDataMgrSvc

protected

Reference to the Event Data Service's IDataManagerSvc interface.

Definition at line 29 of file HiveSlimEventLoopMgr.h.

std::string HiveSlimEventLoopMgr::m_evtsel

protected

Event selector.

Definition at line 35 of file HiveSlimEventLoopMgr.h.

SmartIF<IEvtSelector> HiveSlimEventLoopMgr::m_evtSelector

protected

Reference to the Event Selector.

Definition at line 31 of file HiveSlimEventLoopMgr.h.

SmartIF<IDataManagerSvc> HiveSlimEventLoopMgr::m_histoDataMgrSvc

protected

Reference to the Histogram Data Service.

Definition at line 37 of file HiveSlimEventLoopMgr.h.

SmartIF<IConversionSvc> HiveSlimEventLoopMgr::m_histoPersSvc

protected

Reference to the Histogram Persistency Service.

Definition at line 39 of file HiveSlimEventLoopMgr.h.

std::string HiveSlimEventLoopMgr::m_histPersName

protected

Name of the Hist Pers type.

Definition at line 45 of file HiveSlimEventLoopMgr.h.

SmartIF<IIncidentSvc> HiveSlimEventLoopMgr::m_incidentSvc

protected

Reference to the incident service.

Definition at line 72 of file HiveSlimEventLoopMgr.h.

bool HiveSlimEventLoopMgr::m_scheduledStop

protected

Scheduled stop of event processing.

Definition at line 68 of file HiveSlimEventLoopMgr.h.

std::string HiveSlimEventLoopMgr::m_schedulerName

protected

Name of the scheduler to be used.

Definition at line 66 of file HiveSlimEventLoopMgr.h.

SmartIF<IScheduler> HiveSlimEventLoopMgr::m_schedulerSvc

protected

A shortcut for the scheduler.

Definition at line 54 of file HiveSlimEventLoopMgr.h.

bool HiveSlimEventLoopMgr::m_warnings

protected

Flag to disable warning messages when using external input.

Definition at line 52 of file HiveSlimEventLoopMgr.h.

SmartIF<IHiveWhiteBoard> HiveSlimEventLoopMgr::m_whiteboard

protected

Reference to the Whiteboard.

Definition at line 41 of file HiveSlimEventLoopMgr.h.

---

The documentation for this class was generated from the following files:

• GaudiHive/GaudiHive/HiveSlimEventLoopMgr.h
• GaudiHive/src/HiveSlimEventLoopMgr.cpp