Roll base to ec59756cc1ad02cc835bcca10056a621c9eb346c.

mojo/android/system/core_impl.cc

 // Copyright 2014 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/core_impl.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"
@@ skipping 76 matching lines @@
       reinterpret_cast<const MojoHandleSignals*>(buffer_start + 4 * nb_handles);
   MojoHandleSignalsState* states_start =
       reinterpret_cast<MojoHandleSignalsState*>(buffer_start + 8 * nb_handles);
   uint32_t* result_index =
       reinterpret_cast<uint32_t*>(buffer_start + 16 * nb_handles);
   *result_index = static_cast<uint32_t>(-1);
   return MojoWaitMany(handle_start, signals_start, nb_handles, deadline,
                       result_index, states_start);
 }
 
-static jobject CreateMessagePipe(JNIEnv* env,
-                                 jobject jcaller,
-                                 jobject options_buffer) {
+static ScopedJavaLocalRef<jobject> CreateMessagePipe(JNIEnv* env,
+                                                     jobject jcaller,
+                                                     jobject options_buffer) {
   const MojoCreateMessagePipeOptions* options = NULL;
   if (options_buffer) {
     const void* buffer_start = env->GetDirectBufferAddress(options_buffer);
     DCHECK(buffer_start);
     DCHECK_EQ(reinterpret_cast<const uintptr_t>(buffer_start) % 8, 0u);
     const size_t buffer_size = env->GetDirectBufferCapacity(options_buffer);
     DCHECK_EQ(buffer_size, sizeof(MojoCreateMessagePipeOptions));
     options = static_cast<const MojoCreateMessagePipeOptions*>(buffer_start);
     DCHECK_EQ(options->struct_size, buffer_size);
   }
   MojoHandle handle1;
   MojoHandle handle2;
   MojoResult result = MojoCreateMessagePipe(options, &handle1, &handle2);
-  return Java_CoreImpl_newNativeCreationResult(env, result, handle1, handle2)
-      .Release();
+  return Java_CoreImpl_newNativeCreationResult(env, result, handle1, handle2);
 }
 
-static jobject CreateDataPipe(JNIEnv* env,
-                              jobject jcaller,
-                              jobject options_buffer) {
+static ScopedJavaLocalRef<jobject> CreateDataPipe(JNIEnv* env,
+                                                  jobject jcaller,
+                                                  jobject options_buffer) {
   const MojoCreateDataPipeOptions* options = NULL;
   if (options_buffer) {
     const void* buffer_start = env->GetDirectBufferAddress(options_buffer);
     DCHECK(buffer_start);
     DCHECK_EQ(reinterpret_cast<const uintptr_t>(buffer_start) % 8, 0u);
     const size_t buffer_size = env->GetDirectBufferCapacity(options_buffer);
     DCHECK_EQ(buffer_size, sizeof(MojoCreateDataPipeOptions));
     options = static_cast<const MojoCreateDataPipeOptions*>(buffer_start);
     DCHECK_EQ(options->struct_size, buffer_size);
   }
   MojoHandle handle1;
   MojoHandle handle2;
   MojoResult result = MojoCreateDataPipe(options, &handle1, &handle2);
-  return Java_CoreImpl_newNativeCreationResult(env, result, handle1, handle2)
-      .Release();
+  return Java_CoreImpl_newNativeCreationResult(env, result, handle1, handle2);
 }
 
-static jobject CreateSharedBuffer(JNIEnv* env,
-                                  jobject jcaller,
-                                  jobject options_buffer,
-                                  jlong num_bytes) {
+static ScopedJavaLocalRef<jobject> CreateSharedBuffer(JNIEnv* env,
+                                                      jobject jcaller,
+                                                      jobject options_buffer,
+                                                      jlong num_bytes) {
   const MojoCreateSharedBufferOptions* options = 0;
   if (options_buffer) {
     const void* buffer_start = env->GetDirectBufferAddress(options_buffer);
     DCHECK(buffer_start);
     DCHECK_EQ(reinterpret_cast<const uintptr_t>(buffer_start) % 8, 0u);
     const size_t buffer_size = env->GetDirectBufferCapacity(options_buffer);
     DCHECK_EQ(buffer_size, sizeof(MojoCreateSharedBufferOptions));
     options = static_cast<const MojoCreateSharedBufferOptions*>(buffer_start);
     DCHECK_EQ(options->struct_size, buffer_size);
   }
   MojoHandle handle;
   MojoResult result = MojoCreateSharedBuffer(options, num_bytes, &handle);
-  return Java_CoreImpl_newResultAndInteger(env, result, handle).Release();
+  return Java_CoreImpl_newResultAndInteger(env, result, handle);
 }
 
 static jint Close(JNIEnv* env, jobject jcaller, jint mojo_handle) {
   return MojoClose(mojo_handle);
 }
 
 static jint Wait(JNIEnv* env,
                  jobject jcaller,
                  jobject buffer,
                  jint mojo_handle,
@@ skipping 30 matching lines @@
   if (handles_buffer) {
     handles =
         static_cast<MojoHandle*>(env->GetDirectBufferAddress(handles_buffer));
     num_handles = env->GetDirectBufferCapacity(handles_buffer) / 4;
   }
   // Java code will handle invalidating handles if the write succeeded.
   return MojoWriteMessage(
       mojo_handle, buffer_start, buffer_size, handles, num_handles, flags);
 }
 
-static jobject ReadMessage(JNIEnv* env,
-                           jobject jcaller,
-                           jint mojo_handle,
-                           jobject bytes,
-                           jobject handles_buffer,
-                           jint flags) {
+static ScopedJavaLocalRef<jobject> ReadMessage(JNIEnv* env,
+                                               jobject jcaller,
+                                               jint mojo_handle,
+                                               jobject bytes,
+                                               jobject handles_buffer,
+                                               jint flags) {
   void* buffer_start = 0;
   uint32_t buffer_size = 0;
   if (bytes) {
     buffer_start = env->GetDirectBufferAddress(bytes);
     DCHECK(buffer_start);
     buffer_size = env->GetDirectBufferCapacity(bytes);
   }
   MojoHandle* handles = 0;
   uint32_t num_handles = 0;
   if (handles_buffer) {
     handles =
         static_cast<MojoHandle*>(env->GetDirectBufferAddress(handles_buffer));
     num_handles = env->GetDirectBufferCapacity(handles_buffer) / 4;
   }
   MojoResult result = MojoReadMessage(
       mojo_handle, buffer_start, &buffer_size, handles, &num_handles, flags);
   // Jave code will handle taking ownership of any received handle.
-  return Java_CoreImpl_newReadMessageResult(
-             env, result, buffer_size, num_handles).Release();
+  return Java_CoreImpl_newReadMessageResult(env, result, buffer_size,
+                                            num_handles);
 }
 
-static jobject ReadData(JNIEnv* env,
-                        jobject jcaller,
-                        jint mojo_handle,
-                        jobject elements,
-                        jint elements_capacity,
-                        jint flags) {
+static ScopedJavaLocalRef<jobject> ReadData(JNIEnv* env,
+                                            jobject jcaller,
+                                            jint mojo_handle,
+                                            jobject elements,
+                                            jint elements_capacity,
+                                            jint flags) {
   void* buffer_start = 0;
   uint32_t buffer_size = elements_capacity;
   if (elements) {
     buffer_start = env->GetDirectBufferAddress(elements);
     DCHECK(buffer_start);
     DCHECK(elements_capacity <= env->GetDirectBufferCapacity(elements));
   }
   MojoResult result =
       MojoReadData(mojo_handle, buffer_start, &buffer_size, flags);
   return Java_CoreImpl_newResultAndInteger(
-             env, result, (result == MOJO_RESULT_OK) ? buffer_size : 0)
-      .Release();
+      env, result, (result == MOJO_RESULT_OK) ? buffer_size : 0);
 }
 
-static jobject BeginReadData(JNIEnv* env,
-                             jobject jcaller,
-                             jint mojo_handle,
-                             jint num_bytes,
-                             jint flags) {
+static ScopedJavaLocalRef<jobject> BeginReadData(JNIEnv* env,
+                                                 jobject jcaller,
+                                                 jint mojo_handle,
+                                                 jint num_bytes,
+                                                 jint flags) {
   void const* buffer = 0;
   uint32_t buffer_size = num_bytes;
   MojoResult result =
       MojoBeginReadData(mojo_handle, &buffer, &buffer_size, flags);
   jobject byte_buffer = 0;
   if (result == MOJO_RESULT_OK) {
     byte_buffer =
         env->NewDirectByteBuffer(const_cast<void*>(buffer), buffer_size);
   }
-  return Java_CoreImpl_newResultAndBuffer(env, result, byte_buffer).Release();
+  return Java_CoreImpl_newResultAndBuffer(env, result, byte_buffer);
 }
 
 static jint EndReadData(JNIEnv* env,
                         jobject jcaller,
                         jint mojo_handle,
                         jint num_bytes_read) {
   return MojoEndReadData(mojo_handle, num_bytes_read);
 }
 
-static jobject WriteData(JNIEnv* env,
-                         jobject jcaller,
-                         jint mojo_handle,
-                         jobject elements,
-                         jint limit,
-                         jint flags) {
+static ScopedJavaLocalRef<jobject> WriteData(JNIEnv* env,
+                                             jobject jcaller,
+                                             jint mojo_handle,
+                                             jobject elements,
+                                             jint limit,
+                                             jint flags) {
   void* buffer_start = env->GetDirectBufferAddress(elements);
   DCHECK(buffer_start);
   DCHECK(limit <= env->GetDirectBufferCapacity(elements));
   uint32_t buffer_size = limit;
   MojoResult result =
       MojoWriteData(mojo_handle, buffer_start, &buffer_size, flags);
   return Java_CoreImpl_newResultAndInteger(
-             env, result, (result == MOJO_RESULT_OK) ? buffer_size : 0)
-      .Release();
+      env, result, (result == MOJO_RESULT_OK) ? buffer_size : 0);
 }
 
-static jobject BeginWriteData(JNIEnv* env,
-                              jobject jcaller,
-                              jint mojo_handle,
-                              jint num_bytes,
-                              jint flags) {
+static ScopedJavaLocalRef<jobject> BeginWriteData(JNIEnv* env,
+                                                  jobject jcaller,
+                                                  jint mojo_handle,
+                                                  jint num_bytes,
+                                                  jint flags) {
   void* buffer = 0;
   uint32_t buffer_size = num_bytes;
   MojoResult result =
       MojoBeginWriteData(mojo_handle, &buffer, &buffer_size, flags);
   jobject byte_buffer = 0;
   if (result == MOJO_RESULT_OK) {
     byte_buffer = env->NewDirectByteBuffer(buffer, buffer_size);
   }
-  return Java_CoreImpl_newResultAndBuffer(env, result, byte_buffer).Release();
+  return Java_CoreImpl_newResultAndBuffer(env, result, byte_buffer);
 }
 
 static jint EndWriteData(JNIEnv* env,
                          jobject jcaller,
                          jint mojo_handle,
                          jint num_bytes_written) {
   return MojoEndWriteData(mojo_handle, num_bytes_written);
 }
 
-static jobject Duplicate(JNIEnv* env,
-                         jobject jcaller,
-                         jint mojo_handle,
-                         jobject options_buffer) {
+static ScopedJavaLocalRef<jobject> Duplicate(JNIEnv* env,
+                                             jobject jcaller,
+                                             jint mojo_handle,
+                                             jobject options_buffer) {
   const MojoDuplicateBufferHandleOptions* options = 0;
   if (options_buffer) {
     const void* buffer_start = env->GetDirectBufferAddress(options_buffer);
     DCHECK(buffer_start);
     const size_t buffer_size = env->GetDirectBufferCapacity(options_buffer);
     DCHECK_EQ(buffer_size, sizeof(MojoDuplicateBufferHandleOptions));
     options =
         static_cast<const MojoDuplicateBufferHandleOptions*>(buffer_start);
     DCHECK_EQ(options->struct_size, buffer_size);
   }
   MojoHandle handle;
   MojoResult result = MojoDuplicateBufferHandle(mojo_handle, options, &handle);
-  return Java_CoreImpl_newResultAndInteger(env, result, handle).Release();
+  return Java_CoreImpl_newResultAndInteger(env, result, handle);
 }
 
-static jobject Map(JNIEnv* env,
-                   jobject jcaller,
-                   jint mojo_handle,
-                   jlong offset,
-                   jlong num_bytes,
-                   jint flags) {
+static ScopedJavaLocalRef<jobject> Map(JNIEnv* env,
+                                       jobject jcaller,
+                                       jint mojo_handle,
+                                       jlong offset,
+                                       jlong num_bytes,
+                                       jint flags) {
   void* buffer = 0;
   MojoResult result =
       MojoMapBuffer(mojo_handle, offset, num_bytes, &buffer, flags);
   jobject byte_buffer = 0;
   if (result == MOJO_RESULT_OK) {
     byte_buffer = env->NewDirectByteBuffer(buffer, num_bytes);
   }
-  return Java_CoreImpl_newResultAndBuffer(env, result, byte_buffer).Release();
+  return Java_CoreImpl_newResultAndBuffer(env, result, byte_buffer);
 }
 
 static int Unmap(JNIEnv* env, jobject jcaller, jobject buffer) {
   void* buffer_start = env->GetDirectBufferAddress(buffer);
   DCHECK(buffer_start);
   return MojoUnmapBuffer(buffer_start);
 }
 
-static jobject AsyncWait(JNIEnv* env,
-                         jobject jcaller,
-                         jint mojo_handle,
-                         jint signals,
-                         jlong deadline,
-                         jobject callback) {
+static ScopedJavaLocalRef<jobject> AsyncWait(JNIEnv* env,
+                                             jobject jcaller,
+                                             jint mojo_handle,
+                                             jint signals,
+                                             jlong deadline,
+                                             jobject callback) {
   AsyncWaitCallbackData* callback_data =
       new AsyncWaitCallbackData(env, jcaller, callback);
   MojoAsyncWaitID cancel_id;
   if (static_cast<MojoHandle>(mojo_handle) != MOJO_HANDLE_INVALID) {
     cancel_id = Environment::GetDefaultAsyncWaiter()->AsyncWait(
         mojo_handle, signals, deadline, AsyncWaitCallback, callback_data);
   } else {
     cancel_id = kInvalidHandleCancelID;
     base::MessageLoop::current()->PostTask(
         FROM_HERE,
         base::Bind(
             &AsyncWaitCallback, callback_data, MOJO_RESULT_INVALID_ARGUMENT));
   }
   base::android::ScopedJavaLocalRef<jobject> cancellable =
       Java_CoreImpl_newAsyncWaiterCancellableImpl(
           env, jcaller, cancel_id, reinterpret_cast<intptr_t>(callback_data));
   callback_data->cancellable.Reset(env, cancellable.obj());
-  return cancellable.Release();
+  return cancellable;
 }
 
 static void CancelAsyncWait(JNIEnv* env,
                             jobject jcaller,
                             jlong id,
                             jlong data_ptr) {
   if (id == 0) {
     // If |id| is |kInvalidHandleCancelID|, the async wait was done on an
     // invalid handle, so the AsyncWaitCallback will be called and will clear
     // the data_ptr.
     return;
   }
   scoped_ptr<AsyncWaitCallbackData> deleter(
       reinterpret_cast<AsyncWaitCallbackData*>(data_ptr));
   Environment::GetDefaultAsyncWaiter()->CancelWait(id);
 }
 
 static jint GetNativeBufferOffset(JNIEnv* env,
                                   jobject jcaller,
                                   jobject buffer,
                                   jint alignment) {
   jint offset =
       reinterpret_cast<uintptr_t>(env->GetDirectBufferAddress(buffer)) %
       alignment;
   if (offset == 0)
     return 0;
   return alignment - offset;
 }
 
-static jobject GetBufferInformation(JNIEnv* env,
-                                    jobject jcaller,
-                                    jint mojo_handle) {
+static ScopedJavaLocalRef<jobject> GetBufferInformation(JNIEnv* env,
+                                                        jobject jcaller,
+                                                        jint mojo_handle) {
   MojoBufferInformation buffer_information;
   MojoResult result =
       MojoGetBufferInformation(static_cast<MojoHandle>(mojo_handle),
                                &buffer_information, sizeof(buffer_information));
   return Java_CoreImpl_newResultAndBufferInformation(
-             env, result, buffer_information.flags,
-             buffer_information.num_bytes)
-      .Release();
+      env, result, buffer_information.flags, buffer_information.num_bytes);
 }
 
 bool RegisterCoreImpl(JNIEnv* env) {
   return RegisterNativesImpl(env);
 }
 
 }  // namespace android
 }  // namespace mojo