_add_ref() | OpenDDS::DCPS::RcObject | inlinevirtual |
_get_weak_object() const | OpenDDS::DCPS::RcObject | inline |
_remove_ref() | OpenDDS::DCPS::RcObject | inlinevirtual |
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_reference() | OpenDDS::DCPS::RcEventHandler | inlinevirtual |
ALL_EVENTS_MASK | ACE_Event_Handler | |
Atomic_Reference_Count typedef | ACE_Event_Handler | protected |
BaseReceiveStrategy typedef | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
begin_transport_header_processing() | OpenDDS::DCPS::RtpsUdpReceiveStrategy | virtual |
BUFFER_COUNT | OpenDDS::DCPS::RtpsUdpReceiveStrategy | static |
buffer_index_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
BUFFER_LOW_WATER | OpenDDS::DCPS::TransportReceiveConstants | static |
check_encoded(const EntityId_t &sender) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
check_header(const RtpsTransportHeader &header) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | privatevirtual |
check_header(const RtpsSampleHeader &header) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | privatevirtual |
choose_recv_socket(ACE_HANDLE fd) const | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
clear_completed_fragments(const GUID_t &pub_id) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | |
CONNECT_MASK | ACE_Event_Handler | |
data_allocator_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
DATA_BLOCKS | OpenDDS::DCPS::TransportReceiveConstants | static |
data_sample_header_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
db_allocator_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
decode_payload(ReceivedDataSample &sample, const RTPS::DataSubmessage &submessage) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
deliver_from_secure(const RTPS::Submessage &submessage, const NetworkAddress &remote_addr) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
deliver_sample(ReceivedDataSample &sample, const ACE_INET_Addr &remote_address) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | privatevirtual |
deliver_sample_i(ReceivedDataSample &sample, const RTPS::Submessage &submessage, const NetworkAddress &remote_addr) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
do_not_withhold_data_from(const GUID_t &sub_id) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | |
DONT_CALL | ACE_Event_Handler | |
encoded_rtps_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
encoded_submsg_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
end_transport_header_processing() | OpenDDS::DCPS::RtpsUdpReceiveStrategy | virtual |
EXCEPT_MASK | ACE_Event_Handler | |
finish_message() | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | inlineprotectedvirtual |
fragment_size_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
frags_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
get_handle(void) const | ACE_Event_Handler | virtual |
getDirectedWriteReaders(RepoIdSet &directedWriteReaders, const RTPS::DataSubmessage &ds) const | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
good_pdu_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
gracefully_disconnected_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
GROUP_QOS_MASK | ACE_Event_Handler | |
handle_close(ACE_HANDLE handle, ACE_Reactor_Mask close_mask) | ACE_Event_Handler | virtual |
handle_dds_input(ACE_HANDLE fd) | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | |
handle_exception(ACE_HANDLE fd=ACE_INVALID_HANDLE) | ACE_Event_Handler | 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) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | 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 ¤t_time, const void *act=0) | ACE_Event_Handler | virtual |
has_fragments(const SequenceRange &range, const GUID_t &pub_id, FragmentInfo *frag_info=0) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | |
HI_PRIORITY | ACE_Event_Handler | |
last_received_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
link_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
LO_PRIORITY | ACE_Event_Handler | |
mb_allocator_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
message_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
MESSAGE_BLOCKS | OpenDDS::DCPS::TransportReceiveConstants | static |
NULL_MASK | ACE_Event_Handler | |
OPENDDS_VECTOR(SeqFragPair) FragmentInfo | OpenDDS::DCPS::RtpsUdpReceiveStrategy | |
OPENDDS_VECTOR(RTPS::Submessage) secure_submessages_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >::OPENDDS_VECTOR(ACE_Message_Block *) receive_buffers_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
payload_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
pdu_remaining() const | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | inlineprotected |
pdu_remaining_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
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 | inlineprotected |
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_adapter(void *event_handler) | ACE_Event_Handler | static |
READ_MASK | ACE_Event_Handler | |
readers_selected_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
readers_withheld_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
reassemble(ReceivedDataSample &data) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | privatevirtual |
reassemble_i(ReceivedDataSample &data, RtpsSampleHeader &rsh) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | privatevirtual |
reassembly_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
RECEIVE_BUFFERS | OpenDDS::DCPS::TransportReceiveConstants | static |
receive_bytes(iovec iov[], int n, ACE_INET_Addr &remote_address, ACE_HANDLE fd, bool &stop) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | privatevirtual |
receive_bytes_helper(iovec iov[], int n, const ACE_SOCK_Dgram &socket, ACE_INET_Addr &remote_address, DCPS::RcHandle< ICE::Agent > agent, DCPS::WeakRcHandle< ICE::Endpoint > endpoint, RtpsUdpTransport &tport, bool &stop) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | static |
receive_lock_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
receive_sample_remaining_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
receive_transport_header_ | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
received_header() const | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | |
received_header() | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | |
received_sample_header() const | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | |
received_sample_header() | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | |
receiver_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
recvd_sample_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
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 |
relink(bool do_suspend=true) | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | virtual |
remote_address_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
remove_fragments(const SequenceRange &range, const GUID_t &pub_id) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | |
remove_frags_from_bitmap(CORBA::Long bitmap[], CORBA::ULong num_bits, const SequenceNumber &base, const GUID_t &pub_id, ACE_CDR::ULong &samples_requested) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | |
remove_reference() | OpenDDS::DCPS::RcEventHandler | inlinevirtual |
remove_stdin_handler(ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr) | ACE_Event_Handler | static |
reset() | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
resume_handler(void) | ACE_Event_Handler | virtual |
RtpsUdpReceiveStrategy(RtpsUdpDataLink *link, const GuidPrefix_t &local_prefix, ThreadStatusManager &thread_status_manager) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | |
RWE_MASK | ACE_Event_Handler | |
sec_submsg_to_octets(DDS::OctetSeq &encoded, const RTPS::Submessage &postfix) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
secure_prefix_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
secure_sample_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
SeqFragPair typedef | OpenDDS::DCPS::RtpsUdpReceiveStrategy | |
set_handle(ACE_HANDLE) | ACE_Event_Handler | virtual |
SIGNAL_MASK | ACE_Event_Handler | |
skip_bad_pdus() | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
start() | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | virtual |
start_i() | OpenDDS::DCPS::RtpsUdpReceiveStrategy | privatevirtual |
stop() | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | virtual |
stop_i() | OpenDDS::DCPS::RtpsUdpReceiveStrategy | privatevirtual |
successor_index(size_t index) const | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
thread_status_manager_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
TIMER_MASK | ACE_Event_Handler | |
to_msgblock(const ReceivedDataSample &sample) | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | |
total_frags_ | OpenDDS::DCPS::RtpsUdpReceiveStrategy | private |
TransportReceiveStrategy(const TransportInst_rch &config, size_t receive_buffers_count=RECEIVE_BUFFERS) | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | explicitprotected |
update_buffer_index(bool &done) | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | protected |
withhold_data_from(const GUID_t &sub_id) | OpenDDS::DCPS::RtpsUdpReceiveStrategy | |
WRITE_MASK | ACE_Event_Handler | |
~ACE_Event_Handler(void) | ACE_Event_Handler | virtual |
~RcObject() | OpenDDS::DCPS::RcObject | inlinevirtual |
~TransportReceiveStrategy() | OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader > | virtual |
~TransportStrategy() | OpenDDS::DCPS::TransportStrategy | virtual |