evf::rb_statemachine::SharedResources Class Reference

#include <SharedResources.h>

Inheritance diagram for evf::rb_statemachine::SharedResources:

Public Member Functions
void	cancelAllWorkloops ()
void	configureResources (xdaq::Application *app)
void	lock ()
void	lockRSAccess ()
void	printWorkLoopStatus ()
void	reset ()
void	setFsmPointer (RBStateMachine *const fsm)
	SharedResources (Logger log)
int	tryLockRSAccess ()
void	unlock ()
void	unlockRSAccess ()
void	updateGUIExternalState (std::string newState)
void	updateGUIInternalState (std::string newState)
	~SharedResources ()

Private Types
typedef toolbox::task::ActionSignature	ActionSignature_t
typedef toolbox::task::WorkLoop	WorkLoop_t

Private Member Functions
double	deltaT (const struct timeval *start, const struct timeval *end)
bool	discard (toolbox::task::WorkLoop *wl)
void	goToFailedState (evf::Exception &e)
bool	monitoring (toolbox::task::WorkLoop *wl)
bool	sendData (toolbox::task::WorkLoop *wl)
bool	sendDqm (toolbox::task::WorkLoop *wl)
void	startDiscardWorkLoop () throw (evf::Exception)
void	startMonitoringWorkLoop () throw (evf::Exception)
void	startSendDataWorkLoop () throw (evf::Exception)
void	startSendDqmWorkLoop () throw (evf::Exception)
void	startWatchingWorkLoop () throw (evf::Exception)
bool	watching (toolbox::task::WorkLoop *wl)

Private Attributes
sem_t	accessToResourceStructureLock_
bool	allowI2ODiscards_
ActionSignature_t *	asDiscard_
ActionSignature_t *	asMonitoring_
ActionSignature_t *	asSendData_
ActionSignature_t *	asSendDqm_
ActionSignature_t *	asWatching_
xdata::Double	average_
BUProxy *	bu_
xdata::String	buClassName_
xdata::UnsignedInteger32	buInstance_
xdata::String	clientPrcIds_
CommandQueue	commands_
xdata::UnsignedInteger32	dataErrorFlag_
xdata::UnsignedInteger32	deltaN_
xdata::UnsignedInteger32	deltaSumOfSizes_
xdata::Double	deltaSumOfSquares_
xdata::Double	deltaT_
xdata::UnsignedInteger32	doCrcCheck_
xdata::Boolean	doDropEvents_
xdata::UnsignedInteger32	doDumpEvents_
xdata::Boolean	doFedIdCheck_
xdata::UnsignedInteger32	dqmCellSize_
EvffedFillerRB *	frb_
xdata::Integer	freeResRequiredForAllocate_
RBStateMachine *	fsm_
IndependentWebGUI *	gui_
xdata::UnsignedInteger32	highestEolReceived_
toolbox::mem::Pool *	i2oPool_
IPCManager *	ipcManager_
sem_t	lock_
Logger	log_
xdata::UnsignedInteger32	monSleepSec_
struct timeval	monStartTime_
xdata::UnsignedInteger32	nbAllocatedEvents_
xdata::UnsignedInteger32	nbAllocateSent_
xdata::UnsignedInteger32	nbClients_
xdata::UnsignedInteger32	nbCrcErrors_
xdata::UnsignedInteger32	nbDataDiscardReceived_
xdata::UnsignedInteger32	nbDataErrors_
xdata::UnsignedInteger32	nbDiscardedEvents_
xdata::UnsignedInteger32	nbDqmCells_
xdata::UnsignedInteger32	nbDqmDiscardReceived_
xdata::UnsignedInteger32	nbEolDiscarded_
xdata::UnsignedInteger32	nbEolPosted_
xdata::UnsignedInteger32	nbLostEvents_
xdata::UnsignedInteger32	nbPendingRequests_
xdata::UnsignedInteger32	nbPendingSMDiscards_
xdata::UnsignedInteger32	nbPendingSMDqmDiscards_
xdata::UnsignedInteger32	nbProcessedEvents_
xdata::UnsignedInteger32	nbRawCells_
xdata::UnsignedInteger32	nbReceivedEol_
xdata::UnsignedInteger32	nbReceivedEvents_
xdata::UnsignedInteger32	nbRecoCells_
xdata::UnsignedInteger32	nbSentDqmEvents_
xdata::UnsignedInteger32	nbSentErrorEvents_
xdata::UnsignedInteger32	nbSentEvents_
UInt_t	nbSentLast_
xdata::UnsignedInteger32	nbTakeReceived_
xdata::UnsignedInteger32	nbTimeoutsWithEvent_
xdata::UnsignedInteger32	nbTimeoutsWithoutEvent_
xdata::Boolean	processKillerEnabled_
xdata::Double	rate_
xdata::UnsignedInteger32	rawCellSize_
xdata::String	reasonForFailed_
xdata::UnsignedInteger32	recoCellSize_
IPCMethod *	resourceStructure_
xdata::UnsignedInteger32	resourceStructureTimeout_
xdata::Double	rms_
xdata::UnsignedInteger32	runNumber_
xdata::Boolean	segmentationMode_
bool	shmInconsistent_
SMProxy *	sm_
xdata::String	smClassName_
xdata::UnsignedInteger32	smInstance_
std::string	sourceId_
UInt_t	sumOfSizesLast_
uint64_t	sumOfSquaresLast_
xdata::Double	throughput_
xdata::UnsignedInteger32	timeOutSec_
xdata::Boolean	useEvmBoard_
xdata::Boolean	useMessageQueueIPC_
xdata::UnsignedInteger32	watchSleepSec_
WorkLoop_t *	wlDiscard_
WorkLoop_t *	wlMonitoring_
WorkLoop_t *	wlSendData_
WorkLoop_t *	wlSendDqm_
WorkLoop_t *	wlWatching_

Friends
class	Configuring
class	Enabled
class	Enabling
class	evf::FUResourceBroker
class	Failed
class	Halted
class	Halting
class	Normal
class	Ready
	not [yet] run More...
