Method remove_reader_acks

dds/DCPS/WriteDataContainer.cpp:190–204

}

void
WriteDataContainer::remove_reader_acks(const GUID_t& reader)
{
  ACE_Guard<ACE_Thread_Mutex> guard(wfa_lock_);

  const SequenceNumber prev_cum_ack = get_cumulative_ack();
  const AckedSequenceMap::iterator it = acked_sequences_.find(reader);
  if (it != acked_sequences_.end()) {
    acked_sequences_.erase(it);
    cached_cumulative_ack_valid_ = false;
    if (prev_cum_ack != get_cumulative_ack()) {
      wfa_condition_.notify_all();
    }
  }
}

SequenceNumber
WriteDataContainer::get_cumulative_ack()