evf::rb_statemachine::Halting Class Reference

#include <RBStateMachine.h>

Inheritance diagram for evf::rb_statemachine::Halting:

Public Types
typedef bsc::transition < HaltDone, Halted >	HD
typedef boost::mpl::list< HD >	reactions

Public Member Functions
virtual bool	discardDataEvent (MemRef_t *bufRef) const
virtual bool	discardDqmEvent (MemRef_t *bufRef) const
virtual void	do_stateAction () const
virtual void	do_stateNotify ()
	Halting (my_context)
virtual int	stateID () const
virtual	~Halting ()
Public Member Functions inherited from evf::rb_statemachine::BaseState
	BaseState ()
void	moveToFailedState (xcept::Exception &exception) const
std::string	stateName () const
virtual	~BaseState ()=0

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

Additional Inherited Members
Protected Member Functions inherited from evf::rb_statemachine::BaseState
void	fail ()
void	safeEntryAction ()
void	safeExitAction ()

Detailed Description

Halting state

Definition at line 639 of file RBStateMachine.h.

Member Typedef Documentation

typedef bsc::transition<HaltDone, Halted> evf::rb_statemachine::Halting::HD

Definition at line 643 of file RBStateMachine.h.

typedef boost::mpl::list<HD> evf::rb_statemachine::Halting::reactions

Definition at line 644 of file RBStateMachine.h.

Constructor & Destructor Documentation

Halting::Halting

(

my_context

c

)

Definition at line 119 of file Halting.cc.

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

                             :
    my_base(c) {
    safeEntryAction();
}

Halting::~Halting ( )

virtual

Definition at line 124 of file Halting.cc.

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

                  {
    safeExitAction();
}

Member Function Documentation

bool evf::rb_statemachine::Halting::destructionIsDone ( ) const

private

bool Halting::discardDataEvent ( MemRef_t *  bufRef ) const

virtual

Base callback on process buffer received via I2O_SM_DATA_DISCARD message

Reimplemented from evf::rb_statemachine::BaseState.

Definition at line 94 of file Halting.cc.

References alignCSCRings::e, and evf::rb_statemachine::BaseState::moveToFailedState().

                                                     {
    SharedResourcesPtr_t res = outermost_context().getSharedResources();
    bool returnValue = false;
    try {
        returnValue = res->resourceStructure_->discardDataEventWhileHalting(
                bufRef);
    } catch (evf::Exception& e) {
        moveToFailedState(e);
    }
    return returnValue;
}

bool Halting::discardDqmEvent ( MemRef_t *  bufRef ) const

virtual

Base callback on process buffer received via I2O_SM_DQM_DISCARD message

Reimplemented from evf::rb_statemachine::BaseState.

Definition at line 105 of file Halting.cc.

References alignCSCRings::e, and evf::rb_statemachine::BaseState::moveToFailedState().

                                                    {
    SharedResourcesPtr_t res = outermost_context().getSharedResources();
    bool returnValue = false;
    try {
        returnValue = res->resourceStructure_->discardDqmEvent(bufRef);
        //returnValue = res->resourceStructure_->discardDqmEventWhileHalting(bufRef);
    } catch (evf::Exception& e) {
        moveToFailedState(e);
    }
    return returnValue;
}

void Halting::do_entryActionWork ( )

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 18 of file Halting.cc.

                                 {
}

void Halting::do_exitActionWork ( )

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 130 of file Halting.cc.

                                {
}

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

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 137 of file Halting.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 Halting::do_stateAction ( ) const

virtual

State-dependent actions

Reimplemented from evf::rb_statemachine::BaseState.

Definition at line 31 of file Halting.cc.

References prof2calltree::count, alignCSCRings::e, edm::hlt::Exception, edm::hlt::Fail, evf::rb_statemachine::BaseState::moveToFailedState(), and stor::utils::sleep().

                                   {
    SharedResourcesPtr_t res = outermost_context().getSharedResources();
    try {
        LOG4CPLUS_INFO(res->log_, "Start halting ...");
        if (res->resourceStructure_->isActive()) {
            res->resourceStructure_->shutDownClients();
            UInt_t count = 0;
            while (count < 10) {
                if (res->resourceStructure_->isReadyToShutDown()) {
                    res->lock();

                    delete res->resourceStructure_;
                    res->resourceStructure_ = 0;

                    res->unlock();
                    LOG4CPLUS_INFO(
                            res->log_,
                            count + 1
                                    << ". try to destroy resource table succeeded!");
                    break;
                } else {
                    count++;

                    LOG4CPLUS_DEBUG(
                            res->log_,
                            count
                                    << ". try to destroy resource table failed ...");

                    ::sleep(1);
                }
            }
        } else {
            res->lock();

            delete res->resourceStructure_;
            res->resourceStructure_ = 0;

            res->unlock();
        }

        if (0 == res->resourceStructure_) {
            LOG4CPLUS_INFO(res->log_, "Finished halting!");
            EventPtr haltDone(new HaltDone());
            res->commands_.enqEvent(haltDone);
        } else {
            res->reasonForFailed_
                    = "halting FAILED: ResourceTable shutdown timed out.";
            LOG4CPLUS_FATAL(res->log_,
                        "Moving to FAILED state! Reason: " << res->reasonForFailed_.value_);
            EventPtr failTimeOut(new Fail());
            res->commands_.enqEvent(failTimeOut);
        }
    } catch (xcept::Exception &e) {
        moveToFailedState(e);
    }

    if (res->frb_)
        delete res->frb_;
}

string Halting::do_stateName ( ) const

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 133 of file Halting.cc.

                                   {
    return string("Halting");
}

void Halting::do_stateNotify ( )

virtual

State entry notifications

Implements evf::rb_statemachine::BaseState.

Definition at line 21 of file Halting.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();
}

void evf::rb_statemachine::Halting::doAsync ( ) const

private

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

inlinevirtual

Return the current state ID

Implements evf::rb_statemachine::BaseState.

Definition at line 655 of file RBStateMachine.h.

References evf::rb_statemachine::HALTING.

                                {
        return rb_statemachine::HALTING;
    }