Method DumpCacheFiles

be/src/runtime/io/data-cache.cc:1114–1131

}

Status DataCache::Partition::DumpCacheFiles(DumpData& dump_data) {
  lock_.DCheckLocked();
  int64_t index = 0;
  for (const auto& file : cache_files_) {
    // There is no need to dump closed file, it can no longer be read or written or even
    // deleted.
    if (file->closed()) continue;

    // Just to be safe, flush the file.
    RETURN_IF_ERROR(file->Flush());

    dump_data.cache_files_data.emplace_back(file->path(), file->allow_append(),
        file->current_offset(), file->mtime());
    auto result = dump_data.file_indexs.emplace(file.get(), index++);
    DCHECK(result.second);
  }
  return Status::OK();
}

Status DataCache::Partition::LoadCacheFiles(const DumpData& dump_data) {
  lock_.DCheckLocked();