Code cleanup
This commit is contained in:
parent
7281cdb9f4
commit
835ae99e9c
@ -585,7 +585,7 @@ open class Client<CONNECTION : Connection>(
|
|||||||
logger.info { "Creating new handshake to $logInfo" }
|
logger.info { "Creating new handshake to $logInfo" }
|
||||||
}
|
}
|
||||||
|
|
||||||
connect0(handshake, handshakeConnection, handshakeTimeoutSec, connectionCloseTimeoutInSeconds, connectLatch)
|
connect0(handshake, handshakeConnection, handshakeTimeoutSec)
|
||||||
success = true
|
success = true
|
||||||
slowDownForException = false
|
slowDownForException = false
|
||||||
|
|
||||||
@ -665,13 +665,7 @@ open class Client<CONNECTION : Connection>(
|
|||||||
|
|
||||||
|
|
||||||
// the handshake process might have to restart this connection process.
|
// the handshake process might have to restart this connection process.
|
||||||
private suspend fun connect0(
|
private suspend fun connect0(handshake: ClientHandshake<CONNECTION>, handshakeConnection: ClientHandshakeDriver, connectionTimeoutSec: Int) {
|
||||||
handshake: ClientHandshake<CONNECTION>,
|
|
||||||
handshakeConnection: ClientHandshakeDriver,
|
|
||||||
connectionTimeoutSec: Int,
|
|
||||||
connectionCloseTimeoutInSeconds: Long,
|
|
||||||
connectLatch: CountDownLatch
|
|
||||||
) {
|
|
||||||
// this will block until the connection timeout, and throw an exception if we were unable to connect with the server
|
// this will block until the connection timeout, and throw an exception if we were unable to connect with the server
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user