class	Running
class	Stopped
class	Stopping

Detailed Description

Class holding resources shared between FSM states.

Author:

smorovic

Definition at line 71 of file SharedResources.h.

Member Typedef Documentation

typedef toolbox::task::ActionSignature evf::rb_statemachine::SharedResources::ActionSignature_t

private

Definition at line 196 of file SharedResources.h.

typedef toolbox::task::WorkLoop evf::rb_statemachine::SharedResources::WorkLoop_t

private

Definition at line 195 of file SharedResources.h.

Constructor & Destructor Documentation

SharedResources::SharedResources

(

Logger

log

)

Definition at line 24 of file SharedResources.cc.

References accessToResourceStructureLock_, and lock_.

                                           :
            wlMonitoring_(0),
            asMonitoring_(0),
            wlWatching_(0),
            asWatching_(0),
            wlSendData_(0),
            asSendData_(0),
            wlSendDqm_(0),
            asSendDqm_(0),
            wlDiscard_(0),
            asDiscard_(0),
            gui_(0),
            commands_(CommandQueue()),
            log_(log),
            bu_(0),
            sm_(0),
            i2oPool_(0),
            ipcManager_(0),
            resourceStructure_(0),
            runNumber_(0),
            deltaT_(0.0),
            deltaN_(0),
            deltaSumOfSquares_(0),
            deltaSumOfSizes_(0),
            throughput_(0.0),
            rate_(0.0),
            average_(0.0),
            rms_(0.0),
            nbAllocatedEvents_(0),
            nbPendingRequests_(0),
            nbReceivedEvents_(0),
            nbSentEvents_(0),
            nbSentDqmEvents_(0),
            nbSentErrorEvents_(0),
            nbPendingSMDiscards_(0),
            nbPendingSMDqmDiscards_(0),
            nbDiscardedEvents_(0),
            // UPDATED
            nbReceivedEol_(0),
            highestEolReceived_(0),
            nbEolPosted_(0),
            nbEolDiscarded_(0),
            nbLostEvents_(0),
            nbDataErrors_(0),
            nbCrcErrors_(0),
            nbTimeoutsWithEvent_(0),
            nbTimeoutsWithoutEvent_(0),
            dataErrorFlag_(0),
            segmentationMode_(false),
            useMessageQueueIPC_(false),
            nbClients_(0),
            clientPrcIds_(""),
            nbRawCells_(16),
            nbRecoCells_(8),
            nbDqmCells_(8),
            rawCellSize_(0x400000) // 4MB
            ,
            recoCellSize_(0x800000) // 8MB
            ,
            dqmCellSize_(0x800000) // 8MB
            // at least nbRawCells / 2 free resources to send allocate
            , freeResRequiredForAllocate_(-1), doDropEvents_(false),
            doFedIdCheck_(true), doCrcCheck_(1), doDumpEvents_(0),
            buClassName_("BU"), buInstance_(0), smClassName_("StorageManager"),
            smInstance_(0), resourceStructureTimeout_(200000), monSleepSec_(2),
            watchSleepSec_(10), timeOutSec_(30), processKillerEnabled_(true),
            useEvmBoard_(true), reasonForFailed_(""), nbAllocateSent_(0),
            nbTakeReceived_(0), nbDataDiscardReceived_(0),
            nbDqmDiscardReceived_(0), nbSentLast_(0), sumOfSquaresLast_(0),
            sumOfSizesLast_(0), frb_(0), shmInconsistent_(false),
            allowI2ODiscards_(true) {

    sem_init(&lock_, 0, 1);
    sem_init(&accessToResourceStructureLock_, 0, 1);

}

SharedResources::~SharedResources

(

)

Definition at line 101 of file SharedResources.cc.

                                  {

}

Member Function Documentation

void SharedResources::cancelAllWorkloops

(

)

Definition at line 152 of file SharedResources.cc.

References wlDiscard_, wlMonitoring_, wlSendData_, wlSendDqm_, and wlWatching_.

                                         {
    if (wlSendData_) {
        wlSendData_->cancel();
        toolbox::task::getWorkLoopFactory()->removeWorkLoop("SendData",
                "waiting");
    }
    if (wlSendDqm_) {
        wlSendDqm_->cancel();
        toolbox::task::getWorkLoopFactory()->removeWorkLoop("SendDqm",
                "waiting");
    }
    if (wlDiscard_) {
        wlDiscard_->cancel();
        toolbox::task::getWorkLoopFactory()->removeWorkLoop("Discard",
                "waiting");
    }

    if (wlMonitoring_) {
        wlMonitoring_->cancel();
        toolbox::task::getWorkLoopFactory()->removeWorkLoop("Monitoring",
                "waiting");
    }
    if (wlWatching_) {
        wlWatching_->cancel();
        toolbox::task::getWorkLoopFactory()->removeWorkLoop("Watching",
                "waiting");
    }
}

void SharedResources::configureResources

(

xdaq::Application *

app

)

Sets-up the type of IPC to be used, and sets the resourceStructure_ pointer.

Definition at line 106 of file SharedResources.cc.

References bu_, doCrcCheck_, doDumpEvents_, evf::FUResource::doFedIdCheck(), doFedIdCheck_, dqmCellSize_, frb_, freeResRequiredForAllocate_, evf::IPCManager::initialise(), evf::IPCManager::ipc(), ipcManager_, log_, nbDqmCells_, evf::IPCMethod::nbFreeSlots(), nbRawCells_, nbRecoCells_, evf::IPCMethod::nbResources(), rawCellSize_, recoCellSize_, reset(), resourceStructure_, resourceStructureTimeout_, segmentationMode_, evf::IPCMethod::setDoCrcCheck(), evf::IPCMethod::setDoDumpEvents(), shmInconsistent_, sm_, evf::FUResource::useEvmBoard(), useEvmBoard_, and useMessageQueueIPC_.

                                                             {

    ipcManager_ = new IPCManager(useMessageQueueIPC_);

    ipcManager_->initialise(segmentationMode_.value_, nbRawCells_.value_,
            nbRecoCells_.value_, nbDqmCells_.value_, rawCellSize_.value_,
            recoCellSize_.value_, dqmCellSize_.value_,
            freeResRequiredForAllocate_, bu_, sm_, log_,
            resourceStructureTimeout_.value_, frb_, app);

    resourceStructure_ = ipcManager_->ipc();

    FUResource::doFedIdCheck(doFedIdCheck_);
    FUResource::useEvmBoard(useEvmBoard_);
    resourceStructure_->setDoCrcCheck(doCrcCheck_);
    resourceStructure_->setDoDumpEvents(doDumpEvents_);
    reset();
    shmInconsistent_ = false;

    // XXX shmInconsistent check
    if (resourceStructure_->nbResources() != nbRawCells_.value_
            || resourceStructure_->nbFreeSlots() != nbRawCells_.value_)
        shmInconsistent_ = true;
}

