subscriber_sse.h

Go to the documentation of this file.

#ifndef CVMFS_NOTIFY_SUBSCRIBER_SSE_H_
#define CVMFS_NOTIFY_SUBSCRIBER_SSE_H_

#include <string>

#include "duplex_curl.h"
#include "subscriber.h"
#include "util/atomic.h"

namespace notify {

class SubscriberSSE : public Subscriber {
 public:
  explicit SubscriberSSE(const std::string &server_url);
  virtual ~SubscriberSSE();

  virtual bool Subscribe(const std::string &topic);
  virtual void Unsubscribe();

 private:
  bool ShouldQuit() const;

  void AppendToBuffer(const std::string &s);

  void ClearBuffer();

  static size_t CurlRecvCB(void *buffer, size_t size, size_t nmemb,
                           void *userp);
  static int CurlProgressCB(void *clientp, curl_off_t dltotal, curl_off_t dlnow,
                            curl_off_t ultotal, curl_off_t ulnow);

  std::string server_url_;
  std::string topic_;
  std::string buffer_;

  mutable atomic_int32 should_quit_;
};

}  // namespace notify

#endif  // CVMFS_NOTIFY_SUBSCRIBER_SSE_H_