MessageServicePresence.h

Go to the documentation of this file.

#ifndef FWCore_MessageService_MessageServicePresence_h
#define FWCore_MessageService_MessageServicePresence_h

#include "FWCore/Utilities/interface/Presence.h"
#include "FWCore/Utilities/interface/get_underlying_safe.h"

#include "boost/thread/thread.hpp"

#include <memory>


namespace edm  {
namespace service {       

class ThreadQueue;

class MessageServicePresence : public Presence
{
public:
  // ---  birth/death:
  MessageServicePresence();
  ~MessageServicePresence() override;

private:
  // --- no copying:
  MessageServicePresence(MessageServicePresence const&) = delete; // Disallow copying
  void operator=(MessageServicePresence const &) = delete; // Disallow copying

  std::shared_ptr<ThreadQueue const> queue() const {return get_underlying_safe(m_queue);}
  std::shared_ptr<ThreadQueue>& queue() {return get_underlying_safe(m_queue);}

  // --- data:
  edm::propagate_const<std::shared_ptr<ThreadQueue>> m_queue;
  boost::thread  m_scribeThread;

};  // MessageServicePresence


}   // end of namespace service
}  // namespace edm


#endif  // FWCore_MessageService_MessageServicePresence_h