SubscriptionParameter.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef SUBSCRIPTION_PARAMETER_H_
#define SUBSCRIPTION_PARAMETER_H_

#include <fesa-core/Core/FesaDefs.h>

#include <string>
#include <vector>
#include <sstream>
#include <boost/shared_ptr.hpp>

class rdaData;
class rdaValueChangeListener;

namespace fesa
{

class AbstractSubscriptionFilter;
class AbstractDevice;
class Property;
class NotificationThread;
class MultiplexingContext;

class SubscriptionParameter
{
  public:
    SubscriptionParameter(const std::string& paramName, AbstractDevice& device, Property& property, bool useFastUpdate, NotificationThread* pNotificationThread);

    ~SubscriptionParameter();

    void notify(MultiplexingContext& muxContext, RequestType& reqType, std::vector<std::string>& validCS);

    void addSubscriber(const std::string& cycleSelector, const rdaData& filter, rdaValueChangeListener* subscriber);

    void removeSubscriber(const std::string& cycleSelector, rdaValueChangeListener* subscriber, bool& isEmpty);

    const std::string& getName();

    Property& getProperty();

    AbstractDevice& getDevice();

    void reportInternalError(const std::string& errorCategory, int32_t errorCode, const std::string&  message, bool changed);

    void printDebugState(std::stringstream& str);

  private:

    typedef std::vector<boost::shared_ptr<AbstractSubscriptionFilter> > SubscriptionFilterVector;
    typedef SubscriptionFilterVector::iterator SubscriptionFilterItr;
    SubscriptionFilterVector filters_;

    std::string name_;

    AbstractDevice& device_;

    Property& property_;

    bool useFastUpdate_;

    NotificationThread* pNotificationThread_;
};

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

inline Property& SubscriptionParameter::getProperty()
{
    return property_;
}

inline AbstractDevice& SubscriptionParameter::getDevice()
{
    return device_;
}

} // fesa

#endif // SUBSCRIPTION_PARAMETER_H_