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);
}