#include <source/ariba/utility/transport/tcpip/protlib/fqueue.h>
Classes | |
class | FQError |
FastQueue error. More... | |
Public Member Functions | |
FastQueue (const char *qname=0, bool exp=false) | |
constructor | |
~FastQueue () | |
destructor | |
bool | enqueue (message *element, bool exp=false) |
enqueue message | |
message * | dequeue (bool blocking=true) |
dequeue message | |
message * | dequeue_timedwait (const struct timespec &tspec) |
dequeue message, timed wait | |
message * | dequeue_timedwait (const long int msec) |
dequeue message, timed wait | |
bool | is_empty () const |
is queue empty | |
unsigned long | size () const |
get number of enqueued messages | |
bool | is_expedited_enabled () const |
is expedited data support enabled | |
bool | enable_expedited (bool exp) |
enable/disable expedited data | |
void | shutdown () |
shutdown queue, do not accept messages | |
unsigned long | cleanup () |
delete stored messages | |
const char * | get_name () const |
Return the name of the queue. | |
Private Attributes | |
queue_t * | queue |
C fastqueue. | |
string | queue_name |
name of the queue, also stored in the queue_t | |
bool | shutdownflag |
accept or reject messages |
This is a fast and thread-safe message queue with expedited data support. It is an object oriented wrapper around fastqueue.c. The queue grows dynamically and has no built-in entry limit.
Definition at line 63 of file fqueue.h.
const char* protlib::FastQueue::get_name | ( | ) | const [inline] |
queue_t* protlib::FastQueue::queue [private] |
C fastqueue.
Definition at line 95 of file fqueue.h.
Referenced by dequeue(), dequeue_timedwait(), enable_expedited(), enqueue(), FastQueue(), is_empty(), is_expedited_enabled(), size(), and ~FastQueue().
string protlib::FastQueue::queue_name [private] |
name of the queue, also stored in the queue_t
Definition at line 97 of file fqueue.h.
Referenced by enqueue(), FastQueue(), get_name(), and ~FastQueue().
bool protlib::FastQueue::shutdownflag [private] |
accept or reject messages
Definition at line 99 of file fqueue.h.
Referenced by cleanup(), enqueue(), and shutdown().