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 21 of file MainThreadMLscribe.cc.

References runCommand().

{}

Member Function Documentation

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

overridevirtual

Reimplemented from edm::service::AbstractMLscribe.

Definition at line 25 of file MainThreadMLscribe.cc.

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

Referenced by ~MainThreadMLscribe().

{
  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 53 of file MainThreadMLscribe.h.

Referenced by runCommand().