stor::Starting Class Reference

#include <StateMachine.h>

Inheritance diagram for stor::Starting:

Public Types
typedef bsc::transition < EmergencyStop, Stopping >	ET
typedef bsc::in_state_reaction < HaltDone, Starting,&Starting::logHaltDoneRequest >	HaltDoneIR
typedef boost::mpl::list< ST, ET, StopDoneIR, HaltDoneIR >	reactions
typedef bsc::transition < StartRun, Running >	ST
typedef bsc::in_state_reaction < StopDone, Starting,&Starting::logStopDoneRequest >	StopDoneIR

Public Member Functions
void	logHaltDoneRequest (const HaltDone &request)
void	logStopDoneRequest (const StopDone &request)
	Starting (my_context)
virtual	~Starting ()
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 void	do_noFragmentToProcess () const
virtual std::string	do_stateName () const
bool	workerThreadsConfigured () const

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

Detailed Description

Starting state

Author:

mommsen

Revision:

1.10.12.1

Date:

2011/03/07 11:33:04

Definition at line 369 of file StateMachine.h.

Member Typedef Documentation

typedef bsc::transition<EmergencyStop,Stopping> stor::Starting::ET

Definition at line 378 of file StateMachine.h.

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

Definition at line 380 of file StateMachine.h.

typedef boost::mpl::list<ST,ET,StopDoneIR,HaltDoneIR> stor::Starting::reactions

Definition at line 381 of file StateMachine.h.

typedef bsc::transition<StartRun,Running> stor::Starting::ST

Definition at line 377 of file StateMachine.h.

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

Definition at line 379 of file StateMachine.h.

Constructor & Destructor Documentation

Starting::Starting

(

my_context

c

)

Definition at line 20 of file Starting.cc.

References stor::Operations::safeEntryAction().

                                : my_base(c)
{
  safeEntryAction();
}

Starting::~Starting ( )

virtual

Definition at line 54 of file Starting.cc.

References stor::Operations::safeExitAction().

{
  safeExitAction();
}

Member Function Documentation

void Starting::do_entryActionWork ( )

privatevirtual

Implements stor::Operations.

Definition at line 25 of file Starting.cc.

References stor::WorkerThreadParams::DQMEPdeqWaitTime_, stor::WorkerThreadParams::DWdeqWaitTime_, and stor::Operations::stateName().

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

  SharedResourcesPtr sharedResources =
    outermost_context().getSharedResources();

  // Request DiskWriter to configure streams
  EvtStrConfigListPtr evtCfgList = sharedResources->configuration_->
    getCurrentEventStreamConfig();
  ErrStrConfigListPtr errCfgList = sharedResources->configuration_->
    getCurrentErrorStreamConfig();

  WorkerThreadParams workerParams =
    sharedResources->configuration_->getWorkerThreadParams();
  sharedResources->diskWriterResources_->
    requestStreamConfiguration(evtCfgList, errCfgList,
      sharedResources->configuration_->getDiskWritingParams(),
      sharedResources->configuration_->getRunNumber(),
      workerParams.DWdeqWaitTime_);

  // Request configuration of DQMEventProcessor
  sharedResources->dqmEventProcessorResources_->
    requestConfiguration(
      sharedResources->configuration_->getDQMProcessingParams(),
      workerParams.DQMEPdeqWaitTime_);
}

void Starting::do_exitActionWork ( )

privatevirtual

Implements stor::Operations.

Definition at line 59 of file Starting.cc.

References stor::Operations::stateName().

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

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

privatevirtual

Implements stor::Operations.

Definition at line 70 of file Starting.cc.

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

void Starting::do_noFragmentToProcess ( ) const

privatevirtual

Reimplemented from stor::Operations.

Definition at line 86 of file Starting.cc.

References workerThreadsConfigured().

{
  if ( workerThreadsConfigured() )
  {
    SharedResourcesPtr sharedResources =
      outermost_context().getSharedResources();
    EventPtr_t stMachEvent( new StartRun() );
    sharedResources->commandQueue_->enqWait( stMachEvent );
  }
}

string Starting::do_stateName ( ) const

privatevirtual

Implements stor::Operations.

Definition at line 65 of file Starting.cc.

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

void Starting::logHaltDoneRequest

(

const HaltDone &

request

)

Definition at line 80 of file Starting.cc.

{
  outermost_context().unconsumed_event( request );
}

void Starting::logStopDoneRequest

(

const StopDone &

request

)

Definition at line 75 of file Starting.cc.

{
  outermost_context().unconsumed_event( request );
}

bool Starting::workerThreadsConfigured ( ) const

private

Definition at line 98 of file Starting.cc.

Referenced by do_noFragmentToProcess().

{
  SharedResourcesPtr sharedResources =
    outermost_context().getSharedResources();

  // check if the requests are still being processed
  if ( sharedResources->diskWriterResources_->streamChangeOngoing() ) return false;

  if ( sharedResources->dqmEventProcessorResources_->requestsOngoing() ) return false;

  return true; 
}