33 # include <omniORB3/CORBA.h>
37 # include <omniORB4/CORBA.h>
46 _queue(new CORBA::Any*[_size]),
49 DB(5,
"MaxQueueLength="<<size)
59 for(
long i=0; i<
_size; ++i)
71 : _eventQueue(eventQueue),
72 _next(eventQueue._next)
80 return(
_next!=_eventQueue._next );
86 CORBA::Any* result =_eventQueue._queue[
_next];
The EventQueue is a circular buffer, that contains _size-1 events.
long _next
Always points to the next slot to which an event will be written.
EventQueue(long size=1023)
Reader(EventQueue &eventQueue)