edm::service::ThreadQueue Class Reference

#include <ThreadQueue.h>

Public Member Functions
void	consume (MessageLoggerQ::OpCode &opcode, void *&operand)
void	produce (MessageLoggerQ::OpCode opcode, void *operand)
	ThreadQueue ()
virtual	~ThreadQueue ()

Private Member Functions
const ThreadQueue &	operator= (const ThreadQueue &)=delete
	ThreadQueue (const ThreadQueue &)=delete

Private Attributes
SingleConsumerQ	m_buf

Static Private Attributes
static const int	buf_depth = 500
static const int	buf_size = sizeof(MessageLoggerQ::OpCode) + sizeof(void*)

Detailed Description

Definition at line 27 of file ThreadQueue.h.

Constructor & Destructor Documentation

ThreadQueue::ThreadQueue

(

)

Definition at line 15 of file ThreadQueue.cc.

: m_buf(buf_size, buf_depth) {}

ThreadQueue::~ThreadQueue ( )

virtual

Definition at line 16 of file ThreadQueue.cc.

{}

edm::service::ThreadQueue::ThreadQueue ( const ThreadQueue &  )

privatedelete

Member Function Documentation

void ThreadQueue::consume	(	MessageLoggerQ::OpCode &	opcode,
		void *&	operand
	)

Definition at line 27 of file ThreadQueue.cc.

References b, buf_size, edm::SingleConsumerQ::OperateBuffer< T >::buffer(), edm::SingleConsumerQ::OperateBuffer< T >::commit(), and m_buf.

                                                                          {
      SingleConsumerQ::ConsumerBuffer b(m_buf);  // Look -- CONSUMER buffer
      char *slot_p = static_cast<char *>(b.buffer());
      std::memcpy(&opcode, slot_p + 0, sizeof(MessageLoggerQ::OpCode));
      std::memcpy(&operand, slot_p + sizeof(MessageLoggerQ::OpCode), sizeof(void *));
      b.commit(buf_size);
    }

const ThreadQueue& edm::service::ThreadQueue::operator= ( const ThreadQueue &  )

privatedelete

void ThreadQueue::produce	(	MessageLoggerQ::OpCode	opcode,
		void *	operand
	)

Definition at line 18 of file ThreadQueue.cc.

References b, buf_size, edm::SingleConsumerQ::OperateBuffer< T >::buffer(), edm::SingleConsumerQ::OperateBuffer< T >::commit(), m_buf, and findQualityFiles::v.

                                                                   {
      SingleConsumerQ::ProducerBuffer b(m_buf);
      char *slot_p = static_cast<char *>(b.buffer());
      void *v = operand;
      std::memcpy(slot_p + 0, &o, sizeof(MessageLoggerQ::OpCode));
      std::memcpy(slot_p + sizeof(MessageLoggerQ::OpCode), &v, sizeof(void *));
      b.commit(buf_size);
    }  // runCommand

Member Data Documentation

const int edm::service::ThreadQueue::buf_depth = 500

staticprivate

Definition at line 52 of file ThreadQueue.h.

const int edm::service::ThreadQueue::buf_size = sizeof(MessageLoggerQ::OpCode) + sizeof(void*)

staticprivate

Definition at line 53 of file ThreadQueue.h.

Referenced by consume(), and produce().

SingleConsumerQ edm::service::ThreadQueue::m_buf

private

Definition at line 54 of file ThreadQueue.h.

Referenced by consume(), and produce().