mirror of
https://gitlab.futo.org/videostreaming/grayjay.git
synced 2025-05-02 15:44:26 +02:00
Should not crash app when StateSync fails to bind.
This commit is contained in:
parent
4066ce73a8
commit
7c9e9d5f52
@ -112,18 +112,23 @@ class StateSync {
|
|||||||
Logger.i(TAG, "Sync key pair initialized (public key = ${publicKey})")
|
Logger.i(TAG, "Sync key pair initialized (public key = ${publicKey})")
|
||||||
|
|
||||||
_thread = Thread {
|
_thread = Thread {
|
||||||
val serverSocket = ServerSocket(PORT)
|
try {
|
||||||
_serverSocket = serverSocket
|
val serverSocket = ServerSocket(PORT)
|
||||||
|
_serverSocket = serverSocket
|
||||||
|
|
||||||
Log.i(TAG, "Running on port ${PORT} (TCP)")
|
Log.i(TAG, "Running on port ${PORT} (TCP)")
|
||||||
|
|
||||||
while (_started) {
|
while (_started) {
|
||||||
val socket = serverSocket.accept()
|
val socket = serverSocket.accept()
|
||||||
val session = createSocketSession(socket, true) { session, socketSession ->
|
val session = createSocketSession(socket, true) { session, socketSession ->
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
session.startAsResponder()
|
||||||
}
|
}
|
||||||
|
} catch (e: Throwable) {
|
||||||
session.startAsResponder()
|
Logger.e(TAG, "Failed to bind server socket to port ${PORT}", e)
|
||||||
|
UIDialogs.toast("Failed to start sync, port in use")
|
||||||
}
|
}
|
||||||
}.apply { start() }
|
}.apply { start() }
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user