bluetooth: Post a task when sending GATT events to simulate another thread.

device/bluetooth/test/bluetooth_test_android.cc

 // Copyright 2015 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 "device/bluetooth/test/bluetooth_test_android.h"
 
 #include <iterator>
 #include <sstream>
 
 #include "base/android/jni_array.h"
 #include "base/android/jni_string.h"
+#include "base/bind.h"
 #include "base/logging.h"
 #include "base/run_loop.h"
 #include "device/bluetooth/android/wrappers.h"
 #include "device/bluetooth/bluetooth_adapter_android.h"
 #include "device/bluetooth/bluetooth_device_android.h"
 #include "device/bluetooth/bluetooth_remote_gatt_characteristic_android.h"
 #include "device/bluetooth/bluetooth_remote_gatt_descriptor_android.h"
 #include "device/bluetooth/bluetooth_remote_gatt_service_android.h"
 #include "device/bluetooth/test/test_bluetooth_adapter_observer.h"
 #include "jni/Fakes_jni.h"
@@ skipping 10 matching lines @@
 BluetoothTestAndroid::~BluetoothTestAndroid() {
 }
 
 void BluetoothTestAndroid::SetUp() {
   // Register in SetUp so that ASSERT can be used.
   ASSERT_TRUE(RegisterNativesImpl(AttachCurrentThread()));
 
   // Set the permission to true so that we can use the API.
   Java_Fakes_setLocationServicesState(
       AttachCurrentThread(), true /* hasPermission */, true /* isEnabled */);
+  Java_Fakes_initFakeThreadUtilsWrapper(AttachCurrentThread(),
+                                        reinterpret_cast<intptr_t>(this));
 }
 
 void BluetoothTestAndroid::TearDown() {
   BluetoothAdapter::DeviceList devices = adapter_->GetDevices();
   for (auto* device : devices) {
     DeleteDevice(device);
   }
   EXPECT_EQ(0, gatt_open_connections_);
+
   BluetoothTestBase::TearDown();
 }
 
+static void RunJavaRunnable(
+    const base::android::ScopedJavaGlobalRef<jobject>& runnable_ref) {
+  Java_Fakes_runRunnable(AttachCurrentThread(), runnable_ref);
+}
+
+void BluetoothTestAndroid::PostTaskFromJava(
+    JNIEnv* env,
+    const JavaParamRef<jobject>& caller,
+    const JavaParamRef<jobject>& runnable) {
+  base::android::ScopedJavaGlobalRef<jobject> runnable_ref;
+  // ScopedJavaGlobalRef does not hold onto the env reference, so it is safe to
+  // use it across threads. |RunJavaRunnable| will acquire a new JNIEnv before
+  // running the Runnable.
+  runnable_ref.Reset(env, runnable);
+  message_loop_.task_runner()->PostTask(
+      FROM_HERE, base::Bind(&RunJavaRunnable, runnable_ref));
+}
+
 bool BluetoothTestAndroid::PlatformSupportsLowEnergy() {
   return true;
 }
 
 void BluetoothTestAndroid::InitWithDefaultAdapter() {
   adapter_ = BluetoothAdapterAndroid::Create(
                  BluetoothAdapterWrapper_CreateWithDefaultAdapter())
                  .get();
 }
 
@@ skipping 456 matching lines @@
 }
 
 void BluetoothTestAndroid::OnFakeAdapterStateChanged(
     JNIEnv* env,
     const JavaParamRef<jobject>& caller,
     const bool powered) {
   adapter_->NotifyAdapterPoweredChanged(powered);
 }
 
 }  // namespace device