NotificationThread.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef NOTIFICATION_THREAD_H_
#define NOTIFICATION_THREAD_H_

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

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

namespace fesa
{

class SubscriptionFilter;

class NotificationThread : public Thread
{
  public:

    NotificationThread(const std::string& className, const std::string& notificationThreadKey);

    virtual ~NotificationThread();

    void addNotificationEvent(MultiplexingContext& muxContext, RequestType& reqType,
                              std::vector<std::string>& validCS, SubscriptionFilter* subFilter);

    bool removeNotificationEvent(SubscriptionFilter* subFilter);

    Mutex& getMutex();

  private:

    void run();

    class NotificationQueueElement
    {
      public:

        NotificationQueueElement(MultiplexingContext& muxContext, RequestType& reqType,
                                 std::vector<std::string>& validCS, SubscriptionFilter* subFilter);

        ~NotificationQueueElement();

        SubscriptionFilter* subFilter_;

        MultiplexingContext muxContext_;

        RequestType reqType_;

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

    std::deque<boost::shared_ptr<NotificationQueueElement> > queue_;

    SubscriptionFilter* inUseSubFilter_;

    Mutex mutexQueue_;

    Mutex mutexBackThread_;

    ConditionalVariable startConsumption_;
};

inline Mutex& NotificationThread::getMutex()
{
    return mutexBackThread_;
}

} // fesa

#endif // NOTIFICATION_THREAD_H_