double SharedResources::deltaT ( const struct timeval *  start, const struct timeval *  end  )

private

Definition at line 388 of file SharedResources.cc.

Referenced by monitoring().

                                   {
    unsigned int sec;
    unsigned int usec;

    sec = end->tv_sec - start->tv_sec;

    if (end->tv_usec > start->tv_usec) {
        usec = end->tv_usec - start->tv_usec;
    } else {
        sec--;
        usec = 1000000 - ((unsigned int) (start->tv_usec - end->tv_usec));
    }

    return ((double) sec) + ((double) usec) / 1000000.0;
}

bool SharedResources::discard ( toolbox::task::WorkLoop *  wl )

private

Action for Discard Work loop. The forwards the call to the current state of the FSM.

Definition at line 537 of file SharedResources.cc.

References gather_cfg::cout, evf::IPCMethod::discard(), evf::IPCMethod::discardWhileHalting(), alignCSCRings::e, evf::rb_statemachine::FAILED, fsm_, evf::rb_statemachine::RBStateMachine::getCurrentState(), goToFailedState(), evf::rb_statemachine::HALTING, resourceStructure_, evf::rb_statemachine::RUNNING, evf::rb_statemachine::BaseState::stateID(), evf::rb_statemachine::STOPPING, evf::rb_statemachine::RBStateMachine::transitionReadLock(), and evf::rb_statemachine::RBStateMachine::transitionUnlock().

Referenced by startDiscardWorkLoop().

                                                  {
    int currentStateID = -1;
    bool reschedule = true;

    fsm_->transitionReadLock();
    currentStateID = fsm_->getCurrentState().stateID();
    fsm_->transitionUnlock();
    try {
        switch (currentStateID) {
        case rb_statemachine::RUNNING:
            reschedule = resourceStructure_->discard();
            break;
        case rb_statemachine::STOPPING:
            // XXX: communication with BU after stop!
            reschedule = resourceStructure_->discardWhileHalting(true);
            break;
        case rb_statemachine::HALTING:
            // XXX: no more communication with BU after halt!
            reschedule = resourceStructure_->discardWhileHalting(false);
            break;
        case rb_statemachine::FAILED:
            // workloop must be exited in this state
            return false;
        default:
            cout << "RBStateMachine: current state: " << currentStateID
                    << " does not support action: >>discard<<" << endl;
            ::usleep(50000);
            reschedule = true;
        }
    } catch (evf::Exception& e) {
        goToFailedState(e);
    }

    return reschedule;
}

void SharedResources::goToFailedState ( evf::Exception &  e )

private

Goes to failed state due to the given exception

Definition at line 587 of file SharedResources.cc.

References commands_, evf::rb_statemachine::CommandQueue::enqEvent(), edm::hlt::Fail, cmsPerfPublish::fail(), log_, and reasonForFailed_.

Referenced by discard(), sendData(), sendDqm(), and watching().

                                                             {
    reasonForFailed_ = exception.what();
    LOG4CPLUS_FATAL(log_,
            "Moving to FAILED state! Reason: " << exception.what());
    EventPtr fail(new Fail());
    commands_.enqEvent(fail);
}

void evf::rb_statemachine::SharedResources::lock ( void  )

inline

Definition at line 107 of file SharedResources.h.

References lock_, and log_.

Referenced by monitoring(), and watching().

                {
        while (0 != sem_wait(&lock_)) {
            if (errno != EINTR) {
                LOG4CPLUS_ERROR(log_, "Cannot obtain lock on sem LOCK!");
            }
        }
    }

void evf::rb_statemachine::SharedResources::lockRSAccess ( )

inline

Definition at line 118 of file SharedResources.h.

References accessToResourceStructureLock_, and log_.

                        {
        while (0 != sem_wait(&accessToResourceStructureLock_)) {
            if (errno != EINTR) {
                LOG4CPLUS_ERROR(log_, "Cannot obtain lock on sem accessToResourceStructureLock_!");
            }
        }
    }

bool SharedResources::monitoring ( toolbox::task::WorkLoop *  wl )

private

Action for Monitoring workloop.

Definition at line 202 of file SharedResources.cc.

References average_, deltaN_, deltaSumOfSizes_, deltaSumOfSquares_, deltaT(), deltaT_, gui_, lock(), timingPdfMaker::mean, evf::IndependentWebGUI::monInfoSpace(), monSleepSec_, monStartTime_, evf::IPCMethod::nbSent(), nbSentLast_, rate_, resourceStructure_, rms_, stor::utils::sleep(), mathSSE::sqrt(), evf::IPCMethod::sumOfSizes(), sumOfSizesLast_, evf::IPCMethod::sumOfSquares(), sumOfSquaresLast_, throughput_, and unlock().

