Error Frames and User Image Invalidation #1604

mikeb01 · 2024-05-24T04:18:06Z

Support the ability to allow a user to invalidate an image within a subscription.
Report error frames for publications back to the client.

aeron-client/src/test/java/io/aeron/ImageTest.java

aeron-driver/src/main/c/aeron_driver_conductor.c

aeron-system-tests/src/test/java/io/aeron/ImageInvalidationTest.java

aeron-client/src/main/java/io/aeron/Aeron.java

aeron-driver/src/main/java/io/aeron/driver/status/SystemCounterDescriptor.java

aeron-client/src/main/java/io/aeron/Image.java

aeron-client/src/main/java/io/aeron/Subscription.java

aeron-client/src/main/java/io/aeron/protocol/ErrorFlyweight.java

aeron-driver/src/main/java/io/aeron/driver/status/SystemCounterDescriptor.java

aeron-system-tests/src/test/java/io/aeron/RejectImageTest.java

aeron-client/src/main/c/aeron_client_conductor.c

aeron-client/src/main/c/command/aeron_control_protocol.h

aeron-client/src/main/c/protocol/aeron_udp_protocol.h

aeron-client/src/main/c/aeronc.h

aeron-client/src/main/java/io/aeron/ClientConductor.java

aeron-client/src/main/java/io/aeron/command/ControlProtocolEvents.java

aeron-client/src/main/java/io/aeron/Aeron.java

aeron-driver/src/main/c/aeron_publication_image.c

aeron-driver/src/main/java/io/aeron/driver/PublicationImage.java

aeron-agent/src/main/java/io/aeron/agent/CmdInterceptor.java

…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.

…ol and liveness.

…t send max frame size each time.

…cifically with error frames for publications. Add test to verify that it works for exclusive publications.

…ve error frames.

…lications.

…. Also add copy and move constructors for dealing with the limit lifecycle of callback objects.

…within the client conductor.

… to all clients with the same publication and not to ones that without it.

…mes.

github-advanced-security bot found potential problems May 24, 2024

View reviewed changes

aeron-client/src/test/java/io/aeron/ImageTest.java Fixed Show fixed Hide fixed

github-advanced-security bot found potential problems May 24, 2024

View reviewed changes

aeron-driver/src/main/c/aeron_driver_conductor.c Fixed Show resolved Hide resolved

mikeb01 force-pushed the feature/error_frames branch from ce58a33 to 6bda98e Compare June 12, 2024 04:32

mikeb01 changed the title ~~User Image Invalidation~~ Error Frames and User Image Invalidation Jun 13, 2024

mikeb01 force-pushed the feature/error_frames branch from 5f4396c to 574e267 Compare June 18, 2024 00:57

github-advanced-security bot found potential problems Jun 19, 2024

View reviewed changes

aeron-system-tests/src/test/java/io/aeron/ImageInvalidationTest.java Fixed Show fixed Hide fixed

github-advanced-security bot found potential problems Jun 24, 2024

View reviewed changes

aeron-system-tests/src/test/java/io/aeron/ImageInvalidationTest.java Fixed Show fixed Hide fixed

wojciech-adaptive reviewed Jun 24, 2024

View reviewed changes

aeron-client/src/main/java/io/aeron/Aeron.java Outdated Show resolved Hide resolved

aeron-client/src/main/java/io/aeron/Aeron.java Outdated Show resolved Hide resolved

aeron-driver/src/main/java/io/aeron/driver/status/SystemCounterDescriptor.java Outdated Show resolved Hide resolved

mikeb01 force-pushed the feature/error_frames branch from cb113e8 to e6f62bb Compare June 27, 2024 04:30