MCPcopy Create free account
hub / github.com/OpenDDS/OpenDDS / decrement_read_count

Method decrement_read_count

dds/DCPS/ReceivedDataElementList.cpp:277–288  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

275}
276
277void 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
290void OpenDDS::DCPS::ReceivedDataElementList::increment_not_read_count()
291{

Callers

nothing calls this directly

Calls 2

lockMethod · 0.45
state_updatedMethod · 0.45

Tested by

no test coverage detected