Main Page   Namespace List   Class Hierarchy   Alphabetical List   Compound List   File List   Compound Members   File Members  

QueuedConnectionReader Class Reference

#include <queuedConnectionReader.h>

Inheritance diagram for QueuedConnectionReader:

ConnectionReader QueuedReturn< NetDatagram > List of all members.

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< DelayedDatagramDelayed

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

Member Typedef Documentation

typedef pdeque<DelayedDatagram> QueuedConnectionReader::Delayed [private]
 

Definition at line 79 of file queuedConnectionReader.h.


Constructor & Destructor Documentation

QueuedConnectionReader::~QueuedConnectionReader  )  [private, virtual]
 

Definition at line 46 of file queuedConnectionReader.cxx.

References _dd_mutex, and ConnectionReader::shutdown().


Member Function Documentation

bool QueuedConnectionReader::data_available  )  [private]
 

Definition at line 63 of file queuedConnectionReader.cxx.

References get_delayed(), ConnectionReader::poll(), and QueuedReturn< NetDatagram >::thing_available().

Referenced by main(), and HTTPClient::read().

void QueuedConnectionReader::delay_datagram const NetDatagram datagram  )  [private]
 

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().

bool QueuedConnectionReader::get_data Datagram result  )  [private]
 

Definition at line 100 of file queuedConnectionReader.cxx.

References QueuedReturn< NetDatagram >::get_thing().

bool QueuedConnectionReader::get_data NetDatagram result  )  [private]
 

Definition at line 85 of file queuedConnectionReader.cxx.

References QueuedReturn< NetDatagram >::get_thing().

Referenced by main(), and HTTPClient::read().

void QueuedConnectionReader::get_delayed  )  [private]
 

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().

void QueuedConnectionReader::receive_datagram const NetDatagram datagram  )  [protected, virtual]
 

Implements ConnectionReader.

Definition at line 118 of file queuedConnectionReader.cxx.

References delay_datagram(), and QueuedReturn< NetDatagram >::enqueue_thing().

void QueuedConnectionReader::stop_delay  )  [protected]
 

Definition at line 167 of file queuedConnectionReader.cxx.

References QueuedConnectionReader::DelayedDatagram::_datagram, _dd_mutex, _delay_active, _delayed, and QueuedReturn< NetDatagram >::enqueue_thing().


Member Data Documentation

PUBLISHED QueuedConnectionReader::__pad0__ [private]
 

Reimplemented from ConnectionReader.

Definition at line 53 of file queuedConnectionReader.h.

PUBLISHED QueuedConnectionReader::__pad1__ [protected]
 

Definition at line 65 of file queuedConnectionReader.h.

PRLock* QueuedConnectionReader::_dd_mutex [private]
 

Definition at line 78 of file queuedConnectionReader.h.

Referenced by delay_datagram(), get_delayed(), stop_delay(), and ~QueuedConnectionReader().

bool QueuedConnectionReader::_delay_active [private]
 

Definition at line 81 of file queuedConnectionReader.h.

Referenced by delay_datagram(), and stop_delay().

double QueuedConnectionReader::_delay_variance [private]
 

Definition at line 82 of file queuedConnectionReader.h.

Referenced by delay_datagram().

Delayed QueuedConnectionReader::_delayed [private]
 

Definition at line 80 of file queuedConnectionReader.h.

Referenced by delay_datagram(), get_delayed(), and stop_delay().

double QueuedConnectionReader::_min_delay [private]
 

Definition at line 82 of file queuedConnectionReader.h.

Referenced by delay_datagram().

PUBLISHED double QueuedConnectionReader::max_delay [protected]
 

Definition at line 65 of file queuedConnectionReader.h.

PUBLISHED int QueuedConnectionReader::num_threads [private]
 

Reimplemented from ConnectionReader.

Definition at line 53 of file queuedConnectionReader.h.


The documentation for this class was generated from the following files:
Generated on Fri Apr 18 00:13:22 2003 for Panda by doxygen1.3