// Copyright 2018 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 <fs/synchronous-vfs.h>

#include <fbl/unique_ptr.h>
#include <lib/async/cpp/task.h>
#include <lib/sync/completion.h>

#include <utility>

namespace fs {

SynchronousVfs::SynchronousVfs() : is_shutting_down_(false) {}

SynchronousVfs::SynchronousVfs(async_dispatcher_t* dispatcher) : Vfs(dispatcher),
    is_shutting_down_(false) {}

SynchronousVfs::~SynchronousVfs() {
    Shutdown(nullptr);
    ZX_DEBUG_ASSERT(connections_.is_empty());
}

// Synchronously drop all connections.
void SynchronousVfs::Shutdown(ShutdownCallback handler) {
    is_shutting_down_ = true;

    UninstallAll(ZX_TIME_INFINITE);
    while (!connections_.is_empty()) {
        connections_.front().SyncTeardown();
    }
    ZX_ASSERT_MSG(connections_.is_empty(), "Failed to complete VFS shutdown");
    if (handler) {
        handler(ZX_OK);
    }
}

void SynchronousVfs::RegisterConnection(fbl::unique_ptr<Connection> connection) {
    ZX_DEBUG_ASSERT(!is_shutting_down_);
    connections_.push_back(std::move(connection));
}

void SynchronousVfs::UnregisterConnection(Connection* connection) {
    // We drop the result of |erase| on the floor, effectively destroying the
    // connection.
    connections_.erase(*connection);
}

bool SynchronousVfs::IsTerminating() const {
    return is_shutting_down_;
}

} // namespace fs