/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_6_2_5/src/FWCore/MessageService/src/ThreadQueue.cc

Go to the documentation of this file.

// ----------------------------------------------------------------------
//
// ThreadQueue.cc
//
// Changes:
//
// 

#include "FWCore/MessageService/interface/ThreadQueue.h"
#include <cstring>

namespace edm {
namespace service {

ThreadQueue::ThreadQueue() 
  : m_buf (buf_size, buf_depth)
{
}
ThreadQueue::~ThreadQueue() {}

void  
ThreadQueue::
produce(MessageLoggerQ::OpCode  o, void * operand)
{
  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
  
void  
ThreadQueue::
consume( MessageLoggerQ::OpCode & opcode, void * & operand )
{
  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);
}


  

} // end of namespace service  
} // end of namespace edm