Referenced by startMonitoringWorkLoop().

                                                     {

    unsigned int nbSent;
    uint64_t sumOfSquares;
    unsigned int sumOfSizes;
    uint64_t deltaSumOfSquares;

    lock();
    if (0 == resourceStructure_) {
        deltaT_.value_ = 0.0;
        deltaN_.value_ = 0;
        deltaSumOfSquares_.value_ = 0.0;
        deltaSumOfSizes_.value_ = 0;
        throughput_ = 0.0;
        rate_ = 0.0;
        average_ = 0.0;
        rms_ = 0.0;
        unlock();
        return false;
    } else {
        nbSent = resourceStructure_->nbSent();
        sumOfSquares = resourceStructure_->sumOfSquares();
        sumOfSizes = resourceStructure_->sumOfSizes();
    }
    unlock();

    struct timeval monEndTime;
    struct timezone timezone;

    gettimeofday(&monEndTime, &timezone);

    xdata::getInfoSpaceFactory()->lock();
    gui_->monInfoSpace()->lock();

    deltaT_.value_ = deltaT(&monStartTime_, &monEndTime);
    monStartTime_ = monEndTime;

    deltaN_.value_ = nbSent - nbSentLast_;
    nbSentLast_ = nbSent;

    deltaSumOfSquares = sumOfSquares - sumOfSquaresLast_;
    deltaSumOfSquares_.value_ = (double) deltaSumOfSquares;
    sumOfSquaresLast_ = sumOfSquares;

    deltaSumOfSizes_.value_ = sumOfSizes - sumOfSizesLast_;
    sumOfSizesLast_ = sumOfSizes;

    if (deltaT_.value_ != 0) {
        throughput_ = deltaSumOfSizes_.value_ / deltaT_.value_;
        rate_ = deltaN_.value_ / deltaT_.value_;
    } else {
        throughput_ = 0.0;
        rate_ = 0.0;
    }

    double meanOfSquares, mean, squareOfMean, variance;

    if (deltaN_.value_ != 0) {
        meanOfSquares = deltaSumOfSquares_.value_ / ((double) (deltaN_.value_));
        mean = ((double) (deltaSumOfSizes_.value_))
                / ((double) (deltaN_.value_));
        squareOfMean = mean * mean;
        variance = meanOfSquares - squareOfMean;
        if (variance < 0.0)
            variance = 0.0;

        average_ = deltaSumOfSizes_.value_ / deltaN_.value_;
        rms_ = std::sqrt(variance);
    } else {
        average_ = 0.0;
        rms_ = 0.0;
    }

    gui_->monInfoSpace()->unlock();
    xdata::getInfoSpaceFactory()->unlock();

    ::sleep(monSleepSec_.value_);

    return true;
}

void SharedResources::printWorkLoopStatus

(

)

Definition at line 574 of file SharedResources.cc.

References gather_cfg::cout, wlDiscard_, wlSendData_, and wlSendDqm_.

                                          {
    cout << "Workloop status===============" << endl;
    cout << "==============================" << endl;
    if (wlSendData_ != 0)
        cout << "SendData -> " << wlSendData_->isActive() << endl;
    if (wlSendDqm_ != 0)
        cout << "SendDqm  -> " << wlSendDqm_->isActive() << endl;
    if (wlDiscard_ != 0)
        cout << "Discard  -> " << wlDiscard_->isActive() << endl;
    //cout << "Workloops Active  -> " << isActive_ << endl;
}

void SharedResources::reset

(

void

)

Resets counters

Definition at line 132 of file SharedResources.cc.

References average_, deltaN_, deltaSumOfSizes_, deltaSumOfSquares_, deltaT_, gui_, nbSentLast_, rate_, evf::IndependentWebGUI::resetCounters(), rms_, sumOfSizesLast_, sumOfSquaresLast_, and throughput_.

Referenced by configureResources().

                            {

    gui_->resetCounters();

    deltaT_ = 0.0;
    deltaN_ = 0;
    deltaSumOfSquares_ = 0.0;
    deltaSumOfSizes_ = 0;

    throughput_ = 0.0;
    rate_ = 0.0;
    average_ = 0.0;
    rms_ = 0.0;

    nbSentLast_ = 0;
    sumOfSquaresLast_ = 0;
    sumOfSizesLast_ = 0;
}

bool SharedResources::sendData ( toolbox::task::WorkLoop *  wl )

private

Action for SendData Work loop. The forwards the call to the current state of the FSM.

Definition at line 425 of file SharedResources.cc.

References gather_cfg::cout, alignCSCRings::e, evf::rb_statemachine::FAILED, fsm_, evf::rb_statemachine::RBStateMachine::getCurrentState(), goToFailedState(), evf::rb_statemachine::HALTING, resourceStructure_, evf::rb_statemachine::RUNNING, evf::IPCMethod::sendData(), evf::IPCMethod::sendDataWhileHalting(), evf::rb_statemachine::BaseState::stateID(), evf::rb_statemachine::STOPPING, evf::rb_statemachine::RBStateMachine::transitionReadLock(), and evf::rb_statemachine::RBStateMachine::transitionUnlock().

Referenced by startSendDataWorkLoop().

                                                   {
    int currentStateID = -1;
    bool reschedule = true;

    fsm_->transitionReadLock();
    currentStateID = fsm_->getCurrentState().stateID();
    fsm_->transitionUnlock();

    try {
        switch (currentStateID) {
        case rb_statemachine::RUNNING:
            reschedule = resourceStructure_->sendData();
            break;
        case rb_statemachine::STOPPING:
            reschedule = resourceStructure_->sendData();
            break;
        case rb_statemachine::HALTING:
            reschedule = resourceStructure_->sendDataWhileHalting();
            break;
        case rb_statemachine::FAILED:
            // workloop must be exited in this state
            return false;
        default:
            cout << "RBStateMachine: current state: " << currentStateID
                    << " does not support action: >>sendData<<" << endl;
            ::usleep(50000);
            reschedule = true;
        }
    } catch (evf::Exception& e) {
        goToFailedState(e);
    }

    return reschedule;
}

bool SharedResources::sendDqm ( toolbox::task::WorkLoop *  wl )

private

Action for SendDqm Work loop. The forwards the call to the current state of the FSM.

Definition at line 480 of file SharedResources.cc.

