code/comment cleanup
This commit is contained in:
parent
ee25f0d2ce
commit
c289f02cb9
|
@ -543,7 +543,7 @@ open class Client<CONNECTION : Connection>(
|
||||||
// want to have 1 in-flight handshake, per connection attempt, during the aeron connection timeout
|
// want to have 1 in-flight handshake, per connection attempt, during the aeron connection timeout
|
||||||
|
|
||||||
// ALSO, we want to make sure we DO NOT approach the linger timeout!
|
// ALSO, we want to make sure we DO NOT approach the linger timeout!
|
||||||
sleep(aeronDriver.driverTimeout().coerceAtLeast(TimeUnit.NANOSECONDS.toSeconds(aeronDriver.getLingerNs()*2)))
|
sleep(aeronDriver.driverTimeout().coerceAtLeast(TimeUnit.NANOSECONDS.toSeconds(aeronDriver.getLingerNs() * 2)))
|
||||||
|
|
||||||
if (e.cause is ServerException) {
|
if (e.cause is ServerException) {
|
||||||
val cause = e.cause!!
|
val cause = e.cause!!
|
||||||
|
@ -565,7 +565,7 @@ open class Client<CONNECTION : Connection>(
|
||||||
// want to have 1 in-flight handshake, per connection attempt, during the aeron connection timeout
|
// want to have 1 in-flight handshake, per connection attempt, during the aeron connection timeout
|
||||||
|
|
||||||
// ALSO, we want to make sure we DO NOT approach the linger timeout!
|
// ALSO, we want to make sure we DO NOT approach the linger timeout!
|
||||||
sleep(aeronDriver.driverTimeout().coerceAtLeast(TimeUnit.NANOSECONDS.toSeconds(aeronDriver.getLingerNs()*2)))
|
sleep(aeronDriver.driverTimeout().coerceAtLeast(TimeUnit.NANOSECONDS.toSeconds(aeronDriver.getLingerNs() * 2)))
|
||||||
|
|
||||||
listenerManager.notifyError(e)
|
listenerManager.notifyError(e)
|
||||||
throw e
|
throw e
|
||||||
|
@ -644,7 +644,7 @@ open class Client<CONNECTION : Connection>(
|
||||||
throw exception
|
throw exception
|
||||||
}
|
}
|
||||||
|
|
||||||
// every time we connect to a server, we have to reconfigure AND reassign the readKryo.
|
// every time we connect to a server, we have to reconfigure AND reassign the readKryos.
|
||||||
readKryo = kryoConfiguredFromServer
|
readKryo = kryoConfiguredFromServer
|
||||||
streamingReadKryo = serialization.initKryo()
|
streamingReadKryo = serialization.initKryo()
|
||||||
|
|
||||||
|
|
|
@ -109,6 +109,8 @@ internal class ServerUdpPairedDriver(
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
val subscription = aeronDriver.addSubscription(subscriptionUri, streamId)
|
||||||
|
|
||||||
val remoteAddressString = if (isRemoteIpv4) {
|
val remoteAddressString = if (isRemoteIpv4) {
|
||||||
IPv4.toString(remoteAddress as Inet4Address)
|
IPv4.toString(remoteAddress as Inet4Address)
|
||||||
} else {
|
} else {
|
||||||
|
@ -119,6 +121,6 @@ internal class ServerUdpPairedDriver(
|
||||||
|
|
||||||
this.success = true
|
this.success = true
|
||||||
this.publication = publication
|
this.publication = publication
|
||||||
this.subscription = aeronDriver.addSubscription(subscriptionUri, streamId)
|
this.subscription = subscription
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue