blob: 4f89eeeece4e4429d219dbe146fd5ff04703e9de [file] [log] [blame]
// Copyright 2019 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 <lib/async-loop/cpp/loop.h>
#include <lib/async-loop/default.h>
#include <lib/vfs/cpp/pseudo_dir.h>
#include <condition_variable>
#include <mutex>
#include <thread>
#include <fbl/unique_fd.h>
#include "src/lib/fsl/io/fd.h"
namespace modular {
// Given a pseudo directory, spins up a thread and serves Directory operations
// over it. This utility is useful for making thread-blocking posix calls to the
// given PseudoDir, which needs its owning thread to not be blocked to service
// directory calls.
// The directory is accessible using |OpenAt()|.
// This class is thread-unsafe.
class PseudoDirServer final {
// Serves |pseudo_dir| on an async loop on a new thread. All requests to |pseudo_dir|
// are processed on the new thread.
PseudoDirServer(std::unique_ptr<vfs::PseudoDir> pseudo_dir);
// Stops |loop_| and blocks the current thread until the |loop_| thread is finished.
// Opens a read-only FD at |path|. |path| must not lead with a '/'.
fbl::unique_fd OpenAt(std::string path);
// Returns a new directory connection to |pseudo_dir_|.
fuchsia::io::DirectoryPtr Serve();
// Binds |request| to |pseudo_dir_|.
void Serve(zx::channel request);
// This loop is configured to attach to its own thread.
async::Loop loop_;
std::unique_ptr<vfs::PseudoDir> pseudo_dir_;
// A directory connection, bound to |pseudo_dir_|, used by |OpenAt()|.
fuchsia::io::DirectoryPtr dir_ptr_;
} // namespace modular