References gather_cfg::cout, alignCSCRings::e, evf::rb_statemachine::FAILED, fsm_, evf::rb_statemachine::RBStateMachine::getCurrentState(), goToFailedState(), evf::rb_statemachine::HALTING, resourceStructure_, evf::rb_statemachine::RUNNING, evf::IPCMethod::sendDqm(), evf::IPCMethod::sendDqmWhileHalting(), evf::rb_statemachine::BaseState::stateID(), evf::rb_statemachine::STOPPING, evf::rb_statemachine::RBStateMachine::transitionReadLock(), and evf::rb_statemachine::RBStateMachine::transitionUnlock().

Referenced by startSendDqmWorkLoop().

                                                  {
    int currentStateID = -1;
    bool reschedule = true;

    fsm_->transitionReadLock();
    currentStateID = fsm_->getCurrentState().stateID();
    fsm_->transitionUnlock();

    try {
        switch (currentStateID) {
        case rb_statemachine::RUNNING:
            reschedule = resourceStructure_->sendDqm();
            break;
        case rb_statemachine::STOPPING:
            reschedule = resourceStructure_->sendDqm();
            break;
        case rb_statemachine::HALTING:
            reschedule = resourceStructure_->sendDqmWhileHalting();
            break;
        case rb_statemachine::FAILED:
            // workloop must be exited in this state
            return false;
        default:
            cout << "RBStateMachine: current state: " << currentStateID
                    << " does not support action: >>sendDqm<<" << endl;
            ::usleep(50000);
            reschedule = true;
        }
    } catch (evf::Exception& e) {
        goToFailedState(e);
    }

    return reschedule;
}

void evf::rb_statemachine::SharedResources::setFsmPointer ( RBStateMachine *const  fsm )

inline

Definition at line 98 of file SharedResources.h.

References fsm_.

                                                  {
        fsm_ = fsm;
    }

void SharedResources::startDiscardWorkLoop ( ) throw ( evf::Exception )

private

Work loop to discard events to Builder Unit

Definition at line 517 of file SharedResources.cc.

References asDiscard_, discard(), alignCSCRings::e, edm::hlt::Exception, log_, lumiQueryAPI::msg, resourceStructure_, evf::IPCMethod::setActive(), evf::IPCMethod::setReadyToShutDown(), and wlDiscard_.

                                                                {
    try {
        LOG4CPLUS_INFO(log_, "Start 'discard' workloop.");
        wlDiscard_ = toolbox::task::getWorkLoopFactory()->getWorkLoop(
                "Discard", "waiting");
        if (!wlDiscard_->isActive())
            wlDiscard_->activate();
        asDiscard_ = toolbox::task::bind(this, &SharedResources::discard,
                "Discard");
        wlDiscard_->submit(asDiscard_);
        resourceStructure_->setActive(true);

    } catch (xcept::Exception& e) {
        string msg = "Failed to start workloop 'Discard'.";
        XCEPT_RETHROW(evf::Exception, msg, e);
    }
    resourceStructure_->setReadyToShutDown(false);
}

void SharedResources::startMonitoringWorkLoop ( ) throw ( evf::Exception )

private

Calculate monitoring information in separate thread. Starts the workloop.

Definition at line 182 of file SharedResources.cc.

References asMonitoring_, alignCSCRings::e, edm::hlt::Exception, monitoring(), monStartTime_, lumiQueryAPI::msg, sourceId_, and wlMonitoring_.

                                                                   {

    struct timezone timezone;
    gettimeofday(&monStartTime_, &timezone);

    try {
        wlMonitoring_ = toolbox::task::getWorkLoopFactory()->getWorkLoop(
                sourceId_ + "Monitoring", "waiting");
        if (!wlMonitoring_->isActive())
            wlMonitoring_->activate();
        asMonitoring_ = toolbox::task::bind(this, &SharedResources::monitoring,
                sourceId_ + "Monitoring");
        wlMonitoring_->submit(asMonitoring_);
    } catch (xcept::Exception& e) {
        string msg = "Failed to start workloop 'Monitoring'.";
        XCEPT_RETHROW(evf::Exception, msg, e);
    }
}

void SharedResources::startSendDataWorkLoop ( ) throw ( evf::Exception )

private

Work loop to send data events to Storage Manager

Definition at line 407 of file SharedResources.cc.

References asSendData_, alignCSCRings::e, edm::hlt::Exception, log_, lumiQueryAPI::msg, sendData(), and wlSendData_.

                                                                 {
    try {
        LOG4CPLUS_INFO(log_, "Start 'send data' workloop.");
        wlSendData_ = toolbox::task::getWorkLoopFactory()->getWorkLoop(
                "SendData", "waiting");
        if (!wlSendData_->isActive())
            wlSendData_->activate();
        asSendData_ = toolbox::task::bind(this, &SharedResources::sendData,
                "SendData");
        wlSendData_->submit(asSendData_);

    } catch (xcept::Exception& e) {
        string msg = "Failed to start workloop 'SendData'.";
        XCEPT_RETHROW(evf::Exception, msg, e);
    }
}

void SharedResources::startSendDqmWorkLoop ( ) throw ( evf::Exception )

private

Work loop to send dqm events to Storage Manager

Definition at line 462 of file SharedResources.cc.

References asSendDqm_, alignCSCRings::e, edm::hlt::Exception, log_, lumiQueryAPI::msg, sendDqm(), and wlSendDqm_.

                                                                {
    try {
        LOG4CPLUS_INFO(log_, "Start 'send dqm' workloop.");
        wlSendDqm_ = toolbox::task::getWorkLoopFactory()->getWorkLoop(
                "SendDqm", "waiting");
        if (!wlSendDqm_->isActive())
            wlSendDqm_->activate();
        asSendDqm_ = toolbox::task::bind(this, &SharedResources::sendDqm,
                "SendDqm");
        wlSendDqm_->submit(asSendDqm_);

    } catch (xcept::Exception& e) {
        string msg = "Failed to start workloop 'SendDqm'.";
        XCEPT_RETHROW(evf::Exception, msg, e);
    }
}

void SharedResources::startWatchingWorkLoop ( ) throw ( evf::Exception )

private

Watch the state of the shm buffer in a separate thread. Start the workloop.

Definition at line 284 of file SharedResources.cc.

