aeron-io/aeron 1.50.0 on GitHub

New & Noteworthy

[Breaking] Remove deprecated standalone C++ API. The C++ Wrapper API should be used instead.
The interface channel parameter now accepts network interface names in the \{interface-name} format, e.g. interface=\{eth0}.
When used with multicast channels, it specifies the interface to join with and send on.
The interface parameter might sometimes be used with non-multicast channels to control the local address of a socket.
In those cases, the socket will be bound to an address of an appropriate family assigned to the named interface.
If there are multiple matching addresses available, it's unspecified which one will be used.
It's also possible to specify the port used with the resolved address by using the \{interface-name}:port format.

Changelog

[Archive] Do not set session-id on the replay channel if response channels are used to avoid session-id clash.
[Archive] Default AeronArchive.Context.Archive instance is configured with RethrowingErrorHandler for Subscriptions.
[Archive] Allow asynchronously connecting to Archive using AgentInvokers.
[Archive] Format size and duration parameters when using ChannelUriStringBuilder to create full channel URI.
[Archive] Use the configured control term buffer length for the replication client instead of hardcoding 64k.
[Archive/Java/C/C++Wrapper] Make message retry attempts for aeron_archive configurable. (Java PR: #1885)
[Archive] Ensure that errors from ReplaySession are both captured in the error log and sent to the control session. Improve error messages.
[Cluster] Prevent fast follower node from consuming log ahead of the commit position when majority lags behind. (#1898)
[Cluster] Prevent infinite loop while awaiting service ACKs if services terminated/crashed.
[Cluster] Add reason to the STATE_CHANGE event. Always quote reason value across all events.
[Cluster] Default AeronCluster.Context.Archive instance is configured with RethrowingErrorHandler for Subscriptions.
[Cluster] Add support for AgentInvoker/Aeron.conductorAgentInvoker to AeronCluster#asyncConnect.
[Cluster] Add log event for Vote message, i.e. a response to RequestVote.
[Cluster] Handle quorum commit position going backwards.
[Cluster] Make default Cluster consensus channel use UDP term length of the media driver instead of assigning term-length=64k. With the Aeron defaults this increases the term length from 64KB to 16MB.
[Cluster] Unconditionally set reliable=true on the ingress subscription to ensure that the ingress stream is reliable.
[Cluster] Ignore unknown schema messages (e.g. from Sequencer) in EgressPoller.
[Cluster] Make AeronCluster.asyncConnect fully asynchronous by using Aeron#asyncAddExclusivePublication/asyncAddPublication API when dealing with redirect requests in case no valid existing leader publication was found.
[Cluster] Reuse existing leader ingress publication if it is still valid when receiving redirect response.
[Cluster] Only consider active members when computing hasQuorumAtPosition. We now always await for the active quorum of nodes o reach target position. Remove hasVotersAtPosition since it is no longer used.
[Cluster] Refactor isCandidate checks and document why we must consider all existing members when doing so. We cannot check only the "active" nodes since that breaks the nomination phase whereby the nodes will stop proposing themselves as candidates once timeOfLastAppendPositionNs stops advancing.
[Cluster] Only consider active Cluster members when computing the quorum position.
[Cluster] Consistently update follower position, i.e. always set logPosition, leadershipTermId and timeOfLastAppendPositionNs together. Add missing update of the follower info upon receiving CanvassPosition.
[Cluster] Increment snapshot counter after updating snapshot duration tracker to avoid a race in a test.
[Java/C] Allow to specify network interface name in the interface channel parameter. (#1901)
[Driver] Do not append threading mode to the name resolver cycle counters.
[C] Fix threshold formatting + format threshold info for the name resolver cycle tracker.
[C] Remove duty cycle threshold limit of 1 hour.
[C] Format duty cycle threshold before adding to the driver counters.
[Java] Use SystemUtil#formatDuration to format threshold for the duty cycle tracker counters.
[C] Set ownerId for each stream counter created via client command (e.g. ADD_PUBLICATION).
[Java] Set ownerId for each stream counter created via client command (e.g. ADD_PUBLICATION).
[Java] Add Publication type to the counters and log buffer metadata, i.e. pub-pos counter now has a suffix ((concurrent) or (exclusive) depending on the type) and log buffer metadata contains a new field type (unit8) at offset 497 which can have values 0 (concurrent publication), 1 (exclusive publication) or 2 (publication image).
[C] Add Publication type to the counters and log buffer metadata, i.e. pub-pos counter now has a suffix ((concurrent) or (exclusive) depending on the type) and log buffer metadata contains a new field is_exclusive_publication (unit8) at offset 497.
[Driver/C] Increase sender/receiver IO vector capacity and publication max messages per send to 4 from 2.
[C] Do not throttle sends to one per call if short sends are encountered.
[Driver/C/Java] Add EF_VI, VMA, ATS, DPDK and Selector counter types. Synchronize Java and C counter definitions.
[C] Add aeron_format_duration_ns.
[C] Add aeron_format_size64.
[C] Refactor duration and size parsing.
[C] Fixes data races on AERON_GET_ACQUIRE and AERON_SET_RELEASE usages. (#1902)
[C] Fixes broken atomic instructions. (#1905)
[C] Replace __asm__ volatile with __asm__ __volatile__ just like in Linux kernel.
[C] aeron_atomic64_gcc_x86_64.h acquire/release fixes (#1904)
[C] Optimized register allocation aeron_atomic64_gcc_x86_64h (#1910)
[C] Fix aeron_log_buffer.c mem leak (#1907)
[C] Fixed aeron_agent_init role_name bugs. (#1908)
[C] Do not resolve endpoint with ephemeral port for MDS subscription. Copy original channel as-is if no resolution is performed.
[Java] Do not resolve endpoint with ephemeral port if MDS is used.
[Java] Parse channel lazily when tryResolveChannelEndpointPort is called.
[Java] Fix Subscription#tryResolveChannelEndpointPort when no addresses exist, i.e. return null if active address is not yet available. Also cache results and avoid doing any work if endpoint is not defined or does not contain a port zero.
[Java] Fixed StatusIndicator deprecated method usage. (#1895)
[Java] Replaced the AtomicCounter.getWeak usages by getPlain. (#1893)
[Java] Replaced Counter.getAndAddOrdered by getAndAddRelease. (#1894)
[Java] Add per-stream counters to StreamStat and extract counter name from label instead of relying on static mapping by type.
[C] fix: double free in aeron_archive_context_t. (#1897)
[C] Make aeron_subscription_image_release and aeron_subscription_image_retain no op if image is not found in the
current image list, i.e. handle a case of on_unavailable_image being called and attempting to retain an image that
was already removed (i.e. C++ Wrapper)).
[C] invoke the client when in aeron_archive_replay_merge_close. (#1873)
[C] Handle aeron_archive_encoded_credentials_t being NULL as well as data field being NULL, i.e. treat both as empty credentials.
[C] Fix race condition in aeron_archive_client reentrancy check, i.e. first acquire lock and then do the check. Use
mutex to protect aeron_archive_close from concurrent execution.
[C] Create aeron_mutex_t as recursive/reentrant on POSIX systems, i.e. match behavior on Windows and the Java implementation.
[C] Fix missing mutex unlock in case of an error.
[Cluster] Optimize redirect handling in AeronCluster: reuse existing publication if available and use async API
to connect to the leader otherwise.
[Cluster] Protect against NPE during follower catchup if recording is stopped, because the leader transitions to a
follower and stops sending log.
[Driver/C] Perform sender address re-resolution checks on a fixed schedule rather than awaiting next control
polling cycle, i.e. align behavior with the Sender#doWork implementation.
[Driver/Java] Perform full name and address matching in driver name resolver. Add tests to ensure partial matches
are not allowed. Remove allocations when matching neighbors by address.
[Driver/C] Fix segfault when invalid name resolver configuration is provided. Cleanup allocated resources to avoid
leaking memory.
[Driver/C] Use aeron_interface_parse_and_resolve to resolve aeron.driver.resolver.interface parameter, i.e.
skip the aeron_find_interface checks. This aligns the implementation with the DriverNameResolver in Java. Fix
filtering out of self entries, i.e. use full name matching instead of a prefix match.
[C] Add aeron_is_frame_valid method.
[C/Java] Add all missing counter type constants for the premium components.
[C] Do not truncate frames longer than 1408 bytes when logging, i.e. allow up to AERON_MAX_UDP_PAYLOAD_LENGTH
(65504) bytes instead.
[C] Ensure that fallback receiverId cannot be zero.
[Java] Improve mark file APIs: use high-level operations to signal ready/terminated, reset activity timestamp
upon failure, update tests to reflect activity timestamp changes during startup sequence.
[Java/C] Fix formatting of large values and counter ids in AeronStat.
[Java/C] Add dissector for the ERR (0x04) frame type.
[Java] Add version information to ComponentLogger and print enabled loggers upon agent startup.
[C] Print enabled loggers upon agent startup and their versions.
[C] Add function to counter number of leading zeroes in 64 bit value (aeron_number_of_leading_zeroes_u64).
[C] Add ability to counter number of digits in a 32-bit number (aeron_digit_count).
[C] Link aeron-client against libbsd.
[Java] Delete DeduplicateTask, i.e. use built-in capabilities of the Shadow plugin instead.
[Java] Upgrade to Agrona 2.4.0.
[Java] Upgrade to SBE 1.37.1.
[Java] Upgrade to ByteBuddy 1.18.3.
[Java] Upgrade to ASM 9.9.1.
[Java] Upgrade to JUnit 6.0.2.
[Java] Upgrade to Mockito 5.21.0.
[Java] Upgrade to Checkstyle 12.3.0.
[Java] Upgrade to Shadow 9.3.1.
[C] Upgrade to CMake 4.2.1.