mf::service::ThreadQueue Class Reference

#include <ThreadQueue.h>

Public Member Functions
	ThreadQueue ()
virtual	~ThreadQueue ()=default
void	consume (OpCode &opcode, void *&operand)
void	produce (OpCode opcode, void *operand)
	ThreadQueue (ThreadQueue const &)=delete
ThreadQueue &	operator= (ThreadQueue const &)=delete

Private Attributes
SingleConsumerQ	m_buf

Static Private Attributes
static constexpr int	buf_depth {500}
static constexpr int	buf_size {sizeof(OpCode) + sizeof(void*)}

Detailed Description

Definition at line 10 of file ThreadQueue.h.

Constructor & Destructor Documentation

mf::service::ThreadQueue::ThreadQueue

(

)

Definition at line 7 of file ThreadQueue.cc.

: m_buf{buf_size, buf_depth} {}

virtual mf::service::ThreadQueue::~ThreadQueue ( )

virtualdefault

mf::service::ThreadQueue::ThreadQueue ( ThreadQueue const &  )

delete

Member Function Documentation

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

Definition at line 21 of file ThreadQueue.cc.

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

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

delete

void mf::service::ThreadQueue::produce	(	OpCode	opcode,
		void *	operand
	)

Definition at line 10 of file ThreadQueue.cc.

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

Member Data Documentation

constexpr int mf::service::ThreadQueue::buf_depth {500}

staticprivate

Definition at line 27 of file ThreadQueue.h.

constexpr int mf::service::ThreadQueue::buf_size {sizeof(OpCode) + sizeof(void*)}

staticprivate

Definition at line 28 of file ThreadQueue.h.

SingleConsumerQ mf::service::ThreadQueue::m_buf

private

Definition at line 29 of file ThreadQueue.h.

---

The documentation for this class was generated from the following files:

• messagefacility/messagefacility/MessageService/ThreadQueue.h
• messagefacility/messagefacility/MessageService/ThreadQueue.cc