RTController.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef RT_CONTROLLER_H_
#define RT_CONTROLLER_H_

#include <fesa-core/RealTime/AbstractRTDeviceClass.h>
#include <fesa-core/RealTime/AbstractRTEquipment.h>

#include <string>
#include <map>
#include <vector>
#include <stdint.h>

#include <boost/scoped_ptr.hpp>
#include <boost/shared_ptr.hpp>

namespace fesa
{

class FesaStream;
class RTScheduler;
class RTLayerInfo;
class AbstractRTDeviceClass;
class EventElement;
class AbstractEventSourceFactory;
class RTSchedulingUnitRef;
class EventsMappingLoader;
class AbstractRTAction;
struct RTActionConfig;


class RTController
{

  public:
    RTController();

    virtual ~RTController();

    void start();

    void printConfigAll(FesaStream* fesaStream);

    void printStateAll(FesaStream* fesaStream, double elapsedTime);

    void initialize();

  protected:
    std::map<const std::string, RTScheduler*> schedulersCol_;

  private:

    void createSchedulers(std::vector<RTLayerInfo*>& layerInfoCol, AbstractRTDeviceClass* pRTDeviceClass,
                    const std::string instanceFile);

    void createRTActionConfig(AbstractRTEquipment::RTLayerInfoCol& layerInfoCol, AbstractRTDeviceClass* pRTDeviceClass,
                    RTSchedulingUnitInfo* schedulingUnit, AbstractRTDeviceClass::RTActionInfoCol& actionInfoCol, EventsMappingLoader& eventsManager);

    RTScheduler* createAction(AbstractRTEquipment::RTLayerInfoCol& layerInfoCol, AbstractRTDeviceClass* pRTDeviceClass,
                    RTSchedulingUnitInfo* schedulingUnit, RTActionConfig& actionConfig, std::set<AbstractDevice*>* deviceCollection);

    RTScheduler* findScheduler(const std::string& schedulerName, uint32_t queueSize);

    void createEventSource(const std::string& eventSourceName, boost::shared_ptr<fesa::EventElement>& element,
                           RTScheduler* currentScheduler, AbstractEventSourceFactory* eventSourceFactory);

    void assertSchedulingUnitsConfig(const std::vector<RTSchedulingUnitRef> schedulingUnits);

    std::vector<std::string> schedulingUnitWithEmptyDevCol_;
};

} // fesa

#endif // RT_CONTROLLER_H_