_add_ref() | OpenDDS::DCPS::RcObject | inlinevirtual |
_get_weak_object() const | OpenDDS::DCPS::RcObject | inline |
_remove_ref() | OpenDDS::DCPS::RcObject | inlinevirtual |
add_delayed_notification(TransportQueueElement *element) | OpenDDS::DCPS::RtpsUdpSendStrategy | protectedvirtual |
append_submessages(const RTPS::SubmessageSeq &submessages) | OpenDDS::DCPS::RtpsUdpSendStrategy | |
choose_send_socket(const NetworkAddress &addr) const | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
clear(SendMode new_mode, SendMode old_mode=MODE_NOT_SET) | OpenDDS::DCPS::TransportSendStrategy | |
current_packet_first_element() const | OpenDDS::DCPS::TransportSendStrategy | protected |
deliver_ack_request(TransportQueueElement *element) | OpenDDS::DCPS::TransportSendStrategy | |
do_remove_sample(const GUID_t &pub_id, const TransportQueueElement::MatchCriteria &criteria, bool remove_all=false) | OpenDDS::DCPS::TransportSendStrategy | protectedvirtual |
encode_payload(const GUID_t &pub_id, Message_Block_Ptr &payload, RTPS::SubmessageSeq &submessages) | OpenDDS::DCPS::RtpsUdpSendStrategy | |
encode_reader_submessage(const GUID_t &sender, const GUID_t &receiver, OPENDDS_VECTOR(Chunk)&replacements, DDS::Security::CryptoTransform *crypto, const DDS::OctetSeq &plain, DDS::Security::DatareaderCryptoHandle sender_drch, const char *submessage_start, CORBA::Octet msgId) | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
encode_rtps_message(const ACE_Message_Block *plain, DDS::Security::CryptoTransform *crypto) | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
encode_submessages(const ACE_Message_Block *plain, DDS::Security::CryptoTransform *crypto, bool &stateless_or_volatile) | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
encode_writer_submessage(const GUID_t &sender, const GUID_t &receiver, OPENDDS_VECTOR(Chunk)&replacements, DDS::Security::CryptoTransform *crypto, const DDS::OctetSeq &plain, DDS::Security::DatawriterCryptoHandle sender_dwch, const char *submessage_start, CORBA::Octet msgId) | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
fragmentation_helper(TransportQueueElement *original_element, TqeVector &elements_to_send) | OpenDDS::DCPS::TransportSendStrategy | |
get_handle() | OpenDDS::DCPS::TransportSendStrategy | virtual |
id() const | OpenDDS::DCPS::ThreadSynchWorker | |
isDirectMode() | OpenDDS::DCPS::TransportSendStrategy | |
link_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
link_released(bool flag) | OpenDDS::DCPS::TransportSendStrategy | |
marshal_transport_header(ACE_Message_Block *mb) | OpenDDS::DCPS::RtpsUdpSendStrategy | privatevirtual |
max_message_size() const | OpenDDS::DCPS::RtpsUdpSendStrategy | protectedvirtual |
max_message_size_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
MaxCryptoFooterSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxCryptoHeaderSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxSecureFullMessageAdditionalSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxSecureFullMessageFollowingSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxSecureFullMessageLeadingSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxSecurePrefixSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxSecureSubmessageAdditionalSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxSecureSubmessageFollowingSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxSecureSubmessageLeadingSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxSecureSuffixSize | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
MaxSubmessagePadding | OpenDDS::DCPS::RtpsUdpSendStrategy | static |
mb_to_iov(const ACE_Message_Block &msg, iovec *iov) | OpenDDS::DCPS::TransportSendStrategy | static |
mode() const | OpenDDS::DCPS::TransportSendStrategy | |
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 | |
network_is_unreachable_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
non_blocking_send(const iovec iov[], int n, int &bp) | OpenDDS::DCPS::TransportSendStrategy | protectedvirtual |
override_dest_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
override_destinations(const NetworkAddress &destination) | OpenDDS::DCPS::RtpsUdpSendStrategy | |
override_destinations(const AddrSet &destinations) | OpenDDS::DCPS::RtpsUdpSendStrategy | |
override_single_dest_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
OverrideToken | OpenDDS::DCPS::RtpsUdpSendStrategy | friend |
perform_work() | OpenDDS::DCPS::TransportSendStrategy | virtual |
pre_send_packet(const ACE_Message_Block *plain) | OpenDDS::DCPS::RtpsUdpSendStrategy | privatevirtual |
prepare_header_i() | OpenDDS::DCPS::TransportSendStrategy | protectedvirtual |
prepare_packet_i() | OpenDDS::DCPS::TransportSendStrategy | protectedvirtual |
QueueType typedef | OpenDDS::DCPS::TransportSendStrategy | |
RcObject() | OpenDDS::DCPS::RcObject | inlineprotected |
ref_count() const | OpenDDS::DCPS::RcObject | inline |
relink(bool do_suspend=true) | OpenDDS::DCPS::TransportSendStrategy | virtual |
remove_all_msgs(const GUID_t &pub_id) | OpenDDS::DCPS::TransportSendStrategy | |
remove_sample(const DataSampleElement *sample) | OpenDDS::DCPS::TransportSendStrategy | |
replace_chunks(const ACE_Message_Block *plain, const OPENDDS_VECTOR(Chunk)&replacements) | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
resume_send() | OpenDDS::DCPS::TransportSendStrategy | |
rtps_header_data_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
rtps_header_db_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
rtps_header_mb_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
rtps_header_mb_lock_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
rtps_message_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
rtps_message_mutex_ | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
RtpsUdpSendStrategy(RtpsUdpDataLink *link, const GuidPrefix_t &local_prefix) | OpenDDS::DCPS::RtpsUdpSendStrategy | |
schedule_output() | OpenDDS::DCPS::ThreadSynchWorker | virtual |
security_config() const | OpenDDS::DCPS::RtpsUdpSendStrategy | virtual |
send(TransportQueueElement *element, bool relink=true) | OpenDDS::DCPS::TransportSendStrategy | |
send_buffer(TransportSendBuffer *send_buffer) | OpenDDS::DCPS::TransportSendStrategy | |
send_bytes(const iovec iov[], int n, int &bp) | OpenDDS::DCPS::TransportSendStrategy | protectedvirtual |
send_bytes_i(const iovec iov[], int n) | OpenDDS::DCPS::RtpsUdpSendStrategy | protectedvirtual |
send_bytes_i_helper(const iovec iov[], int n) | OpenDDS::DCPS::RtpsUdpSendStrategy | protected |
send_delayed_notifications(const TransportQueueElement::MatchCriteria *match=0) | OpenDDS::DCPS::TransportSendStrategy | protected |
send_multi_i(const iovec iov[], int n, const AddrSet &addrs) | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
send_rtps_control(RTPS::Message &message, ACE_Message_Block &submessages, const NetworkAddress &destination) | OpenDDS::DCPS::RtpsUdpSendStrategy | |
send_rtps_control(RTPS::Message &message, ACE_Message_Block &submessages, const AddrSet &destinations) | OpenDDS::DCPS::RtpsUdpSendStrategy | |
send_single_i(const iovec iov[], int n, const NetworkAddress &addr) | OpenDDS::DCPS::RtpsUdpSendStrategy | private |
send_start() | OpenDDS::DCPS::TransportSendStrategy | |
send_stop(GUID_t repoId) | OpenDDS::DCPS::TransportSendStrategy | |
SendMode enum name | OpenDDS::DCPS::TransportSendStrategy | |
set_graceful_disconnecting(bool flag) | OpenDDS::DCPS::TransportSendStrategy | protected |
set_header_source(ACE_INT64 source) | OpenDDS::DCPS::TransportSendStrategy | protected |
start() | OpenDDS::DCPS::TransportSendStrategy | |
start_i() | OpenDDS::DCPS::TransportSendStrategy | inlinevirtual |
stop() | OpenDDS::DCPS::TransportSendStrategy | |
stop_i() | OpenDDS::DCPS::RtpsUdpSendStrategy | virtual |
suspend_send() | OpenDDS::DCPS::TransportSendStrategy | |
synch() const | OpenDDS::DCPS::TransportSendStrategy | protected |
terminate_send(bool graceful_disconnecting=false) | OpenDDS::DCPS::TransportSendStrategy | |
terminate_send_if_suspended() | OpenDDS::DCPS::TransportSendStrategy | virtual |
ThreadSynchWorker(std::size_t id=0) | OpenDDS::DCPS::ThreadSynchWorker | protected |
TransportSendStrategy(std::size_t id, const TransportImpl_rch &transport, ThreadSynchResource *synch_resource, Priority priority, const ThreadSynchStrategy_rch &thread_sync_strategy) | OpenDDS::DCPS::TransportSendStrategy | protected |
UDP_MAX_MESSAGE_SIZE | OpenDDS::DCPS::TransportSendStrategy | 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 | inlinevirtual |
~ThreadSynchWorker() | OpenDDS::DCPS::ThreadSynchWorker | virtual |
~TransportSendStrategy() | OpenDDS::DCPS::TransportSendStrategy | virtual |