// Copyright 2016 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 <sync/completion.h>

#include <limits.h>
#include <magenta/syscalls.h>
#include <stdatomic.h>

enum {
    UNSIGNALED = 0,
    SIGNALED = 1,
};

mx_status_t completion_wait(completion_t* completion, mx_time_t timeout) {
    // TODO(kulakowski): With a little more state (a waiters count),
    // this could optimistically spin before entering the kernel.

    atomic_int* futex = &completion->futex;

    for (;;) {
        int current_value = atomic_load(futex);
        if (current_value == SIGNALED) {
            return MX_OK;
        }
        mx_time_t deadline = (timeout == MX_TIME_INFINITE) ? timeout : mx_deadline_after(timeout);
        switch (mx_futex_wait(futex, current_value, deadline)) {
        case MX_OK:
            continue;
        case MX_ERR_BAD_STATE:
            // If we get MX_ERR_BAD_STATE, the value of the futex changed between
            // our load and the wait. This could only have happened if we
            // were signaled.
            return MX_OK;
        case MX_ERR_TIMED_OUT:
            return MX_ERR_TIMED_OUT;
        case MX_ERR_INVALID_ARGS:
        default:
            __builtin_trap();
        }
    }
}

void completion_signal(completion_t* completion) {
    atomic_int* futex = &completion->futex;
    atomic_store(futex, SIGNALED);
    mx_futex_wake(futex, UINT32_MAX);
}

void completion_reset(completion_t* completion) {
    atomic_store(&completion->futex, UNSIGNALED);
}