/data/refman/pasoursint/CMSSW_5_3_0/src/EventFilter/ResourceBroker/src/SMEventScheduler.cc

Go to the documentation of this file.

//
// SMEventScheduler.h
// -------
//
// Holds and executes a list FIFO of FSM transition events.
//
//  Created on: Dec 13, 2011
//                                                                              Andrei Spataru : aspataru@cern.ch

#include "EventFilter/ResourceBroker/interface/SMEventScheduler.h"

#include <string>
#include <iostream>

using namespace evf::rb_statemachine;
using namespace evf;

using std::string;
using std::cout;
using std::endl;

SMEventScheduler::SMEventScheduler(RBStateMachinePtr fsm, CommandQueue& comms) :
        fsm_(fsm), commands_(comms), continueWorkloop_(true) {

        startSchedulerWorkloop();
}

SMEventScheduler::~SMEventScheduler() {
        stopScheduling();
}

//______________________________________________________________________________
void SMEventScheduler::startSchedulerWorkloop() throw (evf::Exception) {
        try {
                //improve log instead of cout
                cout << "Start 'SCHEDULER EVENT PROCESSING' workloop" << endl;
                wlProcessingEvents_ = toolbox::task::getWorkLoopFactory()->getWorkLoop(
                                "Scheduler Processing Events", "waiting");
                if (!wlProcessingEvents_->isActive())
                        wlProcessingEvents_->activate();
                asProcessingEvents_ = toolbox::task::bind(this,
                                &SMEventScheduler::processing, "SchedulerProcessing");
                wlProcessingEvents_->submit(asProcessingEvents_);
        } catch (xcept::Exception& e) {
                string msg = "Failed to start workloop 'SCHEDULER EVENT PROCESSING'.";
                //improve log instead of cout
                cout << msg << endl;
        }
}

//______________________________________________________________________________
bool SMEventScheduler::processing(toolbox::task::WorkLoop* wl) {
        // deqEvent() blocks until a command is present in the queue
        EventPtr topEvent = commands_.deqEvent();

        // 0. lock state transition
        fsm_->transitionWriteLock();
        // 1. process top event from the queue
        fsm_->process_event(*topEvent);
        // 1.5 unlock state transition
        fsm_->transitionUnlock();

        // 2. update state of the FSM, also notifying RCMS
        /*
         *  XXX casting away constness for the state Notification call
         *  done because state stateChanged in rcmsStateListener is not const
         *  stateNotify does not change BaseState& so operation is safe
         */
        const_cast<BaseState&> (fsm_->getCurrentState()).do_stateNotify();

        // 3. perform state-specific action
        fsm_->getCurrentState().do_stateAction();

        return continueWorkloop_;
}