code cleanup
This commit is contained in:
parent
a42c9ad940
commit
6020f06661
@ -94,9 +94,6 @@ internal class Handshaker<CONNECTION : Connection>(
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (System.nanoTime() - startTime < timeoutInNanos) {
|
if (System.nanoTime() - startTime < timeoutInNanos) {
|
||||||
// NOTE: Handlers are called on the client conductor thread. The client conductor thread expects handlers to do safe
|
|
||||||
// publication of any state to other threads and not be long running or re-entrant with the client.
|
|
||||||
|
|
||||||
// we should retry.
|
// we should retry.
|
||||||
handshakeSendIdleStrategy.idle()
|
handshakeSendIdleStrategy.idle()
|
||||||
continue
|
continue
|
||||||
@ -105,9 +102,7 @@ internal class Handshaker<CONNECTION : Connection>(
|
|||||||
// this exception will be a ClientException or a ServerException
|
// this exception will be a ClientException or a ServerException
|
||||||
val exception = newException(
|
val exception = newException(
|
||||||
"[$aeronLogInfo] Error sending message. (Connection in non-connected state longer than linger timeout. ${
|
"[$aeronLogInfo] Error sending message. (Connection in non-connected state longer than linger timeout. ${
|
||||||
EndPoint.errorCodeName(
|
EndPoint.errorCodeName(result)
|
||||||
result
|
|
||||||
)
|
|
||||||
})",
|
})",
|
||||||
null
|
null
|
||||||
)
|
)
|
||||||
|
Loading…
Reference in New Issue
Block a user