changed config.id -> mediaDriverId()

This commit is contained in:
Robinson 2023-08-09 21:45:28 -06:00
parent 836c8abce6
commit 6e76160c83
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
2 changed files with 3 additions and 3 deletions

View File

@ -416,13 +416,13 @@ class AeronDriver private constructor(config: Configuration, val logger: KLogger
mediaDriverConfig.validate()
require(!config.contextDefined) { "Aeron configuration has already been initialized, unable to reuse this configuration!" }
require(!config.contextDefined) { "Aeron configuration [${config.mediaDriverId()}] has already been initialized, unable to reuse this configuration!" }
// cannot make any more changes to the configuration!
config.initialize(logger)
// technically possible, but practically unlikely because of the different values calculated
require(mediaDriverConfig.id != 0) { "There has been a severe error when calculating the media configuration ID. Aborting" }
require(mediaDriverConfig.mediaDriverId() != 0) { "There has been a severe error when calculating the media configuration ID. Aborting" }
return mediaDriverConfig
}

View File

@ -91,7 +91,7 @@ internal class AeronDriverInternal(endPoint: EndPoint<*>?, private val config: C
}
}
val driverId = config.id
val driverId = config.mediaDriverId()
private val endPointUsages = mutableListOf<EndPoint<*>>()