Method add_reader_acks

dds/DCPS/WriteDataContainer.cpp:175–188

}

void
WriteDataContainer::add_reader_acks(const GUID_t& reader, const SequenceNumber& base)
{
  ACE_Guard<ACE_Thread_Mutex> guard(wfa_lock_);

  DisjointSequence& ds = acked_sequences_[reader];
  ds.reset();
  if (base == SequenceNumber::SEQUENCENUMBER_UNKNOWN()) {
    ds.insert(SequenceNumber::ZERO());
  } else {
    ds.insert(SequenceRange(SequenceNumber(), base));
  }
  cached_cumulative_ack_valid_ = false;
}

void
WriteDataContainer::remove_reader_acks(const GUID_t& reader)