evf::rb_statemachine::Enabling Class Reference

#include <RBStateMachine.h>

Inheritance diagram for evf::rb_statemachine::Enabling:

Public Types
typedef bsc::transition < EnableDone, Enabled >	ED
typedef boost::mpl::list< ED >	reactions

Public Member Functions
virtual void	do_stateAction () const
virtual void	do_stateNotify ()
	Enabling (my_context)
virtual int	stateID () const
virtual	~Enabling ()
Public Member Functions inherited from evf::rb_statemachine::BaseState
	BaseState ()
virtual bool	discardDataEvent (MemRef_t *bufRef) const
virtual bool	discardDqmEvent (MemRef_t *bufRef) const
void	moveToFailedState (xcept::Exception &exception) const
std::string	stateName () const
virtual	~BaseState ()=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 evf::rb_statemachine::BaseState
void	fail ()
void	safeEntryAction ()
void	safeExitAction ()

Detailed Description

Enabling state

Definition at line 498 of file RBStateMachine.h.

Member Typedef Documentation

typedef bsc::transition<EnableDone, Enabled> evf::rb_statemachine::Enabling::ED

Definition at line 504 of file RBStateMachine.h.

typedef boost::mpl::list<ED> evf::rb_statemachine::Enabling::reactions

Definition at line 505 of file RBStateMachine.h.

Constructor & Destructor Documentation

Enabling::Enabling

(

my_context

c

)

Definition at line 92 of file Enabling.cc.

References evf::rb_statemachine::BaseState::safeEntryAction().

                               :
    my_base(c) {
    safeEntryAction();
}

Enabling::~Enabling ( )

virtual

Definition at line 97 of file Enabling.cc.

References evf::rb_statemachine::BaseState::safeExitAction().

                    {
    safeExitAction();
}

Member Function Documentation

void Enabling::do_entryActionWork ( )

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 17 of file Enabling.cc.

                                  {
}

void Enabling::do_exitActionWork ( )

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 103 of file Enabling.cc.

                                 {
}

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

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 110 of file Enabling.cc.

References edm::hlt::Fail, and evf::rb_statemachine::BaseState::fail().

                                                                   {
    SharedResourcesPtr_t res = outermost_context().getSharedResources();
    res->reasonForFailed_ = exception.what();
    LOG4CPLUS_FATAL(res->log_,
            "Moving to FAILED state! Reason: " << exception.what());
    EventPtr fail(new Fail());
    res->commands_.enqEvent(fail);
}

void Enabling::do_stateAction ( ) const

virtual

State-dependent actions

Reimplemented from evf::rb_statemachine::BaseState.

Definition at line 30 of file Enabling.cc.

References alignCSCRings::e, edm::hlt::Exception, evf::rb_statemachine::BaseState::moveToFailedState(), evf::IPCMethod::resetCounters(), evf::IPCMethod::sendAllocate(), and evf::IPCMethod::setRunNumber().

                                    {
    SharedResourcesPtr_t res = outermost_context().getSharedResources();
    IPCMethod* resourceStructure = res->resourceStructure_;

    try {
        LOG4CPLUS_INFO(res->log_, "Start enabling ...");

        // set current run number and reset GUI counters
        // UPDATED
        res->reset();
        resourceStructure->setRunNumber(res->runNumber_);
        res->lock();

        /*
         *  UPDATE:
         *  releaseResources
         *  resetPendingAllocates
         *  resetIPC
         *
         *  after stopping
         */

        resourceStructure->resetCounters();
        res->unlock();

        LOG4CPLUS_INFO(res->log_, "Starting monitoring / watching workloops.");
        // starting monitoring workloop
        res->startMonitoringWorkLoop();

        // Watching Workloop is used only for Shared Memory IPC
        if (!res->useMessageQueueIPC_)
            res->startWatchingWorkLoop();

        // starting main workloops
        // 1. Discard
        res->startDiscardWorkLoop();
        // 2. Send Data
        res->startSendDataWorkLoop();
        // 3. Send DQM
        res->startSendDqmWorkLoop();

        resourceStructure->sendAllocate();

        res->nbTimeoutsWithEvent_ = 0;
        res->nbTimeoutsWithoutEvent_ = 0;
        res->dataErrorFlag_ = 0;

        // make sure I2O discards are allowed
        // (re-enable discards after stop)
        res->allowI2ODiscards_ = true;

        LOG4CPLUS_INFO(res->log_, "Finished enabling!");
        EventPtr enableDone(new EnableDone());
        res->commands_.enqEvent(enableDone);

    } catch (xcept::Exception &e) {
        moveToFailedState(e);
    }
}

string Enabling::do_stateName ( ) const

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 106 of file Enabling.cc.

                                    {
    return string("Enabling");
}

void Enabling::do_stateNotify ( )

virtual

State entry notifications

Implements evf::rb_statemachine::BaseState.

Definition at line 20 of file Enabling.cc.

References evf::rb_statemachine::BaseState::stateName().

                              {
    SharedResourcesPtr_t res = outermost_context().getSharedResources();
    LOG4CPLUS_INFO(res->log_, "--> ResourceBroker: NEW STATE: " << stateName());
    outermost_context().setExternallyVisibleState(stateName());
    outermost_context().setInternalStateName(stateName());
    // RCMS notification no longer required here
    // this is done in FUResourceBroker in SOAP reply
    //outermost_context().rcmsStateChangeNotify();
}

virtual int evf::rb_statemachine::Enabling::stateID ( ) const

inlinevirtual

Return the current state ID

Implements evf::rb_statemachine::BaseState.

Definition at line 512 of file RBStateMachine.h.

References evf::rb_statemachine::ENABLING.

                                {
        return rb_statemachine::ENABLING;
    }