#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 | |
A fast message queue.
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().
1.6.1