more comments

This commit is contained in:
Robinson 2023-10-18 19:50:04 +02:00
parent d4e3e2e41d
commit 2245f0bfc5
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 3 additions and 0 deletions

View File

@ -141,6 +141,9 @@ internal class AeronDriverInternal(endPoint: EndPoint<*>?, config: Configuration
// configure the aeron error handler
val filter = config.aeronErrorFilter
aeronErrorHandler = { error ->
// NOTE: this is an error callback for MANY things, MOST of them are ASYNC! This means that a messages can successfully be ADDED
// to aeron, but NOT successfully sent over the network.
// this is bad! We must close this connection. THIS WILL BE CALLED AS FAST AS THE CPU CAN RUN (because of how aeron works).
if (!mustRestartDriverOnError) {