Notification.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef NOTIFICATION_H_
#define NOTIFICATION_H_

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

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

namespace fesa
{

class SubscriptionParameter;
class NotificationID;
class MultiplexingContext;

class Notification
{
  public:
    Notification(NotificationID& id);

    void notify(MultiplexingContext& muxContext, RequestType& reqType);

    void addSubscriber(boost::shared_ptr<SubscriptionParameter> sp);

    void addCycle(const std::string& cycleSelector);

    void removeSubscriber(boost::shared_ptr<SubscriptionParameter> sp, const std::string& cycleSelector, bool toBeDeleted);

    bool contains(const std::string& deviceName, const std::string& propName);

    void printDebugState(std::stringstream& str);

  private:
    NotificationID& id_;

    typedef std::map<std::string, boost::shared_ptr<SubscriptionParameter> > SubscriptionMap;
    typedef SubscriptionMap::iterator SubscriptionItr;
    SubscriptionMap subscriptions_;

    SubscriptionCycle subscriptionCycle_;
};

} // fesa

#endif // NOTIFICATION_H_