mirrors/grayjay
1
0
Fork 0
mirror of https://gitlab.futo.org/videostreaming/grayjay.git synced 2025-04-20 03:24:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Made FCastCastingDevice more able to reconnect.

Browse source
This commit is contained in:
Koen 2023-12-13 13:47:38 +01:00
parent 52d833d726
commit 7bfab8409f
2 changed files with 13 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
app/src/main/java/com/futo/platformplayer/casting/FCastCastingDevice.kt
View file

@ -261,7 +261,8 @@ class FCastCastingDevice : CastingDevice {
val buffer = ByteArray(4096);
Logger.i(TAG, "Started receiving.");
while (_scopeIO?.isActive == true) {
var exceptionOccurred = false;
while (_scopeIO?.isActive == true && !exceptionOccurred) {
try {
val inputStream = _inputStream ?: break;
Log.d(TAG, "Receiving next packet...");
@ -289,20 +290,25 @@ class FCastCastingDevice : CastingDevice {
}
try {
handleMessage(Opcode.values().first { it.value == opcode }, json);
handleMessage(Opcode.entries.first { it.value == opcode }, json);
} catch (e:Throwable) {
Logger.w(TAG, "Failed to handle message.", e);
}
} catch (e: java.net.SocketException) {
Logger.e(TAG, "Socket exception while receiving.", e);
break;
exceptionOccurred = true;
} catch (e: Throwable) {
Logger.e(TAG, "Exception while receiving.", e);
break;
exceptionOccurred = true;
}
}
_socket?.close();
Logger.i(TAG, "Socket disconnected.");
try {
_socket?.close();
Logger.i(TAG, "Socket disconnected.");
} catch (e: Throwable) {
Logger.e(TAG, "Failed to close socket.", e)
}
connectionState = CastConnectionState.CONNECTING;
Thread.sleep(3000);

1
app/src/main/java/com/futo/platformplayer/views/casting/CastView.kt
View file

@ -124,6 +124,7 @@ class CastView : ConstraintLayout {
}
}
updateNextPrevious();
_buttonPrevious.setOnClickListener { onPrevious.emit() };
_buttonNext.setOnClickListener { onNext.emit() };
}