Mojo: Armed Watchers

mojo/edk/system/watcher.cc

-// Copyright 2016 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 "mojo/edk/system/watcher.h"
-
-#include "mojo/edk/system/handle_signals_state.h"
-#include "mojo/edk/system/request_context.h"
-
-namespace mojo {
-namespace edk {
-
-Watcher::Watcher(MojoHandleSignals signals, const WatchCallback& callback)
-    : signals_(signals), callback_(callback) {
-}
-
-void Watcher::MaybeInvokeCallback(MojoResult result,
-                                  const HandleSignalsState& state,
-                                  MojoWatchNotificationFlags flags) {
-  base::AutoLock lock(lock_);
-  if (is_cancelled_)
-    return;
-
-  callback_.Run(result, state, flags);
-}
-
-void Watcher::NotifyForStateChange(const HandleSignalsState& signals_state) {
-  RequestContext* request_context = RequestContext::current();
-  if (signals_state.satisfies(signals_)) {
-    request_context->AddWatchNotifyFinalizer(
-        make_scoped_refptr(this), MOJO_RESULT_OK, signals_state);
-  } else if (!signals_state.can_satisfy(signals_)) {
-    request_context->AddWatchNotifyFinalizer(
-        make_scoped_refptr(this), MOJO_RESULT_FAILED_PRECONDITION,
-        signals_state);
-  }
-}
-
-void Watcher::NotifyClosed() {
-  static const HandleSignalsState closed_state = {0, 0};
-  RequestContext::current()->AddWatchNotifyFinalizer(
-      make_scoped_refptr(this), MOJO_RESULT_CANCELLED, closed_state);
-}
-
-void Watcher::Cancel() {
-  base::AutoLock lock(lock_);
-  is_cancelled_ = true;
-}
-
-Watcher::~Watcher() {}
-
-}  // namespace edk
-}  // namespace mojo