sjs/media
1
0
Fork 0
mirror of https://github.com/samsonjs/media.git synced 2026-04-03 10:55:48 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add missing Future cancellation checks

Browse source 
Future.isDone and getDone doesn't imply the Future was successful
and it may have been cancelled or failed.

In case where we handle failure, we should also handle cancellation
to avoid CancellationException to bubble up unchecked.

In demo app code where we use isDone for field initialization, we
want to crash in the failure case (usually security exception where
the connection is disallowed), but we want to gracefully handle
cancellation. Cancellation of these variables usually happens in
Activity.onDestroy/onStop, but methods may be called after this point.

#minor-release

PiperOrigin-RevId: 572178018
(cherry picked from commit fe7c62afe0)
This commit is contained in:
tonihei 2023-10-10 02:12:22 -07:00 committed by Rohit Singh
parent c913237e92
commit 7d063e9aab
5 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
demos/session/src/main/java/androidx/media3/demo/session/PlayableFolderActivity.kt
View file

@ -43,7 +43,7 @@ import com.google.common.util.concurrent.ListenableFuture
class PlayableFolderActivity : AppCompatActivity() {
private lateinit var browserFuture: ListenableFuture<MediaBrowser>
private val browser: MediaBrowser?
get() = if (browserFuture.isDone) browserFuture.get() else null
get() = if (browserFuture.isDone && !browserFuture.isCancelled) browserFuture.get() else null
private lateinit var mediaList: ListView
private lateinit var mediaListAdapter: PlayableMediaItemArrayAdapter

3
demos/session/src/main/java/androidx/media3/demo/session/PlayerActivity.kt
View file

@ -45,7 +45,8 @@ import com.google.common.util.concurrent.MoreExecutors
class PlayerActivity : AppCompatActivity() {
private lateinit var controllerFuture: ListenableFuture<MediaController>
private val controller: MediaController?
get() = if (controllerFuture.isDone) controllerFuture.get() else null
get() =
if (controllerFuture.isDone && !controllerFuture.isCancelled) controllerFuture.get() else null
private lateinit var playerView: PlayerView
private lateinit var mediaItemListView: ListView

3
libraries/session/src/main/java/androidx/media3/session/DefaultMediaNotificationProvider.java
View file

@ -53,6 +53,7 @@ import com.google.common.util.concurrent.ListenableFuture;
import com.google.errorprone.annotations.CanIgnoreReturnValue;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import org.checkerframework.checker.nullness.qual.MonotonicNonNull;
@ -348,7 +349,7 @@ public class DefaultMediaNotificationProvider implements MediaNotification.Provi
if (bitmapFuture.isDone()) {
try {
builder.setLargeIcon(Futures.getDone(bitmapFuture));
} catch (ExecutionException e) {
} catch (CancellationException | ExecutionException e) {
Log.w(TAG, getBitmapLoadErrorMessage(e));
}
} else {

4
libraries/session/src/main/java/androidx/media3/session/MediaNotificationManager.java
View file

@ -214,7 +214,7 @@ import java.util.concurrent.TimeoutException;
if (controllerAndListener != null && controllerAndListener.controller.isDone()) {
try {
mediaNotificationController = Futures.getDone(controllerAndListener.controller);
} catch (ExecutionException e) {
} catch (CancellationException | ExecutionException e) {
// Ignore.
}
}
@ -323,7 +323,7 @@ import java.util.concurrent.TimeoutException;
}
try {
return Futures.getDone(controllerAndListener.controller);
} catch (ExecutionException exception) {
} catch (CancellationException | ExecutionException exception) {
// We should never reach this.
throw new IllegalStateException(exception);
}

2
libraries/session/src/main/java/androidx/media3/session/MediaSessionLegacyStub.java
View file

@ -1375,7 +1375,7 @@ import org.checkerframework.checker.initialization.qual.Initialized;
if (bitmapFuture.isDone()) {
try {
artworkBitmap = Futures.getDone(bitmapFuture);
} catch (ExecutionException e) {
} catch (CancellationException | ExecutionException e) {
Log.w(TAG, getBitmapLoadErrorMessage(e));
}
} else {