aeron
aeron copied to clipboard
real-logic
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
`private void onError(final String errorMessage) { this.errorMessage = errorMessage; state(State.INACTIVE); }` Can I add some information here？ e.g. recordingId, sessionId and so on When an error occurs, more information can...
In the codebase my team is working on we would like to use `concurrent::ringbuffers`. For us, `tryClaim` interface is preferred. I tried following you're code convetion as much as possible...
TSAN emits whole bunch of data race warnings on a simple single publisher, single subscriber application. Log attached. Threading model of the application: - Both publisher and subscriber are on...
In the C++ client, the `DISABLE_BOUNDS_CHECKS` macro, if defined, is intended to make `AtomicBuffer` operations faster at the cost of safety. It is defined by file `aeron-client/src/main/cpp/CMakeLists.txt` when performing a...
ConsensusModuleAgent generally uses ClusterClock.time() for log timestamps and ClusterClock.timeNanos() for internal time-related tasks. During time travel tests we want adjust/offset the log timestamps only. Modified ConsensusModuleAgent to use ClusterClock.convertToNanos instead...
UDP publications are lingered so tail loss can be detected and recovered. The majority of time loss will not occur and thus the resources tied up with a publication stay...
Hi, Currently, Aeron does not provide a way to configure the QoS of the underlying sockets created by the media driver. This is something users might want to have control...
The Java side uses `org.agrona.SystemUtil#loadPropertiesFiles(java.lang.String...)` API which ignores non-existing files/resources. However the C implementation of the `aeron_properties_file_load` fails with error if file cannot be opened. This leads to media driver...
Hi, I would like to be able to publish on a multicast address such that processes both on the local machine and on remote machines are able to receive these...
Metadata
Owner
Metadata
Efficient reliable UDP unicast, UDP multicast, and IPC message transport