| 275 | } |
| 276 | |
| 277 | void OpenDDS::DCPS::ReceivedDataElementList::decrement_read_count() |
| 278 | { |
| 279 | OPENDDS_ASSERT(read_sample_count_); |
| 280 | --read_sample_count_; |
| 281 | if (!read_sample_count_) { |
| 282 | sample_states_ &= (~DDS::READ_SAMPLE_STATE); |
| 283 | DataReaderImpl_rch reader(reader_.lock()); |
| 284 | if (reader) { |
| 285 | reader->state_updated(instance_state_->instance_handle()); |
| 286 | } |
| 287 | } |
| 288 | } |
| 289 | |
| 290 | void OpenDDS::DCPS::ReceivedDataElementList::increment_not_read_count() |
| 291 | { |
nothing calls this directly
no test coverage detected