, including all inherited members.
abort_processing(bool do_lock=true) | protlib::Thread | |
already_aborted | protlib::TPoverTCP | [private] |
broadcast_cond() | protlib::Thread | [inline] |
check_send_args(const NetMsg &msg, const address &addr) const | protlib::TP | |
cleanup_receiver_thread(AssocData *peer_assoc) | protlib::TPoverTCP | [private] |
common_header_length | protlib::TP | [protected] |
connmap | protlib::TPoverTCP | [private] |
create_new_receiver_thread(AssocData *peer_assoc) | protlib::TPoverTCP | [private] |
create_new_sender_thread(FastQueue *senderqueue) | protlib::TPoverTCP | [private] |
debug_pdu | protlib::TPoverTCP | [private] |
get_connection_to(const appladdress &addr) | protlib::TPoverTCP | [private] |
get_fqueue() | protlib::Thread | [inline] |
get_max_payload() const | protlib::TP | |
get_state(bool do_lock=true) | protlib::Thread | |
get_time_of_day(struct timespec &ts) | protlib::Thread | [static] |
get_tp_name() const | protlib::TP | |
get_underlying_protocol() const | protlib::TP | |
get_underlying_protocol_name() const | protlib::TP | |
getmsglength | protlib::TP | [protected] |
init | protlib::TP | [protected] |
is_init() const | protlib::TP | [inline] |
is_running(bool do_lock=true) | protlib::Thread | |
lock() | protlib::Thread | [inline] |
main_loop(uint32 nr) | protlib::TPoverTCP | [virtual] |
master_listener_thread() | protlib::TPoverTCP | [private] |
master_listener_thread_starter(void *argp) | protlib::TPoverTCP | [private, static] |
max_payload | protlib::TP | [protected] |
msgqueue | protlib::TPoverTCP | [private] |
protocol | protlib::TP | [protected] |
protoname | protlib::TP | [protected] |
receiver_thread(void *argp) | protlib::TPoverTCP | [private] |
receiver_thread_arg_t typedef | protlib::TPoverTCP | |
receiver_thread_starter(void *argp) | protlib::TPoverTCP | [private, static] |
recv_thread_argmap | protlib::TPoverTCP | [private] |
recv_thread_argmap_t typedef | protlib::TPoverTCP | [private] |
send(NetMsg *msg, const address &addr, bool use_existing_connection) | protlib::TPoverTCP | [virtual] |
sender_thread(void *argp) | protlib::TPoverTCP | [private] |
sender_thread_queuemap_t typedef | protlib::TPoverTCP | [private] |
sender_thread_starter(void *argp) | protlib::TPoverTCP | [private, static] |
senderthread_queuemap | protlib::TPoverTCP | [private] |
signal_cond() | protlib::Thread | [inline] |
start_processing() | protlib::Thread | |
STATE_ABORT enum value | protlib::Thread | |
STATE_INIT enum value | protlib::Thread | |
STATE_RUN enum value | protlib::Thread | |
STATE_STOP enum value | protlib::Thread | |
state_t enum name | protlib::Thread | |
stop_processing(bool do_lock=true) | protlib::Thread | |
stop_receiver_thread(AssocData *peer_assoc) | protlib::TPoverTCP | [private] |
tcpsend(NetMsg *msg, appladdress *addr) | protlib::TPoverTCP | [private] |
terminate(const address &addr) | protlib::TPoverTCP | [virtual] |
terminate_all_threads() | protlib::TPoverTCP | [private] |
terminate_sender_thread(const AssocData *assoc) | protlib::TPoverTCP | [private] |
Thread(const ThreadParam &p, bool create_queue=true, bool exp_allow=true) | protlib::Thread | |
TP(protocol_t p, const string &pname, const string &tpn, const unsigned short common_header_length, bool(*const getmsglength)(NetMsg &netmsg, uint32 &msglen), uint32 mp=(uint32)-1) | protlib::TP | |
tp_name | protlib::TP | [protected] |
TPoverTCP(const TPoverTCPParam &p) | protlib::TPoverTCP | [inline] |
tpparam | protlib::TPoverTCP | [private] |
unlock() | protlib::Thread | [inline] |
wait_cond() | protlib::Thread | [inline] |
wait_cond(const struct timespec &ts) | protlib::Thread | [inline] |
wait_cond(int32 sec, int32 nsec=0) | protlib::Thread | |
~Thread() | protlib::Thread | [virtual] |
~TP()=0 | protlib::TP | [pure virtual] |
~TPoverTCP() | protlib::TPoverTCP | [virtual] |