src/storage/bin/start-storage-benchmark/memfs.cc

// Copyright 2022 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "src/storage/bin/start-storage-benchmark/memfs.h"

#include <fidl/fuchsia.io/cpp/wire.h>
#include <lib/async-loop/cpp/loop.h>
#include <lib/async-loop/loop.h>
#include <lib/fdio/directory.h>
#include <lib/fidl/llcpp/channel.h>
#include <lib/zx/status.h>

#include <memory>

#include "src/storage/memfs/scoped_memfs.h"

namespace storage_benchmark {

zx::status<std::unique_ptr<Memfs>> Memfs::Create() {
  auto loop = std::make_unique<async::Loop>(&kAsyncLoopConfigNeverAttachToThread);
  if (zx_status_t status = loop->StartThread(); status != ZX_OK) {
    return zx::error(status);
  }
  auto setup = ScopedMemfs::Create(loop->dispatcher());
  if (setup.is_error()) {
    return setup.take_error();
  }
  return zx::ok(std::unique_ptr<Memfs>(new Memfs(std::move(loop), std::move(*setup))));
}

zx::status<fidl::ClientEnd<fuchsia_io::Directory>> Memfs::GetFilesystemRoot() const {
  auto endpoints = fidl::CreateEndpoints<fuchsia_io::Directory>();
  if (endpoints.is_error()) {
    return endpoints.take_error();
  }
  if (zx_status_t status =
          fdio_service_clone_to(memfs_.root().get(), endpoints->server.TakeChannel().release());
      status != ZX_OK) {
    return zx::error(status);
  }
  return zx::ok(std::move(endpoints->client));
}

}  // namespace storage_benchmark