, 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_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_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 | |
Atomic_Reference_Count typedef | ACE_Event_Handler | [protected] |
cancel_release() | OpenDDS::DCPS::DataLink | |
clear_associations() | OpenDDS::DCPS::DataLink | |
config_ | OpenDDS::DCPS::ShmemDataLink | [protected] |
CONNECT_MASK | ACE_Event_Handler | |
ConnectionNotice enum name | OpenDDS::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 value | OpenDDS::DCPS::DataLink | |
DONT_CALL | ACE_Event_Handler | |
EXCEPT_MASK | ACE_Event_Handler | |
get_handle(void) const | ACE_Event_Handler | [virtual] |
get_next_datalink_id() | OpenDDS::DCPS::DataLink | [protected, static] |
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] |
HI_PRIORITY | ACE_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_PRIORITY | ACE_Event_Handler | |
local_address() | OpenDDS::DCPS::ShmemDataLink | |
local_allocator() | OpenDDS::DCPS::ShmemDataLink | |
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 | |
mb_allocator_ | OpenDDS::DCPS::DataLink | [protected] |
notify(ConnectionNotice notice) | OpenDDS::DCPS::DataLink | |
NULL_MASK | ACE_Event_Handler | |
OnStartCallback typedef | OpenDDS::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_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_timer_interface(void) const | ACE_Event_Handler | [virtual] |
read() | OpenDDS::DCPS::ShmemDataLink | [inline] |
read_adapter(void *event_handler) | ACE_Event_Handler | [static] |
READ_MASK | ACE_Event_Handler | |
receive_strategy_ | OpenDDS::DCPS::DataLink | [protected] |
RECONNECTED enum value | OpenDDS::DCPS::DataLink | |
recv_strategy_ | OpenDDS::DCPS::ShmemDataLink | [protected] |
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_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_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_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_MASK | ACE_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 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 | |
WRITE_MASK | ACE_Event_Handler | |
~ACE_Event_Handler(void) | ACE_Event_Handler | [virtual] |
~DataLink() | OpenDDS::DCPS::DataLink | [virtual] |
~RcObject() | OpenDDS::DCPS::RcObject | [inline, virtual] |