OpenDDS: DataReaderImpl.inl Source File

00001 /*
00002  *
00003  *
00004  * Distributed under the OpenDDS License.
00005  * See: http://www.opendds.org/license.html
00006  */
00007 
00008 ACE_INLINE
00009 DDS::DataReader_ptr
00010 OpenDDS::DCPS::DataReaderImpl::get_dr_obj_ref()
00011 {
00012   return DDS::DataReader::_duplicate(dr_local_objref_.in()) ;
00013 }
00014 
00015 
00016 
00017 ACE_INLINE
00018 const OpenDDS::DCPS::DataReaderImpl::StatsMapType&
00019 OpenDDS::DCPS::DataReaderImpl::raw_latency_statistics() const
00020 {
00021   return this->statistics_;
00022 }
00023 
00024 ACE_INLINE
00025 unsigned int&
00026 OpenDDS::DCPS::DataReaderImpl::raw_latency_buffer_size()
00027 {
00028   return this->raw_latency_buffer_size_;
00029 }
00030 
00031 ACE_INLINE
00032 OpenDDS::DCPS::DataCollector<double>::OnFull&
00033 OpenDDS::DCPS::DataReaderImpl::raw_latency_buffer_type()
00034 {
00035   return this->raw_latency_buffer_type_;
00036 }
00037 
00038 ACE_INLINE
00039 void
00040 OpenDDS::DCPS::DataReaderImpl::disable_transport()
00041 {
00042   this->transport_disabled_ = true;
00043 }