Added starting the aeron driver if necessary when clients are reconnecting
This commit is contained in:
parent
2c1155943e
commit
3893a9be5a
@ -480,6 +480,9 @@ open class Client<CONNECTION : Connection>(
|
|||||||
} catch (e: ClientRetryException) {
|
} catch (e: ClientRetryException) {
|
||||||
handshake.reset()
|
handshake.reset()
|
||||||
|
|
||||||
|
// maybe the aeron driver isn't running?
|
||||||
|
aeronDriver.start()
|
||||||
|
|
||||||
// short delay, since it failed we want to limit the retry rate to something slower than "as fast as the CPU can do it"
|
// short delay, since it failed we want to limit the retry rate to something slower than "as fast as the CPU can do it"
|
||||||
delay(500)
|
delay(500)
|
||||||
if (logger.isTraceEnabled) {
|
if (logger.isTraceEnabled) {
|
||||||
@ -523,9 +526,10 @@ open class Client<CONNECTION : Connection>(
|
|||||||
}
|
}
|
||||||
|
|
||||||
// MAYBE the server doesn't have IPC enabled? If no, we need to connect via network instead
|
// MAYBE the server doesn't have IPC enabled? If no, we need to connect via network instead
|
||||||
val ipcConnection = IpcMediaDriverConnection(streamIdSubscription = ipcSubscriptionId,
|
val ipcConnection = IpcMediaDriverConnection(
|
||||||
|
streamIdSubscription = ipcSubscriptionId,
|
||||||
streamId = ipcPublicationId,
|
streamId = ipcPublicationId,
|
||||||
sessionId = AeronDriver.RESERVED_SESSION_ID_INVALID
|
sessionId = AeronDriver.RESERVED_SESSION_ID_INVALID,
|
||||||
)
|
)
|
||||||
|
|
||||||
// throws a ConnectTimedOutException if the client cannot connect for any reason to the server handshake ports
|
// throws a ConnectTimedOutException if the client cannot connect for any reason to the server handshake ports
|
||||||
|
Loading…
Reference in New Issue
Block a user