Fix race condition in PeerConnectionTransport.trackBitrates

adrian-niculescu · adrian-niculescu · commit 7ff2a4959270 · 2026-05-20T00:16:05.000+03:00
diff --git a/.changeset/fix-track-bitrates-race-condition.md b/.changeset/fix-track-bitrates-race-condition.md
@@ -0,0 +1,5 @@
+---
+"client-sdk-android": patch
+---
+
+Fixed race condition in `PeerConnectionTransport.trackBitrates` by ensuring writes happen on the RTC thread.
diff --git a/livekit-android-sdk/src/main/java/io/livekit/android/room/PeerConnectionTransport.kt b/livekit-android-sdk/src/main/java/io/livekit/android/room/PeerConnectionTransport.kt
@@ -325,11 +325,15 @@ constructor(
     }
 
     fun registerTrackBitrateInfo(cid: String, trackBitrateInfo: TrackBitrateInfo) {
-        trackBitrates[TrackBitrateInfoKey.Cid(cid)] = trackBitrateInfo
+        executeRTCIfNotClosed {
+            trackBitrates[TrackBitrateInfoKey.Cid(cid)] = trackBitrateInfo
+        }
     }
 
     fun registerTrackBitrateInfo(transceiver: RtpTransceiver, trackBitrateInfo: TrackBitrateInfo) {
-        trackBitrates[TrackBitrateInfoKey.Transceiver(transceiver)] = trackBitrateInfo
+        executeRTCIfNotClosed {
+            trackBitrates[TrackBitrateInfoKey.Transceiver(transceiver)] = trackBitrateInfo
+        }
     }
 
     suspend fun isConnected(): Boolean {

-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +---
 +"client-sdk-android": patch
 +---
++
 +Fixed race condition in `PeerConnectionTransport.trackBitrates` by ensuring writes happen on the RTC thread.
Original file line number	Diff line number	Diff line change
`@@ -325,11 +325,15 @@ constructor(`
`325`	`325`	`}`
`326`	`326`
`327`	`327`	`fun registerTrackBitrateInfo(cid: String, trackBitrateInfo: TrackBitrateInfo) {`
`328`		`- trackBitrates[TrackBitrateInfoKey.Cid(cid)] = trackBitrateInfo`
	`328`	`+ executeRTCIfNotClosed {`
	`329`	`+ trackBitrates[TrackBitrateInfoKey.Cid(cid)] = trackBitrateInfo`
	`330`	`+ }`
`329`	`331`	`}`
`330`	`332`
`331`	`333`	`fun registerTrackBitrateInfo(transceiver: RtpTransceiver, trackBitrateInfo: TrackBitrateInfo) {`
`332`		`- trackBitrates[TrackBitrateInfoKey.Transceiver(transceiver)] = trackBitrateInfo`
	`334`	`+ executeRTCIfNotClosed {`
	`335`	`+ trackBitrates[TrackBitrateInfoKey.Transceiver(transceiver)] = trackBitrateInfo`
	`336`	`+ }`
`333`	`337`	`}`
`334`	`338`
`335`	`339`	`suspend fun isConnected(): Boolean {`