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

Detailed Description

Definition at line 30 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 19 of file ThreadQueue.cc.

References produce().

{}

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

privatedelete

Member Function Documentation

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

Definition at line 35 of file ThreadQueue.cc.

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

Referenced by produce().

{
  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 23 of file ThreadQueue.cc.

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

Referenced by ~ThreadQueue().

{
  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 58 of file ThreadQueue.h.

const int edm::service::ThreadQueue::buf_size

staticprivate

Initial value:

= sizeof(MessageLoggerQ::OpCode)
                               + sizeof(void *)

Definition at line 59 of file ThreadQueue.h.

Referenced by consume(), and produce().

SingleConsumerQ edm::service::ThreadQueue::m_buf

private

Definition at line 61 of file ThreadQueue.h.

Referenced by consume(), and produce().