Merge 5cdf0c4 into f982bad

runningcode · web-flow · commit 5f1e9d5d8370 · 2026-06-23T12:43:22.000Z
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -5,6 +5,7 @@
 ### Fixes
 
 - Release `MediaMuxer` when a replay segment has no encodable frames to avoid a resource leak ([#5583](https://github.com/getsentry/sentry-java/pull/5583))
+- Release `MediaMuxer` when the replay video encoder fails to start to avoid a resource leak ([#5607](https://github.com/getsentry/sentry-java/pull/5607))
 
 ## 8.44.1
 
diff --git a/sentry-android-replay/src/main/java/io/sentry/android/replay/ReplayCache.kt b/sentry-android-replay/src/main/java/io/sentry/android/replay/ReplayCache.kt
@@ -162,7 +162,16 @@ public class ReplayCache(private val options: SentryOptions, private val replayI
               bitRate = bitRate,
             ),
           )
-          .also { it.start() }
+          .apply {
+            // the constructor already opened the MediaMuxer, so release it if start() fails,
+            // otherwise the encoder is never assigned and its resources leak (CloseGuard warning)
+            try {
+              start()
+            } catch (t: Throwable) {
+              release()
+              throw t
+            }
+          }
       }
 
     val step = 1000 / frameRate.toLong()
diff --git a/sentry-android-replay/src/main/java/io/sentry/android/replay/video/SimpleVideoEncoder.kt b/sentry-android-replay/src/main/java/io/sentry/android/replay/video/SimpleVideoEncoder.kt
@@ -289,10 +289,12 @@ internal class SimpleVideoEncoder(
       mediaCodec.stop()
       mediaCodec.release()
       surface?.release()
-
-      frameMuxer.release()
     } catch (e: Throwable) {
       options.logger.log(DEBUG, "Failed to properly release video encoder", e)
+    } finally {
+      // always release the muxer, even if draining/stopping the codec above threw (e.g. when the
+      // encoder failed to fully start), otherwise its MediaMuxer leaks (CloseGuard warning)
+      frameMuxer.release()
     }
   }
 }
diff --git a/sentry-android-replay/src/test/java/io/sentry/android/replay/ReplayCacheTest.kt b/sentry-android-replay/src/test/java/io/sentry/android/replay/ReplayCacheTest.kt
@@ -27,6 +27,7 @@ import java.util.concurrent.atomic.AtomicReference
 import kotlin.test.BeforeTest
 import kotlin.test.Test
 import kotlin.test.assertEquals
+import kotlin.test.assertFailsWith
 import kotlin.test.assertFalse
 import kotlin.test.assertNull
 import kotlin.test.assertTrue
@@ -35,6 +36,7 @@ import org.junit.rules.TemporaryFolder
 import org.junit.runner.RunWith
 import org.robolectric.annotation.Config
 import org.robolectric.shadows.ShadowBitmapFactory
+import org.robolectric.shadows.ShadowCloseGuard
 
 @RunWith(AndroidJUnit4::class)
 @Config(sdk = [26], shadows = [ReplayShadowMediaCodec::class])
@@ -55,6 +57,7 @@ class ReplayCacheTest {
   @BeforeTest
   fun `set up`() {
     ReplayShadowMediaCodec.framesToEncode = 5
+    ReplayShadowMediaCodec.throwOnStart = false
     ShadowBitmapFactory.setAllowInvalidImageData(true)
   }
 
@@ -92,6 +95,26 @@ class ReplayCacheTest {
     assertNull(video)
   }
 
+  @Test
+  fun `releases the muxer when the encoder fails to start`() {
+    ReplayShadowMediaCodec.throwOnStart = true
+    val replayCache = fixture.getSut(tmpDir)
+
+    val bitmap = Bitmap.createBitmap(1, 1, ARGB_8888)
+    replayCache.addFrame(bitmap, 1)
+
+    ShadowCloseGuard.reset()
+    assertFailsWith<IllegalStateException> {
+      replayCache.createVideoOf(5000L, 0, 0, 100, 200, 1, 20_000)
+    }
+
+    val muxerLeaks =
+      ShadowCloseGuard.getErrors().filter { error ->
+        error.stackTrace.any { it.className.contains("MediaMuxer") }
+      }
+    assertTrue(muxerLeaks.isEmpty(), "MediaMuxer was not released: $muxerLeaks")
+  }
+
   @Test
   fun `deletes frames after creating a video`() {
     ReplayShadowMediaCodec.framesToEncode = 3
diff --git a/sentry-android-replay/src/test/java/io/sentry/android/replay/util/ReplayShadowMediaCodec.kt b/sentry-android-replay/src/test/java/io/sentry/android/replay/util/ReplayShadowMediaCodec.kt
@@ -15,12 +15,16 @@ class ReplayShadowMediaCodec : ShadowMediaCodec() {
   companion object {
     var frameRate = 1
     var framesToEncode = 5
+    var throwOnStart = false
   }
 
   private val encoded = AtomicBoolean(false)
 
   @Implementation
   fun start() {
+    if (throwOnStart) {
+      throw IllegalStateException("Simulated codec start failure")
+    }
     super.native_start()
   }
 

Original file line number	Diff line number	Diff line change
`@@ -289,10 +289,12 @@ internal class SimpleVideoEncoder(`
`289`	`289`	`mediaCodec.stop()`
`290`	`290`	`mediaCodec.release()`
`291`	`291`	`surface?.release()`
`292`		`-`
`293`		`- frameMuxer.release()`
`294`	`292`	`} catch (e: Throwable) {`
`295`	`293`	`options.logger.log(DEBUG, "Failed to properly release video encoder", e)`
	`294`	`+ } finally {`
	`295`	`+ // always release the muxer, even if draining/stopping the codec above threw (e.g. when the`
	`296`	`+ // encoder failed to fully start), otherwise its MediaMuxer leaks (CloseGuard warning)`
	`297`	`+ frameMuxer.release()`
`296`	`298`	`}`
`297`	`299`	`}`
`298`	`300`	`}`
Original file line number	Diff line number	Diff line change
`@@ -15,12 +15,16 @@ class ReplayShadowMediaCodec : ShadowMediaCodec() {`
`15`	`15`	`companion object {`
`16`	`16`	`var frameRate = 1`
`17`	`17`	`var framesToEncode = 5`
	`18`	`+ var throwOnStart = false`
`18`	`19`	`}`
`19`	`20`
`20`	`21`	`private val encoded = AtomicBoolean(false)`
`21`	`22`
`22`	`23`	`@Implementation`
`23`	`24`	`fun start() {`
	`25`	`+ if (throwOnStart) {`
	`26`	`+ throw IllegalStateException("Simulated codec start failure")`
	`27`	`+ }`
`24`	`28`	`super.native_start()`
`25`	`29`	`}`
`26`	`30`