| 935 | } |
| 936 | |
| 937 | DDS::ReturnCode_t |
| 938 | DataReaderImpl::get_sample_rejected_status( |
| 939 | DDS::SampleRejectedStatus & status) |
| 940 | { |
| 941 | ACE_Guard<ACE_Recursive_Thread_Mutex> justMe(this->sample_lock_); |
| 942 | |
| 943 | set_status_changed_flag(DDS::SAMPLE_REJECTED_STATUS, false); |
| 944 | status = sample_rejected_status_; |
| 945 | sample_rejected_status_.total_count_change = 0; |
| 946 | return DDS::RETCODE_OK; |
| 947 | } |
| 948 | |
| 949 | DDS::ReturnCode_t |
| 950 | DataReaderImpl::get_liveliness_changed_status( |