stor::Running Class Reference

#include <StateMachine.h>

Inheritance diagram for stor::Running:

Public Types
typedef bsc::transition < EmergencyStop, Stopping >	EST
typedef bsc::transition < EndRun, Stopping >	ET
typedef bsc::in_state_reaction < HaltDone, Running,&Running::logHaltDoneRequest >	HaltDoneIR
typedef bsc::transition< Halt, Halting >	HT
typedef boost::mpl::list< ET, EST, HT, StopDoneIR, HaltDoneIR >	reactions
typedef bsc::in_state_reaction < StopDone, Running,&Running::logStopDoneRequest >	StopDoneIR

Public Member Functions
void	logHaltDoneRequest (const HaltDone &request)
void	logStopDoneRequest (const StopDone &request)
	Running (my_context)
virtual	~Running ()
Public Member Functions inherited from stor::Operations
void	moveToFailedState (xcept::Exception &exception) const
void	noFragmentToProcess () const
	Operations ()
void	processI2OFragment (I2OChain &frag) const
std::string	stateName () const
virtual	~Operations ()=0

Private Member Functions
virtual void	do_entryActionWork ()
virtual void	do_exitActionWork ()
virtual void	do_moveToFailedState (xcept::Exception &exception) const
virtual std::string	do_stateName () const

Additional Inherited Members
Protected Member Functions inherited from stor::Operations
virtual void	do_noFragmentToProcess () const
virtual void	do_processI2OFragment (I2OChain &frag) const
void	safeEntryAction ()
void	safeExitAction ()

Detailed Description

Running state

Author:

mommsen

Revision:

1.10.12.1

Date:

2011/03/07 11:33:04

Definition at line 469 of file StateMachine.h.

Member Typedef Documentation

typedef bsc::transition<EmergencyStop,Stopping> stor::Running::EST

Definition at line 478 of file StateMachine.h.

typedef bsc::transition<EndRun,Stopping> stor::Running::ET

Definition at line 477 of file StateMachine.h.

typedef bsc::in_state_reaction<HaltDone,Running,&Running::logHaltDoneRequest> stor::Running::HaltDoneIR

Definition at line 481 of file StateMachine.h.

typedef bsc::transition<Halt,Halting> stor::Running::HT

Definition at line 479 of file StateMachine.h.

typedef boost::mpl::list<ET,EST,HT,StopDoneIR,HaltDoneIR> stor::Running::reactions

Definition at line 482 of file StateMachine.h.

typedef bsc::in_state_reaction<StopDone,Running,&Running::logStopDoneRequest> stor::Running::StopDoneIR

Definition at line 480 of file StateMachine.h.

Constructor & Destructor Documentation

Running::Running

(

my_context

c

)

Definition at line 19 of file Running.cc.

References stor::Operations::safeEntryAction().

                              : my_base(c)
{
  safeEntryAction();
}

Running::~Running ( )

virtual

Definition at line 52 of file Running.cc.

References stor::Operations::safeExitAction().

{
  safeExitAction();
}

Member Function Documentation

void Running::do_entryActionWork ( )

privatevirtual

Implements stor::Operations.

Definition at line 24 of file Running.cc.

References stor::EventDistributor::clearConsumers(), stor::EventDistributor::registerErrorStreams(), stor::EventDistributor::registerEventStreams(), and stor::Operations::stateName().

{

  TransitionRecord tr( stateName(), true );
  outermost_context().updateHistory( tr );

  SharedResourcesPtr sharedResources =
    outermost_context().getSharedResources();

  // Configure event distributor
  EventDistributor* ed = outermost_context().getEventDistributor();
  EvtStrConfigListPtr evtCfgList = sharedResources->configuration_->
    getCurrentEventStreamConfig();
  ErrStrConfigListPtr errCfgList = sharedResources->configuration_->
    getCurrentErrorStreamConfig();
  ed->registerEventStreams(evtCfgList);
  ed->registerErrorStreams(errCfgList);

  // Clear old consumer registrations:
  sharedResources->registrationCollection_->clearRegistrations();
  ed->clearConsumers();
  sharedResources->eventQueueCollection_->removeQueues();
  sharedResources->dqmEventQueueCollection_->removeQueues();

  // Enable consumer registration:
  sharedResources->registrationCollection_->enableConsumerRegistration();
}

void Running::do_exitActionWork ( )

privatevirtual

Implements stor::Operations.

Definition at line 57 of file Running.cc.

References stor::Operations::stateName().

{

  TransitionRecord tr( stateName(), false );
  outermost_context().updateHistory( tr );

  SharedResourcesPtr sharedResources =
    outermost_context().getSharedResources();

  // Disable consumer registration:
  sharedResources->registrationCollection_->disableConsumerRegistration();

  // Clear consumer queues
  sharedResources->eventQueueCollection_->clearQueues();
  sharedResources->dqmEventQueueCollection_->clearQueues();

  // Clear the queues
  sharedResources->fragmentQueue_->clear();
  sharedResources->streamQueue_->clear();
  sharedResources->dqmEventQueue_->clear();
  sharedResources->registrationQueue_->clear();

  // Clear any fragments left in the fragment store
  outermost_context().getFragmentStore()->clear();

}

void Running::do_moveToFailedState ( xcept::Exception &  exception ) const

privatevirtual

Implements stor::Operations.

Definition at line 89 of file Running.cc.

{
  outermost_context().getSharedResources()->moveToFailedState( exception );
}

string Running::do_stateName ( ) const

privatevirtual

Implements stor::Operations.

Definition at line 84 of file Running.cc.

{
  return std::string( "Running" );
}

void Running::logHaltDoneRequest

(

const HaltDone &

request

)

Definition at line 99 of file Running.cc.

{
  outermost_context().unconsumed_event( request );
}

void Running::logStopDoneRequest

(

const StopDone &

request

)

Definition at line 94 of file Running.cc.

{
  outermost_context().unconsumed_event( request );
}