evf::rb_statemachine::Configuring Class Reference

#include <RBStateMachine.h>

Inheritance diagram for evf::rb_statemachine::Configuring:

Public Types
typedef bsc::transition < ConfigureDone, Ready >	CR
typedef boost::mpl::list< CR >	reactions

Public Member Functions
	Configuring (my_context)
virtual void	do_stateAction () const
virtual void	do_stateNotify ()
virtual int	stateID () const
virtual	~Configuring ()
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
void	connectToBUandSM () const throw (evf::Exception)
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

Configuring state

Definition at line 395 of file RBStateMachine.h.

Member Typedef Documentation

typedef bsc::transition<ConfigureDone, Ready> evf::rb_statemachine::Configuring::CR

Definition at line 399 of file RBStateMachine.h.

typedef boost::mpl::list<CR> evf::rb_statemachine::Configuring::reactions

Definition at line 400 of file RBStateMachine.h.

Constructor & Destructor Documentation

Configuring::Configuring

(

my_context

c

)

Definition at line 67 of file Configuring.cc.

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

                                     :
    my_base(c) {
    safeEntryAction();
}

Configuring::~Configuring ( )

virtual

Definition at line 72 of file Configuring.cc.

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

                          {
    safeExitAction();
}

Member Function Documentation

void Configuring::connectToBUandSM ( ) const throw ( evf::Exception )

private

Connection to BuilderUnit bu_ and StorageManager sm_

Definition at line 96 of file Configuring.cc.

References lumiQueryAPI::msg.

                                                              {

    SharedResourcesPtr_t res = outermost_context().getSharedResources();
    xdaq::Application* app = outermost_context().getApp();

    typedef set<xdaq::ApplicationDescriptor*> AppDescSet_t;
    typedef AppDescSet_t::iterator AppDescIter_t;

    // locate input BU
    AppDescSet_t
            setOfBUs =
                    app->getApplicationContext()->getDefaultZone()-> getApplicationDescriptors(
                            res->buClassName_.toString());

    if (0 != res->bu_) {
        delete res->bu_;
        res->bu_ = 0;
    }

    for (AppDescIter_t it = setOfBUs.begin(); it != setOfBUs.end(); ++it)

        if ((*it)->getInstance() == res->buInstance_)

            res->bu_ = new BUProxy(app->getApplicationDescriptor(), *it,
                    app->getApplicationContext(), res->i2oPool_);

    if (0 == res->bu_) {
        string msg = res->sourceId_ + " failed to locate input BU!";
        XCEPT_RAISE(evf::Exception, msg);
    }

    // locate output SM
    AppDescSet_t
            setOfSMs =
                    app->getApplicationContext()->getDefaultZone()-> getApplicationDescriptors(
                            res->smClassName_.toString());

    if (0 != res->sm_) {
        delete res->sm_;
        res->sm_ = 0;
    }

    for (AppDescIter_t it = setOfSMs.begin(); it != setOfSMs.end(); ++it)
        if ((*it)->getInstance() == res->smInstance_)
            res->sm_ = new SMProxy(app->getApplicationDescriptor(), *it,
                    app->getApplicationContext(), res->i2oPool_);

    if (0 == res->sm_)
        LOG4CPLUS_WARN(res->log_,
                res->sourceId_ << " failed to locate output SM!");
}

void Configuring::do_entryActionWork ( )

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 18 of file Configuring.cc.

                                     {
}

void Configuring::do_exitActionWork ( )

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 78 of file Configuring.cc.

                                    {
}

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

privatevirtual

Implements evf::rb_statemachine::BaseState.

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

virtual

State-dependent actions

Reimplemented from evf::rb_statemachine::BaseState.

Definition at line 31 of file Configuring.cc.

References alignCSCRings::e, and edm::hlt::Exception.

                                       {
    SharedResourcesPtr_t res = outermost_context().getSharedResources();

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

        connectToBUandSM();

        res->frb_ = new EvffedFillerRB(
                (FUResourceBroker*) outermost_context().getApp());
        // IPC choice & init
        res->configureResources(outermost_context().getApp());

        if (res->shmInconsistent_) {
            std::ostringstream ost;
            ost
                    << "configuring FAILED: Inconsistency in ResourceTable - nbRaw="
                    << res->nbRawCells_.value_ << " but nbResources="
                    << res->resourceStructure_->nbResources()
                    << " and nbFreeSlots="
                    << res->resourceStructure_->nbFreeSlots();
            XCEPT_RAISE(evf::Exception, ost.str());
        }

        LOG4CPLUS_INFO(res->log_, "Finished configuring!");

        EventPtr configureDone(new ConfigureDone());
        res->commands_.enqEvent(configureDone);

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

string Configuring::do_stateName ( ) const

privatevirtual

Implements evf::rb_statemachine::BaseState.

Definition at line 81 of file Configuring.cc.

                                       {
    return string("Configuring");
}

void Configuring::do_stateNotify ( )

virtual

State entry notifications

Implements evf::rb_statemachine::BaseState.

Definition at line 21 of file Configuring.cc.

                                 {
    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::Configuring::stateID ( ) const

inlinevirtual

Return the current state ID

Implements evf::rb_statemachine::BaseState.

Definition at line 407 of file RBStateMachine.h.

References evf::rb_statemachine::CONFIGURING.

                                {
        return rb_statemachine::CONFIGURING;
    }