diff options
author | William Escande <wescande@google.com> | 2022-04-14 05:25:31 +0000 |
---|---|---|
committer | Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com> | 2022-04-14 05:25:31 +0000 |
commit | f836ba2d0cc932c5ddadb5158184174416e886bb (patch) | |
tree | d539edaac8d71c7b00806aee31cc506477050136 /framework/java/android/bluetooth/BluetoothAdapter.java | |
parent | fcba111bd30469d84637f8de2a19d4a850358c5f (diff) | |
parent | aa1288c9d21455d588bc52603fa1472f5f2d58eb (diff) |
Merge "Fix write lock locking mechanisme" am: c7ceab19a8 am: aa1288c9d2
Original change: https://android-review.googlesource.com/c/platform/packages/modules/Bluetooth/+/2063178
Change-Id: Icee07d0383a0dfffe0cea4e6ae5356e8e1aefc87
Signed-off-by: Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
Diffstat (limited to 'framework/java/android/bluetooth/BluetoothAdapter.java')
-rw-r--r-- | framework/java/android/bluetooth/BluetoothAdapter.java | 19 |
1 files changed, 16 insertions, 3 deletions
diff --git a/framework/java/android/bluetooth/BluetoothAdapter.java b/framework/java/android/bluetooth/BluetoothAdapter.java index 4f17110e65..1759276de6 100644 --- a/framework/java/android/bluetooth/BluetoothAdapter.java +++ b/framework/java/android/bluetooth/BluetoothAdapter.java @@ -82,6 +82,7 @@ import java.util.UUID; import java.util.WeakHashMap; import java.util.concurrent.Executor; import java.util.concurrent.TimeoutException; +import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantReadWriteLock; /** @@ -962,8 +963,12 @@ public final class BluetoothAdapter { BluetoothAdapter(IBluetoothManager managerService, AttributionSource attributionSource) { mManagerService = Objects.requireNonNull(managerService); mAttributionSource = Objects.requireNonNull(attributionSource); - synchronized (mServiceLock.writeLock()) { + Lock l = mServiceLock.writeLock(); + l.lock(); + try { mService = getBluetoothService(mManagerCallback); + } finally { + l.unlock(); } mLeScanClients = new HashMap<LeScanCallback, ScanCallback>(); mToken = new Binder(DESCRIPTOR); @@ -3859,8 +3864,12 @@ public final class BluetoothAdapter { private final IBluetoothManagerCallback mManagerCallback = new IBluetoothManagerCallback.Stub() { public void onBluetoothServiceUp(IBluetooth bluetoothService) { - synchronized (mServiceLock.writeLock()) { + Lock l = mServiceLock.writeLock(); + l.lock(); + try { mService = bluetoothService; + } finally { + l.unlock(); } synchronized (mMetadataListeners) { mMetadataListeners.forEach((device, pair) -> { @@ -3894,7 +3903,9 @@ public final class BluetoothAdapter { } public void onBluetoothServiceDown() { - synchronized (mServiceLock.writeLock()) { + Lock l = mServiceLock.writeLock(); + l.lock(); + try { mService = null; if (mLeScanClients != null) { mLeScanClients.clear(); @@ -3905,6 +3916,8 @@ public final class BluetoothAdapter { if (mBluetoothLeScanner != null) { mBluetoothLeScanner.cleanup(); } + } finally { + l.unlock(); } } |