-
Notifications
You must be signed in to change notification settings - Fork 870
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Error Frames and User Image Invalidation #1604
base: master
Are you sure you want to change the base?
Conversation
mikeb01
commented
May 24, 2024
- Support the ability to allow a user to invalidate an image within a subscription.
ce58a33
to
6bda98e
Compare
5f4396c
to
574e267
Compare
aeron-driver/src/main/java/io/aeron/driver/status/SystemCounterDescriptor.java
Outdated
Show resolved
Hide resolved
…ode. Prevent new data being inserted into an invalidated image. Add logging.
…e is found during invalidation on the receiver.
… have it disconnect. Allow receiver side image to linger to prevent immediately recreation of the image. Treat errors received by the NetworkPublication to behaviour like end of stream messages.
…t send max frame size each time.
… Check that we don't spam out error messages too quickly. Reset timestamp of last SM sent by the publication image when sending errors.
…eck that we don't spam out error messages too quickly. Reset timestamp of last SM sent by the publication image when sending errors.
…t on invalidate image.
…lication registered.
…n object to be reported to the caller.
cb113e8
to
e6f62bb
Compare
*/ | ||
public static final int MAX_ERROR_MESSAGE_LENGTH = 1023; | ||
|
||
public static final int MAX_ERROR_FRAME_LENGTH = HEADER_LENGTH + MAX_ERROR_MESSAGE_LENGTH; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Missing javadoc
*/ | ||
public String errorMessage() | ||
{ | ||
return getStringUtf8(ERROR_STRING_FIELD_OFFSET); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It would be better to treat encoded strings at US_ASCII as this is consistent elsewhere and ports to C.
/** | ||
* A count of the number of error frames received by this driver. | ||
*/ | ||
ERROR_FRAMES_RECEIVED(38, "Error Frames received"); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should we have a corresponding error frames sent counter?