1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
// 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
|
