system/ulib/async-loop/loop_wrapper.cpp

// Copyright 2017 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 <zircon/assert.h>

namespace async {

Loop::Loop(const async_loop_config_t* config) {
    zx_status_t status = async_loop_create(config, &loop_);
    ZX_ASSERT_MSG(status == ZX_OK, "status=%d", status);
}

Loop::~Loop() {
    async_loop_destroy(loop_);
}

void Loop::Shutdown() {
    async_loop_shutdown(loop_);
}

zx_status_t Loop::Run(zx::time deadline, bool once) {
    return async_loop_run(loop_, deadline.get(), once);
}

zx_status_t Loop::RunUntilIdle() {
    return async_loop_run_until_idle(loop_);
}

void Loop::Quit() {
    async_loop_quit(loop_);
}

zx_status_t Loop::ResetQuit() {
    return async_loop_reset_quit(loop_);
}

async_loop_state_t Loop::GetState() const {
    return async_loop_get_state(loop_);
}

zx_status_t Loop::StartThread(const char* name, thrd_t* out_thread) {
    return async_loop_start_thread(loop_, name, out_thread);
}

void Loop::JoinThreads() {
    async_loop_join_threads(loop_);
}

} // namespace async