RTScheduler.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef RT_SCHEDULER_H_
#define RT_SCHEDULER_H_

#include <fesa-core/Diagnostic/DiagnosticUtils.h>
#include <fesa-core/Utilities/Thread.h>
#include <fesa-core/Utilities/Mutex.h>
#include <fesa-core/Utilities/ConditionalVariable.h>

#include <string>
#include <map>
#include <vector>
#include <deque>

#include <boost/shared_ptr.hpp>

namespace fesa
{

class RTEvent;
class AbstractRTAction;
class FesaStream;

class RTScheduler : public Thread
{
  public:


    RTScheduler(const std::string& name, int32_t eventQueueSize);

    void post(boost::shared_ptr<RTEvent>& pEv);

    void addRTAction(const std::string& eventName, AbstractRTAction* rtAction);

    const std::string& getName();

    virtual ~RTScheduler();

    void printState(FesaStream* fesaStream, double elapsedTime);

    void printConfig(FesaStream* fesaStream);

    void cancel();

  private:

    std::map<const std::string, std::vector<AbstractRTAction*> > schedulingMap_;

    std::deque<boost::shared_ptr<RTEvent> > eventQueue_;

    std::string name_;

    int32_t queueSize_;

    Mutex mutexQueue_;

    ConditionalVariable conditionalVariableQueue_;

    void run();

    void schedule(RTEvent* event);

    void logDiagnostics(RTEvent*& pEvent);

    //Diagnostic status
    DiagnosticUtils::DiagStateCounter postEventCount_;
    DiagnosticUtils::DiagStateCounter scheduledEventCount_;
    DiagnosticUtils::DiagStateCounter accumulatedEventCount_;
    uint32_t lostEventCount_;
};

/**********************************************************************************/

inline const std::string& RTScheduler::getName()
{
    return name_;
}

} // fesa

#endif // RT_SCHEDULER_H_