/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_6_2_7/src/EventFilter/ResourceBroker/src/Halting.cc

Go to the documentation of this file.

#include "EventFilter/ResourceBroker/interface/RBStateMachine.h"
#include "EvffedFillerRB.h"

#include <iostream>

using std::string;
using std::cout;
using std::endl;
using namespace evf::rb_statemachine;

// entry action, state notification, state action
//______________________________________________________________________________
void Halting::do_entryActionWork() {
}

void Halting::do_stateNotify() {
        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 Halting::do_stateAction() const {
        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_;
}

/*
 * I2O capability
 */
bool Halting::discardDataEvent(MemRef_t* bufRef) const {
        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 {
        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;
}

// construction / destruction
//______________________________________________________________________________
Halting::Halting(my_context c) :
        my_base(c) {
        safeEntryAction();
}

Halting::~Halting() {
        safeExitAction();
}

// exit action, state name, move to failed state
//______________________________________________________________________________
void Halting::do_exitActionWork() {
}

string Halting::do_stateName() const {
        return string("Halting");
}

void Halting::do_moveToFailedState(xcept::Exception& exception) const {
        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);
}