OnSubscriptionEventSource.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef ON_SUBSCRIPTION_EVENT_SOURCE_H
#define ON_SUBSCRIPTION_EVENT_SOURCE_H

#include <fesa-core/RealTime/AbstractEventSource.h>
#include <fesa-core/Proxy/ProxyInterface.h>

#include <string>
#include <set>

namespace fesa
{

class EventElement;

class OnSubscriptionEventSource : public AbstractEventSource
{
  public:

    OnSubscriptionEventSource();

  private:

    friend class AbstractRealTimeLabObjectFactory;
    friend class AbstractEventSourceFactory;

    ~OnSubscriptionEventSource();

    void connect(boost::shared_ptr<fesa::EventElement>& eventElement);

    RTEvent* wait();

    bool startSubscriptions();

    struct EventInfo
    {
        std::string deviceName;
        std::string propertyName;
        std::string cycleSelectorName;
        rdaData data;
    };
    EventInfo eventInfo_;
    ProxyInterface proxy_;

    typedef std::multimap<std::pair<std::string, std::string>, std::string> OnSubscriptionEventMapping;

    OnSubscriptionEventMapping onSubscriptionEventMapping_;

    typedef std::set<std::pair<std::string, std::string> > PendingSubscriptions;
    PendingSubscriptions pendingSubscriptions_;

    OnSubscriptionEventMapping::iterator itr1_;

    OnSubscriptionEventMapping::iterator itr2_;

    bool IsSubscriptionStarted_;

    class SubscriptionThread : public Thread
    {
      public:
        SubscriptionThread(OnSubscriptionEventSource*);
        ~SubscriptionThread();
      private:
        void run();
        OnSubscriptionEventSource* evtSrc_;
    };

    SubscriptionThread* subscriptionThread_;

    void createSubscriptionThread();
    void deleteSubscriptionThread();

};

} // fesa

#endif // ON_SUBSCRIPTION_EVENT_SOURCE_H