, including all inherited members.
_manager (defined in ConnectionReader) | ConnectionReader | [protected] |
_removed_sockets (defined in ConnectionReader) | ConnectionReader | [protected] |
_sockets (defined in ConnectionReader) | ConnectionReader | [protected] |
_sockets_mutex (defined in ConnectionReader) | ConnectionReader | [protected] |
add_connection(Connection *connection) | ConnectionReader | |
clear_manager() | ConnectionReader | [protected] |
connection_opened(const PT(Connection)&rendezvous, const NetAddress &address, const PT(Connection)&new_connection) | QueuedConnectionListener | [protected, virtual] |
ConnectionListener(ConnectionManager *manager, int num_threads, const string &thread_name=string()) (defined in ConnectionListener) | ConnectionListener | |
ConnectionReader(ConnectionManager *manager, int num_threads, const string &thread_name=string()) | ConnectionReader | |
enqueue_thing(const ConnectionListenerData &thing) | QueuedReturn< ConnectionListenerData > | [protected] |
enqueue_unique_thing(const ConnectionListenerData &thing) | QueuedReturn< ConnectionListenerData > | [protected] |
finish_socket(SocketInfo *sinfo) | ConnectionReader | [protected] |
flush_read_connection(Connection *connection) | ConnectionReader | [protected, virtual] |
get_current_queue_size() const | QueuedReturn< ConnectionListenerData > | |
get_manager() const | ConnectionReader | |
get_max_queue_size() const | QueuedReturn< ConnectionListenerData > | |
get_new_connection(PT(Connection)&rendezvous, NetAddress &address, PT(Connection)&new_connection) | QueuedConnectionListener | |
get_new_connection(PT(Connection)&new_connection) | QueuedConnectionListener | |
get_num_threads() const | ConnectionReader | |
get_overflow_flag() const | QueuedReturn< ConnectionListenerData > | |
get_raw_mode() const | ConnectionReader | |
get_tcp_header_size() const | ConnectionReader | |
get_thing(ConnectionListenerData &thing) | QueuedReturn< ConnectionListenerData > | [protected] |
is_connection_ok(Connection *connection) | ConnectionReader | |
is_polling() const | ConnectionReader | [inline] |
new_connection_available() | QueuedConnectionListener | |
poll() | ConnectionReader | |
process_incoming_data(SocketInfo *sinfo) | ConnectionListener | [protected, virtual] |
process_incoming_tcp_data(SocketInfo *sinfo) (defined in ConnectionReader) | ConnectionReader | [protected, virtual] |
process_incoming_udp_data(SocketInfo *sinfo) (defined in ConnectionReader) | ConnectionReader | [protected, virtual] |
process_raw_incoming_tcp_data(SocketInfo *sinfo) (defined in ConnectionReader) | ConnectionReader | [protected, virtual] |
process_raw_incoming_udp_data(SocketInfo *sinfo) (defined in ConnectionReader) | ConnectionReader | [protected, virtual] |
QueuedConnectionListener(ConnectionManager *manager, int num_threads) (defined in QueuedConnectionListener) | QueuedConnectionListener | |
QueuedReturn() (defined in QueuedReturn< ConnectionListenerData >) | QueuedReturn< ConnectionListenerData > | [protected] |
receive_datagram(const NetDatagram &datagram) | ConnectionListener | [protected, virtual] |
remove_connection(Connection *connection) | ConnectionReader | |
reset_overflow_flag() | QueuedReturn< ConnectionListenerData > | |
set_max_queue_size(int max_size) | QueuedReturn< ConnectionListenerData > | |
set_raw_mode(bool mode) | ConnectionReader | |
set_tcp_header_size(int tcp_header_size) | ConnectionReader | |
shutdown() | ConnectionReader | |
Sockets typedef (defined in ConnectionReader) | ConnectionReader | [protected] |
thing_available() const | QueuedReturn< ConnectionListenerData > | [inline, protected] |
~ConnectionReader() (defined in ConnectionReader) | ConnectionReader | [virtual] |
~QueuedConnectionListener() (defined in QueuedConnectionListener) | QueuedConnectionListener | [virtual] |
~QueuedReturn() (defined in QueuedReturn< ConnectionListenerData >) | QueuedReturn< ConnectionListenerData > | [protected] |