#include <queuedConnectionReader.h>
Inheritance diagram for QueuedConnectionReader:
Protected Member Functions | |
virtual void | receive_datagram (const NetDatagram &datagram) |
void | stop_delay () |
Protected Attributes | |
PUBLISHED | __pad1__: void start_delay(double min_delay |
PUBLISHED double | max_delay |
Private Types | |
typedef pdeque< DelayedDatagram > | Delayed |
Private Member Functions | |
virtual | ~QueuedConnectionReader () |
bool | data_available () |
bool | get_data (NetDatagram &result) |
bool | get_data (Datagram &result) |
void | get_delayed () |
void | delay_datagram (const NetDatagram &datagram) |
Private Attributes | |
PUBLISHED | __pad0__: QueuedConnectionReader(ConnectionManager *manager |
PUBLISHED int | num_threads |
PRLock * | _dd_mutex |
Delayed | _delayed |
bool | _delay_active |
double | _min_delay |
double | _delay_variance |
|
Definition at line 79 of file queuedConnectionReader.h. |
|
Definition at line 46 of file queuedConnectionReader.cxx. References _dd_mutex, and ConnectionReader::shutdown(). |
|
Definition at line 63 of file queuedConnectionReader.cxx. References get_delayed(), ConnectionReader::poll(), and QueuedReturn< NetDatagram >::thing_available(). Referenced by main(), and HTTPClient::read(). |
|
Definition at line 219 of file queuedConnectionReader.cxx. References QueuedConnectionReader::DelayedDatagram::_datagram, _dd_mutex, _delay_active, _delay_variance, _delayed, _min_delay, QueuedConnectionReader::DelayedDatagram::_reveal_time, QueuedReturn< NetDatagram >::enqueue_thing(), ClockObject::get_global_clock(), and ClockObject::get_real_time(). Referenced by receive_datagram(). |
|
Definition at line 100 of file queuedConnectionReader.cxx. References QueuedReturn< NetDatagram >::get_thing(). |
|
Definition at line 85 of file queuedConnectionReader.cxx. References QueuedReturn< NetDatagram >::get_thing(). Referenced by main(), and HTTPClient::read(). |
|
Definition at line 192 of file queuedConnectionReader.cxx. References QueuedConnectionReader::DelayedDatagram::_datagram, _dd_mutex, _delayed, QueuedConnectionReader::DelayedDatagram::_reveal_time, QueuedReturn< NetDatagram >::enqueue_thing(), ClockObject::get_global_clock(), and ClockObject::get_real_time(). Referenced by data_available(). |
|
Implements ConnectionReader. Definition at line 118 of file queuedConnectionReader.cxx. References delay_datagram(), and QueuedReturn< NetDatagram >::enqueue_thing(). |
|
Definition at line 167 of file queuedConnectionReader.cxx. References QueuedConnectionReader::DelayedDatagram::_datagram, _dd_mutex, _delay_active, _delayed, and QueuedReturn< NetDatagram >::enqueue_thing(). |
|
Reimplemented from ConnectionReader. Definition at line 53 of file queuedConnectionReader.h. |
|
Definition at line 65 of file queuedConnectionReader.h. |
|
Definition at line 78 of file queuedConnectionReader.h. Referenced by delay_datagram(), get_delayed(), stop_delay(), and ~QueuedConnectionReader(). |
|
Definition at line 81 of file queuedConnectionReader.h. Referenced by delay_datagram(), and stop_delay(). |
|
Definition at line 82 of file queuedConnectionReader.h. Referenced by delay_datagram(). |
|
Definition at line 80 of file queuedConnectionReader.h. Referenced by delay_datagram(), get_delayed(), and stop_delay(). |
|
Definition at line 82 of file queuedConnectionReader.h. Referenced by delay_datagram(). |
|
Definition at line 65 of file queuedConnectionReader.h. |
|
Reimplemented from ConnectionReader. Definition at line 53 of file queuedConnectionReader.h. |