// Copyright 2014 The Chromium 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 "device/serial/async_waiter.h"

namespace device {

AsyncWaiter::AsyncWaiter(mojo::Handle handle,
                         MojoHandleSignals signals,
                         const Callback& callback)
    : waiter_(mojo::Environment::GetDefaultAsyncWaiter()),
      id_(0),
      callback_(callback) {
  id_ = waiter_->AsyncWait(handle.value(),
                           signals,
                           MOJO_DEADLINE_INDEFINITE,
                           &AsyncWaiter::WaitComplete,
                           this);
}

AsyncWaiter::~AsyncWaiter() {
  if (id_)
    waiter_->CancelWait(id_);
}

// static
void AsyncWaiter::WaitComplete(void* waiter, MojoResult result) {
  static_cast<AsyncWaiter*>(waiter)->WaitCompleteInternal(result);
}

void AsyncWaiter::WaitCompleteInternal(MojoResult result) {
  id_ = 0;
  callback_.Run(result);
}

}  // namespace device