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