| // 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 "event.h" |
| |
| #include <lib/stdcompat/atomic.h> |
| |
| zx_status_t Event::Wait(zx::duration timeout) { |
| zx::time deadline = |
| (timeout == zx::duration::infinite()) ? zx::time::infinite() : zx::deadline_after(timeout); |
| |
| while (cpp20::atomic_ref<zx_futex_t>(signaled_).load(std::memory_order_relaxed) == 0) { |
| zx_status_t res = zx_futex_wait(&signaled_, 0, ZX_HANDLE_INVALID, deadline.get()); |
| if ((res != ZX_OK) && (res != ZX_ERR_BAD_STATE)) { |
| return res; |
| } |
| } |
| |
| return ZX_OK; |
| } |
| |
| void Event::Signal() { |
| cpp20::atomic_ref<zx_futex_t> signal_ref(signaled_); |
| if (signal_ref.load(std::memory_order_relaxed) == 0) { |
| signal_ref.store(1, std::memory_order_relaxed); |
| zx_futex_wake(&signaled_, UINT32_MAX); |
| } |
| } |
| |
| void Event::Reset() { |
| cpp20::atomic_ref<zx_futex_t>(signaled_).store(0, std::memory_order_relaxed); |
| } |