Android/frameworks_base
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge "Prevent modifying mAudioPolicies during iteration" into tm-qpr-dev

Browse Source
This commit is contained in:
Atneya Nair
2022-08-20 00:48:57 +00:00
committed by Android (Google) Code Review
parent 4c8cb70261 65b8980444
commit 7926ae7f37
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
services/core/java/com/android/server/audio/AudioService.java
View File

@@ -1614,6 +1614,7 @@ public class AudioService extends IAudioService.Stub
} }
synchronized (mAudioPolicies) { synchronized (mAudioPolicies) {
ArrayList<AudioPolicyProxy> invalidProxies = new ArrayList<>();
for (AudioPolicyProxy policy : mAudioPolicies.values()) { for (AudioPolicyProxy policy : mAudioPolicies.values()) {
final int status = policy.connectMixes(); final int status = policy.connectMixes();
if (status != AudioSystem.SUCCESS) { if (status != AudioSystem.SUCCESS) {
@@ -1621,7 +1622,7 @@ public class AudioService extends IAudioService.Stub
Log.e(TAG, "onAudioServerDied: error " Log.e(TAG, "onAudioServerDied: error "
+ AudioSystem.audioSystemErrorToString(status) + AudioSystem.audioSystemErrorToString(status)
+ " when connecting mixes for policy " + policy.toLogFriendlyString()); + " when connecting mixes for policy " + policy.toLogFriendlyString());
policy.release(); invalidProxies.add(policy);
} else { } else {
final int deviceAffinitiesStatus = policy.setupDeviceAffinities(); final int deviceAffinitiesStatus = policy.setupDeviceAffinities();
if (deviceAffinitiesStatus != AudioSystem.SUCCESS) { if (deviceAffinitiesStatus != AudioSystem.SUCCESS) {
@@ -1629,10 +1630,12 @@ public class AudioService extends IAudioService.Stub
+ AudioSystem.audioSystemErrorToString(deviceAffinitiesStatus) + AudioSystem.audioSystemErrorToString(deviceAffinitiesStatus)
+ " when connecting device affinities for policy " + " when connecting device affinities for policy "
+ policy.toLogFriendlyString()); + policy.toLogFriendlyString());
policy.release(); invalidProxies.add(policy);
} }
} }
} }
invalidProxies.forEach((policy) -> policy.release());
} }
// Restore capture policies // Restore capture policies