xenia-canary/src/xenia/kernel/objects/xtimer.cc

/**
 ******************************************************************************
 * Xenia : Xbox 360 Emulator Research Project                                 *
 ******************************************************************************
 * Copyright 2013 Ben Vanik. All rights reserved.                             *
 * Released under the BSD license - see LICENSE in the root for more details. *
 ******************************************************************************
 */

#include "xenia/kernel/objects/xtimer.h"

#include "xenia/base/clock.h"
#include "xenia/base/logging.h"
#include "xenia/cpu/processor.h"

namespace xe {
namespace kernel {

XTimer::XTimer(KernelState* kernel_state)
    : XObject(kernel_state, kTypeTimer), native_handle_(NULL) {}

XTimer::~XTimer() {
  if (native_handle_) {
    CloseHandle(native_handle_);
  }
}

void XTimer::Initialize(uint32_t timer_type) {
  assert_null(native_handle_);

  bool manual_reset = false;
  switch (timer_type) {
    case 0:  // NotificationTimer
      manual_reset = true;
      break;
    case 1:  // SynchronizationTimer
      manual_reset = false;
      break;
    default:
      assert_always();
      break;
  }

  native_handle_ = CreateWaitableTimer(NULL, manual_reset, NULL);
}

X_STATUS XTimer::SetTimer(int64_t due_time, uint32_t period_ms,
                          uint32_t routine, uint32_t routine_arg, bool resume) {
  // Stash routine for callback.
  current_routine_ = routine;
  current_routine_arg_ = routine_arg;

  due_time = Clock::ScaleGuestDurationFileTime(due_time);
  period_ms = Clock::ScaleGuestDurationMillis(period_ms);

  LARGE_INTEGER due_time_li;
  due_time_li.QuadPart = due_time;
  BOOL result =
      SetWaitableTimer(native_handle_, &due_time_li, period_ms,
                       routine ? (PTIMERAPCROUTINE)CompletionRoutine : NULL,
                       this, resume ? TRUE : FALSE);

  // Caller is checking for STATUS_TIMER_RESUME_IGNORED.
  // This occurs if result == TRUE but error is set.
  if (!result && GetLastError() == ERROR_NOT_SUPPORTED) {
    return X_STATUS_TIMER_RESUME_IGNORED;
  }

  return result ? X_STATUS_SUCCESS : X_STATUS_UNSUCCESSFUL;
}

void XTimer::CompletionRoutine(XTimer* timer, DWORD timer_low,
                               DWORD timer_high) {
  assert_true(timer->current_routine_);

  // Queue APC to call back routine with (arg, low, high).
  // TODO(benvanik): APC dispatch.
  XELOGE("Timer needs APC!");

  DebugBreak();
}

X_STATUS XTimer::Cancel() {
  return CancelWaitableTimer(native_handle_) == 0 ? X_STATUS_SUCCESS
                                                  : X_STATUS_UNSUCCESSFUL;
}

}  // namespace kernel
}  // namespace xe