References asWatching_, alignCSCRings::e, edm::hlt::Exception, lumiQueryAPI::msg, sourceId_, watching(), and wlWatching_.

                                                                 {
    try {
        wlWatching_ = toolbox::task::getWorkLoopFactory()->getWorkLoop(
                sourceId_ + "Watching", "waiting");
        if (!wlWatching_->isActive())
            wlWatching_->activate();
        asWatching_ = toolbox::task::bind(this, &SharedResources::watching,
                sourceId_ + "Watching");
        wlWatching_->submit(asWatching_);
    } catch (xcept::Exception& e) {
        string msg = "Failed to start workloop 'Watching'.";
        XCEPT_RETHROW(evf::Exception, msg, e);
    }
}

int evf::rb_statemachine::SharedResources::tryLockRSAccess ( )

inline

Definition at line 126 of file SharedResources.h.

References accessToResourceStructureLock_.

                          {
        if (sem_trywait(&accessToResourceStructureLock_)) return -1;
        return 0;
    }

void evf::rb_statemachine::SharedResources::unlock ( void  )

inline

Definition at line 114 of file SharedResources.h.

References lock_.

Referenced by monitoring(), and watching().

                  {
        sem_post(&lock_);
    }

void evf::rb_statemachine::SharedResources::unlockRSAccess ( )

inline

Definition at line 131 of file SharedResources.h.

References accessToResourceStructureLock_.

                          {
        sem_post(&accessToResourceStructureLock_);
    }

void evf::rb_statemachine::SharedResources::updateGUIExternalState ( std::string  newState )

inline

Definition at line 88 of file SharedResources.h.

References gui_, and evf::IndependentWebGUI::updateExternalState().

                                                    {
        //lock();
        gui_->updateExternalState(newState);
        //unlock();
    }

void evf::rb_statemachine::SharedResources::updateGUIInternalState ( std::string  newState )

inline

Definition at line 93 of file SharedResources.h.

References gui_, and evf::IndependentWebGUI::updateInternalState().

                                                    {
        //lock();
        gui_->updateInternalState(newState);
        //unlock();
    }

bool SharedResources::watching ( toolbox::task::WorkLoop *  wl )

private

Action for Watching workloop.

Definition at line 300 of file SharedResources.cc.

References evf::IPCMethod::cellEvtNumbers(), evf::IPCMethod::cellPrcIds(), evf::IPCMethod::cellTimeStamps(), evf::IPCMethod::clientPrcIds(), alignCSCRings::e, fsm_, evf::rb_statemachine::RBStateMachine::getApp(), goToFailedState(), evf::IPCMethod::handleCrashedEP(), i, lock(), log_, evf::IPCMethod::nbFreeSlots(), nbRawCells_, evf::IPCMethod::nbResources(), nbTimeoutsWithEvent_, nbTimeoutsWithoutEvent_, evf::utils::pid, processKillerEnabled_, resourceStructure_, runNumber_, shmInconsistent_, stor::utils::sleep(), ntuplemaker::status, cond::rpcobgas::time, timeOutSec_, unlock(), and watchSleepSec_.

Referenced by startWatchingWorkLoop().

                                                   {
    lock();
    if (0 == resourceStructure_) {
        unlock();
        return false;
    }

    vector<pid_t> evt_prcids;
    vector<UInt_t> evt_numbers;
    vector<time_t> evt_tstamps;
    try {
        evt_prcids = resourceStructure_->cellPrcIds();
        evt_numbers = resourceStructure_->cellEvtNumbers();
        evt_tstamps = resourceStructure_->cellTimeStamps();
    } catch (evf::Exception& e) {
        goToFailedState(e);
    }

    time_t tcurr = time(0);
    for (UInt_t i = 0; i < evt_tstamps.size(); i++) {
        pid_t pid = evt_prcids[i];
        UInt_t evt = evt_numbers[i];
        time_t tstamp = evt_tstamps[i];
        if (tstamp == 0)
            continue;
        double tdiff = difftime(tcurr, tstamp);
        if (tdiff > timeOutSec_) {
            if (processKillerEnabled_) {
                // UPDATED
                kill(pid, 9);
                nbTimeoutsWithEvent_++;
            }
            LOG4CPLUS_ERROR(
                    log_,
                    "evt " << evt << " under processing for more than "
                            << timeOutSec_ << "sec for process " << pid);

        }
    }

    vector<pid_t> prcids;
    try {  
                #ifdef linux 
        auto lk = resourceStructure_->lockCrashHandler();
                #endif
        prcids = resourceStructure_->clientPrcIds();
        for (UInt_t i = 0; i < prcids.size(); i++) {
            pid_t pid = prcids[i];
            int status = kill(pid, 0);
            if (status != 0) {
                LOG4CPLUS_ERROR(
                        log_,
                        "EP prc " << pid
                                << " died, send to error stream if processing.");
                if (!resourceStructure_->handleCrashedEP(runNumber_, pid))
                    nbTimeoutsWithoutEvent_++;
            }
        }

    } catch (evf::Exception& e) {
        goToFailedState(e);
    }

    try {
        if ((resourceStructure_->nbResources() != nbRawCells_.value_)
                && !shmInconsistent_) {
            std::ostringstream ost;
            ost << "Watchdog spotted inconsistency in ResourceTable - nbRaw="
                    << nbRawCells_.value_ << " but nbResources="
                    << resourceStructure_->nbResources() << " and nbFreeSlots="
                    << resourceStructure_->nbFreeSlots();
            XCEPT_DECLARE(evf::Exception, sentinelException, ost.str());
            fsm_->getApp()->notifyQualified("error", sentinelException);

            // XXX shmInconsistent
            shmInconsistent_ = true;
        }
    } catch (evf::Exception& e) {
        goToFailedState(e);
    }

    unlock();

    ::sleep(watchSleepSec_.value_);
    return true;
}

Friends And Related Function Documentation

friend class Configuring

friend

Definition at line 347 of file SharedResources.h.

friend class Enabled

friend

Definition at line 351 of file SharedResources.h.

friend class Enabling

friend

Definition at line 350 of file SharedResources.h.

friend class evf::FUResourceBroker

friend

