Method Append

src/leveldb/persistent_cache/persistent_cache_file.cc:88–110

}

Status WriteableCacheFile::Append(const Slice& val) {
  uint64_t i = 0;

  Status s;
  while (!(s = cache_->MakeRoomForWrite(val.size())).ok()) {
    Env::Default()->SleepForMicroseconds(kRetryIntervalUs);
    if (i++ >= write_retry_times_) {
      cache_->GetStats()->cache_errors.Inc();
      return s;
    }
  }

  s = file_->Append(val);
  cache_->GetStats()->write_count.Inc();

  if (s.ok()) {
    cache_->GetStats()->write_throughput.Add(val.size());
  } else {
    cache_->GetStats()->cache_errors.Inc();
  }

  return s;
}

void WriteableCacheFile::Close(const Slice& key) {
  file_.reset();