/data/refman/pasoursint/CMSSW_4_1_8_patch9/src/EventFilter/Utilities/interface/MsgBuf.h

Go to the documentation of this file.

#ifndef EVENTFILTER_UTILITIES_MSG_BUF_H
#define EVENTFILTER_UTILITIES_MSG_BUF_H

#include "EventFilter/Utilities/interface/queue_defs.h"

//@EM ToDo move implementation to .cc file

namespace evf{
  class MsgBuf{
  public:
    MsgBuf() : msize_(MAX_MSG_SIZE+sizeof(struct msgbuf)+1)
      {
        buf = new unsigned char[MAX_MSG_SIZE+sizeof(struct msgbuf)+1];
        ptr_ = (msgbuf*)buf;
        ptr_->mtype = MSQM_MESSAGE_TYPE_NOP;
      }

    MsgBuf(unsigned int size, unsigned int type) : msize_(size)
      {
        buf = new unsigned char[msize_+sizeof(struct msgbuf)+1];
        ptr_ = (msgbuf*)buf;
        ptr_->mtype = type;
      }
    size_t msize(){return msize_;}
    virtual ~MsgBuf(){delete[] buf;}
    msgbuf* operator->(){return ptr_;}
  private:
    struct msgbuf *ptr_;
    unsigned char *buf;
    size_t msize_;
    friend class MasterQueue;
    friend class SlaveQueue;
  };
}
#endif