---

stor::EvtMsgRingBuffer Class Reference

#include <EventFilter/StorageManager/interface/EvtMsgRingBuffer.h>

List of all members.

Public Types
typedef std::vector< unsigned char >	Buffer
Public Member Functions
	EvtMsgRingBuffer (unsigned int size)
bool	isEmpty ()
bool	isFull ()
EventMsgView	pop_front ()
void	push_back (EventMsgView msg)
virtual	~EvtMsgRingBuffer ()
Private Attributes
int	head_
unsigned int	maxsize_
int	nextfree_
std::vector< Buffer >	ring_buffer_
std::vector< int >	ring_totmsgsize_
int	tail_

---

Detailed Description

Definition at line 26 of file EvtMsgRingBuffer.h.

---

Member Typedef Documentation

typedef std::vector<unsigned char> stor::EvtMsgRingBuffer::Buffer

Definition at line 29 of file EvtMsgRingBuffer.h.

---

Constructor & Destructor Documentation

EvtMsgRingBuffer::EvtMsgRingBuffer

(

unsigned int

size

)

Definition at line 22 of file EvtMsgRingBuffer.cc.

References i, int, MAX_EVTBUF_SIZE, maxsize_, and ring_buffer_.

                                                   :
  maxsize_(size), head_(0), tail_(0), nextfree_(0),
  ring_buffer_(maxsize_), ring_totmsgsize_(maxsize_)
{
  for (int i=0; i<(int)maxsize_; i++)
    ring_buffer_[i].reserve(MAX_EVTBUF_SIZE);
}

virtual stor::EvtMsgRingBuffer::~EvtMsgRingBuffer

(

)

[inline, virtual]

Definition at line 32 of file EvtMsgRingBuffer.h.

{};

---

Member Function Documentation

bool EvtMsgRingBuffer::isEmpty

(

)

Definition at line 76 of file EvtMsgRingBuffer.cc.

References head_, nextfree_, and tail_.

Referenced by pop_front().

{
  return ((head_ == tail_) && (head_ == nextfree_));
}

bool EvtMsgRingBuffer::isFull

(

)

Definition at line 81 of file EvtMsgRingBuffer.cc.

References head_, nextfree_, and tail_.

Referenced by push_back().

{
  return ((head_ != tail_) && (head_ == nextfree_));
}

EventMsgView EvtMsgRingBuffer::pop_front

(

)

Definition at line 30 of file EvtMsgRingBuffer.cc.

References lat::endl(), EventMsgView::event(), EventMsgView::eventLength(), FDEBUG, head_, isEmpty(), maxsize_, nextfree_, ring_buffer_, and tail_.

{
  // check to see if empty - what to return?
  // calling code needs to check ifEmpty() and do appropriate thing
  // should really return a message an appropriate MsgCode
  if(isEmpty()) return EventMsgView(&ring_buffer_[head_][0]);

  EventMsgView popthis(&ring_buffer_[head_][0]);
  if(head_ == (int)maxsize_-1) head_ = 0;
  else head_++;
  // see if now empty and need to move the tail
  if(head_ == nextfree_) tail_ = head_;
  FDEBUG(10) << "after pop_front head = " << head_ << " tail = " << tail_
             << " next free = " << nextfree_ << endl;
  FDEBUG(10) << "popping event = " << popthis.event() << endl;
  FDEBUG(10) << "pop_front msg event size " << popthis.eventLength() << std::endl;
  return popthis;
}

void EvtMsgRingBuffer::push_back

(

EventMsgView

msg

)

Definition at line 49 of file EvtMsgRingBuffer.cc.

References edmNew::copy(), lat::endl(), EventMsgView::eventData(), EventMsgView::eventLength(), FDEBUG, Capri::details::from(), head_, EventMsgView::headerSize(), isFull(), maxsize_, nextfree_, ring_buffer_, ring_totmsgsize_, and tail_.

{
  // see if full and need to move the head
  if(isFull()) {
    if(head_ == (int)maxsize_-1) head_ = 0;
    else head_++;
  }

  // 31-Jul-2006, KAB:  I expect that the correct way to copy an
  // event message is create an EventMsgBuilder using data fetched from
  // the input message.  However, there currently doesn't seem to be 
  // sufficient methods in EventMsgView to support this.  So, for now,
  // we just copy the data directly (ugly hack).
  unsigned char* pos = (unsigned char*) &ring_buffer_[nextfree_][0];
  unsigned char* from = (unsigned char*)
    ((unsigned int) inputMsgView.eventData() - inputMsgView.headerSize());
  int dsize = inputMsgView.eventLength() + inputMsgView.headerSize();
  copy(from,from+dsize,pos);
  ring_totmsgsize_[nextfree_]=dsize;

  tail_ = nextfree_;
  if(tail_ == (int)maxsize_-1) nextfree_ = 0;
  else nextfree_++;
  FDEBUG(10) << "after push_back head = " << head_ << " tail = " << tail_
             << " next free = " << nextfree_ << endl;
}

---

Member Data Documentation

int stor::EvtMsgRingBuffer::head_ [private]

Definition at line 41 of file EvtMsgRingBuffer.h.

Referenced by isEmpty(), isFull(), pop_front(), and push_back().

unsigned int stor::EvtMsgRingBuffer::maxsize_ [private]

Definition at line 40 of file EvtMsgRingBuffer.h.

Referenced by EvtMsgRingBuffer(), pop_front(), and push_back().

int stor::EvtMsgRingBuffer::nextfree_ [private]

Definition at line 43 of file EvtMsgRingBuffer.h.

Referenced by isEmpty(), isFull(), pop_front(), and push_back().

std::vector<Buffer> stor::EvtMsgRingBuffer::ring_buffer_ [private]

Definition at line 44 of file EvtMsgRingBuffer.h.

Referenced by EvtMsgRingBuffer(), pop_front(), and push_back().

std::vector<int> stor::EvtMsgRingBuffer::ring_totmsgsize_ [private]

Definition at line 45 of file EvtMsgRingBuffer.h.

Referenced by push_back().

int stor::EvtMsgRingBuffer::tail_ [private]

Definition at line 42 of file EvtMsgRingBuffer.h.

Referenced by isEmpty(), isFull(), pop_front(), and push_back().

---

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

• EventFilter/StorageManager/interface/EvtMsgRingBuffer.h
• EventFilter/StorageManager/src/EvtMsgRingBuffer.cc

---