AbstractRTEquipment.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef ABSTRACT_RT_EQUIPMENT_H_
#define ABSTRACT_RT_EQUIPMENT_H_

#include <fesa-core/Core/AbstractComponentEquipment.h>
#include <fesa-core/Utilities/Thread.h>
#include <fesa-core/Exception/FesaException.h>

namespace fesa
{

class FesaStream;
class AbstractEventSource;
class RTScheduler;
class AbstractRTDeviceClass;
class RTController;

struct RTSchedulingUnitRef
{
    std::string name_;

    std::string className_;

    bool perDeviceCollection_;

    bool found_;

};

struct RTLayerInfo
{
    std::string layerName_;

    int32_t queueSize_;

    std::vector<RTSchedulingUnitRef> schedulingUnitRefCol_;

    void print();

};

class AbstractRTEquipment: public AbstractComponentEquipment
{
  public:

    static AbstractRTEquipment* getInstance();

    // CRFESA-764 check whether we still need this method
    // virtual void concreteInit() = 0;

    AbstractRTDeviceClass* getRTDeviceClass(const std::string& rtDeviceClass);

    void initialize();

    void start(RunMode mode);

    void printConfigAll(FesaStream* fesaStream);

    void printStateAll(FesaStream* fesaStream, double elapsedTime);

    virtual void handleEventSourceError (AbstractEventSource* eventSource,FesaException& exception) = 0;


    virtual void handleSchedulerError (RTScheduler* scheduler,FesaException& exception) = 0;



  protected:
    friend class RTController;

    typedef std::vector<RTLayerInfo*> RTLayerInfoCol;

    AbstractRTEquipment();

    virtual ~AbstractRTEquipment();

    virtual void fillRTSchedulerInfo(std::vector<RTLayerInfo*>& layerCol);

    void waitSignal();

    RTController* rtController_;

    static AbstractRTEquipment* theInstance_;

};

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


inline AbstractRTDeviceClass* AbstractRTEquipment::getRTDeviceClass(const std::string& rtDeviceClass)
{
    return (AbstractRTDeviceClass*) this->getDeviceClass(rtDeviceClass);
}

inline AbstractRTEquipment* AbstractRTEquipment::getInstance()
{
    if (theInstance_ == NULL)
        throw FesaException(__FILE__, __LINE__, FesaErrorRTEquipmentNotCreated.c_str());
    else
        return theInstance_;
}

} // namespace end

#endif /* ABSTRACT_RT_EQUIPMENT_H_ */