| ::DDS_TEST class | OpenDDS::DCPS::RtpsUdpDataLink | [friend] |
| _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::RtpsUdpDataLink | |
| add_gap_submsg(RTPS::SubmessageSeq &msg, const TransportQueueElement &tqe, const DestToEntityMap &dtem) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| add_locator(const RepoId &remote_id, const ACE_INET_Addr &address, bool requires_inline_qos) | OpenDDS::DCPS::RtpsUdpDataLink | |
| add_on_start_callback(TransportClient *client, const RepoId &remote) | OpenDDS::DCPS::DataLink | |
| associated(const RepoId &local, const RepoId &remote, bool local_reliable, bool remote_reliable, bool local_durable, bool remote_durable) | OpenDDS::DCPS::RtpsUdpDataLink | |
| best_effort_heartbeat_count_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| CallbackType typedef | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| cancel_release() | OpenDDS::DCPS::DataLink | |
| check_handshake_complete(const RepoId &local, const RepoId &remote) | OpenDDS::DCPS::RtpsUdpDataLink | |
| check_heartbeats() | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| clear_associations() | OpenDDS::DCPS::DataLink | |
| config() | OpenDDS::DCPS::RtpsUdpDataLink | |
| config_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| ConnectionNotice enum name | OpenDDS::DCPS::DataLink | |
| create_control(char submessage_id, DataSampleHeader &header, ACE_Message_Block *data) | OpenDDS::DCPS::DataLink | |
| customize_queue_element(TransportQueueElement *element) | OpenDDS::DCPS::RtpsUdpDataLink | [private, virtual] |
| data_received(ReceivedDataSample &sample, const RepoId &readerId=GUID_UNKNOWN) | OpenDDS::DCPS::DataLink | |
| data_received_include(ReceivedDataSample &sample, const RepoIdSet &incl) | OpenDDS::DCPS::DataLink | |
| DataLink(TransportImpl *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, const FN &func) | OpenDDS::DCPS::RtpsUdpDataLink | [inline, private] |
| db_allocator_ | OpenDDS::DCPS::DataLink | [protected] |
| default_listener(TransportReceiveListener *trl) | OpenDDS::DCPS::DataLink | |
| default_listener() const | OpenDDS::DCPS::DataLink | |
| deliver_held_data(const RepoId &readerId, WriterInfo &info, bool durable) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| DISCONNECTED enum value | OpenDDS::DCPS::DataLink | |
| do_remove_sample(const RepoId &pub_id, const TransportQueueElement::MatchCriteria &criteria) | OpenDDS::DCPS::RtpsUdpDataLink | |
| durability_resend(TransportQueueElement *element) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| end_historic_samples(RtpsWriterMap::iterator writer, const DataSampleHeader &header, ACE_Message_Block *body) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| extend_bitmap_range(RTPS::FragmentNumberSet &fnSet, CORBA::ULong extent) | OpenDDS::DCPS::RtpsUdpDataLink | [private, static] |
| force_inline_qos_ | OpenDDS::DCPS::RtpsUdpDataLink | [private, static] |
| generate_nack_frags(OPENDDS_VECTOR(RTPS::NackFragSubmessage)&nack_frags, WriterInfo &wi, const RepoId &pub_id) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| get_locator(const RepoId &remote_id) const | OpenDDS::DCPS::RtpsUdpDataLink | |
| get_locators(const RepoId &local_id, OPENDDS_SET(ACE_INET_Addr)&addrs) const | OpenDDS::DCPS::RtpsUdpDataLink | |
| get_next_datalink_id() | OpenDDS::DCPS::DataLink | [protected, static] |
| get_reactor() | OpenDDS::DCPS::RtpsUdpDataLink | |
| GuardType typedef | OpenDDS::DCPS::DataLink | [protected] |
| handle_close(ACE_HANDLE h, ACE_Reactor_Mask m) | OpenDDS::DCPS::DataLink | |
| handle_exception(ACE_HANDLE) | OpenDDS::DCPS::DataLink | |
| handle_timeout(const ACE_Time_Value &tv, const void *arg) | OpenDDS::DCPS::DataLink | |
| heartbeat_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| heartbeat_counts_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| heartbeat_reply_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| heartbeatchecker_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| id() const | OpenDDS::DCPS::DataLink | |
| impl() const | OpenDDS::DCPS::DataLink | |
| interesting_ack_nacks_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| interesting_readers_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| interesting_writers_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| invoke_on_start_callbacks(bool success) | OpenDDS::DCPS::DataLink | |
| is_active() | OpenDDS::DCPS::DataLink | |
| is_active() const | OpenDDS::DCPS::DataLink | |
| is_active_ | OpenDDS::DCPS::DataLink | [protected] |
| is_loopback() | OpenDDS::DCPS::DataLink | |
| is_loopback() const | OpenDDS::DCPS::DataLink | |
| is_loopback_ | OpenDDS::DCPS::DataLink | [protected] |
| is_target(const RepoId &remote_sub_id) | OpenDDS::DCPS::DataLink | |
| issues_on_deleted_callback() const | OpenDDS::DCPS::DataLink | [virtual] |
| local_prefix() const | OpenDDS::DCPS::RtpsUdpDataLink | [inline] |
| local_prefix_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| lock_ | OpenDDS::DCPS::RtpsUdpDataLink | [mutable, private] |
| LOST enum value | OpenDDS::DCPS::DataLink | |
| make_reservation(const RepoId &remote_subscription_id, const RepoId &local_publication_id, TransportSendListener *send_listener) | OpenDDS::DCPS::DataLink | |
| make_reservation(const RepoId &remote_publication_id, const RepoId &local_subcription_id, TransportReceiveListener *receive_listener) | OpenDDS::DCPS::DataLink | |
| marshal_gaps(const RepoId &writer, const RepoId &reader, const DisjointSequence &gaps, bool durable=false) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| mb_allocator_ | OpenDDS::DCPS::DataLink | [protected] |
| multi_buff_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| multicast_socket() | OpenDDS::DCPS::RtpsUdpDataLink | |
| multicast_socket_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| nack_reply_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| notify(ConnectionNotice notice) | OpenDDS::DCPS::DataLink | |
| notify_connection_deleted() | OpenDDS::DCPS::DataLink | |
| OnStartCallback typedef | OpenDDS::DCPS::DataLink | |
| open(const ACE_SOCK_Dgram &unicast_socket) | OpenDDS::DCPS::RtpsUdpDataLink | |
| OPENDDS_MAP_CMP(RepoId, OPENDDS_VECTOR(RepoId), GUID_tKeyLessThan) DestToEntityMap | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_MAP_CMP(RepoId, RemoteInfo, GUID_tKeyLessThan) locators_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_MAP_CMP(RepoId, ReaderInfo, GUID_tKeyLessThan) ReaderInfoMap | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_MAP_CMP(RepoId, RtpsWriter, GUID_tKeyLessThan) RtpsWriterMap | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_MAP_CMP(RepoId, WriterInfo, GUID_tKeyLessThan) WriterInfoMap | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_MAP_CMP(RepoId, RtpsReader, GUID_tKeyLessThan) RtpsReaderMap | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_MAP_CMP(RepoId, CORBA::Long, DCPS::GUID_tKeyLessThan) HeartBeatCountMapType | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_MULTIMAP_CMP(RepoId, RtpsReaderMap::iterator, GUID_tKeyLessThan) RtpsReaderIndex | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_MULTIMAP_CMP(RepoId, InterestingRemote, DCPS::GUID_tKeyLessThan) InterestingRemoteMapType | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_SET(InterestingAckNack) InterestingAckNackSetType | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_VECTOR(CallbackType) writerDoesNotExistCallbacks_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OPENDDS_VECTOR(CallbackType) readerDoesNotExistCallbacks_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| OpenDDS::DCPS::DataLink::OPENDDS_VECTOR(OnStartCallback) on_start_callbacks_ | OpenDDS::DCPS::DataLink | [protected] |
| peer_ids(const RepoId &local_id) const | OpenDDS::DCPS::DataLink | [protected] |
| PMF typedef | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| pre_stop_i() | OpenDDS::DCPS::RtpsUdpDataLink | [virtual] |
| process_acked_by_all_i(ACE_Guard< ACE_Thread_Mutex > &g, const RepoId &pub_id) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| process_data_i(const RTPS::DataSubmessage &data, const RepoId &src, RtpsReaderMap::value_type &rr) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| process_gap_i(const RTPS::GapSubmessage &gap, const RepoId &src, RtpsReaderMap::value_type &rr) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| process_hb_frag_i(const RTPS::HeartBeatFragSubmessage &hb_frag, const RepoId &src, RtpsReaderMap::value_type &rr) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| process_heartbeat_i(const RTPS::HeartBeatSubmessage &heartbeat, const RepoId &src, RtpsReaderMap::value_type &rr) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| RcObject(ACE_Allocator *allocator=0) | OpenDDS::DCPS::RcObject< ACE_SYNCH_MUTEX > | [inline, protected] |
| reactor_is_shut_down() | OpenDDS::DCPS::RtpsUdpDataLink | |
| reactor_task_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| reader_index_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| reader_no_longer_exists_lock_ | OpenDDS::DCPS::RtpsUdpDataLink | [mutable, private] |
| readers_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| receive_strategy(RtpsUdpReceiveStrategy *recv_strategy) | OpenDDS::DCPS::RtpsUdpDataLink | |
| receive_strategy_ | OpenDDS::DCPS::DataLink | [protected] |
| received(const RTPS::DataSubmessage &data, const GuidPrefix_t &src_prefix) | OpenDDS::DCPS::RtpsUdpDataLink | |
| received(const RTPS::GapSubmessage &gap, const GuidPrefix_t &src_prefix) | OpenDDS::DCPS::RtpsUdpDataLink | |
| received(const RTPS::HeartBeatSubmessage &heartbeat, const GuidPrefix_t &src_prefix) | OpenDDS::DCPS::RtpsUdpDataLink | |
| received(const RTPS::HeartBeatFragSubmessage &hb_frag, const GuidPrefix_t &src_prefix) | OpenDDS::DCPS::RtpsUdpDataLink | |
| received(const RTPS::AckNackSubmessage &acknack, const GuidPrefix_t &src_prefix) | OpenDDS::DCPS::RtpsUdpDataLink | |
| received(const RTPS::NackFragSubmessage &nackfrag, const GuidPrefix_t &src_prefix) | OpenDDS::DCPS::RtpsUdpDataLink | |
| RECONNECTED enum value | OpenDDS::DCPS::DataLink | |
| recv_strategy_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| ref_count() const | OpenDDS::DCPS::RcObject< ACE_SYNCH_MUTEX > | [inline] |
| register_for_reader(const RepoId &writerid, const RepoId &readerid, const ACE_INET_Addr &address, OpenDDS::DCPS::DiscoveryListener *listener) | OpenDDS::DCPS::RtpsUdpDataLink | |
| register_for_writer(const RepoId &readerid, const RepoId &writerid, const ACE_INET_Addr &address, OpenDDS::DCPS::DiscoveryListener *listener) | OpenDDS::DCPS::RtpsUdpDataLink | |
| release_remote_i(const RepoId &remote_id) | OpenDDS::DCPS::RtpsUdpDataLink | [private, virtual] |
| release_reservations(RepoId remote_id, RepoId local_id, DataLinkSetMap &released_locals) | OpenDDS::DCPS::DataLink | |
| release_reservations_i(const RepoId &remote_id, const RepoId &local_id) | OpenDDS::DCPS::RtpsUdpDataLink | [private, virtual] |
| release_resources() | OpenDDS::DCPS::DataLink | |
| remove_all_msgs(RepoId pub_id) | OpenDDS::DCPS::DataLink | |
| remove_listener(const RepoId &local_id) | OpenDDS::DCPS::DataLink | |
| remove_on_start_callback(TransportClient *client, const RepoId &remote) | OpenDDS::DCPS::DataLink | |
| remove_sample(const DataSampleElement *sample) | OpenDDS::DCPS::DataLink | |
| requires_inline_qos(const PublicationId &pub_id) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| resume_send() | OpenDDS::DCPS::DataLink | |
| rtps_customized_element_allocator_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| RtpsUdpDataLink(RtpsUdpTransport *transport, const GuidPrefix_t &local_prefix, RtpsUdpInst *config, TransportReactorTask *reactor_task) | OpenDDS::DCPS::RtpsUdpDataLink | |
| schedule_delayed_release() | OpenDDS::DCPS::DataLink | |
| schedule_stop(ACE_Time_Value &schedule_to_stop_at) | OpenDDS::DCPS::DataLink | |
| send(TransportQueueElement *element) | OpenDDS::DCPS::DataLink | |
| send_ack_nacks(RtpsReaderMap::iterator rr, bool finalFlag=false) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| send_control(const DataSampleHeader &header, ACE_Message_Block *data) | OpenDDS::DCPS::DataLink | |
| send_control_allocator_ | OpenDDS::DCPS::DataLink | [protected] |
| send_durability_gaps(const RepoId &writer, const RepoId &reader, const DisjointSequence &gaps) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| send_final_acks(const RepoId &readerid) | OpenDDS::DCPS::RtpsUdpDataLink | [virtual] |
| send_heartbeat_replies() | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| send_heartbeats() | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| send_heartbeats_manual(const TransportSendControlElement *tsce) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| send_i(TransportQueueElement *element, bool relink=true) | OpenDDS::DCPS::RtpsUdpDataLink | [private, virtual] |
| send_nack_replies() | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| send_nackfrag_replies(RtpsWriter &writer, DisjointSequence &gaps, OPENDDS_SET(ACE_INET_Addr)&gap_recipients) | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| send_response_listener_ | OpenDDS::DCPS::DataLink | [protected] |
| send_start() | OpenDDS::DCPS::DataLink | |
| send_start_i() | OpenDDS::DCPS::DataLink | [protected] |
| send_stop(RepoId repoId) | OpenDDS::DCPS::DataLink | |
| send_stop_i(RepoId repoId) | OpenDDS::DCPS::DataLink | [protected] |
| send_strategy(RtpsUdpSendStrategy *send_strategy) | OpenDDS::DCPS::RtpsUdpDataLink | |
| send_strategy_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| set_dscp_codepoint(int cp, ACE_SOCK &socket) | OpenDDS::DCPS::DataLink | |
| set_scheduling_release(bool scheduling_release) | OpenDDS::DCPS::DataLink | |
| start(const TransportSendStrategy_rch &send_strategy, const TransportStrategy_rch &receive_strategy) | OpenDDS::DCPS::DataLink | [protected] |
| started_ | OpenDDS::DCPS::DataLink | [protected] |
| stop() | OpenDDS::DCPS::DataLink | |
| stop_i() | OpenDDS::DCPS::RtpsUdpDataLink | [private, virtual] |
| strategy_lock_ | OpenDDS::DCPS::DataLink | [protected] |
| target_intersection(const RepoId &pub_id, const GUIDSeq &in, size_t &n_subs) | OpenDDS::DCPS::DataLink | |
| terminate_send() | OpenDDS::DCPS::DataLink | |
| ThreadPerConnectionSendTask class | OpenDDS::DCPS::DataLink | [friend] |
| transport_priority() | OpenDDS::DCPS::DataLink | |
| transport_priority() const | OpenDDS::DCPS::DataLink | |
| transport_shutdown() | OpenDDS::DCPS::DataLink | |
| unicast_socket() | OpenDDS::DCPS::RtpsUdpDataLink | |
| unicast_socket_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| unregister_for_reader(const RepoId &writerid, const RepoId &readerid) | OpenDDS::DCPS::RtpsUdpDataLink | |
| unregister_for_writer(const RepoId &readerid, const RepoId &writerid) | OpenDDS::DCPS::RtpsUdpDataLink | |
| writer_no_longer_exists_lock_ | OpenDDS::DCPS::RtpsUdpDataLink | [mutable, private] |
| writers_ | OpenDDS::DCPS::RtpsUdpDataLink | [private] |
| ~DataLink() | OpenDDS::DCPS::DataLink | [virtual] |
| ~RcObject() | OpenDDS::DCPS::RcObject< ACE_SYNCH_MUTEX > | [inline, virtual] |
