Holds a data sample received by the transport. More...
#include <ReceivedDataSample.h>
Public Member Functions | |
ReceivedDataSample (ACE_Message_Block *payload) | |
ReceivedDataSample (const ReceivedDataSample &) | |
ReceivedDataSample & | operator= (const ReceivedDataSample &) |
~ReceivedDataSample () | |
Public Attributes | |
DataSampleHeader | header_ |
The demarshalled sample header. | |
Message_Block_Ptr | sample_ |
The "data" part (ie, no "header" part) of the sample. |
Holds a data sample received by the transport.
This is the type of object that is delivered to the TransportReceiveListener objects by the transport. Note that the data sample header has already been demarshalled by the transport, and the ACE_Message_Block (chain) represents the "data" portion of the sample.
Definition at line 33 of file ReceivedDataSample.h.
ACE_INLINE OpenDDS::DCPS::ReceivedDataSample::ReceivedDataSample | ( | ACE_Message_Block * | payload | ) | [explicit] |
Definition at line 17 of file ReceivedDataSample.inl.
References DBG_ENTRY_LVL.
00018 : sample_(payload) 00019 { 00020 DBG_ENTRY_LVL("ReceivedDataSample", "ReceivedDataSample",6); 00021 }
ACE_INLINE OpenDDS::DCPS::ReceivedDataSample::ReceivedDataSample | ( | const ReceivedDataSample & | other | ) |
Definition at line 24 of file ReceivedDataSample.inl.
References DBG_ENTRY_LVL.
00025 : header_(other.header_) 00026 , sample_(ACE_Message_Block::duplicate(other.sample_.get())) 00027 { 00028 DBG_ENTRY_LVL("ReceivedDataSample", "ReceivedDataSample(copy)", 6); 00029 }
ACE_INLINE OpenDDS::DCPS::ReceivedDataSample::~ReceivedDataSample | ( | ) |
Definition at line 41 of file ReceivedDataSample.inl.
References DBG_ENTRY_LVL.
00042 { 00043 DBG_ENTRY_LVL("ReceivedDataSample", "~ReceivedDataSample", 6); 00044 }
ACE_INLINE ReceivedDataSample & OpenDDS::DCPS::ReceivedDataSample::operator= | ( | const ReceivedDataSample & | other | ) |
Definition at line 32 of file ReceivedDataSample.inl.
References DBG_ENTRY_LVL, and OpenDDS::DCPS::swap().
00033 { 00034 DBG_ENTRY_LVL("ReceivedDataSample", "operator=", 6); 00035 ReceivedDataSample cpy(other); 00036 swap(*this, cpy); 00037 return *this; 00038 }
The demarshalled sample header.
Definition at line 44 of file ReceivedDataSample.h.
Referenced by OpenDDS::DCPS::TcpDataLink::ack_received(), OpenDDS::DCPS::DataReaderImpl::check_historic(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::DCPS::RecorderImpl::data_received(), OpenDDS::DCPS::DataReaderImpl::data_received(), OpenDDS::DCPS::DataLink::data_received_i(), OpenDDS::DCPS::TransportReassembly::data_unavailable(), OpenDDS::DCPS::DataReaderImpl_T< MessageType >::dds_demarshal(), OpenDDS::RTPS::decode_parameter_list(), OpenDDS::DCPS::DataReaderImpl::deliver_historic(), OpenDDS::DCPS::UdpReceiveStrategy::deliver_sample(), OpenDDS::DCPS::TcpReceiveStrategy::deliver_sample(), OpenDDS::DCPS::ShmemReceiveStrategy::deliver_sample(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::deliver_sample_i(), OpenDDS::DCPS::DataReaderImpl_T< MessageType >::dispose_unregister(), OpenDDS::DCPS::TransportReassembly::insert(), OpenDDS::DCPS::RtpsSampleHeader::into_received_data_sample(), OpenDDS::DCPS::DataSampleHeader::into_received_data_sample(), OpenDDS::DCPS::DataReaderImpl_T< MessageType >::lookup_instance(), OpenDDS::DCPS::DataReaderImpl::process_latency(), OpenDDS::DCPS::ReliableSession::ready_to_deliver(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::reassemble(), OpenDDS::DCPS::TransportReassembly::reassemble_i(), OpenDDS::DCPS::TcpDataLink::request_ack_received(), OpenDDS::DCPS::MulticastDataLink::sample_received(), and OpenDDS::DCPS::swap().
The "data" part (ie, no "header" part) of the sample.
Definition at line 47 of file ReceivedDataSample.h.
Referenced by OpenDDS::DCPS::UdpDataLink::control_received(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::DCPS::RecorderImpl::data_received(), OpenDDS::DCPS::ReceiveListenerSet::data_received(), OpenDDS::DCPS::DataReaderImpl::data_received(), OpenDDS::DCPS::DataReaderImpl_T< MessageType >::dds_demarshal(), OpenDDS::DCPS::TransportReassembly::insert(), OpenDDS::DCPS::RtpsSampleHeader::into_received_data_sample(), OpenDDS::DCPS::DataReaderImpl_T< MessageType >::lookup_instance(), OpenDDS::DCPS::RtpsSampleHeader::payload_byte_order(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::reassemble(), OpenDDS::DCPS::TransportReassembly::reassemble_i(), OpenDDS::DCPS::MulticastDataLink::sample_received(), and OpenDDS::DCPS::swap().