#include <RIPCQueue.h>
Inheritance diagram for RIPCQueue:
Public Types | |
enum | RIPCPrimitiveType { RIPC_MUTEX, RIPC_EVENT, RIPC_SEMAPHORE, RIPC_BARRIER, RIPC_LOCK, RIPC_SHARED_MEMORY, RIPC_QUEUE } |
enum | RIPCRanks { DEFAULT_RANK = 0 } |
Public Member Functions | |
void | get (RIPCObject &objDesc) |
void * | get () |
bool | get (RIPCObject &objDesc, unsigned timeout) |
void * | get (unsigned timeout) |
virtual void | priorityGet (int rank, RIPCObject &objDesc)=0 |
void * | priorityGet (int rank) |
virtual bool | priorityGet (int rank, RIPCObject &objDesc, unsigned timeout)=0 |
void * | priorityGet (int rank, unsigned timeout) |
virtual void | put (RIPCObject const &objDesc)=0 |
virtual void | put (void const *obj, size_t objSize)=0 |
virtual void | broadcast (RIPCObject const &objDesc)=0 |
virtual void | broadcast (void const *obj, size_t objSize)=0 |
RIPCPrimitiveType | getType () |
char const * | getTypeName () |
virtual char const * | getName ()=0 |
virtual bool | alreadyExists ()=0 |
void | waitFor () |
bool | waitFor (unsigned timeout) |
virtual void | priorityWait (int rank)=0 |
virtual bool | priorityWait (int rank, unsigned timeout)=0 |
virtual void | reset ()=0 |
virtual void | close ()=0 |
virtual void * | allocate (size_t size) |
virtual void | deallocate (void *obj, size_t size=0) |
Static Public Member Functions | |
void | deallocator (RIPCObject const &objDesc) |
Semantic of methods inherited from RIPCPrimitive
:
waitFor
reset
|
Primitive types |
|
Method for allocation memory for container elements (currently queue and shared memory). This method can be overriden by derived class* to provide custom allocation policy. |
|
Primitive returned by
|
|
Broadcast message to all sessions currently connected to the queue. The message will no be deleted from the queue until all session read this
|
|
Broadcast message to all sessions currently connected to the queue. The message will no be deleted from the queue until all session read this
|
|
Close primitive. This method decrease access counter of the primitive and once it becomes zero, primitive is destroyed. |
|
Method for deallocation memory for container elements (currently queue and shared memory). This method can be overriden by derived class to provide custom allocation policy. |
|
Get element from the queue with timeout. If queue is empty this method waits until somebody else put element in the queue.
|
|
Get element from the queue with timeout. If queue is empty this method waits until somebody else put element in the queue.
|
|
Get element from the queue. If queue is empty this method waits until somebody else put element in the queue.
|
|
Get element from the queue. If queue is empty this method waits until somebody else put element in the queue.
|
|
Get primitive name. Name of the primitive is unique with primitives of the same type (events, semaphores,...). It is possible that, for example, event and mutex has the same name.
|
|
Get RIPC primitive type
Implements RIPCPrimitive. |
|
Get RIPC primitive type name
|
|
Get element from the queue with timeout. If queue is empty this method waits until somebody else put element in the queue.
|
|
Get element from the queue with timeout. If queue is empty this method waits until somebody else put element in the queue.
|
|
Get element from the queue. If queue is empty this method waits until somebody else put element in the queue.
|
|
Get element from the queue. If queue is empty this method waits until somebody else put element in the queue.
|
|
Priority wait until state of primitive is switched with timeout. Requests with the lowest
|
|
Priority wait until state of primitive is switched. Requests with the lowest
|
|
Put element at the end of the queue.
|
|
Put element at the end of the queue.
|
|
Reset primitive. Semantic of this method depends on particular primitive type and is explained in specification of each primitive. |
|
Wait until state of primitive is switched with timeout. Semantic of this method depends on particular primitive type and is explained in specification of each primitive.
|
|
Wait until state of primitive is switched. Semantic of this method depends on particular primitive type and is explained in specification of each primitive. |