::DDS_TEST class | OpenDDS::DCPS::RtpsUdpDataLink | friend |
_add_ref() | OpenDDS::DCPS::RcObject | inlinevirtual |
_get_weak_object() const | OpenDDS::DCPS::RcObject | inline |
_remove_ref() | OpenDDS::DCPS::RcObject | inlinevirtual |
ACCEPT_MASK | ACE_Event_Handler | |
accumulate_addresses(const GUID_t &local, const GUID_t &remote, AddrSet &addresses, bool prefer_unicast=false) const | OpenDDS::DCPS::RtpsUdpDataLink | private |
ACE_APPLICATION_RESUMES_HANDLER | ACE_Event_Handler | |
ACE_Event_Handler(ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY) | ACE_Event_Handler | protected |
ACE_EVENT_HANDLER_NOT_RESUMED | ACE_Event_Handler | |
ACE_REACTOR_RESUMES_HANDLER | ACE_Event_Handler | |
add_delayed_notification(TransportQueueElement *element) | OpenDDS::DCPS::RtpsUdpDataLink | |
add_on_start_callback(const TransportClient_wrch &client, const GUID_t &remote) | OpenDDS::DCPS::DataLink | |
add_reference() | OpenDDS::DCPS::RcEventHandler | inlinevirtual |
ALL_EVENTS_MASK | ACE_Event_Handler | |
alloc_msgblock(size_t size, ACE_Allocator *data_allocator) | OpenDDS::DCPS::RtpsUdpDataLink | private |
associated(const GUID_t &local, const GUID_t &remote, bool local_reliable, bool remote_reliable, bool local_durable, bool remote_durable, const MonotonicTime_t &participant_discovered_at, ACE_CDR::ULong participant_flags, SequenceNumber max_sn, const TransportClient_rch &client, AddrSet &unicast_addresses, AddrSet &multicast_addresses, const NetworkAddress &last_addr_hint, bool requires_inline_qos) | OpenDDS::DCPS::RtpsUdpDataLink | |
Atomic_Reference_Count typedef | ACE_Event_Handler | protected |
best_effort_heartbeat_count_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
build_meta_submessage_map(MetaSubmessageVec &meta_submessages, AddrDestMetaSubmessageMap &addr_map) | OpenDDS::DCPS::RtpsUdpDataLink | private |
bundle_allocator_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
bundle_and_send_submessages(MetaSubmessageVec &meta_submessages) | OpenDDS::DCPS::RtpsUdpDataLink | private |
bundle_mapped_meta_submessages(const Encoding &encoding, AddrDestMetaSubmessageMap &addr_map, BundleVec &bundles, CountKeeper &counts) | OpenDDS::DCPS::RtpsUdpDataLink | private |
bundling_cache_ | OpenDDS::DCPS::RtpsUdpDataLink | mutableprivate |
CallbackType typedef | OpenDDS::DCPS::RtpsUdpDataLink | private |
cancel_release() | OpenDDS::DCPS::DataLink | |
check_heartbeats(const MonotonicTimePoint &now) | OpenDDS::DCPS::RtpsUdpDataLink | private |
clear_associations() | OpenDDS::DCPS::DataLink | |
client_stop(const GUID_t &localId) | OpenDDS::DCPS::RtpsUdpDataLink | |
config() const | OpenDDS::DCPS::RtpsUdpDataLink | |
CONNECT_MASK | ACE_Event_Handler | |
ConnectionNotice enum name | OpenDDS::DCPS::DataLink | |
create_control(char submessage_id, DataSampleHeader &header, Message_Block_Ptr data) | OpenDDS::DCPS::DataLink | |
custom_allocator_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
customize_queue_element(TransportQueueElement *element) | OpenDDS::DCPS::RtpsUdpDataLink | privatevirtual |
customize_queue_element_non_reliable_i(TransportQueueElement *element, bool requires_inline_qos, MetaSubmessageVec &meta_submessages, bool &deliver_after_send, ACE_Guard< ACE_Thread_Mutex > &guard) | OpenDDS::DCPS::RtpsUdpDataLink | private |
data_received(ReceivedDataSample &sample, const GUID_t &readerId=GUID_UNKNOWN) | OpenDDS::DCPS::DataLink | |
data_received_include(ReceivedDataSample &sample, const RepoIdSet &incl) | OpenDDS::DCPS::DataLink | |
DataLink(const TransportImpl_rch &impl, Priority priority, bool is_loopback, bool is_active) | OpenDDS::DCPS::DataLink | |
datalink_release_delay() const | OpenDDS::DCPS::DataLink | |
datalink_release_delay_ | OpenDDS::DCPS::DataLink | protected |
datareader_dispatch(const T &submessage, const GuidPrefix_t &src_prefix, bool directed, const FN &func) | OpenDDS::DCPS::RtpsUdpDataLink | inlineprivate |
datawriter_dispatch(const T &submessage, const GuidPrefix_t &src_prefix, const FN &func) | OpenDDS::DCPS::RtpsUdpDataLink | inlineprivate |
db_allocator_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
db_lock_pool_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
default_listener(const TransportReceiveListener_wrch &trl) | OpenDDS::DCPS::DataLink | |
default_listener() const | OpenDDS::DCPS::DataLink | |
disable_response_queue(bool send_immediately) | OpenDDS::DCPS::RtpsUdpDataLink | |
disassociated(const GUID_t &local, const GUID_t &remote) | OpenDDS::DCPS::RtpsUdpDataLink | |
DISCONNECTED enum value | OpenDDS::DCPS::DataLink | |
DONT_CALL | ACE_Event_Handler | |
durability_resend(TransportQueueElement *element, size_t &cumulative_send_count) | OpenDDS::DCPS::RtpsUdpDataLink | private |
durability_resend(TransportQueueElement *element, const RTPS::FragmentNumberSet &fragmentSet, size_t &cumulative_send_count) | OpenDDS::DCPS::RtpsUdpDataLink | private |
enable_response_queue() | OpenDDS::DCPS::RtpsUdpDataLink | |
event_dispatcher() | OpenDDS::DCPS::RtpsUdpDataLink | inline |
event_dispatcher_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
EXCEPT_MASK | ACE_Event_Handler | |
extend_bitmap_range(RTPS::FragmentNumberSet &fnSet, CORBA::ULong extent, ACE_CDR::ULong &cumulative_bits_added) | OpenDDS::DCPS::RtpsUdpDataLink | privatestatic |
filterBestEffortReaders(const ReceivedDataSample &ds, RepoIdSet &selected, RepoIdSet &withheld) | OpenDDS::DCPS::RtpsUdpDataLink | |
flush_send_queue(const MonotonicTimePoint &now) | OpenDDS::DCPS::RtpsUdpDataLink | private |
flush_send_queue_i() | OpenDDS::DCPS::RtpsUdpDataLink | private |
flush_send_queue_sporadic_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
force_inline_qos_ | OpenDDS::DCPS::RtpsUdpDataLink | privatestatic |
FragmentNumberValue typedef | OpenDDS::DCPS::RtpsUdpDataLink | private |
fsq_mutex_ | OpenDDS::DCPS::RtpsUdpDataLink | mutableprivate |
fsq_vec_size_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
get_addresses(const GUID_t &local, const GUID_t &remote) const | OpenDDS::DCPS::RtpsUdpDataLink | |
get_addresses(const GUID_t &local) const | OpenDDS::DCPS::RtpsUdpDataLink | |
get_addresses_i(const GUID_t &local, const GUID_t &remote) const | OpenDDS::DCPS::RtpsUdpDataLink | private |
get_addresses_i(const GUID_t &local) const | OpenDDS::DCPS::RtpsUdpDataLink | private |
get_handle(void) const | ACE_Event_Handler | virtual |
get_ice_agent() const | OpenDDS::DCPS::RtpsUdpDataLink | |
get_ice_endpoint() const | OpenDDS::DCPS::RtpsUdpDataLink | virtual |
get_job_queue() const | OpenDDS::DCPS::RtpsUdpDataLink | inline |
get_last_recv_address(const GUID_t &remote_id) | OpenDDS::DCPS::RtpsUdpDataLink | |
get_next_datalink_id() | OpenDDS::DCPS::DataLink | protectedstatic |
get_reactor() | OpenDDS::DCPS::RtpsUdpDataLink | |
get_reactor_interceptor() const | OpenDDS::DCPS::RtpsUdpDataLink | |
get_send_strategy() | OpenDDS::DCPS::DataLink | protected |
get_writer_send_buffer(const GUID_t &pub_id) | OpenDDS::DCPS::RtpsUdpDataLink | private |
GROUP_QOS_MASK | ACE_Event_Handler | |
GuardType typedef | OpenDDS::DCPS::DataLink | protected |
handle_close(ACE_HANDLE h, ACE_Reactor_Mask m) | OpenDDS::DCPS::DataLink | virtual |
handle_exception(ACE_HANDLE) | OpenDDS::DCPS::DataLink | virtual |
handle_exit(ACE_Process *) | ACE_Event_Handler | virtual |
handle_group_qos(ACE_HANDLE=ACE_INVALID_HANDLE) | ACE_Event_Handler | virtual |
handle_input(ACE_HANDLE fd=ACE_INVALID_HANDLE) | ACE_Event_Handler | virtual |
handle_output(ACE_HANDLE fd=ACE_INVALID_HANDLE) | ACE_Event_Handler | virtual |
handle_qos(ACE_HANDLE=ACE_INVALID_HANDLE) | ACE_Event_Handler | virtual |
handle_registry() const | OpenDDS::DCPS::RtpsUdpDataLink | inline |
handle_registry_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
handle_signal(int signum, siginfo_t *=0, ucontext_t *=0) | ACE_Event_Handler | virtual |
handle_timeout(const ACE_Time_Value &tv, const void *arg) | OpenDDS::DCPS::DataLink | virtual |
harvest_send_queue(const MonotonicTimePoint &now) | OpenDDS::DCPS::RtpsUdpDataLink | private |
harvest_send_queue_sporadic_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
heartbeat_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
heartbeat_counts_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
heartbeatchecker_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
HI_PRIORITY | ACE_Event_Handler | |
ice_agent_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
id() const | OpenDDS::DCPS::DataLink | |
impl() const | OpenDDS::DCPS::DataLink | |
include_fragment(const TransportQueueElement &element, const DisjointSequence &fragments, SequenceNumber &lastFragment) | OpenDDS::DCPS::RtpsUdpDataLink | privatestatic |
interceptor_ | OpenDDS::DCPS::DataLink | protected |
interesting_readers_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
interesting_writers_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
InternalDataReader_rch typedef | OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress > | |
InternalDataReaderListener() | OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress > | inline |
InternalDataReaderListener(JobQueue_rch job_queue) | OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress > | inlineexplicit |
invoke_on_start_callbacks(bool success) | OpenDDS::DCPS::DataLink | |
invoke_on_start_callbacks(const GUID_t &local, const GUID_t &remote, bool success) | OpenDDS::DCPS::DataLink | |
is_active() | OpenDDS::DCPS::DataLink | |
is_active() const | OpenDDS::DCPS::DataLink | |
is_active_ | OpenDDS::DCPS::DataLink | protected |
is_leading(const GUID_t &writer_id, const GUID_t &reader_id) const | OpenDDS::DCPS::RtpsUdpDataLink | virtual |
is_loopback() | OpenDDS::DCPS::DataLink | |
is_loopback() const | OpenDDS::DCPS::DataLink | |
is_loopback_ | OpenDDS::DCPS::DataLink | protected |
is_target(const GUID_t &remote_id) | OpenDDS::DCPS::DataLink | |
job_queue(JobQueue_rch job_queue) | OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress > | inline |
job_queue_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
LO_PRIORITY | ACE_Event_Handler | |
local_crypto_handle() const | OpenDDS::DCPS::RtpsUdpDataLink | |
local_crypto_handle(DDS::Security::ParticipantCryptoHandle pch) | OpenDDS::DCPS::RtpsUdpDataLink | |
local_crypto_handle_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
local_prefix() const | OpenDDS::DCPS::RtpsUdpDataLink | inline |
local_prefix_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
locator_cache_ | OpenDDS::DCPS::RtpsUdpDataLink | mutableprivate |
locators_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
locators_lock_ | OpenDDS::DCPS::RtpsUdpDataLink | mutableprivate |
LOST enum value | OpenDDS::DCPS::DataLink | |
make_reservation(const GUID_t &remote_publication_id, const GUID_t &local_subscription_id, const TransportReceiveListener_wrch &receive_listener, bool reliable) | OpenDDS::DCPS::RtpsUdpDataLink | virtual |
OpenDDS::DCPS::DataLink::make_reservation(const GUID_t &remote_subscription_id, const GUID_t &local_publication_id, const TransportSendListener_wrch &send_listener, bool reliable) | OpenDDS::DCPS::DataLink | virtual |
max_bundle_size_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
mb_allocator_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
multi_buff_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
multicast_manager_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
multicast_socket() | OpenDDS::DCPS::RtpsUdpDataLink | |
multicast_socket_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
network_change() const | OpenDDS::DCPS::DataLink | protected |
network_interface_address_reader_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
notify(ConnectionNotice notice) | OpenDDS::DCPS::DataLink | |
NULL_MASK | ACE_Event_Handler | |
on_data_available(RcHandle< InternalDataReader< NetworkInterfaceAddress > > reader) | OpenDDS::DCPS::RtpsUdpDataLink | private |
InternalDataReaderListener< NetworkInterfaceAddress >::on_data_available(InternalDataReader_rch reader)=0 | OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress > | pure virtual |
on_start_callbacks_ | OpenDDS::DCPS::DataLink | protected |
OnStartCallback typedef | OpenDDS::DCPS::DataLink | |
open(const ACE_SOCK_Dgram &unicast_socket) | OpenDDS::DCPS::RtpsUdpDataLink | |
OPENDDS_MAP(FragmentNumberValue, RTPS::FragmentNumberSet) RequestedFragMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP(SequenceNumber, RequestedFragMap) RequestedFragSeqMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP(SequenceNumber, ReaderInfoSetHolder_rch) SNRIS | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP(AddressCacheEntryProxy, DestMetaSubmessageMap) AddrDestMetaSubmessageMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP(CORBA::Long, CountMapPair) CountMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP_CMP(GUID_t, RemoteInfo, GUID_tKeyLessThan) RemoteInfoMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP_CMP(GUID_t, ReaderInfo_rch, GUID_tKeyLessThan) ReaderInfoMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP_CMP(GUID_t, RtpsWriter_rch, GUID_tKeyLessThan) RtpsWriterMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP_CMP(GUID_t, WriterInfo_rch, GUID_tKeyLessThan) WriterInfoMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP_CMP(GUID_t, MetaSubmessageIterVec, GUID_tKeyLessThan) DestMetaSubmessageMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP_CMP(EntityId_t, CountSet, EntityId_tKeyLessThan) IdCountSet | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP_CMP(EntityId_t, CountMapping, EntityId_tKeyLessThan) IdCountMapping | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP_CMP(GUID_t, RtpsReader_rch, GUID_tKeyLessThan) RtpsReaderMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MAP_CMP(EntityId_t, CORBA::Long, EntityId_tKeyLessThan) CountMapType | OpenDDS::DCPS::RtpsUdpDataLink | private |
OpenDDS::DCPS::DataLink::OPENDDS_MAP_CMP(GUID_t, TransportClient_wrch, GUID_tKeyLessThan) RepoToClientMap | OpenDDS::DCPS::DataLink | protected |
OpenDDS::DCPS::DataLink::OPENDDS_MAP_CMP(GUID_t, RepoToClientMap, GUID_tKeyLessThan) OnStartCallbackMap | OpenDDS::DCPS::DataLink | protected |
OpenDDS::DCPS::DataLink::OPENDDS_MAP_CMP(GUID_t, RepoIdSet, GUID_tKeyLessThan) PendingOnStartsMap | OpenDDS::DCPS::DataLink | protected |
OPENDDS_MULTIMAP_CMP(GUID_t, RtpsReader_rch, GUID_tKeyLessThan) RtpsReaderMultiMap | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_MULTIMAP_CMP(GUID_t, InterestingRemote, GUID_tKeyLessThan) InterestingRemoteMapType | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_SET(ReaderInfo_rch) ReaderInfoSet | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_SET(WriterInfo_rch) WriterInfoSet | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_SET(CORBA::Long) CountSet | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_VECTOR(MetaSubmessageVec::iterator) MetaSubmessageIterVec | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_VECTOR(MetaSubmessageIterVec) MetaSubmessageIterVecVec | OpenDDS::DCPS::RtpsUdpDataLink | private |
OPENDDS_VECTOR(Bundle) BundleVec | OpenDDS::DCPS::RtpsUdpDataLink | |
OPENDDS_VECTOR(MetaSubmessageVec) fsq_vec_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
peer_ids(const GUID_t &local_id) const | OpenDDS::DCPS::DataLink | protected |
pending_on_starts_ | OpenDDS::DCPS::DataLink | protected |
pending_reliable_readers_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
pre_stop_i() | OpenDDS::DCPS::RtpsUdpDataLink | virtual |
priority(void) const | ACE_Event_Handler | virtual |
priority(int priority) | ACE_Event_Handler | virtual |
QOS_MASK | ACE_Event_Handler | |
queue_submessages(MetaSubmessageVec &meta_submessages) | OpenDDS::DCPS::RtpsUdpDataLink | private |
RcEventHandler() | OpenDDS::DCPS::RcEventHandler | inline |
RcObject() | OpenDDS::DCPS::RcObject | inlineprotected |
reactor(ACE_Reactor *reactor) | ACE_Event_Handler | virtual |
reactor(void) const | ACE_Event_Handler | virtual |
reactor_is_shut_down() | OpenDDS::DCPS::RtpsUdpDataLink | |
reactor_task_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
reactor_timer_interface(void) const | ACE_Event_Handler | virtual |
read_adapter(void *event_handler) | ACE_Event_Handler | static |
READ_MASK | ACE_Event_Handler | |
ReaderInfo_rch typedef | OpenDDS::DCPS::RtpsUdpDataLink | private |
ReaderInfoSetHolder_rch typedef | OpenDDS::DCPS::RtpsUdpDataLink | private |
readers_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
readers_lock_ | OpenDDS::DCPS::RtpsUdpDataLink | mutableprivate |
readers_of_writer_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
receive_strategy() | OpenDDS::DCPS::RtpsUdpDataLink | private |
receive_strategy_ | OpenDDS::DCPS::DataLink | protected |
received(const RTPS::DataSubmessage &data, const GuidPrefix_t &src_prefix, const NetworkAddress &remote_addr) | OpenDDS::DCPS::RtpsUdpDataLink | |
received(const RTPS::GapSubmessage &gap, const GuidPrefix_t &src_prefix, bool directed, const NetworkAddress &remote_addr) | OpenDDS::DCPS::RtpsUdpDataLink | |
received(const RTPS::HeartBeatSubmessage &heartbeat, const GuidPrefix_t &src_prefix, bool directed, const NetworkAddress &remote_addr) | OpenDDS::DCPS::RtpsUdpDataLink | |
received(const RTPS::HeartBeatFragSubmessage &hb_frag, const GuidPrefix_t &src_prefix, bool directed, const NetworkAddress &remote_addr) | OpenDDS::DCPS::RtpsUdpDataLink | |
received(const RTPS::AckNackSubmessage &acknack, const GuidPrefix_t &src_prefix, const NetworkAddress &remote_addr) | OpenDDS::DCPS::RtpsUdpDataLink | |
received(const RTPS::NackFragSubmessage &nackfrag, const GuidPrefix_t &src_prefix, const NetworkAddress &remote_addr) | OpenDDS::DCPS::RtpsUdpDataLink | |
RECONNECTED enum value | OpenDDS::DCPS::DataLink | |
ref_count() const | OpenDDS::DCPS::RcObject | inline |
Reference_Count typedef | ACE_Event_Handler | |
reference_count_ | ACE_Event_Handler | protected |
reference_counting_policy(void) | ACE_Event_Handler | |
register_for_reader(const GUID_t &writerid, const GUID_t &readerid, const AddrSet &addresses, DiscoveryListener *listener) | OpenDDS::DCPS::RtpsUdpDataLink | |
register_for_writer(const GUID_t &readerid, const GUID_t &writerid, const AddrSet &addresses, DiscoveryListener *listener) | OpenDDS::DCPS::RtpsUdpDataLink | |
register_stdin_handler(ACE_Event_Handler *eh, ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED) | ACE_Event_Handler | static |
release_reservations(GUID_t remote_id, GUID_t local_id, DataLinkSetMap &released_locals) | OpenDDS::DCPS::DataLink | |
release_reservations_i(const GUID_t &remote_id, const GUID_t &local_id) | OpenDDS::DCPS::RtpsUdpDataLink | privatevirtual |
release_resources() | OpenDDS::DCPS::DataLink | |
remove_all_msgs(const GUID_t &pub_id) | OpenDDS::DCPS::RtpsUdpDataLink | virtual |
remove_listener(const GUID_t &local_id) | OpenDDS::DCPS::DataLink | |
remove_locator_and_bundling_cache(const GUID_t &remote_id) | OpenDDS::DCPS::RtpsUdpDataLink | |
remove_on_start_callback(const TransportClient_wrch &client, const GUID_t &remote) | OpenDDS::DCPS::DataLink | |
remove_reference() | OpenDDS::DCPS::RcEventHandler | inlinevirtual |
remove_sample(const DataSampleElement *sample) | OpenDDS::DCPS::RtpsUdpDataLink | virtual |
remove_startup_callbacks(const GUID_t &local, const GUID_t &remote) | OpenDDS::DCPS::DataLink | |
remove_stdin_handler(ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr) | ACE_Event_Handler | static |
replay_durable_data(const GUID_t &local_pub_id, const GUID_t &remote_sub_id) const | OpenDDS::DCPS::DataLink | protected |
requires_inline_qos(const GUIDSeq_var &peers) | OpenDDS::DCPS::RtpsUdpDataLink | |
resume_handler(void) | ACE_Event_Handler | virtual |
resume_send() | OpenDDS::DCPS::DataLink | |
RtpsReader_rch typedef | OpenDDS::DCPS::RtpsUdpDataLink | private |
RtpsUdpDataLink(const RtpsUdpTransport_rch &transport, const GuidPrefix_t &local_prefix, const RtpsUdpInst_rch &config, const ReactorTask_rch &reactor_task, InternalTransportStatistics &transport_statistics, ACE_Thread_Mutex &transport_statistics_mutex) | OpenDDS::DCPS::RtpsUdpDataLink | |
RtpsWriter_rch typedef | OpenDDS::DCPS::RtpsUdpDataLink | private |
RWE_MASK | ACE_Event_Handler | |
schedule(InternalDataReader_rch reader) | OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress > | inline |
schedule_delayed_release() | OpenDDS::DCPS::DataLink | |
schedule_stop(const MonotonicTimePoint &schedule_to_stop_at) | OpenDDS::DCPS::DataLink | |
security_config() const | OpenDDS::DCPS::RtpsUdpDataLink | inline |
security_config_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
security_mutex_ | OpenDDS::DCPS::RtpsUdpDataLink | mutableprivate |
send(TransportQueueElement *element) | OpenDDS::DCPS::DataLink | |
send_control(const DataSampleHeader &header, Message_Block_Ptr data) | OpenDDS::DCPS::DataLink | |
send_final_acks(const GUID_t &readerid) | OpenDDS::DCPS::DataLink | virtual |
send_heartbeats(const MonotonicTimePoint &now) | OpenDDS::DCPS::RtpsUdpDataLink | private |
send_heartbeats_manual_i(const TransportSendControlElement *tsce, MetaSubmessageVec &meta_submessages) | OpenDDS::DCPS::RtpsUdpDataLink | private |
send_i(TransportQueueElement *element, bool relink=true) | OpenDDS::DCPS::DataLink | protectedvirtual |
send_response_listener_ | OpenDDS::DCPS::DataLink | protected |
send_start() | OpenDDS::DCPS::DataLink | |
send_start_i() | OpenDDS::DCPS::DataLink | protected |
send_stop(GUID_t repoId) | OpenDDS::DCPS::DataLink | |
send_stop_i(GUID_t repoId) | OpenDDS::DCPS::DataLink | protected |
send_strategy() | OpenDDS::DCPS::RtpsUdpDataLink | private |
send_strategy_ | OpenDDS::DCPS::DataLink | protected |
separate_message(EntityId_t entity) | OpenDDS::DCPS::RtpsUdpDataLink | static |
set_dscp_codepoint(int cp, ACE_SOCK &socket) | OpenDDS::DCPS::DataLink | |
set_handle(ACE_HANDLE) | ACE_Event_Handler | virtual |
set_scheduling_release(bool scheduling_release) | OpenDDS::DCPS::DataLink | |
SIGNAL_MASK | ACE_Event_Handler | |
sq_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
start(const TransportSendStrategy_rch &send_strategy, const TransportStrategy_rch &receive_strategy, bool invoke_all=true) | OpenDDS::DCPS::DataLink | protected |
started_ | OpenDDS::DCPS::DataLink | protected |
stop() | OpenDDS::DCPS::DataLink | |
stop_i() | OpenDDS::DCPS::RtpsUdpDataLink | privatevirtual |
strategy_lock_ | OpenDDS::DCPS::DataLink | protected |
submsgs_to_msgblock(const RTPS::SubmessageSeq &subm) | OpenDDS::DCPS::RtpsUdpDataLink | private |
target_intersection(const GUID_t &pub_id, const GUIDSeq &in, size_t &n_subs) | OpenDDS::DCPS::DataLink | |
terminate_send() | OpenDDS::DCPS::DataLink | |
terminate_send_if_suspended() | OpenDDS::DCPS::DataLink | |
TIMER_MASK | ACE_Event_Handler | |
transport() | OpenDDS::DCPS::RtpsUdpDataLink | |
transport_priority() | OpenDDS::DCPS::DataLink | |
transport_priority() const | OpenDDS::DCPS::DataLink | |
transport_shutdown() | OpenDDS::DCPS::DataLink | |
transport_statistics_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
transport_statistics_mutex_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
TransportClient_wrch typedef | OpenDDS::DCPS::DataLink | |
unicast_socket() | OpenDDS::DCPS::RtpsUdpDataLink | |
unicast_socket_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
unregister_for_reader(const GUID_t &writerid, const GUID_t &readerid) | OpenDDS::DCPS::RtpsUdpDataLink | |
unregister_for_writer(const GUID_t &readerid, const GUID_t &writerid) | OpenDDS::DCPS::RtpsUdpDataLink | |
update_last_recv_addr(const GUID_t &src, const NetworkAddress &addr, const MonotonicTimePoint &now=MonotonicTimePoint::now()) | OpenDDS::DCPS::RtpsUdpDataLink | private |
update_locators(const GUID_t &remote_id, AddrSet &unicast_addresses, AddrSet &multicast_addresses, bool requires_inline_qos, bool add_ref) | OpenDDS::DCPS::RtpsUdpDataLink | |
update_required_acknack_count(const GUID_t &local_id, const GUID_t &remote_id, CORBA::Long current) | OpenDDS::DCPS::RtpsUdpDataLink | private |
WRITE_MASK | ACE_Event_Handler | |
writer_to_seq_best_effort_readers_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
WriterInfo_rch typedef | OpenDDS::DCPS::RtpsUdpDataLink | private |
writers_ | OpenDDS::DCPS::RtpsUdpDataLink | private |
writers_lock_ | OpenDDS::DCPS::RtpsUdpDataLink | mutableprivate |
~ACE_Event_Handler(void) | ACE_Event_Handler | virtual |
~DataLink() | OpenDDS::DCPS::DataLink | virtual |
~RcObject() | OpenDDS::DCPS::RcObject | inlinevirtual |
~RtpsUdpDataLink() | OpenDDS::DCPS::RtpsUdpDataLink | |