FesaDeviceServer.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef FESA_DEVICE_SERVER_H_
#define FESA_DEVICE_SERVER_H_

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

#include <cmw-rda/DeviceServerBase.h>

#include <string>

namespace fesa
{

class AbstractDevice;
class AbstractServerDeviceClass;
class ProcessConfiguration;
class Property;
class SubscriptionTreeManager;

class FesaDeviceServer: public rdaDeviceServerBase, public Thread
{
  public:
    static void initCMW();

    FesaDeviceServer(const std::string& name, const ProcessConfiguration* processConfiguration, SubscriptionTreeManager* subscriptionTreeManager);

    ~FesaDeviceServer();

    rdaData* get(const rdaIOPoint& iop, const rdaData& ctx);

    void set(const rdaIOPoint& iop, const rdaData& ctx, const rdaData& value);

    void monitorOn(const rdaIOPoint& iop, const rdaData& ctx, rdaValueChangeListener* listener);

    void monitorOff(const rdaIOPoint& iop, rdaValueChangeListener* listener);

    void start();

    bool useFastUpdate();

  private:

    void run();

    void runDeviceServer();

    void decodeIOPoint(const rdaIOPoint& iop, AbstractServerDeviceClass*& srvDeviceClass, Property*& prop, AbstractDevice*& device,
                       std::string& cycleSelector);

    // If we delete the about method we could remove this friend
    friend class AbstractServerEquipment;

    bool isRTProcessDown();

    SubscriptionTreeManager* pTreeManager_;

    bool firstUpdateAcquisitionEnabled_;

    bool firstUpdateSettingEnabled_;

    Mutex mutex_;

};

} // fesa

#endif // FESA_DEVICE_SERVER_H_