Method run

src/client/cli/admin/ScanTree.cc:60–80

        path_(path) {}

  CoTryTask<std::vector<BrokenPath>> run(size_t threads, size_t coroutines) {
    auto result = co_await meta_.stat(user_, path_.parent, path_.path, false);
    CO_RETURN_AND_LOG_ON_ERROR(result);
    enqueue({"", {}, *result});

    auto exec = std::make_unique<folly::CPUThreadPoolExecutor>(threads);
    std::vector<folly::SemiFuture<folly::Unit>> workers;
    while (workers.size() < coroutines) {
      workers.push_back(worker().scheduleOn(exec.get()).start());
    }

    while (pending_) {
      co_await folly::coro::sleep(std::chrono::milliseconds(100));
    }
    cancel_.requestCancellation();
    for (auto &worker : workers) {
      worker.wait();
    }

    co_return broken_.withWLock([](auto &broken) { return std::exchange(broken, {}); });
  }

 private:
  struct Task {