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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
// 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/android/system/watcher_impl.h"
#include <stddef.h>
#include <stdint.h>
#include "base/android/base_jni_registrar.h"
#include "base/android/jni_android.h"
#include "base/android/jni_registrar.h"
#include "base/android/library_loader/library_loader_hooks.h"
#include "base/android/scoped_java_ref.h"
#include "base/bind.h"
#include "jni/WatcherImpl_jni.h"
#include "mojo/public/cpp/system/handle.h"
#include "mojo/public/cpp/system/watcher.h"
namespace mojo {
namespace android {
using base::android::JavaParamRef;
namespace {
class WatcherImpl {
public:
WatcherImpl() : watcher_(FROM_HERE) {}
~WatcherImpl() = default;
jint Start(JNIEnv* env,
const JavaParamRef<jobject>& jcaller,
jint mojo_handle,
jint signals) {
java_watcher_.Reset(env, jcaller);
auto ready_callback =
base::Bind(&WatcherImpl::OnHandleReady, base::Unretained(this));
MojoResult result =
watcher_.Start(mojo::Handle(static_cast<MojoHandle>(mojo_handle)),
static_cast<MojoHandleSignals>(signals), ready_callback);
if (result != MOJO_RESULT_OK)
java_watcher_.Reset();
return result;
}
void Cancel() {
java_watcher_.Reset();
watcher_.Cancel();
}
private:
void OnHandleReady(MojoResult result) {
DCHECK(!java_watcher_.is_null());
base::android::ScopedJavaGlobalRef<jobject> java_watcher_preserver;
if (result == MOJO_RESULT_CANCELLED)
java_watcher_preserver = std::move(java_watcher_);
Java_WatcherImpl_onHandleReady(
base::android::AttachCurrentThread(),
java_watcher_.is_null() ? java_watcher_preserver : java_watcher_,
result);
}
Watcher watcher_;
base::android::ScopedJavaGlobalRef<jobject> java_watcher_;
DISALLOW_COPY_AND_ASSIGN(WatcherImpl);
};
} // namespace
static jlong CreateWatcher(JNIEnv* env, const JavaParamRef<jobject>& jcaller) {
return reinterpret_cast<jlong>(new WatcherImpl);
}
static jint Start(JNIEnv* env,
const JavaParamRef<jobject>& jcaller,
jlong watcher_ptr,
jint mojo_handle,
jint signals) {
auto* watcher = reinterpret_cast<WatcherImpl*>(watcher_ptr);
return watcher->Start(env, jcaller, mojo_handle, signals);
}
static void Cancel(JNIEnv* env,
const JavaParamRef<jobject>& jcaller,
jlong watcher_ptr) {
reinterpret_cast<WatcherImpl*>(watcher_ptr)->Cancel();
}
static void Delete(JNIEnv* env,
const JavaParamRef<jobject>& jcaller,
jlong watcher_ptr) {
delete reinterpret_cast<WatcherImpl*>(watcher_ptr);
}
bool RegisterWatcherImpl(JNIEnv* env) {
return RegisterNativesImpl(env);
}
} // namespace android
} // namespace mojo
|
