edm::service::MainThreadMLscribe Class Reference

#include <MainThreadMLscribe.h>

Inheritance diagram for edm::service::MainThreadMLscribe:

Public Member Functions
	MainThreadMLscribe (std::shared_ptr< ThreadQueue > tqp)
void	runCommand (MessageLoggerQ::OpCode opcode, void *operand) override
	~MainThreadMLscribe () override
Public Member Functions inherited from edm::service::AbstractMLscribe
	AbstractMLscribe ()
virtual	~AbstractMLscribe ()

Private Attributes
edm::propagate_const< std::shared_ptr< ThreadQueue > >	m_queue

Detailed Description

Definition at line 39 of file MainThreadMLscribe.h.

Constructor & Destructor Documentation

edm::service::MainThreadMLscribe::MainThreadMLscribe

(

std::shared_ptr< ThreadQueue >

tqp

)

Definition at line 16 of file MainThreadMLscribe.cc.

: m_queue(tqp) {}

edm::service::MainThreadMLscribe::~MainThreadMLscribe ( )

override

Definition at line 18 of file MainThreadMLscribe.cc.

{}

Member Function Documentation

void edm::service::MainThreadMLscribe::runCommand ( MessageLoggerQ::OpCode  opcode, void *  operand  )

overridevirtual

Reimplemented from edm::service::AbstractMLscribe.

Definition at line 20 of file MainThreadMLscribe.cc.

References edm::ConfigurationHandshake::c, edm::ConfigurationHandshake::epp, h, edm::MessageLoggerQ::handshaked(), edm::ConfigurationHandshake::m, m_queue, and findQualityFiles::v.

                                                                                  {
      if (MessageLoggerQ::handshaked(opcode)) {
        Place_for_passing_exception_ptr epp(new Pointer_to_new_exception_on_heap());
        ConfigurationHandshake h(operand, epp);
        void *v(static_cast<void *>(&h));
        Pointer_to_new_exception_on_heap ep;
        {
          std::unique_lock<std::mutex> sl(h.m);  // get lock
          m_queue->produce(opcode, v);
          // wait for result to appear (in epp)
          h.c.wait(sl);  // c.wait(sl) unlocks the scoped lock and sleeps till notified
          // ... and once the MessageLoggerScribe does h.c.notify_all() ...
          ep = *h.epp;
          // finally, release the scoped lock by letting it go out of scope
        }
        if (ep) {
          edm::Exception ex(*ep);
          throw ex;
        }
      } else {
        m_queue->produce(opcode, operand);
      }
    }  // runCommand

Member Data Documentation

edm::propagate_const<std::shared_ptr<ThreadQueue> > edm::service::MainThreadMLscribe::m_queue

private

Definition at line 50 of file MainThreadMLscribe.h.

Referenced by runCommand().