| 1015 | } |
| 1016 | |
| 1017 | DDS::ReturnCode_t |
| 1018 | DataReaderImpl::get_sample_lost_status( |
| 1019 | DDS::SampleLostStatus & status) |
| 1020 | { |
| 1021 | ACE_Guard<ACE_Recursive_Thread_Mutex> justMe(this->sample_lock_); |
| 1022 | |
| 1023 | set_status_changed_flag(DDS::SAMPLE_LOST_STATUS, false); |
| 1024 | status = sample_lost_status_; |
| 1025 | sample_lost_status_.total_count_change = 0; |
| 1026 | return DDS::RETCODE_OK; |
| 1027 | } |
| 1028 | |
| 1029 | DDS::ReturnCode_t |
| 1030 | DataReaderImpl::wait_for_historical_data( |