#include <datagramQueue.h>
Public Member Functions | |
| DatagramQueue () | |
| ~DatagramQueue () | |
| void | shutdown () |
| bool | insert (const NetDatagram &data) |
| bool | extract (NetDatagram &result) |
| void | set_max_queue_size (int max_size) |
| int | get_max_queue_size () const |
| int | get_current_queue_size () const |
Private Types | |
| typedef pdeque< NetDatagram > | QueueType |
Private Attributes | |
| PRLock * | _cvlock |
| PRCondVar * | _cv |
| QueueType | _queue |
| bool | _shutdown |
| int | _max_queue_size |
|
|
Definition at line 58 of file datagramQueue.h. |
|
|
Definition at line 28 of file datagramQueue.cxx. References _cv, _cvlock, _max_queue_size, _shutdown, and get_net_max_write_queue(). |
|
|
Definition at line 41 of file datagramQueue.cxx. |
|
|
Definition at line 116 of file datagramQueue.cxx. References _cv, _cvlock, _queue, _shutdown, and NetDatagram::clear(). Referenced by ConnectionWriter::thread_run(). |
|
|
Definition at line 181 of file datagramQueue.cxx. |
|
|
Definition at line 171 of file datagramQueue.cxx. References _max_queue_size. |
|
|
Definition at line 81 of file datagramQueue.cxx. References _cv, _cvlock, _max_queue_size, _queue, and data. Referenced by ConnectionWriter::send(). |
|
|
Definition at line 158 of file datagramQueue.cxx. References _cvlock, and _max_queue_size. |
|
|
Definition at line 61 of file datagramQueue.cxx. References _cv, _cvlock, and _shutdown. Referenced by ConnectionWriter::~ConnectionWriter(). |
|
|
Definition at line 51 of file datagramQueue.h. Referenced by DatagramQueue(), extract(), insert(), shutdown(), and ~DatagramQueue(). |
|
|
Definition at line 50 of file datagramQueue.h. Referenced by DatagramQueue(), extract(), get_current_queue_size(), insert(), set_max_queue_size(), shutdown(), and ~DatagramQueue(). |
|
|
Definition at line 63 of file datagramQueue.h. Referenced by DatagramQueue(), get_max_queue_size(), insert(), and set_max_queue_size(). |
|
|
Definition at line 61 of file datagramQueue.h. Referenced by extract(), get_current_queue_size(), and insert(). |
|
|
Definition at line 62 of file datagramQueue.h. Referenced by DatagramQueue(), extract(), shutdown(), and ~DatagramQueue(). |
1.3