OpenDDS::DCPS::ShmemDataLink Member List

This is the complete list of members for OpenDDS::DCPS::ShmemDataLink, including all inherited members.
_add_ref()OpenDDS::DCPS::RcObject [inline, virtual]
_get_weak_object() const OpenDDS::DCPS::RcObject [inline]
_remove_ref()OpenDDS::DCPS::RcObject [inline, virtual]
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_Handler [protected]
ACE_EVENT_HANDLER_NOT_RESUMEDACE_Event_Handler
ACE_REACTOR_RESUMES_HANDLERACE_Event_Handler
add_on_start_callback(const TransportClient_wrch &client, const RepoId &remote)OpenDDS::DCPS::DataLink
add_reference()OpenDDS::DCPS::RcEventHandler [inline, virtual]
ALL_EVENTS_MASKACE_Event_Handler
Atomic_Reference_Count typedefACE_Event_Handler [protected]
cancel_release()OpenDDS::DCPS::DataLink
clear_associations()OpenDDS::DCPS::DataLink
config_OpenDDS::DCPS::ShmemDataLink [protected]
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 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]
db_allocator_OpenDDS::DCPS::DataLink [protected]
default_listener(const TransportReceiveListener_wrch &trl)OpenDDS::DCPS::DataLink
default_listener() const OpenDDS::DCPS::DataLink
DISCONNECTED enum valueOpenDDS::DCPS::DataLink
DONT_CALLACE_Event_Handler
EXCEPT_MASKACE_Event_Handler
get_handle(void) const ACE_Event_Handler [virtual]
get_next_datalink_id()OpenDDS::DCPS::DataLink [protected, static]
GROUP_QOS_MASKACE_Event_Handler
GuardType typedefOpenDDS::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]
HI_PRIORITYACE_Event_Handler
id() const OpenDDS::DCPS::DataLink
impl() const OpenDDS::DCPS::ShmemDataLink
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_PRIORITYACE_Event_Handler
local_address()OpenDDS::DCPS::ShmemDataLink
local_allocator()OpenDDS::DCPS::ShmemDataLink
LOST enum valueOpenDDS::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
mb_allocator_OpenDDS::DCPS::DataLink [protected]
notify(ConnectionNotice notice)OpenDDS::DCPS::DataLink
NULL_MASKACE_Event_Handler
OnStartCallback typedefOpenDDS::DCPS::DataLink
open(const std::string &peer_address)OpenDDS::DCPS::ShmemDataLink
OPENDDS_VECTOR(OnStartCallback) on_start_callbacks_OpenDDS::DCPS::DataLink [protected]
peer_address()OpenDDS::DCPS::ShmemDataLink
peer_address_OpenDDS::DCPS::ShmemDataLink [private]
peer_alloc_OpenDDS::DCPS::ShmemDataLink [private]
peer_allocator()OpenDDS::DCPS::ShmemDataLink [inline]
peer_ids(const RepoId &local_id) const OpenDDS::DCPS::DataLink [protected]
peer_pid()OpenDDS::DCPS::ShmemDataLink
pre_stop_i()OpenDDS::DCPS::DataLink [virtual]
priority(void) const ACE_Event_Handler [virtual]
priority(int priority)ACE_Event_Handler [virtual]
QOS_MASKACE_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_timer_interface(void) const ACE_Event_Handler [virtual]
read()OpenDDS::DCPS::ShmemDataLink [inline]
read_adapter(void *event_handler)ACE_Event_Handler [static]
READ_MASKACE_Event_Handler
receive_strategy_OpenDDS::DCPS::DataLink [protected]
RECONNECTED enum valueOpenDDS::DCPS::DataLink
recv_strategy_OpenDDS::DCPS::ShmemDataLink [protected]
ref_count() const OpenDDS::DCPS::RcObject [inline]
Reference_Count typedefACE_Event_Handler
reference_count_ACE_Event_Handler [protected]
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_Handler [static]
release_reservations(RepoId remote_id, RepoId local_id, DataLinkSetMap &released_locals)OpenDDS::DCPS::DataLink
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::DataLink [virtual]
remove_stdin_handler(ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr)ACE_Event_Handler [static]
resume_handler(void)ACE_Event_Handler [virtual]
resume_send()OpenDDS::DCPS::DataLink
RWE_MASKACE_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_control(const DataSampleHeader &header, Message_Block_Ptr data)OpenDDS::DCPS::DataLink
send_final_acks(const RepoId &readerid)OpenDDS::DCPS::DataLink [virtual]
send_i(TransportQueueElement *element, bool relink=true)OpenDDS::DCPS::DataLink [protected, virtual]
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::ShmemDataLink [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
ShmemDataLink(ShmemTransport &transport)OpenDDS::DCPS::ShmemDataLink
SIGNAL_MASKACE_Event_Handler
signal_semaphore()OpenDDS::DCPS::ShmemDataLink
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::ShmemDataLink [protected, 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 classOpenDDS::DCPS::DataLink [friend]
TIMER_MASKACE_Event_Handler
transport_priority()OpenDDS::DCPS::DataLink
transport_priority() const OpenDDS::DCPS::DataLink
transport_shutdown()OpenDDS::DCPS::DataLink
TransportClient_wrch typedefOpenDDS::DCPS::DataLink
WRITE_MASKACE_Event_Handler
~ACE_Event_Handler(void)ACE_Event_Handler [virtual]
~DataLink()OpenDDS::DCPS::DataLink [virtual]
~RcObject()OpenDDS::DCPS::RcObject [inline, virtual]
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines

Generated on 10 Aug 2018 for OpenDDS by  doxygen 1.6.1