Method wait

kernel/cellos/src/sys_rsxaudio.cpp:1997–2097

}

rsxaudio_periodic_tmr::wait_result
rsxaudio_periodic_tmr::wait(const std::function<void()> &callback) {
  std::unique_lock lock(mutex);

  if (in_wait || !callback) {
    return wait_result::INVALID_PARAM;
  }

  in_wait = true;

  bool tmr_error = false;
  bool timeout = false;
  bool wait_canceled = false;

  if (!zero_period) {
    lock.unlock();
    constexpr u8 obj_wait_cnt = 2;

#if defined(_WIN32)
    const HANDLE wait_arr[obj_wait_cnt] = {timer_handle, cancel_event};
    const auto wait_status =
        WaitForMultipleObjects(obj_wait_cnt, wait_arr, false, INFINITE);

    if (wait_status == WAIT_FAILED ||
        (wait_status >= WAIT_ABANDONED_0 &&
         wait_status < WAIT_ABANDONED_0 + obj_wait_cnt)) {
      tmr_error = true;
    } else if (wait_status == WAIT_TIMEOUT) {
      timeout = true;
    } else if (wait_status == WAIT_OBJECT_0 + 1) {
      wait_canceled = true;
    }
#elif defined(__linux__)
    epoll_event event[obj_wait_cnt]{};
    int wait_status = 0;
    do {
      wait_status = epoll_wait(epoll_fd, event, obj_wait_cnt, -1);
    } while (wait_status == -1 && errno == EINTR);

    if (wait_status < 0 || wait_status > obj_wait_cnt) {
      tmr_error = true;
    } else if (wait_status == 0) {
      timeout = true;
    } else {
      for (int i = 0; i < wait_status; i++) {
        if (event[i].data.fd == cancel_event) {
          wait_canceled = true;
          break;
        }
      }
    }
#elif defined(BSD) || defined(__APPLE__)
    struct kevent event[obj_wait_cnt]{};
    int wait_status = 0;
    do {
      wait_status = kevent(kq, nullptr, 0, event, obj_wait_cnt, nullptr);
    } while (wait_status == -1 && errno == EINTR);