Definition at line 344 of file SharedResources.h.

friend class Failed

friend

Definition at line 356 of file SharedResources.h.

friend class Halted

friend

Definition at line 346 of file SharedResources.h.

friend class Halting

friend

Definition at line 354 of file SharedResources.h.

friend class Normal

friend

Definition at line 355 of file SharedResources.h.

friend class Ready

friend

not [yet] run

Definition at line 348 of file SharedResources.h.

friend class Running

friend

Definition at line 352 of file SharedResources.h.

friend class Stopped

friend

Definition at line 349 of file SharedResources.h.

friend class Stopping

friend

Definition at line 353 of file SharedResources.h.

Member Data Documentation

sem_t evf::rb_statemachine::SharedResources::accessToResourceStructureLock_

private

Definition at line 338 of file SharedResources.h.

Referenced by lockRSAccess(), SharedResources(), tryLockRSAccess(), and unlockRSAccess().

bool evf::rb_statemachine::SharedResources::allowI2ODiscards_

private

Definition at line 339 of file SharedResources.h.

ActionSignature_t* evf::rb_statemachine::SharedResources::asDiscard_

private

Definition at line 214 of file SharedResources.h.

Referenced by startDiscardWorkLoop().

ActionSignature_t* evf::rb_statemachine::SharedResources::asMonitoring_

private

Definition at line 204 of file SharedResources.h.

Referenced by startMonitoringWorkLoop().

ActionSignature_t* evf::rb_statemachine::SharedResources::asSendData_

private

Definition at line 210 of file SharedResources.h.

Referenced by startSendDataWorkLoop().

ActionSignature_t* evf::rb_statemachine::SharedResources::asSendDqm_

private

Definition at line 212 of file SharedResources.h.

Referenced by startSendDqmWorkLoop().

ActionSignature_t* evf::rb_statemachine::SharedResources::asWatching_

private

Definition at line 207 of file SharedResources.h.

Referenced by startWatchingWorkLoop().

xdata::Double evf::rb_statemachine::SharedResources::average_

private

Definition at line 258 of file SharedResources.h.

Referenced by monitoring(), and reset().

BUProxy* evf::rb_statemachine::SharedResources::bu_

private

Definition at line 233 of file SharedResources.h.

Referenced by configureResources().

xdata::String evf::rb_statemachine::SharedResources::buClassName_

private

Definition at line 305 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::buInstance_

private

Definition at line 306 of file SharedResources.h.

xdata::String evf::rb_statemachine::SharedResources::clientPrcIds_

private

Definition at line 290 of file SharedResources.h.

CommandQueue evf::rb_statemachine::SharedResources::commands_

private

Definition at line 227 of file SharedResources.h.

Referenced by goToFailedState().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::dataErrorFlag_

private

Definition at line 284 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::deltaN_

private

Definition at line 252 of file SharedResources.h.

Referenced by monitoring(), and reset().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::deltaSumOfSizes_

private

Definition at line 254 of file SharedResources.h.

Referenced by monitoring(), and reset().

xdata::Double evf::rb_statemachine::SharedResources::deltaSumOfSquares_

private

Definition at line 253 of file SharedResources.h.

Referenced by monitoring(), and reset().

xdata::Double evf::rb_statemachine::SharedResources::deltaT_

private

Definition at line 251 of file SharedResources.h.

Referenced by monitoring(), and reset().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::doCrcCheck_

private

Definition at line 302 of file SharedResources.h.

Referenced by configureResources().

xdata::Boolean evf::rb_statemachine::SharedResources::doDropEvents_

private

Definition at line 300 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::doDumpEvents_

private

Definition at line 303 of file SharedResources.h.

Referenced by configureResources().

xdata::Boolean evf::rb_statemachine::SharedResources::doFedIdCheck_

private

Definition at line 301 of file SharedResources.h.

Referenced by configureResources().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::dqmCellSize_

private

Definition at line 296 of file SharedResources.h.

Referenced by configureResources().

EvffedFillerRB* evf::rb_statemachine::SharedResources::frb_

private

Definition at line 333 of file SharedResources.h.

Referenced by configureResources().

xdata::Integer evf::rb_statemachine::SharedResources::freeResRequiredForAllocate_

private

Definition at line 298 of file SharedResources.h.

Referenced by configureResources().

RBStateMachine* evf::rb_statemachine::SharedResources::fsm_

private

Definition at line 221 of file SharedResources.h.

Referenced by discard(), sendData(), sendDqm(), setFsmPointer(), and watching().

IndependentWebGUI* evf::rb_statemachine::SharedResources::gui_

private

Definition at line 224 of file SharedResources.h.

Referenced by monitoring(), reset(), updateGUIExternalState(), and updateGUIInternalState().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::highestEolReceived_

private

Definition at line 275 of file SharedResources.h.

toolbox::mem::Pool* evf::rb_statemachine::SharedResources::i2oPool_

private

Definition at line 239 of file SharedResources.h.

IPCManager* evf::rb_statemachine::SharedResources::ipcManager_

private

Definition at line 242 of file SharedResources.h.

Referenced by configureResources().

sem_t evf::rb_statemachine::SharedResources::lock_

private

Definition at line 332 of file SharedResources.h.

Referenced by lock(), SharedResources(), and unlock().

Logger evf::rb_statemachine::SharedResources::log_

private

Definition at line 230 of file SharedResources.h.

Referenced by configureResources(), goToFailedState(), lock(), lockRSAccess(), startDiscardWorkLoop(), startSendDataWorkLoop(), startSendDqmWorkLoop(), and watching().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::monSleepSec_

private

Definition at line 311 of file SharedResources.h.

Referenced by monitoring().

struct timeval evf::rb_statemachine::SharedResources::monStartTime_

private

Definition at line 326 of file SharedResources.h.

Referenced by monitoring(), and startMonitoringWorkLoop().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbAllocatedEvents_

private

Definition at line 262 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbAllocateSent_

private

Definition at line 320 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbClients_

private

Definition at line 289 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbCrcErrors_

private

Definition at line 281 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbDataDiscardReceived_

private

