x/grayjay
1
0
Fork 0
mirror of https://gitlab.futo.org/videostreaming/grayjay.git synced 2026-05-16 04:52:39 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fixed exception in sync.

Browse Source
This commit is contained in:
Koen J
2025-06-05 10:45:36 +02:00
parent 7b53315046
commit 401999b5ea
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/src/main/java/com/futo/platformplayer/sync/internal/SyncSocketSession.kt
+2 -2
View File
@@ -814,7 +814,7 @@ class SyncSocketSession {
return return
} }
val decryptedPayload = channel.decrypt(data) val decryptedPayload = channel.decrypt(data)
val errorCode = SyncErrorCode.entries.find { it.value == decryptedPayload.int } ?: SyncErrorCode.ConnectionClosed val errorCode = decryptedPayload.int
Logger.e(TAG, "Received relayed error (errorCode = $errorCode) on connectionId $connectionId, closing") Logger.e(TAG, "Received relayed error (errorCode = $errorCode) on connectionId $connectionId, closing")
channel.close() channel.close()
_channels.remove(connectionId) _channels.remove(connectionId)
@@ -825,7 +825,7 @@ class SyncSocketSession {
return return
} }
val connectionId = data.long val connectionId = data.long
val errorCode = SyncErrorCode.entries.find { it.value == data.int } ?: SyncErrorCode.ConnectionClosed val errorCode = data.int
val channel = _channels[connectionId] ?: run { val channel = _channels[connectionId] ?: run {
Logger.e(TAG, "Received error code $errorCode for non-existent channel with connectionId $connectionId") Logger.e(TAG, "Received error code $errorCode for non-existent channel with connectionId $connectionId")
return return