Fix race condition in DefaultSocketApi causing disconnection loop whe…

…n changing credentials
jellyfin · Nov 19, 2024 · 89d3146 · 89d3146
1 parent d7656db
commit 89d3146
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/jellyfin-api/src/commonMain/kotlin/org/jellyfin/sdk/api/sockets/DefaultSocketApi.kt b/jellyfin-api/src/commonMain/kotlin/org/jellyfin/sdk/api/sockets/DefaultSocketApi.kt
@@ -144,7 +144,7 @@ public class DefaultSocketApi(
 		.state
 		.onEach { connectionState ->
 			// Automatically reconnect when the socket is closed while subscriptions are active
-			if (_subscriptionCount > 0 && _currentCredentials != null && connectionState is SocketConnectionState.Disconnected) {
+			if (_subscriptionCount > 0 && _currentCredentials != null && connectionState is SocketConnectionState.Disconnected && !reconnectMutex.isLocked) {
 				socketReconnectPolicy.notifyDisconnected()
 
 				val reconnectDelay = socketReconnectPolicy.getReconnectDelay()