Definition at line 322 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbDataErrors_

private

Definition at line 280 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbDiscardedEvents_

private

Definition at line 271 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbDqmCells_

private

Definition at line 293 of file SharedResources.h.

Referenced by configureResources().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbDqmDiscardReceived_

private

Definition at line 323 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbEolDiscarded_

private

Definition at line 277 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbEolPosted_

private

Definition at line 276 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbLostEvents_

private

Definition at line 279 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbPendingRequests_

private

Definition at line 263 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbPendingSMDiscards_

private

Definition at line 269 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbPendingSMDqmDiscards_

private

Definition at line 270 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbProcessedEvents_

private

Definition at line 265 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbRawCells_

private

Definition at line 291 of file SharedResources.h.

Referenced by configureResources(), and watching().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbReceivedEol_

private

Definition at line 274 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbReceivedEvents_

private

Definition at line 264 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbRecoCells_

private

Definition at line 292 of file SharedResources.h.

Referenced by configureResources().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbSentDqmEvents_

private

Definition at line 267 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbSentErrorEvents_

private

Definition at line 268 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbSentEvents_

private

Definition at line 266 of file SharedResources.h.

UInt_t evf::rb_statemachine::SharedResources::nbSentLast_

private

Definition at line 327 of file SharedResources.h.

Referenced by monitoring(), and reset().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbTakeReceived_

private

Definition at line 321 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbTimeoutsWithEvent_

private

Definition at line 282 of file SharedResources.h.

Referenced by watching().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::nbTimeoutsWithoutEvent_

private

Definition at line 283 of file SharedResources.h.

Referenced by watching().

xdata::Boolean evf::rb_statemachine::SharedResources::processKillerEnabled_

private

Definition at line 314 of file SharedResources.h.

Referenced by watching().

xdata::Double evf::rb_statemachine::SharedResources::rate_

private

Definition at line 257 of file SharedResources.h.

Referenced by monitoring(), and reset().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::rawCellSize_

private

Definition at line 294 of file SharedResources.h.

Referenced by configureResources().

xdata::String evf::rb_statemachine::SharedResources::reasonForFailed_

private

Definition at line 317 of file SharedResources.h.

Referenced by goToFailedState().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::recoCellSize_

private

Definition at line 295 of file SharedResources.h.

Referenced by configureResources().

IPCMethod* evf::rb_statemachine::SharedResources::resourceStructure_

private

Definition at line 243 of file SharedResources.h.

Referenced by configureResources(), discard(), monitoring(), sendData(), sendDqm(), startDiscardWorkLoop(), and watching().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::resourceStructureTimeout_

private

Definition at line 310 of file SharedResources.h.

Referenced by configureResources().

xdata::Double evf::rb_statemachine::SharedResources::rms_

private

Definition at line 259 of file SharedResources.h.

Referenced by monitoring(), and reset().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::runNumber_

private

Definition at line 249 of file SharedResources.h.

Referenced by watching().

xdata::Boolean evf::rb_statemachine::SharedResources::segmentationMode_

private

Definition at line 287 of file SharedResources.h.

Referenced by configureResources().

bool evf::rb_statemachine::SharedResources::shmInconsistent_

private

Definition at line 335 of file SharedResources.h.

Referenced by configureResources(), and watching().

SMProxy* evf::rb_statemachine::SharedResources::sm_

private

Definition at line 236 of file SharedResources.h.

Referenced by configureResources().

xdata::String evf::rb_statemachine::SharedResources::smClassName_

private

Definition at line 307 of file SharedResources.h.

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::smInstance_

private

Definition at line 308 of file SharedResources.h.

std::string evf::rb_statemachine::SharedResources::sourceId_

private

Definition at line 246 of file SharedResources.h.

Referenced by startMonitoringWorkLoop(), and startWatchingWorkLoop().

UInt_t evf::rb_statemachine::SharedResources::sumOfSizesLast_

private

Definition at line 329 of file SharedResources.h.

Referenced by monitoring(), and reset().

uint64_t evf::rb_statemachine::SharedResources::sumOfSquaresLast_

private

Definition at line 328 of file SharedResources.h.

Referenced by monitoring(), and reset().

xdata::Double evf::rb_statemachine::SharedResources::throughput_

private

Definition at line 256 of file SharedResources.h.

Referenced by monitoring(), and reset().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::timeOutSec_

private

Definition at line 313 of file SharedResources.h.

Referenced by watching().

xdata::Boolean evf::rb_statemachine::SharedResources::useEvmBoard_

private

Definition at line 315 of file SharedResources.h.

Referenced by configureResources().

xdata::Boolean evf::rb_statemachine::SharedResources::useMessageQueueIPC_

private

Definition at line 288 of file SharedResources.h.

Referenced by configureResources().

xdata::UnsignedInteger32 evf::rb_statemachine::SharedResources::watchSleepSec_

private

Definition at line 312 of file SharedResources.h.

Referenced by watching().

WorkLoop_t* evf::rb_statemachine::SharedResources::wlDiscard_

private

Definition at line 213 of file SharedResources.h.

Referenced by cancelAllWorkloops(), printWorkLoopStatus(), and startDiscardWorkLoop().

WorkLoop_t* evf::rb_statemachine::SharedResources::wlMonitoring_

private

Definition at line 203 of file SharedResources.h.

Referenced by cancelAllWorkloops(), and startMonitoringWorkLoop().

WorkLoop_t* evf::rb_statemachine::SharedResources::wlSendData_

private

Definition at line 209 of file SharedResources.h.

Referenced by cancelAllWorkloops(), printWorkLoopStatus(), and startSendDataWorkLoop().

WorkLoop_t* evf::rb_statemachine::SharedResources::wlSendDqm_

private

Definition at line 211 of file SharedResources.h.

Referenced by cancelAllWorkloops(), printWorkLoopStatus(), and startSendDqmWorkLoop().

WorkLoop_t* evf::rb_statemachine::SharedResources::wlWatching_

private

Definition at line 206 of file SharedResources.h.

Referenced by cancelAllWorkloops(), and startWatchingWorkLoop().