Raw batch reading for ring buffers about aeron.net HOT 10 CLOSED

hmm I take that back, you can't do that unless you know the last message in the batch

from aeron.net.

While I see the benefit of the request, I'm hesitant to introduce changes to this code base that aren't used directly by the Aeron client. It seems like you've already got what you need in RampUp.
If you haven't already, it might be worth having a look at the Disruptor.NET.
Looking at the EventHandler in Getting started (java) it seems like it might fit with your use case.

from aeron.net.

something like this?https://github.com/AdaptiveConsulting/Aeron.NET/blob/master/src/Adaptive.Agrona/Concurrent/RingBuffer/ManyToOneRingBuffer.cs#L114

from aeron.net.

This is not what I meant. Let me rephrase my initial description.
The Read method provides a capability of reading multiple messages one after another and clears the memory afterwards. It does not provide an access to the whole chunk of memory though. I could imagine scenarios, where one wants to have multiple writers which write messages to a buffer. Then a reader would access the whole chunk of buffer and use it somehow (send to a file/socket/something else). In this case existing Read wouldn't be suitable - it reads messages one after another.

from aeron.net.

ahh I see similar to https://github.com/real-logic/Aeron/blob/master/aeron-client/src/main/java/io/aeron/Image.java#L515?

from aeron.net.

That's correct 👍 I'm thinking now, is it the right lvl for introducing it?

from aeron.net.

If you Read using the MessageHandler, you could capture buffer & the first index then sum up the lengths of all the individual messages. Then you have access to the whole block.

from aeron.net.

You can't do it because in any point of time (at the end) cleaning memory and moving head can be called. That's why I asked about making this explicit and calling the "raw handler" only one time.

from aeron.net.

the position is only advanced after the whole batch has been processed
https://github.com/AdaptiveConsulting/Aeron.NET/blob/master/src/Adaptive.Agrona/Concurrent/RingBuffer/ManyToOneRingBuffer.cs#L152

from aeron.net.

Thx for clarification. Closing this :)

from aeron.net.