OpenDDS  Snapshot(2023/04/07-19:43)
OpenDDS::DCPS::ShmemDataLink Member List

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

_add_ref()OpenDDS::DCPS::RcObjectinlinevirtual
_get_weak_object() constOpenDDS::DCPS::RcObjectinline
_remove_ref()OpenDDS::DCPS::RcObjectinlinevirtual
ACCEPT_MASKACE_Event_Handler
ACE_APPLICATION_RESUMES_HANDLERACE_Event_Handler
ACE_Event_Handler(ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY)ACE_Event_Handlerprotected
ACE_EVENT_HANDLER_NOT_RESUMEDACE_Event_Handler
ACE_REACTOR_RESUMES_HANDLERACE_Event_Handler
add_on_start_callback(const TransportClient_wrch &client, const GUID_t &remote)OpenDDS::DCPS::DataLink
add_reference()OpenDDS::DCPS::RcEventHandlerinlinevirtual
ALL_EVENTS_MASKACE_Event_Handler
assoc_resends_OpenDDS::DCPS::ShmemDataLinkprivate
assoc_resends_mutex_OpenDDS::DCPS::ShmemDataLinkprivate
assoc_resends_task_OpenDDS::DCPS::ShmemDataLinkprivate
AssocResends typedefOpenDDS::DCPS::ShmemDataLinkprivate
Atomic_Reference_Count typedefACE_Event_Handlerprotected
cancel_release()OpenDDS::DCPS::DataLink
clear_associations()OpenDDS::DCPS::DataLink
config() constOpenDDS::DCPS::ShmemDataLink
CONNECT_MASKACE_Event_Handler
ConnectionNotice enum nameOpenDDS::DCPS::DataLink
control_received(ReceivedDataSample &sample)OpenDDS::DCPS::ShmemDataLink
create_control(char submessage_id, DataSampleHeader &header, Message_Block_Ptr data)OpenDDS::DCPS::DataLink
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() constOpenDDS::DCPS::DataLink
datalink_release_delay_OpenDDS::DCPS::DataLinkprotected
db_allocator_OpenDDS::DCPS::DataLinkprotected
default_listener(const TransportReceiveListener_wrch &trl)OpenDDS::DCPS::DataLink
default_listener() constOpenDDS::DCPS::DataLink
DISCONNECTED enum valueOpenDDS::DCPS::DataLink
DONT_CALLACE_Event_Handler
EXCEPT_MASKACE_Event_Handler
get_handle(void) constACE_Event_Handlervirtual
get_ice_endpoint() constOpenDDS::DCPS::DataLinkinlinevirtual
get_next_datalink_id()OpenDDS::DCPS::DataLinkprotectedstatic
get_send_strategy()OpenDDS::DCPS::DataLinkprotected
GROUP_QOS_MASKACE_Event_Handler
GuardType typedefOpenDDS::DCPS::DataLinkprotected
handle_close(ACE_HANDLE h, ACE_Reactor_Mask m)OpenDDS::DCPS::DataLinkvirtual
handle_exception(ACE_HANDLE)OpenDDS::DCPS::DataLinkvirtual
handle_exit(ACE_Process *)ACE_Event_Handlervirtual
handle_group_qos(ACE_HANDLE=ACE_INVALID_HANDLE)ACE_Event_Handlervirtual
handle_input(ACE_HANDLE fd=ACE_INVALID_HANDLE)ACE_Event_Handlervirtual
handle_output(ACE_HANDLE fd=ACE_INVALID_HANDLE)ACE_Event_Handlervirtual
handle_qos(ACE_HANDLE=ACE_INVALID_HANDLE)ACE_Event_Handlervirtual
handle_signal(int signum, siginfo_t *=0, ucontext_t *=0)ACE_Event_Handlervirtual
handle_timeout(const ACE_Time_Value &tv, const void *arg)OpenDDS::DCPS::DataLinkvirtual
HI_PRIORITYACE_Event_Handler
id() constOpenDDS::DCPS::DataLink
impl() constOpenDDS::DCPS::DataLink
interceptor_OpenDDS::DCPS::DataLinkprotected
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() constOpenDDS::DCPS::DataLink
is_active_OpenDDS::DCPS::DataLinkprotected
is_leading(const GUID_t &, const GUID_t &) constOpenDDS::DCPS::DataLinkinlinevirtual
is_loopback()OpenDDS::DCPS::DataLink
is_loopback() constOpenDDS::DCPS::DataLink
is_loopback_OpenDDS::DCPS::DataLinkprotected
is_target(const GUID_t &remote_id)OpenDDS::DCPS::DataLink
LO_PRIORITYACE_Event_Handler
local_address()OpenDDS::DCPS::ShmemDataLink
local_allocator()OpenDDS::DCPS::ShmemDataLink
LOST enum valueOpenDDS::DCPS::DataLink
make_reservation(const GUID_t &remote_pub, const GUID_t &local_sub, const TransportReceiveListener_wrch &receive_listener, bool reliable)OpenDDS::DCPS::ShmemDataLinkvirtual
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::DataLinkvirtual
mb_allocator_OpenDDS::DCPS::DataLinkprotected
network_change() constOpenDDS::DCPS::DataLinkprotected
notify(ConnectionNotice notice)OpenDDS::DCPS::DataLink
NULL_MASKACE_Event_Handler
on_start_callbacks_OpenDDS::DCPS::DataLinkprotected
OnStartCallback typedefOpenDDS::DCPS::DataLink
open(const std::string &peer_address)OpenDDS::DCPS::ShmemDataLink
OPENDDS_MAP_CMP(GUID_t, TransportClient_wrch, GUID_tKeyLessThan) RepoToClientMapOpenDDS::DCPS::DataLinkprotected
OPENDDS_MAP_CMP(GUID_t, RepoToClientMap, GUID_tKeyLessThan) OnStartCallbackMapOpenDDS::DCPS::DataLinkprotected
OPENDDS_MAP_CMP(GUID_t, RepoIdSet, GUID_tKeyLessThan) PendingOnStartsMapOpenDDS::DCPS::DataLinkprotected
peer_address()OpenDDS::DCPS::ShmemDataLink
peer_address_OpenDDS::DCPS::ShmemDataLinkprivate
peer_alloc_OpenDDS::DCPS::ShmemDataLinkprivate
peer_alloc_mutex_OpenDDS::DCPS::ShmemDataLinkprivate
peer_allocator()OpenDDS::DCPS::ShmemDataLink
peer_ids(const GUID_t &local_id) constOpenDDS::DCPS::DataLinkprotected
peer_pid()OpenDDS::DCPS::ShmemDataLink
pending_on_starts_OpenDDS::DCPS::DataLinkprotected
pre_stop_i()OpenDDS::DCPS::DataLinkvirtual
priority(void) constACE_Event_Handlervirtual
priority(int priority)ACE_Event_Handlervirtual
QOS_MASKACE_Event_Handler
RcEventHandler()OpenDDS::DCPS::RcEventHandlerinline
RcObject()OpenDDS::DCPS::RcObjectinlineprotected
reactor(ACE_Reactor *reactor)ACE_Event_Handlervirtual
reactor(void) constACE_Event_Handlervirtual
reactor_task_OpenDDS::DCPS::ShmemDataLinkprivate
reactor_timer_interface(void) constACE_Event_Handlervirtual
read()OpenDDS::DCPS::ShmemDataLinkinline
read_adapter(void *event_handler)ACE_Event_Handlerstatic
READ_MASKACE_Event_Handler
receive_strategy_OpenDDS::DCPS::DataLinkprotected
RECONNECTED enum valueOpenDDS::DCPS::DataLink
recv_strategy_OpenDDS::DCPS::ShmemDataLinkprotected
ref_count() constOpenDDS::DCPS::RcObjectinline
Reference_Count typedefACE_Event_Handler
reference_count_ACE_Event_Handlerprotected
reference_counting_policy(void)ACE_Event_Handler
register_stdin_handler(ACE_Event_Handler *eh, ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)ACE_Event_Handlerstatic
release_reservations(GUID_t remote_id, GUID_t local_id, DataLinkSetMap &released_locals)OpenDDS::DCPS::DataLink
release_resources()OpenDDS::DCPS::DataLink
remove_all_msgs(const GUID_t &pub_id)OpenDDS::DCPS::DataLinkvirtual
remove_listener(const GUID_t &local_id)OpenDDS::DCPS::DataLink
remove_on_start_callback(const TransportClient_wrch &client, const GUID_t &remote)OpenDDS::DCPS::DataLink
remove_reference()OpenDDS::DCPS::RcEventHandlerinlinevirtual
remove_sample(const DataSampleElement *sample)OpenDDS::DCPS::DataLinkvirtual
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_Handlerstatic
replay_durable_data(const GUID_t &local_pub_id, const GUID_t &remote_sub_id) constOpenDDS::DCPS::DataLinkprotected
request_ack_received(ReceivedDataSample &sample)OpenDDS::DCPS::ShmemDataLink
resend_association_msgs(const MonotonicTimePoint &now)OpenDDS::DCPS::ShmemDataLinkprivate
resume_handler(void)ACE_Event_Handlervirtual
resume_send()OpenDDS::DCPS::DataLink
RWE_MASKACE_Event_Handler
schedule_delayed_release()OpenDDS::DCPS::DataLink
schedule_stop(const MonotonicTimePoint &schedule_to_stop_at)OpenDDS::DCPS::DataLink
send(TransportQueueElement *element)OpenDDS::DCPS::DataLink
send_association_msg(const GUID_t &local, const GUID_t &remote)OpenDDS::DCPS::ShmemDataLinkprivate
send_control(const DataSampleHeader &header, Message_Block_Ptr data)OpenDDS::DCPS::DataLink
send_final_acks(const GUID_t &readerid)OpenDDS::DCPS::DataLinkvirtual
send_i(TransportQueueElement *element, bool relink=true)OpenDDS::DCPS::DataLinkprotectedvirtual
send_response_listener_OpenDDS::DCPS::DataLinkprotected
send_start()OpenDDS::DCPS::DataLink
send_start_i()OpenDDS::DCPS::DataLinkprotected
send_stop(GUID_t repoId)OpenDDS::DCPS::DataLink
send_stop_i(GUID_t repoId)OpenDDS::DCPS::DataLinkprotected
send_strategy_OpenDDS::DCPS::ShmemDataLinkprotected
set_dscp_codepoint(int cp, ACE_SOCK &socket)OpenDDS::DCPS::DataLink
set_handle(ACE_HANDLE)ACE_Event_Handlervirtual
set_scheduling_release(bool scheduling_release)OpenDDS::DCPS::DataLink
ShmemDataLink(const ShmemTransport_rch &transport)OpenDDS::DCPS::ShmemDataLink
SIGNAL_MASKACE_Event_Handler
signal_semaphore()OpenDDS::DCPS::ShmemDataLink
SmPeriodicTask typedefOpenDDS::DCPS::ShmemDataLinkprivate
start(const TransportSendStrategy_rch &send_strategy, const TransportStrategy_rch &receive_strategy, bool invoke_all=true)OpenDDS::DCPS::DataLinkprotected
started_OpenDDS::DCPS::DataLinkprotected
stop()OpenDDS::DCPS::DataLink
stop_i()OpenDDS::DCPS::ShmemDataLinkprotectedvirtual
stop_resend_association_msgs(const GUID_t &local, const GUID_t &remote)OpenDDS::DCPS::ShmemDataLink
strategy_lock_OpenDDS::DCPS::DataLinkprotected
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_MASKACE_Event_Handler
transport() constOpenDDS::DCPS::ShmemDataLink
transport_priority()OpenDDS::DCPS::DataLink
transport_priority() constOpenDDS::DCPS::DataLink
transport_shutdown()OpenDDS::DCPS::DataLink
TransportClient_wrch typedefOpenDDS::DCPS::DataLink
WRITE_MASKACE_Event_Handler
~ACE_Event_Handler(void)ACE_Event_Handlervirtual
~DataLink()OpenDDS::DCPS::DataLinkvirtual
~RcObject()OpenDDS::DCPS::RcObjectinlinevirtual