_add_ref() | OpenDDS::DCPS::RcObject< ACE_SYNCH_MUTEX > | [inline, virtual] |
_remove_ref() | OpenDDS::DCPS::RcObject< ACE_SYNCH_MUTEX > | [inline, virtual] |
add_delayed_notification(TransportQueueElement *element) | OpenDDS::DCPS::TransportSendStrategy | [protected, virtual] |
adjust_packet_after_send(ssize_t num_bytes_sent) | OpenDDS::DCPS::TransportSendStrategy | [private] |
clear(SendMode mode=MODE_DIRECT) | OpenDDS::DCPS::TransportSendStrategy | |
current_packet_first_element() const | OpenDDS::DCPS::TransportSendStrategy | [protected] |
direct_send(bool relink) | OpenDDS::DCPS::TransportSendStrategy | [private] |
do_remove_sample(const RepoId &pub_id, const TransportQueueElement::MatchCriteria &criteria) | OpenDDS::DCPS::TransportSendStrategy | [protected, virtual] |
do_send_packet(const ACE_Message_Block *packet, int &bp) | OpenDDS::DCPS::TransportSendStrategy | [private] |
elems_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
get_handle() | OpenDDS::DCPS::TransportSendStrategy | [virtual] |
get_packet_elems_from_queue() | OpenDDS::DCPS::TransportSendStrategy | [private] |
graceful_disconnecting_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
GuardType typedef | OpenDDS::DCPS::TransportSendStrategy | [private] |
header_ | OpenDDS::DCPS::TransportSendStrategy | [protected] |
header_block_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
header_complete_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
header_db_allocator_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
header_mb_allocator_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
header_sequence_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
id() const | OpenDDS::DCPS::ThreadSynchWorker | |
isDirectMode() | OpenDDS::DCPS::TransportSendStrategy | |
link_released(bool flag) | OpenDDS::DCPS::TransportSendStrategy | |
link_released_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
lock_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
LockType typedef | OpenDDS::DCPS::TransportSendStrategy | [private] |
marshal_transport_header(ACE_Message_Block *mb) | OpenDDS::DCPS::TransportSendStrategy | [private, virtual] |
max_header_size_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
max_message_size() const | OpenDDS::DCPS::TransportSendStrategy | [protected, virtual] |
max_samples_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
max_size_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
mb_to_iov(const ACE_Message_Block &msg, iovec *iov) | OpenDDS::DCPS::TransportSendStrategy | [static] |
mode() const | OpenDDS::DCPS::TransportSendStrategy | |
mode_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
mode_as_str(SendMode mode) | OpenDDS::DCPS::TransportSendStrategy | [private, static] |
mode_before_suspend_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
MODE_DIRECT enum value | OpenDDS::DCPS::TransportSendStrategy | |
MODE_NOT_SET enum value | OpenDDS::DCPS::TransportSendStrategy | |
MODE_QUEUE enum value | OpenDDS::DCPS::TransportSendStrategy | |
MODE_SUSPEND enum value | OpenDDS::DCPS::TransportSendStrategy | |
MODE_TERMINATED enum value | OpenDDS::DCPS::TransportSendStrategy | |
non_blocking_send(const iovec iov[], int n, int &bp) | OpenDDS::DCPS::TransportSendStrategy | [protected, virtual] |
OPENDDS_VECTOR(TQESendModePair) delayed_delivered_notification_queue_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
optimum_size_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
OUTCOME_BACKPRESSURE enum value | OpenDDS::DCPS::TransportSendStrategy | [private] |
OUTCOME_COMPLETE_SEND enum value | OpenDDS::DCPS::TransportSendStrategy | [private] |
OUTCOME_PARTIAL_SEND enum value | OpenDDS::DCPS::TransportSendStrategy | [private] |
OUTCOME_PEER_LOST enum value | OpenDDS::DCPS::TransportSendStrategy | [private] |
OUTCOME_SEND_ERROR enum value | OpenDDS::DCPS::TransportSendStrategy | [private] |
perform_work() | OpenDDS::DCPS::TransportSendStrategy | [virtual] |
pkt_chain_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
prepare_header() | OpenDDS::DCPS::TransportSendStrategy | [private] |
prepare_header_i() | OpenDDS::DCPS::TransportSendStrategy | [protected, virtual] |
prepare_packet() | OpenDDS::DCPS::TransportSendStrategy | [private] |
prepare_packet_i() | OpenDDS::DCPS::TransportSendStrategy | [protected, virtual] |
queue_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
QueueType typedef | OpenDDS::DCPS::TransportSendStrategy | |
RcObject(ACE_Allocator *allocator=0) | OpenDDS::DCPS::RcObject< ACE_SYNCH_MUTEX > | [inline, protected] |
ref_count() const | OpenDDS::DCPS::RcObject< ACE_SYNCH_MUTEX > | [inline] |
relink(bool do_suspend=true) | OpenDDS::DCPS::TransportSendStrategy | [virtual] |
remove_all_msgs(RepoId pub_id) | OpenDDS::DCPS::TransportSendStrategy | |
remove_sample(const DataSampleElement *sample) | OpenDDS::DCPS::TransportSendStrategy | |
replaced_element_allocator_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
replaced_element_db_allocator_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
replaced_element_mb_allocator_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
resume_send() | OpenDDS::DCPS::TransportSendStrategy | |
retained_element_allocator_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
schedule_output() | OpenDDS::DCPS::ThreadSynchWorker | [virtual] |
send(TransportQueueElement *element, bool relink=true) | OpenDDS::DCPS::TransportSendStrategy | |
send_buffer(TransportSendBuffer *send_buffer) | OpenDDS::DCPS::TransportSendStrategy | |
send_buffer_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
send_bytes(const iovec iov[], int n, int &bp) | OpenDDS::DCPS::TransportSendStrategy | [protected, virtual] |
send_bytes_i(const iovec iov[], int n)=0 | OpenDDS::DCPS::TransportSendStrategy | [protected, pure virtual] |
send_delayed_notifications(const TransportQueueElement::MatchCriteria *match=0) | OpenDDS::DCPS::TransportSendStrategy | [private] |
send_packet() | OpenDDS::DCPS::TransportSendStrategy | [private] |
send_start() | OpenDDS::DCPS::TransportSendStrategy | |
send_stop(RepoId repoId) | OpenDDS::DCPS::TransportSendStrategy | |
SendMode enum name | OpenDDS::DCPS::TransportSendStrategy | |
SendPacketOutcome enum name | OpenDDS::DCPS::TransportSendStrategy | [private] |
set_graceful_disconnecting(bool flag) | OpenDDS::DCPS::TransportSendStrategy | [protected] |
space_available() const | OpenDDS::DCPS::TransportSendStrategy | [private] |
start() | OpenDDS::DCPS::TransportSendStrategy | |
start_counter_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
start_i() | OpenDDS::DCPS::TransportSendStrategy | [inline, virtual] |
stop() | OpenDDS::DCPS::TransportSendStrategy | |
stop_i()=0 | OpenDDS::DCPS::TransportSendStrategy | [pure virtual] |
suspend_send() | OpenDDS::DCPS::TransportSendStrategy | |
synch() const | OpenDDS::DCPS::TransportSendStrategy | [protected] |
synch_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
terminate_send(bool graceful_disconnecting=false) | OpenDDS::DCPS::TransportSendStrategy | |
ThreadSynchWorker(std::size_t id=0) | OpenDDS::DCPS::ThreadSynchWorker | [protected] |
TQESendModePair typedef | OpenDDS::DCPS::TransportSendStrategy | [private] |
transport_inst_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
transport_shutdown() | OpenDDS::DCPS::TransportSendStrategy | |
transport_shutdown_ | OpenDDS::DCPS::TransportSendStrategy | [private] |
TransportSendBuffer class | OpenDDS::DCPS::TransportSendStrategy | [friend] |
TransportSendStrategy(std::size_t id, const TransportInst_rch &transport_inst, ThreadSynchResource *synch_resource, Priority priority, const ThreadSynchStrategy_rch &thread_sync_strategy) | OpenDDS::DCPS::TransportSendStrategy | [protected] |
UDP_MAX_MESSAGE_SIZE | OpenDDS::DCPS::TransportSendStrategy | [protected, static] |
WORK_OUTCOME_BROKEN_RESOURCE enum value | OpenDDS::DCPS::ThreadSynchWorker | |
WORK_OUTCOME_CLOGGED_RESOURCE enum value | OpenDDS::DCPS::ThreadSynchWorker | |
WORK_OUTCOME_MORE_TO_DO enum value | OpenDDS::DCPS::ThreadSynchWorker | |
WORK_OUTCOME_NO_MORE_TO_DO enum value | OpenDDS::DCPS::ThreadSynchWorker | |
WorkOutcome enum name | OpenDDS::DCPS::ThreadSynchWorker | |
~RcObject() | OpenDDS::DCPS::RcObject< ACE_SYNCH_MUTEX > | [inline, virtual] |
~ThreadSynchWorker() | OpenDDS::DCPS::ThreadSynchWorker | [virtual] |
~TransportSendStrategy() | OpenDDS::DCPS::TransportSendStrategy | [virtual] |