OpenDDS::DCPS::RtpsUdpDataLink Member List

This is the complete list of members for OpenDDS::DCPS::RtpsUdpDataLink, including all inherited members.

::DDS_TEST class	OpenDDS::DCPS::RtpsUdpDataLink	[friend]
_add_ref()	OpenDDS::DCPS::RcObject	[inline, virtual]
_get_weak_object() const	OpenDDS::DCPS::RcObject	[inline]
_remove_ref()	OpenDDS::DCPS::RcObject	[inline, virtual]
ACCEPT_MASK	ACE_Event_Handler
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_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(const TransportClient_wrch &client, const RepoId &remote)	OpenDDS::DCPS::DataLink
add_reference()	OpenDDS::DCPS::RcEventHandler	[inline, virtual]
ALL_EVENTS_MASK	ACE_Event_Handler
associated(const RepoId &local, const RepoId &remote, bool local_reliable, bool remote_reliable, bool local_durable, bool remote_durable)	OpenDDS::DCPS::RtpsUdpDataLink
Atomic_Reference_Count typedef	ACE_Event_Handler	[protected]
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() 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
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(const TransportReceiveListener_wrch &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, ACE_Guard< ACE_Thread_Mutex > &guard)	OpenDDS::DCPS::RtpsUdpDataLink
DONT_CALL	ACE_Event_Handler
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]
EXCEPT_MASK	ACE_Event_Handler
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_handle(void) const	ACE_Event_Handler	[virtual]
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
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_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]
heartbeat_	OpenDDS::DCPS::RtpsUdpDataLink	[private]
heartbeat_counts_	OpenDDS::DCPS::RtpsUdpDataLink	[private]
heartbeat_reply_	OpenDDS::DCPS::RtpsUdpDataLink	[private]
heartbeatchecker_	OpenDDS::DCPS::RtpsUdpDataLink	[private]
held_data_delivery_handler_	OpenDDS::DCPS::RtpsUdpDataLink	[private]
HI_PRIORITY	ACE_Event_Handler
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
LO_PRIORITY	ACE_Event_Handler
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, const TransportSendListener_wrch &send_listener)	OpenDDS::DCPS::DataLink
make_reservation(const RepoId &remote_publication_id, const RepoId &local_subcription_id, const TransportReceiveListener_wrch &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
NULL_MASK	ACE_Event_Handler
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(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]
priority(void) const	ACE_Event_Handler	[virtual]
priority(int priority)	ACE_Event_Handler	[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]
process_requested_changes(DisjointSequence &requests, const RtpsWriter &writer, const ReaderInfo &reader)	OpenDDS::DCPS::RtpsUdpDataLink	[private]
QOS_MASK	ACE_Event_Handler
RcEventHandler()	OpenDDS::DCPS::RcEventHandler	[inline]
RcObject()	OpenDDS::DCPS::RcObject	[inline, protected]
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
reader_index_	OpenDDS::DCPS::RtpsUdpDataLink	[private]
readers_	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)	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
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 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
register_stdin_handler(ACE_Event_Handler *eh, ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)	ACE_Event_Handler	[static]
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(const TransportClient_wrch &client, const RepoId &remote)	OpenDDS::DCPS::DataLink
remove_reference()	OpenDDS::DCPS::RcEventHandler	[inline, virtual]
remove_sample(const DataSampleElement *sample, void *context)	OpenDDS::DCPS::RtpsUdpDataLink	[private, virtual]
remove_stdin_handler(ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr)	ACE_Event_Handler	[static]
requires_inline_qos(const GUIDSeq_var &peers)	OpenDDS::DCPS::RtpsUdpDataLink	[private]
resume_handler(void)	ACE_Event_Handler	[virtual]
resume_send()	OpenDDS::DCPS::DataLink
RtpsUdpDataLink(RtpsUdpTransport &transport, const GuidPrefix_t &local_prefix, const RtpsUdpInst &config, const TransportReactorTask_rch &reactor_task)	OpenDDS::DCPS::RtpsUdpDataLink
RWE_MASK	ACE_Event_Handler
schedule_delayed_release()	OpenDDS::DCPS::DataLink
schedule_stop(const 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, Message_Block_Ptr data)	OpenDDS::DCPS::DataLink
send_directed_heartbeats(OPENDDS_VECTOR(RTPS::HeartBeatSubmessage)&hbs)	OpenDDS::DCPS::RtpsUdpDataLink	[private]
send_directed_nack_replies(const RepoId &writerId, RtpsWriter &writer, const RepoId &readerId, ReaderInfo &reader)	OpenDDS::DCPS::RtpsUdpDataLink	[private]
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()	OpenDDS::DCPS::RtpsUdpDataLink	[private]
send_strategy_	OpenDDS::DCPS::DataLink	[protected]
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
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]
TIMER_MASK	ACE_Event_Handler
transport_priority()	OpenDDS::DCPS::DataLink
transport_priority() const	OpenDDS::DCPS::DataLink
transport_shutdown()	OpenDDS::DCPS::DataLink
TransportClient_wrch typedef	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
WRITE_MASK	ACE_Event_Handler
writers_	OpenDDS::DCPS::RtpsUdpDataLink	[private]
~ACE_Event_Handler(void)	ACE_Event_Handler	[virtual]
~DataLink()	OpenDDS::DCPS::DataLink	[virtual]
~RcObject()	OpenDDS::DCPS::RcObject	[inline, virtual]