OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "mojo/android/system/core_impl.h" | 5 #include "mojo/android/system/core_impl.h" |
6 | 6 |
7 #include "base/android/base_jni_registrar.h" | 7 #include "base/android/base_jni_registrar.h" |
8 #include "base/android/jni_android.h" | 8 #include "base/android/jni_android.h" |
9 #include "base/android/jni_registrar.h" | 9 #include "base/android/jni_registrar.h" |
10 #include "base/android/library_loader/library_loader_hooks.h" | 10 #include "base/android/library_loader/library_loader_hooks.h" |
11 #include "base/android/scoped_java_ref.h" | 11 #include "base/android/scoped_java_ref.h" |
12 #include "base/bind.h" | 12 #include "base/bind.h" |
13 #include "base/message_loop/message_loop.h" | 13 #include "base/message_loop/message_loop.h" |
14 #include "jni/CoreImpl_jni.h" | 14 #include "jni/CoreImpl_jni.h" |
15 #include "mojo/embedder/embedder.h" | 15 #include "mojo/embedder/embedder.h" |
16 #include "mojo/public/c/environment/async_waiter.h" | 16 #include "mojo/public/c/environment/async_waiter.h" |
17 #include "mojo/public/c/system/core.h" | 17 #include "mojo/public/c/system/core.h" |
18 #include "mojo/public/cpp/environment/default_async_waiter.h" | 18 #include "mojo/public/cpp/environment/environment.h" |
19 | 19 |
20 namespace { | 20 namespace { |
21 | 21 |
22 // |AsyncWait| is guaranteed never to return 0. | 22 // |AsyncWait| is guaranteed never to return 0. |
23 const MojoAsyncWaitID kInvalidHandleCancelID = 0; | 23 const MojoAsyncWaitID kInvalidHandleCancelID = 0; |
24 | 24 |
25 struct AsyncWaitCallbackData { | 25 struct AsyncWaitCallbackData { |
26 base::android::ScopedJavaGlobalRef<jobject> core_impl; | 26 base::android::ScopedJavaGlobalRef<jobject> core_impl; |
27 base::android::ScopedJavaGlobalRef<jobject> callback; | 27 base::android::ScopedJavaGlobalRef<jobject> callback; |
28 base::android::ScopedJavaGlobalRef<jobject> cancellable; | 28 base::android::ScopedJavaGlobalRef<jobject> cancellable; |
(...skipping 293 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
322 static jobject AsyncWait(JNIEnv* env, | 322 static jobject AsyncWait(JNIEnv* env, |
323 jobject jcaller, | 323 jobject jcaller, |
324 jint mojo_handle, | 324 jint mojo_handle, |
325 jint signals, | 325 jint signals, |
326 jlong deadline, | 326 jlong deadline, |
327 jobject callback) { | 327 jobject callback) { |
328 AsyncWaitCallbackData* callback_data = | 328 AsyncWaitCallbackData* callback_data = |
329 new AsyncWaitCallbackData(env, jcaller, callback); | 329 new AsyncWaitCallbackData(env, jcaller, callback); |
330 MojoAsyncWaitID cancel_id; | 330 MojoAsyncWaitID cancel_id; |
331 if (static_cast<MojoHandle>(mojo_handle) != MOJO_HANDLE_INVALID) { | 331 if (static_cast<MojoHandle>(mojo_handle) != MOJO_HANDLE_INVALID) { |
332 cancel_id = mojo::GetDefaultAsyncWaiter()->AsyncWait(mojo_handle, | 332 cancel_id = mojo::Environment::GetDefaultAsyncWaiter()->AsyncWait( |
333 signals, | 333 mojo_handle, signals, deadline, AsyncWaitCallback, callback_data); |
334 deadline, | |
335 AsyncWaitCallback, | |
336 callback_data); | |
337 } else { | 334 } else { |
338 cancel_id = kInvalidHandleCancelID; | 335 cancel_id = kInvalidHandleCancelID; |
339 base::MessageLoop::current()->PostTask( | 336 base::MessageLoop::current()->PostTask( |
340 FROM_HERE, | 337 FROM_HERE, |
341 base::Bind( | 338 base::Bind( |
342 &AsyncWaitCallback, callback_data, MOJO_RESULT_INVALID_ARGUMENT)); | 339 &AsyncWaitCallback, callback_data, MOJO_RESULT_INVALID_ARGUMENT)); |
343 } | 340 } |
344 base::android::ScopedJavaLocalRef<jobject> cancellable = | 341 base::android::ScopedJavaLocalRef<jobject> cancellable = |
345 Java_CoreImpl_newAsyncWaiterCancellableImpl( | 342 Java_CoreImpl_newAsyncWaiterCancellableImpl( |
346 env, jcaller, cancel_id, reinterpret_cast<intptr_t>(callback_data)); | 343 env, jcaller, cancel_id, reinterpret_cast<intptr_t>(callback_data)); |
347 callback_data->cancellable.Reset(env, cancellable.obj()); | 344 callback_data->cancellable.Reset(env, cancellable.obj()); |
348 return cancellable.Release(); | 345 return cancellable.Release(); |
349 } | 346 } |
350 | 347 |
351 static void CancelAsyncWait(JNIEnv* env, | 348 static void CancelAsyncWait(JNIEnv* env, |
352 jobject jcaller, | 349 jobject jcaller, |
353 jlong id, | 350 jlong id, |
354 jlong data_ptr) { | 351 jlong data_ptr) { |
355 if (id == 0) { | 352 if (id == 0) { |
356 // If |id| is |kInvalidHandleCancelID|, the async wait was done on an | 353 // If |id| is |kInvalidHandleCancelID|, the async wait was done on an |
357 // invalid handle, so the AsyncWaitCallback will be called and will clear | 354 // invalid handle, so the AsyncWaitCallback will be called and will clear |
358 // the data_ptr. | 355 // the data_ptr. |
359 return; | 356 return; |
360 } | 357 } |
361 scoped_ptr<AsyncWaitCallbackData> deleter( | 358 scoped_ptr<AsyncWaitCallbackData> deleter( |
362 reinterpret_cast<AsyncWaitCallbackData*>(data_ptr)); | 359 reinterpret_cast<AsyncWaitCallbackData*>(data_ptr)); |
363 mojo::GetDefaultAsyncWaiter()->CancelWait(id); | 360 mojo::Environment::GetDefaultAsyncWaiter()->CancelWait(id); |
364 } | 361 } |
365 | 362 |
366 bool RegisterCoreImpl(JNIEnv* env) { | 363 bool RegisterCoreImpl(JNIEnv* env) { |
367 return RegisterNativesImpl(env); | 364 return RegisterNativesImpl(env); |
368 } | 365 } |
369 | 366 |
370 } // namespace android | 367 } // namespace android |
371 } // namespace mojo | 368 } // namespace mojo |
OLD | NEW |