dorkbox
/
Network
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

code cleanup

This commit is contained in:
Robinson 2023-09-06 16:44:00 +02:00
parent 9b1650ae31
commit cbb5038eb6
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/dorkbox/network/aeron/AeronDriver.kt
View File

@ -937,9 +937,7 @@ class AeronDriver constructor(config: Configuration, val logger: KLogger, val en
// NOTE: we already know the connection is closed. we closed it (so it doesn't make sense to emit an error about this)
val exception = endPoint!!.newException(
"[${publication.sessionId()}] Unable to send message. (Connection is closed, aborted attempt! ${
AeronDriver.errorCodeName(result)
})"
"[${publication.sessionId()}] Unable to send message. (Connection is closed, aborted attempt! ${errorCodeName(result)})"
)
listenerManager.notifyError(exception)
return false

4
src/dorkbox/network/connection/streaming/StreamingManager.kt
View File

@ -31,7 +31,6 @@ import dorkbox.network.connection.ListenerManager.Companion.cleanStackTrace
import dorkbox.network.exceptions.StreamingException
import dorkbox.network.serialization.AeronInput
import dorkbox.network.serialization.AeronOutput
import dorkbox.network.serialization.KryoReader
import dorkbox.network.serialization.KryoWriter
import dorkbox.os.OS
import dorkbox.util.Sys
@ -126,7 +125,6 @@ internal class StreamingManager<CONNECTION : Connection>(private val logger: KLo
*/
fun processControlMessage(
message: StreamingControl,
kryo: KryoReader<CONNECTION>,
endPoint: EndPoint<CONNECTION>,
connection: CONNECTION
) {
@ -203,6 +201,7 @@ internal class StreamingManager<CONNECTION : Connection>(private val logger: KLo
}
val streamedMessage = if (input != null) {
val kryo = endPoint.serialization.takeRead()
try {
kryo.read(input)
} catch (e: Exception) {
@ -213,6 +212,7 @@ internal class StreamingManager<CONNECTION : Connection>(private val logger: KLo
// either client or server. No other choices. We create an exception, because it's more useful!
throw endPoint.newException(errorMessage, e)
} finally {
endPoint.serialization.putRead(kryo)
if (output is FileWriter) {
val fileName = "${config.appId}_${streamId}_${connection.id}.tmp"
val tempFileLocation = OS.TEMP_DIR.resolve(fileName)