Revert "Reuse SynchronousResultReceivers instead of creating new."
This reverts commit 02dcbe72b3564559eaa9c2e2714824e4aac6f18c.
Reason for revert: Causing builds to fail b/237471430
Change-Id: I6165d838abf312085050359377f67a68a5f8b51a
(cherry picked from commit f5dd42bbd05e68f7763ccaa9fae5642acc4ceba1)
Merged-In: I6165d838abf312085050359377f67a68a5f8b51a
diff --git a/framework/java/android/bluetooth/BluetoothA2dp.java b/framework/java/android/bluetooth/BluetoothA2dp.java
index c1d4fa7..a3dece7 100644
--- a/framework/java/android/bluetooth/BluetoothA2dp.java
+++ b/framework/java/android/bluetooth/BluetoothA2dp.java
@@ -336,7 +336,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connectWithAttribution(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -382,7 +382,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnectWithAttribution(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -408,7 +408,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevicesWithAttribution(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -436,7 +436,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStatesWithAttribution(states,
mAttributionSource, recv);
return Attributable.setAttributionSource(
@@ -464,7 +464,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionStateWithAttribution(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -506,7 +506,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && ((device == null) || isValidDevice(device))) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setActiveDevice(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -538,7 +538,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<BluetoothDevice> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getActiveDevice(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -601,7 +601,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -656,7 +656,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -682,7 +682,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isAvrcpAbsoluteVolumeSupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -736,7 +736,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isA2dpPlaying(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -795,7 +795,7 @@
} else if (isEnabled() && isValidDevice(device)) {
try {
final SynchronousResultReceiver<BluetoothCodecStatus> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getCodecStatus(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -952,7 +952,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.isOptionalCodecsSupported(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -989,7 +989,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.isOptionalCodecsEnabled(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1065,7 +1065,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getDynamicBufferSupport(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1101,7 +1101,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<BufferConstraints> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getBufferConstraints(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1140,7 +1140,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setBufferLengthMillis(codec, value, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothA2dpSink.java b/framework/java/android/bluetooth/BluetoothA2dpSink.java
index 67042de..5941681 100755
--- a/framework/java/android/bluetooth/BluetoothA2dpSink.java
+++ b/framework/java/android/bluetooth/BluetoothA2dpSink.java
@@ -150,7 +150,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -195,7 +195,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -223,7 +223,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -253,7 +253,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -282,7 +282,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -316,7 +316,7 @@
} else if (isEnabled() && isValidDevice(device)) {
try {
final SynchronousResultReceiver<BluetoothAudioConfig> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getAudioConfig(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -377,7 +377,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -433,7 +433,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -466,7 +466,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isA2dpPlaying(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothAdapter.java b/framework/java/android/bluetooth/BluetoothAdapter.java
index 0cd9254..0fdadf8 100644
--- a/framework/java/android/bluetooth/BluetoothAdapter.java
+++ b/framework/java/android/bluetooth/BluetoothAdapter.java
@@ -1276,7 +1276,7 @@
@Override
public @InternalAdapterState Integer apply(IBluetooth serviceQuery) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
serviceQuery.getState(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(BluetoothAdapter.STATE_OFF);
@@ -1561,7 +1561,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_ADVERTISE)
public int getNameLengthForAdvertise() {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.getNameLengthForAdvertise(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(-1);
} catch (RemoteException | TimeoutException e) {
@@ -1586,7 +1586,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.factoryReset(mAttributionSource, recv);
if (recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false)
&& mManagerService != null
@@ -1651,7 +1651,7 @@
mServiceLock.readLock().lock();
try {
final SynchronousResultReceiver<List<ParcelUuid>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.getUuids(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1686,7 +1686,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.setName(name, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -1717,7 +1717,7 @@
mServiceLock.readLock().lock();
if (mService != null) {
final SynchronousResultReceiver<BluetoothClass> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.getBluetoothClass(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -1752,7 +1752,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.setBluetoothClass(bluetoothClass, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -1783,7 +1783,7 @@
mServiceLock.readLock().lock();
if (mService != null) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.getIoCapability(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(BluetoothAdapter.IO_CAPABILITY_UNKNOWN);
@@ -1819,7 +1819,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.setIoCapability(capability, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -1849,7 +1849,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.getLeIoCapability(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(BluetoothAdapter.IO_CAPABILITY_UNKNOWN);
@@ -1885,7 +1885,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.setLeIoCapability(capability, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -1923,7 +1923,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.getScanMode(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(SCAN_MODE_NONE);
}
@@ -1972,7 +1972,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.setScanMode(mode, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(BluetoothStatusCodes.ERROR_UNKNOWN);
@@ -2001,7 +2001,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Long> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Long> recv = new SynchronousResultReceiver();
mService.getDiscoverableTimeout(mAttributionSource, recv);
long timeout = recv.awaitResultNoInterrupt(getSyncTimeout()).getValue((long) -1);
return (timeout == -1) ? null : Duration.ofSeconds(timeout);
@@ -2048,7 +2048,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.setDiscoverableTimeout(timeout.toSeconds(), mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(BluetoothStatusCodes.ERROR_UNKNOWN);
@@ -2081,7 +2081,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Long> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Long> recv = new SynchronousResultReceiver();
mService.getDiscoveryEndMillis(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue((long) -1);
}
@@ -2134,7 +2134,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.startDiscovery(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2172,7 +2172,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.cancelDiscovery(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2212,7 +2212,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.isDiscovering(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2257,7 +2257,7 @@
mServiceLock.readLock().lock();
if (mService != null) {
if (DBG) Log.d(TAG, "removeActiveDevice, profiles: " + profiles);
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.removeActiveDevice(profiles, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2311,7 +2311,7 @@
if (DBG) {
Log.d(TAG, "setActiveDevice, device: " + device + ", profiles: " + profiles);
}
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.setActiveDevice(device, profiles, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2362,7 +2362,7 @@
+ BluetoothProfile.getProfileName(profile) + ")");
}
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.getActiveDevices(profile, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(new ArrayList<>());
}
@@ -2389,7 +2389,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.isMultiAdvertisementSupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2429,7 +2429,7 @@
@Override
public Boolean apply(IBluetooth serviceQuery) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
serviceQuery.isOffloadedFilteringSupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
} catch (RemoteException | TimeoutException e) {
@@ -2493,7 +2493,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.isOffloadedScanBatchingSupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2519,7 +2519,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.isLe2MPhySupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2545,7 +2545,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.isLeCodedPhySupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2571,7 +2571,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.isLeExtendedAdvertisingSupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2597,7 +2597,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.isLePeriodicAdvertisingSupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -2635,7 +2635,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.isLeAudioSupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(BluetoothStatusCodes.ERROR_UNKNOWN);
@@ -2669,7 +2669,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.isLeAudioBroadcastSourceSupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(BluetoothStatusCodes.ERROR_UNKNOWN);
@@ -2704,7 +2704,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.isLeAudioBroadcastAssistantSupported(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(BluetoothStatusCodes.ERROR_UNKNOWN);
@@ -2737,7 +2737,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.getLeMaximumAdvertisingDataLength(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(0);
}
@@ -2777,7 +2777,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.getMaxConnectedAudioDevices(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(1);
}
@@ -2807,7 +2807,7 @@
// BLE is not supported
return false;
}
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
iGatt.numHwTrackFiltersAvailable(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(0) != 0;
} catch (TimeoutException | RemoteException e) {
@@ -2883,7 +2883,7 @@
mServiceLock.readLock().lock();
if (mService != null) {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.getMostRecentlyConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(new ArrayList<>()),
@@ -2918,7 +2918,7 @@
mServiceLock.readLock().lock();
if (mService != null) {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.getBondedDevices(mAttributionSource, recv);
return toDeviceSet(Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(new ArrayList<>()),
@@ -2955,7 +2955,7 @@
try {
synchronized (mManagerCallback) {
if (mService != null) {
- final SynchronousResultReceiver<Long> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Long> recv = new SynchronousResultReceiver();
mService.getSupportedProfiles(mAttributionSource, recv);
final long supportedProfilesBitMask =
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue((long) 0);
@@ -2986,7 +2986,7 @@
public Integer apply(IBluetooth serviceQuery) {
try {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
serviceQuery.getAdapterConnectionState(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(STATE_DISCONNECTED);
@@ -3052,7 +3052,7 @@
final int defaultValue = STATE_DISCONNECTED;
try {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
pairQuery.first.getProfileConnectionState(pairQuery.second, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -3243,7 +3243,7 @@
throw new IllegalArgumentException("The provided PendingIntent is not immutable");
}
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.startRfcommListener(
name, new ParcelUuid(uuid), pendingIntent, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
@@ -3272,7 +3272,7 @@
@RfcommListenerResult
public int stopRfcommServer(@NonNull UUID uuid) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.stopRfcommListener(new ParcelUuid(uuid), mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(BluetoothStatusCodes.ERROR_PROFILE_SERVICE_NOT_BOUND);
@@ -3308,7 +3308,7 @@
try {
final SynchronousResultReceiver<IncomingRfcommSocketInfo> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.retrievePendingSocketForServiceRecord(new ParcelUuid(uuid),
mAttributionSource, recv);
socketInfo = recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -3874,7 +3874,7 @@
mMetadataListeners.forEach((device, pair) -> {
try {
final SynchronousResultReceiver recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.registerMetadataListener(mBluetoothMetadataListener,
device, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -3889,7 +3889,7 @@
if (!mBluetoothConnectionCallbackExecutorMap.isEmpty()) {
try {
final SynchronousResultReceiver recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.registerBluetoothConnectionCallback(mConnectionCallback,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -4078,7 +4078,7 @@
callback.onError(BluetoothStatusCodes.ERROR_BLUETOOTH_NOT_ENABLED);
} else {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.generateLocalOobData(transport, new WrappedOobDataCallback(callback,
executor), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -4681,7 +4681,7 @@
boolean ret = false;
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.registerMetadataListener(mBluetoothMetadataListener, device,
mAttributionSource, recv);
ret = recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
@@ -4749,7 +4749,7 @@
return true;
}
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.unregisterMetadataListener(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
} catch (RemoteException | TimeoutException e) {
@@ -4835,7 +4835,7 @@
mServiceLock.readLock().lock();
if (mService != null) {
final SynchronousResultReceiver<Boolean> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.registerBluetoothConnectionCallback(mConnectionCallback,
mAttributionSource, recv);
if (!recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false)) {
@@ -4894,7 +4894,7 @@
try {
mServiceLock.readLock().lock();
if (mService != null) {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mService.unregisterBluetoothConnectionCallback(mConnectionCallback,
mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
diff --git a/framework/java/android/bluetooth/BluetoothAvrcpController.java b/framework/java/android/bluetooth/BluetoothAvrcpController.java
index 81ad3c6..81fc3e1 100644
--- a/framework/java/android/bluetooth/BluetoothAvrcpController.java
+++ b/framework/java/android/bluetooth/BluetoothAvrcpController.java
@@ -141,7 +141,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -169,7 +169,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -196,7 +196,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -224,7 +224,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<BluetoothAvrcpPlayerSettings> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getPlayerSettings(device, mAttributionSource, recv);
settings = recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -249,7 +249,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setPlayerApplicationSetting(plAppSetting, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -274,7 +274,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.sendGroupNavigationCmd(device, keyCode, keyState, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
return;
diff --git a/framework/java/android/bluetooth/BluetoothCsipSetCoordinator.java b/framework/java/android/bluetooth/BluetoothCsipSetCoordinator.java
index 0c5ebea..16e899d 100644
--- a/framework/java/android/bluetooth/BluetoothCsipSetCoordinator.java
+++ b/framework/java/android/bluetooth/BluetoothCsipSetCoordinator.java
@@ -278,7 +278,7 @@
IBluetoothCsipSetCoordinatorLockCallback delegate =
new BluetoothCsipSetCoordinatorLockCallbackDelegate(executor, callback);
try {
- final SynchronousResultReceiver<ParcelUuid> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<ParcelUuid> recv = new SynchronousResultReceiver();
service.lockGroup(groupId, delegate, mAttributionSource, recv);
final ParcelUuid ret = recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
return ret == null ? defaultValue : ret.getUuid();
@@ -311,7 +311,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.unlockGroup(new ParcelUuid(lockUuid), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
return true;
@@ -343,7 +343,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Map> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Map> recv = new SynchronousResultReceiver();
service.getGroupUuidMapByDevice(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -374,7 +374,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<Integer>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getAllGroupIds(uuid, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -400,7 +400,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -427,7 +427,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -453,7 +453,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -492,7 +492,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -527,7 +527,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothDevice.java b/framework/java/android/bluetooth/BluetoothDevice.java
index 5c91c94..6618a55 100644
--- a/framework/java/android/bluetooth/BluetoothDevice.java
+++ b/framework/java/android/bluetooth/BluetoothDevice.java
@@ -1494,7 +1494,7 @@
Log.e(TAG, "BT not enabled. Cannot get identity address");
} else {
try {
- final SynchronousResultReceiver<String> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<String> recv = new SynchronousResultReceiver();
service.getIdentityAddress(mAddress, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1525,7 +1525,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<String> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<String> recv = new SynchronousResultReceiver();
service.getRemoteName(this, mAttributionSource, recv);
String name = recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
if (name != null) {
@@ -1560,7 +1560,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getRemoteType(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1589,7 +1589,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<String> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<String> recv = new SynchronousResultReceiver();
service.getRemoteAliasWithAttribution(this, mAttributionSource, recv);
String alias = recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
if (alias == null) {
@@ -1650,7 +1650,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.setRemoteAlias(this, alias, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -1684,7 +1684,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getBatteryLevel(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1781,7 +1781,7 @@
Log.e(TAG, "Unable to create bond, invalid address " + mAddress);
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.createBond(this, transport, remoteP192Data, remoteP256Data,
mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
@@ -1812,7 +1812,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isBondingInitiatedLocally(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1842,7 +1842,7 @@
+ " called by pid: " + Process.myPid()
+ " tid: " + Process.myTid());
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.cancelBondProcess(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1875,7 +1875,7 @@
+ " called by pid: " + Process.myPid()
+ " tid: " + Process.myTid());
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.removeBond(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1916,7 +1916,7 @@
}
try {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
pairQuery.first.getBondState(pairQuery.second, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(BOND_NONE);
} catch (RemoteException | TimeoutException e) {
@@ -1995,7 +1995,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.canBondWithoutDialog(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2049,7 +2049,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.connectAllEnabledProfiles(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -2096,7 +2096,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.disconnectAllEnabledProfiles(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -2128,7 +2128,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionStateWithAttribution(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue)
!= CONNECTION_STATE_DISCONNECTED;
@@ -2160,7 +2160,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionStateWithAttribution(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue)
> CONNECTION_STATE_CONNECTED;
@@ -2189,7 +2189,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getRemoteClass(this, mAttributionSource, recv);
int classInt = recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
if (classInt == BluetoothClass.ERROR) return null;
@@ -2224,7 +2224,7 @@
} else {
try {
final SynchronousResultReceiver<List<ParcelUuid>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getRemoteUuids(this, mAttributionSource, recv);
List<ParcelUuid> parcels = recv.awaitResultNoInterrupt(getSyncTimeout())
.getValue(null);
@@ -2290,7 +2290,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.fetchRemoteUuidsWithAttribution(this, transport, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2332,7 +2332,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.sdpSearch(this, uuid, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2359,7 +2359,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setPin(this, true, pin.length, pin, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2405,7 +2405,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setPairingConfirmation(this, confirm, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2444,7 +2444,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getPhonebookAccessPermission(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2490,7 +2490,7 @@
throw new IllegalStateException("Bluetooth is not turned ON");
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setSilenceMode(this, silence, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2520,7 +2520,7 @@
throw new IllegalStateException("Bluetooth is not turned ON");
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.getSilenceMode(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2552,7 +2552,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setPhonebookAccessPermission(this, value, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2581,7 +2581,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getMessageAccessPermission(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2618,7 +2618,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setMessageAccessPermission(this, value, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2647,7 +2647,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getSimAccessPermission(this, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -2680,7 +2680,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setSimAccessPermission(this, value, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -3194,7 +3194,7 @@
+ ", should not over " + METADATA_MAX_LENGTH);
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setMetadata(this, key, value, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -3226,7 +3226,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<byte[]> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<byte[]> recv = new SynchronousResultReceiver();
service.getMetadata(this, key, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -3269,7 +3269,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.allowLowLatencyAudio(allowed, this, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothGatt.java b/framework/java/android/bluetooth/BluetoothGatt.java
index 068188c..ee9c691 100644
--- a/framework/java/android/bluetooth/BluetoothGatt.java
+++ b/framework/java/android/bluetooth/BluetoothGatt.java
@@ -214,7 +214,7 @@
return;
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
// autoConnect is inverse of "isDirect"
mService.clientConnect(mClientIf, mDevice.getAddress(), !mAutoConnect,
mTransport, mOpportunistic, mPhy, mAttributionSource, recv);
@@ -396,7 +396,7 @@
try {
final int authReq = (mAuthRetryState == AUTH_RETRY_STATE_IDLE)
? AUTHENTICATION_NO_MITM : AUTHENTICATION_MITM;
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.readCharacteristic(
mClientIf, address, handle, authReq, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -464,7 +464,7 @@
int requestStatus = BluetoothStatusCodes.ERROR_UNKNOWN;
for (int i = 0; i < WRITE_CHARACTERISTIC_MAX_RETRIES; i++) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
mService.writeCharacteristic(mClientIf, address, handle,
characteristic.getWriteType(), authReq, value,
mAttributionSource, recv);
@@ -559,7 +559,7 @@
try {
final int authReq = (mAuthRetryState == AUTH_RETRY_STATE_IDLE)
? AUTHENTICATION_NO_MITM : AUTHENTICATION_MITM;
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.readDescriptor(mClientIf, address, handle, authReq,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -615,7 +615,7 @@
try {
final int authReq = (mAuthRetryState == AUTH_RETRY_STATE_IDLE)
? AUTHENTICATION_NO_MITM : AUTHENTICATION_MITM;
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.writeDescriptor(mClientIf, address, handle,
authReq, value, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -913,7 +913,7 @@
if (DBG) Log.d(TAG, "registerApp() - UUID=" + uuid);
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.registerClient(new ParcelUuid(uuid), mBluetoothGattCallback, eatt_support,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -937,7 +937,7 @@
try {
mCallback = null;
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.unregisterClient(mClientIf, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
mClientIf = 0;
@@ -1009,7 +1009,7 @@
if (mService == null || mClientIf == 0) return;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.clientDisconnect(mClientIf, mDevice.getAddress(), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1031,7 +1031,7 @@
public boolean connect() {
try {
// autoConnect is inverse of "isDirect"
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.clientConnect(mClientIf, mDevice.getAddress(), false, mTransport,
mOpportunistic, mPhy, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1064,7 +1064,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_CONNECT)
public void setPreferredPhy(int txPhy, int rxPhy, int phyOptions) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.clientSetPreferredPhy(mClientIf, mDevice.getAddress(), txPhy, rxPhy,
phyOptions, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1081,7 +1081,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_CONNECT)
public void readPhy() {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.clientReadPhy(mClientIf, mDevice.getAddress(), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1120,7 +1120,7 @@
mServices.clear();
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.discoverServices(mClientIf, mDevice.getAddress(), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1149,7 +1149,7 @@
mServices.clear();
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.discoverServiceByUuid(mClientIf, mDevice.getAddress(), new ParcelUuid(uuid),
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1243,7 +1243,7 @@
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.readCharacteristic(mClientIf, device.getAddress(),
characteristic.getInstanceId(), AUTHENTICATION_NONE, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1282,7 +1282,7 @@
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.readUsingCharacteristicUuid(mClientIf, mDevice.getAddress(),
new ParcelUuid(uuid), startHandle, endHandle, AUTHENTICATION_NONE,
mAttributionSource, recv);
@@ -1391,7 +1391,7 @@
int requestStatus = BluetoothStatusCodes.ERROR_UNKNOWN;
try {
for (int i = 0; i < WRITE_CHARACTERISTIC_MAX_RETRIES; i++) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.writeCharacteristic(mClientIf, device.getAddress(),
characteristic.getInstanceId(), writeType, AUTHENTICATION_NONE, value,
mAttributionSource, recv);
@@ -1453,7 +1453,7 @@
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.readDescriptor(mClientIf, device.getAddress(),
descriptor.getInstanceId(), AUTHENTICATION_NONE, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1542,7 +1542,7 @@
}
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.writeDescriptor(mClientIf, device.getAddress(),
descriptor.getInstanceId(), AUTHENTICATION_NONE, value, mAttributionSource,
recv);
@@ -1589,7 +1589,7 @@
if (mService == null || mClientIf == 0) return false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.beginReliableWrite(mClientIf, mDevice.getAddress(), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1624,7 +1624,7 @@
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.endReliableWrite(mClientIf, mDevice.getAddress(), true, mAttributionSource,
recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1653,7 +1653,7 @@
if (mService == null || mClientIf == 0) return;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.endReliableWrite(mClientIf, mDevice.getAddress(), false, mAttributionSource,
recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1702,7 +1702,7 @@
if (device == null) return false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.registerForNotification(mClientIf, device.getAddress(),
characteristic.getInstanceId(), enable, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1728,7 +1728,7 @@
if (mService == null || mClientIf == 0) return false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.refreshDevice(mClientIf, mDevice.getAddress(), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1755,7 +1755,7 @@
if (mService == null || mClientIf == 0) return false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.readRemoteRssi(mClientIf, mDevice.getAddress(), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1789,7 +1789,7 @@
if (mService == null || mClientIf == 0) return false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.configureMTU(mClientIf, mDevice.getAddress(), mtu, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1823,7 +1823,7 @@
if (mService == null || mClientIf == 0) return false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.connectionParameterUpdate(mClientIf, mDevice.getAddress(), connectionPriority,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1859,7 +1859,7 @@
if (mService == null || mClientIf == 0) return false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.leConnectionUpdate(mClientIf, mDevice.getAddress(),
minConnectionInterval, maxConnectionInterval,
slaveLatency, supervisionTimeout,
diff --git a/framework/java/android/bluetooth/BluetoothGattServer.java b/framework/java/android/bluetooth/BluetoothGattServer.java
index d652bd8..8b84505 100644
--- a/framework/java/android/bluetooth/BluetoothGattServer.java
+++ b/framework/java/android/bluetooth/BluetoothGattServer.java
@@ -502,7 +502,7 @@
mCallback = callback;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.registerServer(new ParcelUuid(uuid), mBluetoothGattServerCallback,
eatt_support, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -539,7 +539,7 @@
try {
mCallback = null;
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.unregisterServer(mServerIf, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
mServerIf = 0;
@@ -595,7 +595,7 @@
try {
// autoConnect is inverse of "isDirect"
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.serverConnect(mServerIf, device.getAddress(), !autoConnect, mTransport,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -621,7 +621,7 @@
if (mService == null || mServerIf == 0) return;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.serverDisconnect(mServerIf, device.getAddress(), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -651,7 +651,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_CONNECT)
public void setPreferredPhy(BluetoothDevice device, int txPhy, int rxPhy, int phyOptions) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.serverSetPreferredPhy(mServerIf, device.getAddress(), txPhy, rxPhy,
phyOptions, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -670,7 +670,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_CONNECT)
public void readPhy(BluetoothDevice device) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.serverReadPhy(mServerIf, device.getAddress(), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -706,7 +706,7 @@
if (mService == null || mServerIf == 0) return false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.sendResponse(mServerIf, device.getAddress(), requestId,
status, offset, value, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -801,7 +801,7 @@
}
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mService.sendNotification(mServerIf, device.getAddress(),
characteristic.getInstanceId(), confirm,
value, mAttributionSource, recv);
@@ -842,7 +842,7 @@
mPendingService = service;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.addService(mServerIf, service, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -871,7 +871,7 @@
if (intService == null) return false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.removeService(mServerIf, service.getInstanceId(), mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
mServices.remove(intService);
@@ -894,7 +894,7 @@
if (mService == null || mServerIf == 0) return;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.clearServices(mServerIf, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
mServices.clear();
diff --git a/framework/java/android/bluetooth/BluetoothHapClient.java b/framework/java/android/bluetooth/BluetoothHapClient.java
index 08d07ff..1d51670 100644
--- a/framework/java/android/bluetooth/BluetoothHapClient.java
+++ b/framework/java/android/bluetooth/BluetoothHapClient.java
@@ -446,7 +446,7 @@
final IBluetoothHapClient service = getService();
if (service != null) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.registerCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -558,7 +558,7 @@
final IBluetoothHapClient service = getService();
if (service != null) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.registerCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -611,7 +611,7 @@
try {
final IBluetoothHapClient service = getService();
if (service != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.unregisterCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -654,7 +654,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -693,7 +693,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -725,7 +725,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<List> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<List> recv = new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -760,7 +760,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<List> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<List> recv = new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -795,7 +795,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -837,7 +837,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getHapGroup(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -869,7 +869,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getActivePresetIndex(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -904,7 +904,7 @@
} else if (isEnabled() && isValidDevice(device)) {
try {
final SynchronousResultReceiver<BluetoothHapPresetInfo> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getActivePresetInfo(device, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -1123,7 +1123,7 @@
} else if (isEnabled() && isValidDevice(device)) {
try {
final SynchronousResultReceiver<BluetoothHapPresetInfo> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getPresetInfo(device, presetIndex, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -1157,7 +1157,7 @@
} else if (isEnabled() && isValidDevice(device)) {
try {
final SynchronousResultReceiver<List<BluetoothHapPresetInfo>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getAllPresetInfo(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -1189,7 +1189,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getFeatures(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothHeadset.java b/framework/java/android/bluetooth/BluetoothHeadset.java
index dcf0ab7..434542a 100644
--- a/framework/java/android/bluetooth/BluetoothHeadset.java
+++ b/framework/java/android/bluetooth/BluetoothHeadset.java
@@ -494,7 +494,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connectWithAttribution(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -539,7 +539,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnectWithAttribution(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -565,7 +565,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevicesWithAttribution(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -593,7 +593,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -620,7 +620,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionStateWithAttribution(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -661,7 +661,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -717,7 +717,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -745,7 +745,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isNoiseReductionSupported(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -773,7 +773,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isVoiceRecognitionSupported(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -817,7 +817,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.startVoiceRecognition(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -851,7 +851,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.stopVoiceRecognition(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -879,7 +879,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isAudioConnected(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -925,7 +925,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (!isDisabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getAudioState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -988,7 +988,7 @@
return BluetoothStatusCodes.ERROR_PROFILE_SERVICE_NOT_BOUND;
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.setAudioRouteAllowed(allowed, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
return BluetoothStatusCodes.SUCCESS;
@@ -1028,7 +1028,7 @@
return BluetoothStatusCodes.ERROR_PROFILE_SERVICE_NOT_BOUND;
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.getAudioRouteAllowed(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false)
? BluetoothStatusCodes.ALLOWED : BluetoothStatusCodes.NOT_ALLOWED;
@@ -1062,7 +1062,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.setForceScoAudio(forced, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1117,7 +1117,7 @@
return BluetoothStatusCodes.ERROR_PROFILE_SERVICE_NOT_BOUND;
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.connectAudio(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -1172,7 +1172,7 @@
return BluetoothStatusCodes.ERROR_PROFILE_SERVICE_NOT_BOUND;
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.disconnectAudio(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -1226,7 +1226,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.startScoUsingVirtualVoiceCall(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1265,7 +1265,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.stopScoUsingVirtualVoiceCall(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1323,7 +1323,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.clccResponse(index, direction, status, mode, mpty, number, type,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -1367,7 +1367,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.sendVendorSpecificResultCode(device, command, arg,
mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
@@ -1415,7 +1415,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && (device == null || isValidDevice(device))) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setActiveDevice(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1447,7 +1447,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<BluetoothDevice> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getActiveDevice(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -1482,7 +1482,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isInbandRingingEnabled(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothHeadsetClient.java b/framework/java/android/bluetooth/BluetoothHeadsetClient.java
index 1e78f68..d47e41a 100644
--- a/framework/java/android/bluetooth/BluetoothHeadsetClient.java
+++ b/framework/java/android/bluetooth/BluetoothHeadsetClient.java
@@ -804,7 +804,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -835,7 +835,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -866,7 +866,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -903,7 +903,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -938,7 +938,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -999,7 +999,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -1057,7 +1057,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -1094,7 +1094,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.startVoiceRecognition(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1126,7 +1126,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.sendVendorAtCommand(device, vendorId, atCommand, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1160,7 +1160,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.stopVoiceRecognition(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1190,7 +1190,7 @@
} else if (isEnabled() && isValidDevice(device)) {
try {
final SynchronousResultReceiver<List<BluetoothHeadsetClientCall>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getCurrentCalls(device, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -1221,7 +1221,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Bundle> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Bundle> recv = new SynchronousResultReceiver();
service.getCurrentAgEvents(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1254,7 +1254,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.acceptCall(device, flag, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1284,7 +1284,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.holdCall(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1319,7 +1319,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.rejectCall(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1358,7 +1358,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.terminateCall(device, call, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1395,7 +1395,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.enterPrivateMode(device, index, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1431,7 +1431,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.explicitCallTransfer(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1464,7 +1464,7 @@
} else if (isEnabled() && isValidDevice(device)) {
try {
final SynchronousResultReceiver<BluetoothHeadsetClientCall> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.dial(device, number, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -1499,7 +1499,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.sendDTMF(device, code, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1534,7 +1534,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.getLastVoiceTagNumber(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1563,7 +1563,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getAudioState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1594,7 +1594,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.setAudioRouteAllowed(device, allowed, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1623,7 +1623,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.getAudioRouteAllowed(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1655,7 +1655,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connectAudio(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1687,7 +1687,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnectAudio(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1716,7 +1716,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Bundle> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Bundle> recv = new SynchronousResultReceiver();
service.getCurrentAgFeatures(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothHearingAid.java b/framework/java/android/bluetooth/BluetoothHearingAid.java
index 130105d..3fd011f 100644
--- a/framework/java/android/bluetooth/BluetoothHearingAid.java
+++ b/framework/java/android/bluetooth/BluetoothHearingAid.java
@@ -194,7 +194,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -240,7 +240,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -266,7 +266,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -295,7 +295,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -323,7 +323,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -365,7 +365,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && ((device == null) || isValidDevice(device))) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setActiveDevice(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -397,7 +397,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getActiveDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -461,7 +461,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -518,7 +518,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -570,7 +570,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.setVolume(volume, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -605,7 +605,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Long> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Long> recv = new SynchronousResultReceiver();
service.getHiSyncId(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -634,7 +634,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getDeviceSide(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -663,7 +663,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getDeviceMode(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothHidDevice.java b/framework/java/android/bluetooth/BluetoothHidDevice.java
index 46613f7..44a355b 100644
--- a/framework/java/android/bluetooth/BluetoothHidDevice.java
+++ b/framework/java/android/bluetooth/BluetoothHidDevice.java
@@ -466,7 +466,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -491,7 +491,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -515,7 +515,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -577,7 +577,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
CallbackWrapper cbw = new CallbackWrapper(executor, callback, mAttributionSource);
service.registerApp(sdp, inQos, outQos, cbw, mAttributionSource, recv);
result = recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
@@ -608,7 +608,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.unregisterApp(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -636,7 +636,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.sendReport(device, id, data, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -665,7 +665,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.replyReport(device, type, id, data, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -692,7 +692,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.reportError(device, error, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -718,7 +718,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<String> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<String> recv = new SynchronousResultReceiver();
service.getUserAppName(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -746,7 +746,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -773,7 +773,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -818,7 +818,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothHidHost.java b/framework/java/android/bluetooth/BluetoothHidHost.java
index 73c3ca8..ecbeddf 100644
--- a/framework/java/android/bluetooth/BluetoothHidHost.java
+++ b/framework/java/android/bluetooth/BluetoothHidHost.java
@@ -302,7 +302,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -348,7 +348,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -377,7 +377,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -407,7 +407,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -440,7 +440,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -504,7 +504,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -563,7 +563,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -600,7 +600,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.virtualUnplug(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -629,7 +629,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.getProtocolMode(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -658,7 +658,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setProtocolMode(device, protocolMode, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -694,7 +694,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.getReport(device, reportType, reportId, bufferSize, mAttributionSource,
recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
@@ -726,7 +726,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setReport(device, reportType, report, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -756,7 +756,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.sendData(device, report, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -785,7 +785,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.getIdleTime(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -815,7 +815,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setIdleTime(device, idleTime, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothLeAudio.java b/framework/java/android/bluetooth/BluetoothLeAudio.java
index ea39b64..6d9fa07 100644
--- a/framework/java/android/bluetooth/BluetoothLeAudio.java
+++ b/framework/java/android/bluetooth/BluetoothLeAudio.java
@@ -646,7 +646,7 @@
final IBluetoothLeAudio service = getService();
if (service != null) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.registerCallback(mCallback,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout())
@@ -739,7 +739,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -783,7 +783,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -822,7 +822,7 @@
} else if (mAdapter.isEnabled()) {
try {
final SynchronousResultReceiver<BluetoothDevice> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedGroupLeadDevice(groupId, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -850,7 +850,7 @@
} else if (mAdapter.isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -879,7 +879,7 @@
} else if (mAdapter.isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -907,7 +907,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -962,7 +962,7 @@
final IBluetoothLeAudio service = getService();
if (service != null) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.registerCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -1014,7 +1014,7 @@
try {
final IBluetoothLeAudio service = getService();
if (service != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.unregisterCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -1057,7 +1057,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled() && ((device == null) || isValidDevice(device))) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setActiveDevice(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1087,7 +1087,7 @@
} else if (mAdapter.isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getActiveDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -1118,7 +1118,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getGroupId(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1148,7 +1148,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.setVolume(volume, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -1178,7 +1178,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.groupAddNode(group_id, device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1210,7 +1210,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.groupRemoveNode(group_id, device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1248,7 +1248,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getAudioLocation(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultLocation);
} catch (RemoteException | TimeoutException e) {
@@ -1288,7 +1288,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1324,7 +1324,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (mAdapter.isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -1396,7 +1396,7 @@
} else if (mAdapter.isEnabled()) {
try {
final SynchronousResultReceiver<BluetoothLeAudioCodecStatus> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getCodecStatus(groupId, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothLeBroadcast.java b/framework/java/android/bluetooth/BluetoothLeBroadcast.java
index 5db7ea2..3cdf2cd 100644
--- a/framework/java/android/bluetooth/BluetoothLeBroadcast.java
+++ b/framework/java/android/bluetooth/BluetoothLeBroadcast.java
@@ -183,7 +183,7 @@
final IBluetoothLeAudio service = getService();
if (service != null) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.registerLeBroadcastCallback(mCallback,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout())
@@ -442,7 +442,7 @@
final IBluetoothLeAudio service = getService();
if (service != null) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.registerLeBroadcastCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -495,7 +495,7 @@
try {
final IBluetoothLeAudio service = getService();
if (service != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.unregisterLeBroadcastCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -662,7 +662,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isPlaying(broadcastId, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -696,7 +696,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothLeBroadcastMetadata>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getAllBroadcastMetadata(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
@@ -723,7 +723,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getMaximumNumberOfBroadcasts(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothManager.java b/framework/java/android/bluetooth/BluetoothManager.java
index 3fcb58a..7ab32f3 100644
--- a/framework/java/android/bluetooth/BluetoothManager.java
+++ b/framework/java/android/bluetooth/BluetoothManager.java
@@ -172,7 +172,7 @@
IBluetoothGatt iGatt = managerService.getBluetoothGatt();
if (iGatt == null) return devices;
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
iGatt.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
devices = Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(devices),
diff --git a/framework/java/android/bluetooth/BluetoothMap.java b/framework/java/android/bluetooth/BluetoothMap.java
index 2d4bc56..a8b4834 100644
--- a/framework/java/android/bluetooth/BluetoothMap.java
+++ b/framework/java/android/bluetooth/BluetoothMap.java
@@ -154,7 +154,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getState(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -184,7 +184,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<BluetoothDevice> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getClient(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -214,7 +214,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isConnected(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -256,7 +256,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -312,7 +312,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -343,7 +343,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -393,7 +393,7 @@
log("getConnectionState(" + pairQuery.second.getAnonymizedAddress()
+ ") uncached");
}
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
try {
pairQuery.first
.getConnectionState(pairQuery.second, mAttributionSource, recv);
@@ -490,7 +490,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -546,7 +546,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothMapClient.java b/framework/java/android/bluetooth/BluetoothMapClient.java
index 5241410..be3e48a 100644
--- a/framework/java/android/bluetooth/BluetoothMapClient.java
+++ b/framework/java/android/bluetooth/BluetoothMapClient.java
@@ -267,7 +267,7 @@
if (DBG) Log.d(TAG, Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isConnected(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -297,7 +297,7 @@
if (DBG) Log.d(TAG, Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -329,7 +329,7 @@
if (DBG) Log.d(TAG, Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -360,7 +360,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -397,7 +397,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -432,7 +432,7 @@
if (DBG) Log.d(TAG, Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver<>();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -496,7 +496,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -555,7 +555,7 @@
if (DBG) Log.d(TAG, Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -623,7 +623,7 @@
if (DBG) Log.d(TAG, Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.sendMessage(device, contacts, message, sentIntent, deliveredIntent,
mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
@@ -655,7 +655,7 @@
if (DBG) Log.d(TAG, Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.getUnreadMessages(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -684,7 +684,7 @@
if (DBG) Log.d(TAG, Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getSupportedFeatures(device, mAttributionSource, recv);
return (recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue)
& UPLOADING_FEATURE_BITMASK) > 0;
@@ -726,7 +726,7 @@
} else if (isEnabled() && isValidDevice(device) && handle != null && (status == READ
|| status == UNREAD || status == UNDELETED || status == DELETED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setMessageStatus(device, handle, status, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothPan.java b/framework/java/android/bluetooth/BluetoothPan.java
index 2f6fe4e..3aafec9 100644
--- a/framework/java/android/bluetooth/BluetoothPan.java
+++ b/framework/java/android/bluetooth/BluetoothPan.java
@@ -222,7 +222,7 @@
"The tethered interface has already been released.");
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mService.setBluetoothTethering(mPanCallback, mId, false, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -309,7 +309,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -353,7 +353,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -393,7 +393,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -424,7 +424,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -457,7 +457,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -489,7 +489,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -525,7 +525,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.setBluetoothTethering(null, 0, value, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -583,7 +583,7 @@
}
};
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.setBluetoothTethering(panCallback, callback.hashCode(), true,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -614,7 +614,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isTetheringOn(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothPbapClient.java b/framework/java/android/bluetooth/BluetoothPbapClient.java
index 1a29cea..e10f5e5 100644
--- a/framework/java/android/bluetooth/BluetoothPbapClient.java
+++ b/framework/java/android/bluetooth/BluetoothPbapClient.java
@@ -172,7 +172,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.connect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -206,7 +206,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
return true;
@@ -240,7 +240,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -279,7 +279,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -316,7 +316,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -394,7 +394,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
@@ -455,7 +455,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException e) {
diff --git a/framework/java/android/bluetooth/BluetoothSap.java b/framework/java/android/bluetooth/BluetoothSap.java
index 137c25b..100f1d8 100644
--- a/framework/java/android/bluetooth/BluetoothSap.java
+++ b/framework/java/android/bluetooth/BluetoothSap.java
@@ -182,7 +182,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getState(mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -211,7 +211,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<BluetoothDevice> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getClient(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -241,7 +241,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.isConnected(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -282,7 +282,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.disconnect(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -310,7 +310,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -340,7 +340,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -390,7 +390,7 @@
log("getConnectionState(" + pairQuery.second.getAnonymizedAddress()
+ ") uncached");
}
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
try {
pairQuery.first
.getConnectionState(pairQuery.second, mAttributionSource, recv);
@@ -491,7 +491,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -552,7 +552,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/BluetoothVolumeControl.java b/framework/java/android/bluetooth/BluetoothVolumeControl.java
index d76a086..080b9a6 100644
--- a/framework/java/android/bluetooth/BluetoothVolumeControl.java
+++ b/framework/java/android/bluetooth/BluetoothVolumeControl.java
@@ -157,7 +157,7 @@
final IBluetoothVolumeControl service = getService();
if (service != null) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.registerCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -245,7 +245,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getConnectedDevices(mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -276,7 +276,7 @@
} else if (isEnabled()) {
try {
final SynchronousResultReceiver<List<BluetoothDevice>> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.getDevicesMatchingConnectionStates(states, mAttributionSource, recv);
return Attributable.setAttributionSource(
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue),
@@ -306,7 +306,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionState(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -355,7 +355,7 @@
final IBluetoothVolumeControl service = getService();
if (service != null) {
final SynchronousResultReceiver<Integer> recv =
- SynchronousResultReceiver.get();
+ new SynchronousResultReceiver();
service.registerCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -406,7 +406,7 @@
try {
final IBluetoothVolumeControl service = getService();
if (service != null) {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.unregisterCallback(mCallback, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -442,7 +442,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled()) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.setVolumeOffset(device, volumeOffset, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
@@ -483,7 +483,7 @@
final boolean defaultValue = false;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
service.isVolumeOffsetAvailable(device, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -523,7 +523,7 @@
&& (connectionPolicy == BluetoothProfile.CONNECTION_POLICY_FORBIDDEN
|| connectionPolicy == BluetoothProfile.CONNECTION_POLICY_ALLOWED)) {
try {
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
service.setConnectionPolicy(device, connectionPolicy, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
@@ -559,7 +559,7 @@
if (DBG) log(Log.getStackTraceString(new Throwable()));
} else if (isEnabled() && isValidDevice(device)) {
try {
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
service.getConnectionPolicy(device, mAttributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(defaultValue);
} catch (RemoteException | TimeoutException e) {
diff --git a/framework/java/android/bluetooth/le/AdvertisingSet.java b/framework/java/android/bluetooth/le/AdvertisingSet.java
index d65e485..cad62c3 100644
--- a/framework/java/android/bluetooth/le/AdvertisingSet.java
+++ b/framework/java/android/bluetooth/le/AdvertisingSet.java
@@ -81,7 +81,7 @@
public void enableAdvertising(boolean enable, int duration,
int maxExtendedAdvertisingEvents) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mGatt.enableAdvertisingSet(mAdvertiserId, enable, duration,
maxExtendedAdvertisingEvents, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -107,7 +107,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_ADVERTISE)
public void setAdvertisingData(AdvertiseData advertiseData) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mGatt.setAdvertisingData(mAdvertiserId, advertiseData, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -129,7 +129,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_ADVERTISE)
public void setScanResponseData(AdvertiseData scanResponse) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mGatt.setScanResponseData(mAdvertiserId, scanResponse, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -149,7 +149,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_ADVERTISE)
public void setAdvertisingParameters(AdvertisingSetParameters parameters) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mGatt.setAdvertisingParameters(mAdvertiserId, parameters, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -167,7 +167,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_ADVERTISE)
public void setPeriodicAdvertisingParameters(PeriodicAdvertisingParameters parameters) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mGatt.setPeriodicAdvertisingParameters(mAdvertiserId, parameters, mAttributionSource,
recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -191,7 +191,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_ADVERTISE)
public void setPeriodicAdvertisingData(AdvertiseData periodicData) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mGatt.setPeriodicAdvertisingData(mAdvertiserId, periodicData, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -211,7 +211,7 @@
@RequiresPermission(android.Manifest.permission.BLUETOOTH_ADVERTISE)
public void setPeriodicAdvertisingEnabled(boolean enable) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mGatt.setPeriodicAdvertisingEnable(mAdvertiserId, enable, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -233,7 +233,7 @@
})
public void getOwnAddress() {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mGatt.getOwnAddress(mAdvertiserId, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
diff --git a/framework/java/android/bluetooth/le/BluetoothLeAdvertiser.java b/framework/java/android/bluetooth/le/BluetoothLeAdvertiser.java
index 26c8567..c77448f 100644
--- a/framework/java/android/bluetooth/le/BluetoothLeAdvertiser.java
+++ b/framework/java/android/bluetooth/le/BluetoothLeAdvertiser.java
@@ -463,7 +463,7 @@
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
gatt.startAdvertisingSet(parameters, advertiseData, scanResponse, periodicParameters,
periodicData, duration, maxExtendedAdvertisingEvents, wrapped,
mAttributionSource, recv);
@@ -496,7 +496,7 @@
IBluetoothGatt gatt;
try {
gatt = mBluetoothManager.getBluetoothGatt();
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
gatt.stopAdvertisingSet(wrapped, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
diff --git a/framework/java/android/bluetooth/le/BluetoothLeScanner.java b/framework/java/android/bluetooth/le/BluetoothLeScanner.java
index 28d408e..f5f963e 100644
--- a/framework/java/android/bluetooth/le/BluetoothLeScanner.java
+++ b/framework/java/android/bluetooth/le/BluetoothLeScanner.java
@@ -282,7 +282,7 @@
wrapper.startRegistration();
} else {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
gatt.startScanForIntent(callbackIntent, settings, filters,
mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
@@ -330,7 +330,7 @@
IBluetoothGatt gatt;
try {
gatt = mBluetoothManager.getBluetoothGatt();
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
gatt.stopScanForIntent(callbackIntent, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -428,7 +428,7 @@
// Scan stopped.
if (mScannerId == -1 || mScannerId == -2) return;
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mBluetoothGatt.registerScanner(this, mWorkSource, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
wait(REGISTRATION_CALLBACK_TIMEOUT_MILLIS);
@@ -460,11 +460,11 @@
return;
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mBluetoothGatt.stopScan(mScannerId, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
- final SynchronousResultReceiver recv2 = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv2 = new SynchronousResultReceiver();
mBluetoothGatt.unregisterScanner(mScannerId, mAttributionSource, recv2);
recv2.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -482,7 +482,7 @@
return;
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mBluetoothGatt.flushPendingBatchResults(mScannerId, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -501,7 +501,7 @@
synchronized (this) {
if (status == BluetoothGatt.GATT_SUCCESS) {
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
if (mScannerId == -1) {
// Registration succeeds after timeout, unregister scanner.
mBluetoothGatt.unregisterScanner(scannerId, mAttributionSource, recv);
diff --git a/framework/java/android/bluetooth/le/PeriodicAdvertisingManager.java b/framework/java/android/bluetooth/le/PeriodicAdvertisingManager.java
index 7711a00..13b7163 100644
--- a/framework/java/android/bluetooth/le/PeriodicAdvertisingManager.java
+++ b/framework/java/android/bluetooth/le/PeriodicAdvertisingManager.java
@@ -177,7 +177,7 @@
mCallbackWrappers.put(callback, wrapped);
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
gatt.registerSync(scanResult, skip, timeout, wrapped, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -215,7 +215,7 @@
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
gatt.unregisterSync(wrapper, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -246,7 +246,7 @@
return;
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
gatt.transferSync(bda, serviceData , syncHandle, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (TimeoutException | RemoteException e) {
@@ -291,7 +291,7 @@
throw new IllegalArgumentException("callback was not properly registered");
}
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
gatt.transferSetInfo(bda, serviceData , advHandle, wrapper, mAttributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {
diff --git a/service/java/com/android/server/bluetooth/BluetoothManagerService.java b/service/java/com/android/server/bluetooth/BluetoothManagerService.java
index 211154c..a7d9831 100644
--- a/service/java/com/android/server/bluetooth/BluetoothManagerService.java
+++ b/service/java/com/android/server/bluetooth/BluetoothManagerService.java
@@ -794,7 +794,7 @@
private boolean synchronousDisable(AttributionSource attributionSource)
throws RemoteException, TimeoutException {
if (mBluetooth == null) return false;
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mBluetooth.disable(attributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -803,7 +803,7 @@
private boolean synchronousEnable(boolean quietMode, AttributionSource attributionSource)
throws RemoteException, TimeoutException {
if (mBluetooth == null) return false;
- final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Boolean> recv = new SynchronousResultReceiver();
mBluetooth.enable(quietMode, attributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(false);
}
@@ -812,7 +812,7 @@
private String synchronousGetAddress(AttributionSource attributionSource)
throws RemoteException, TimeoutException {
if (mBluetooth == null) return null;
- final SynchronousResultReceiver<String> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<String> recv = new SynchronousResultReceiver();
mBluetooth.getAddressWithAttribution(attributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -821,7 +821,7 @@
private String synchronousGetName(AttributionSource attributionSource)
throws RemoteException, TimeoutException {
if (mBluetooth == null) return null;
- final SynchronousResultReceiver<String> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<String> recv = new SynchronousResultReceiver();
mBluetooth.getName(attributionSource, recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -830,7 +830,7 @@
private int synchronousGetState()
throws RemoteException, TimeoutException {
if (mBluetooth == null) return BluetoothAdapter.STATE_OFF;
- final SynchronousResultReceiver<Integer> recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver<Integer> recv = new SynchronousResultReceiver();
mBluetooth.getState(recv);
return recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(BluetoothAdapter.STATE_OFF);
}
@@ -839,7 +839,7 @@
private void synchronousOnBrEdrDown(AttributionSource attributionSource)
throws RemoteException, TimeoutException {
if (mBluetooth == null) return;
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mBluetooth.onBrEdrDown(attributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -848,7 +848,7 @@
private void synchronousOnLeServiceUp(AttributionSource attributionSource)
throws RemoteException, TimeoutException {
if (mBluetooth == null) return;
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mBluetooth.onLeServiceUp(attributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -857,7 +857,7 @@
private void synchronousRegisterCallback(IBluetoothCallback callback,
AttributionSource attributionSource) throws RemoteException, TimeoutException {
if (mBluetooth == null) return;
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mBluetooth.registerCallback(callback, attributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -866,7 +866,7 @@
private void synchronousUnregisterCallback(IBluetoothCallback callback,
AttributionSource attributionSource) throws RemoteException, TimeoutException {
if (mBluetooth == null) return;
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mBluetooth.unregisterCallback(callback, attributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
}
@@ -1223,7 +1223,7 @@
if (isBleAppPresent()) {
// Need to stay at BLE ON. Disconnect all Gatt connections
try {
- final SynchronousResultReceiver recv = SynchronousResultReceiver.get();
+ final SynchronousResultReceiver recv = new SynchronousResultReceiver();
mBluetoothGatt.unregAll(attributionSource, recv);
recv.awaitResultNoInterrupt(getSyncTimeout()).getValue(null);
} catch (RemoteException | TimeoutException e) {