OpenDDS  Snapshot(2023/04/28-20:55)
OpenDDS::DCPS::RtpsUdpReceiveStrategy Member List

This is the complete list of members for OpenDDS::DCPS::RtpsUdpReceiveStrategy, 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_reference()OpenDDS::DCPS::RcEventHandlerinlinevirtual
ALL_EVENTS_MASKACE_Event_Handler
Atomic_Reference_Count typedefACE_Event_Handlerprotected
BaseReceiveStrategy typedefOpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
begin_transport_header_processing()OpenDDS::DCPS::RtpsUdpReceiveStrategyvirtual
BUFFER_COUNTOpenDDS::DCPS::RtpsUdpReceiveStrategystatic
buffer_index_OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >protected
BUFFER_LOW_WATEROpenDDS::DCPS::TransportReceiveConstantsstatic
check_encoded(const EntityId_t &sender)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
check_header(const RtpsTransportHeader &header)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivatevirtual
check_header(const RtpsSampleHeader &header)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivatevirtual
choose_recv_socket(ACE_HANDLE fd) constOpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
clear_completed_fragments(const GUID_t &pub_id)OpenDDS::DCPS::RtpsUdpReceiveStrategy
CONNECT_MASKACE_Event_Handler
data_allocator_OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >protected
DATA_BLOCKSOpenDDS::DCPS::TransportReceiveConstantsstatic
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::RtpsUdpReceiveStrategyprivate
deliver_from_secure(const RTPS::Submessage &submessage, const NetworkAddress &remote_addr)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
deliver_sample(ReceivedDataSample &sample, const ACE_INET_Addr &remote_address)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivatevirtual
deliver_sample_i(ReceivedDataSample &sample, const RTPS::Submessage &submessage, const NetworkAddress &remote_addr)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
do_not_withhold_data_from(const GUID_t &sub_id)OpenDDS::DCPS::RtpsUdpReceiveStrategy
DONT_CALLACE_Event_Handler
encoded_rtps_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
encoded_submsg_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
end_transport_header_processing()OpenDDS::DCPS::RtpsUdpReceiveStrategyvirtual
EXCEPT_MASKACE_Event_Handler
finish_message()OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >inlineprotectedvirtual
fragment_size_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
frags_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
get_handle(void) constACE_Event_Handlervirtual
getDirectedWriteReaders(RepoIdSet &directedWriteReaders, const RTPS::DataSubmessage &ds) constOpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
good_pdu_OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >protected
gracefully_disconnected_OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >protected
GROUP_QOS_MASKACE_Event_Handler
handle_close(ACE_HANDLE handle, ACE_Reactor_Mask close_mask)ACE_Event_Handlervirtual
handle_dds_input(ACE_HANDLE fd)OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >
handle_exception(ACE_HANDLE fd=ACE_INVALID_HANDLE)ACE_Event_Handlervirtual
handle_exit(ACE_Process *)ACE_Event_Handlervirtual
handle_group_qos(ACE_HANDLE=ACE_INVALID_HANDLE)ACE_Event_Handlervirtual
handle_input(ACE_HANDLE fd)OpenDDS::DCPS::RtpsUdpReceiveStrategyvirtual
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 &current_time, const void *act=0)ACE_Event_Handlervirtual
has_fragments(const SequenceRange &range, const GUID_t &pub_id, FragmentInfo *frag_info=0)OpenDDS::DCPS::RtpsUdpReceiveStrategy
HI_PRIORITYACE_Event_Handler
last_received_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
link_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
LO_PRIORITYACE_Event_Handler
mb_allocator_OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >protected
message_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
MESSAGE_BLOCKSOpenDDS::DCPS::TransportReceiveConstantsstatic
NULL_MASKACE_Event_Handler
OPENDDS_VECTOR(SeqFragPair) FragmentInfoOpenDDS::DCPS::RtpsUdpReceiveStrategy
OPENDDS_VECTOR(RTPS::Submessage) secure_submessages_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
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() constOpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >inlineprotected
pdu_remaining_OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >protected
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_timer_interface(void) constACE_Event_Handlervirtual
read_adapter(void *event_handler)ACE_Event_Handlerstatic
READ_MASKACE_Event_Handler
readers_selected_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
readers_withheld_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
reassemble(ReceivedDataSample &data)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivatevirtual
reassemble_i(ReceivedDataSample &data, RtpsSampleHeader &rsh)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivatevirtual
reassembly_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
RECEIVE_BUFFERSOpenDDS::DCPS::TransportReceiveConstantsstatic
receive_bytes(iovec iov[], int n, ACE_INET_Addr &remote_address, ACE_HANDLE fd, bool &stop)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivatevirtual
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::RtpsUdpReceiveStrategystatic
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() constOpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >
received_header()OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >
received_sample_header() constOpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >
received_sample_header()OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >
receiver_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
recvd_sample_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
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
relink(bool do_suspend=true)OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >virtual
remote_address_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
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::RcEventHandlerinlinevirtual
remove_stdin_handler(ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr)ACE_Event_Handlerstatic
reset()OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >protected
resume_handler(void)ACE_Event_Handlervirtual
RtpsUdpReceiveStrategy(RtpsUdpDataLink *link, const GuidPrefix_t &local_prefix, ThreadStatusManager &thread_status_manager)OpenDDS::DCPS::RtpsUdpReceiveStrategy
RWE_MASKACE_Event_Handler
sec_submsg_to_octets(DDS::OctetSeq &encoded, const RTPS::Submessage &postfix)OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
secure_prefix_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
secure_sample_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
SeqFragPair typedefOpenDDS::DCPS::RtpsUdpReceiveStrategy
set_handle(ACE_HANDLE)ACE_Event_Handlervirtual
SIGNAL_MASKACE_Event_Handler
skip_bad_pdus()OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >protected
start()OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >virtual
start_i()OpenDDS::DCPS::RtpsUdpReceiveStrategyprivatevirtual
stop()OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >virtual
stop_i()OpenDDS::DCPS::RtpsUdpReceiveStrategyprivatevirtual
successor_index(size_t index) constOpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >protected
thread_status_manager_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
TIMER_MASKACE_Event_Handler
to_msgblock(const ReceivedDataSample &sample)OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >
total_frags_OpenDDS::DCPS::RtpsUdpReceiveStrategyprivate
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_MASKACE_Event_Handler
~ACE_Event_Handler(void)ACE_Event_Handlervirtual
~RcObject()OpenDDS::DCPS::RcObjectinlinevirtual
~TransportReceiveStrategy()OpenDDS::DCPS::TransportReceiveStrategy< RtpsTransportHeader, RtpsSampleHeader >virtual
~TransportStrategy()OpenDDS::DCPS::TransportStrategyvirtual