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" |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
63 jlong deadline) { | 63 jlong deadline) { |
64 // Buffer contains first the list of handles, then the list of flags. | 64 // Buffer contains first the list of handles, then the list of flags. |
65 const void* buffer_start = env->GetDirectBufferAddress(buffer); | 65 const void* buffer_start = env->GetDirectBufferAddress(buffer); |
66 DCHECK(buffer_start); | 66 DCHECK(buffer_start); |
67 const size_t record_size = 8; | 67 const size_t record_size = 8; |
68 const size_t buffer_size = env->GetDirectBufferCapacity(buffer); | 68 const size_t buffer_size = env->GetDirectBufferCapacity(buffer); |
69 DCHECK_EQ(buffer_size % record_size, 0u); | 69 DCHECK_EQ(buffer_size % record_size, 0u); |
70 | 70 |
71 const size_t nb_handles = buffer_size / record_size; | 71 const size_t nb_handles = buffer_size / record_size; |
72 const MojoHandle* handle_start = static_cast<const MojoHandle*>(buffer_start); | 72 const MojoHandle* handle_start = static_cast<const MojoHandle*>(buffer_start); |
73 const MojoWaitFlags* flags_start = | 73 const MojoHandleSignals* signals_start = |
74 static_cast<const MojoWaitFlags*>(handle_start + nb_handles); | 74 static_cast<const MojoHandleSignals*>(handle_start + nb_handles); |
75 return MojoWaitMany(handle_start, flags_start, nb_handles, deadline); | 75 return MojoWaitMany(handle_start, signals_start, nb_handles, deadline); |
76 } | 76 } |
77 | 77 |
78 static jobject CreateMessagePipe(JNIEnv* env, jobject jcaller) { | 78 static jobject CreateMessagePipe(JNIEnv* env, jobject jcaller) { |
79 MojoHandle handle1; | 79 MojoHandle handle1; |
80 MojoHandle handle2; | 80 MojoHandle handle2; |
81 // TODO(vtl): Add support for the options struct. | 81 // TODO(vtl): Add support for the options struct. |
82 MojoResult result = MojoCreateMessagePipe(NULL, &handle1, &handle2); | 82 MojoResult result = MojoCreateMessagePipe(NULL, &handle1, &handle2); |
83 return Java_CoreImpl_newNativeCreationResult(env, result, handle1, handle2) | 83 return Java_CoreImpl_newNativeCreationResult(env, result, handle1, handle2) |
84 .Release(); | 84 .Release(); |
85 } | 85 } |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
122 .Release(); | 122 .Release(); |
123 } | 123 } |
124 | 124 |
125 static jint Close(JNIEnv* env, jobject jcaller, jint mojo_handle) { | 125 static jint Close(JNIEnv* env, jobject jcaller, jint mojo_handle) { |
126 return MojoClose(mojo_handle); | 126 return MojoClose(mojo_handle); |
127 } | 127 } |
128 | 128 |
129 static jint Wait(JNIEnv* env, | 129 static jint Wait(JNIEnv* env, |
130 jobject jcaller, | 130 jobject jcaller, |
131 jint mojo_handle, | 131 jint mojo_handle, |
132 jint flags, | 132 jint signals, |
133 jlong deadline) { | 133 jlong deadline) { |
134 return MojoWait(mojo_handle, flags, deadline); | 134 return MojoWait(mojo_handle, signals, deadline); |
135 } | 135 } |
136 | 136 |
137 static jint WriteMessage(JNIEnv* env, | 137 static jint WriteMessage(JNIEnv* env, |
138 jobject jcaller, | 138 jobject jcaller, |
139 jint mojo_handle, | 139 jint mojo_handle, |
140 jobject bytes, | 140 jobject bytes, |
141 jint num_bytes, | 141 jint num_bytes, |
142 jobject handles_buffer, | 142 jobject handles_buffer, |
143 jint flags) { | 143 jint flags) { |
144 const void* buffer_start = 0; | 144 const void* buffer_start = 0; |
(...skipping 170 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
315 | 315 |
316 static int Unmap(JNIEnv* env, jobject jcaller, jobject buffer) { | 316 static int Unmap(JNIEnv* env, jobject jcaller, jobject buffer) { |
317 void* buffer_start = env->GetDirectBufferAddress(buffer); | 317 void* buffer_start = env->GetDirectBufferAddress(buffer); |
318 DCHECK(buffer_start); | 318 DCHECK(buffer_start); |
319 return MojoUnmapBuffer(buffer_start); | 319 return MojoUnmapBuffer(buffer_start); |
320 } | 320 } |
321 | 321 |
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 flags, | 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::GetDefaultAsyncWaiter()->AsyncWait(mojo_handle, |
333 flags, | 333 signals, |
334 deadline, | 334 deadline, |
335 AsyncWaitCallback, | 335 AsyncWaitCallback, |
336 callback_data); | 336 callback_data); |
337 } else { | 337 } else { |
338 cancel_id = kInvalidHandleCancelID; | 338 cancel_id = kInvalidHandleCancelID; |
339 base::MessageLoop::current()->PostTask( | 339 base::MessageLoop::current()->PostTask( |
340 FROM_HERE, | 340 FROM_HERE, |
341 base::Bind( | 341 base::Bind( |
342 &AsyncWaitCallback, callback_data, MOJO_RESULT_INVALID_ARGUMENT)); | 342 &AsyncWaitCallback, callback_data, MOJO_RESULT_INVALID_ARGUMENT)); |
343 } | 343 } |
(...skipping 18 matching lines...) Expand all Loading... |
362 reinterpret_cast<AsyncWaitCallbackData*>(data_ptr)); | 362 reinterpret_cast<AsyncWaitCallbackData*>(data_ptr)); |
363 mojo::GetDefaultAsyncWaiter()->CancelWait(id); | 363 mojo::GetDefaultAsyncWaiter()->CancelWait(id); |
364 } | 364 } |
365 | 365 |
366 bool RegisterCoreImpl(JNIEnv* env) { | 366 bool RegisterCoreImpl(JNIEnv* env) { |
367 return RegisterNativesImpl(env); | 367 return RegisterNativesImpl(env); |
368 } | 368 } |
369 | 369 |
370 } // namespace android | 370 } // namespace android |
371 } // namespace mojo | 371 } // namespace mojo |
OLD | NEW |