Method copyFiles

bolt/tool/trace/TraceFileToolRunner.cpp:91–117

    BOLT_UNSUPPORTED(
        "Unsupported trace file operation type {}",
        FLAGS_bolt_trace_file_operation);
  }
}

void TraceFileToolRunner::copyFiles() const {
  const auto prefixLen = sourceFs_->extractPath(sourceRootDir_).length();
  for (const auto& source : sourceFiles_) {
    const auto targetFile =
        fmt::format("{}/{}", destRootDir_, source.substr(prefixLen));
    const auto readFile = sourceFs_->openFileForRead(source);
    const auto writeFile = destFs_->openFileForWrite(
        targetFile,
        filesystems::FileOptions{
            .values = {}, .shouldCreateParentDirectories = true});
    const auto fileSize = readFile->size();
    constexpr auto batchSize = 4 << 10;
    const auto ioBuf = folly::IOBuf::create(batchSize);
    uint64_t offset = 0;
    while (offset < fileSize) {
      const auto curLen = std::min<uint64_t>(fileSize - offset, batchSize);
      const auto dataView =
          readFile->pread(offset, curLen, ioBuf->writableData());
      writeFile->append(dataView);
      ioBuf->append(curLen);
      offset += curLen;
      ioBuf->clear();
    }
    writeFile->flush();
    writeFile->close();
  }