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

Only notify exceptions when message-send-during-close, when we did not explicitly close the connection

This commit is contained in:
Robinson 2023-09-13 13:52:45 +02:00
parent 8e9e0441ed
commit 3fff69757c
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -934,12 +934,14 @@ class AeronDriver constructor(config: Configuration, val logger: KLogger, val en
// this can happen when we use RMI to close a connection. RMI will (in most cases) ALWAYS send a response when it's
// done executing. If the connection is *closed* first (because an RMI method closed it), then we will not be able to
// send the message.
// 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! ${errorCodeName(result)})"
)
listenerManager.notifyError(exception)
if (!endPoint!!.shutdownInProgress.value) {
// 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! ${errorCodeName(result)})"
)
listenerManager.notifyError(exception)
}
return false
}
@ -1034,12 +1036,15 @@ class AeronDriver constructor(config: Configuration, val logger: KLogger, val en
}
if (result == Publication.CLOSED) {
// 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! ${errorCodeName(result)})"
)
listenerManager.notifyError(exception)
if (!endPoint!!.shutdownInProgress.value) {
// 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! ${errorCodeName(result)})"
)
listenerManager.notifyError(exception)
}
return false
}