A B C D E F G H I J K L M N O P Q R S T U V W Y 

A

AbstractConcurrentArrayQueue<E> - Class in org.agrona.concurrent
Left over immutable queue fields.
AbstractConcurrentArrayQueue(int) - Constructor for class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
accept(int, int, V) - Method in interface org.agrona.collections.BiInt2ObjectMap.EntryConsumer
A map entry
accept(int, int) - Method in interface org.agrona.collections.IntIntConsumer
Accept a key and value that comes as a tuple of ints.
accept(int, T) - Method in interface org.agrona.collections.IntObjConsumer
 
accept(int, long, long, String) - Method in interface org.agrona.concurrent.errors.ErrorConsumer
Callback for accepting errors encountered in the log.
accept(int, int, DirectBuffer, String) - Method in interface org.agrona.concurrent.status.CountersReader.MetaData
Accept a metadata record.
accept(T) - Method in interface org.agrona.generation.ResourceConsumer
 
add(T[], T) - Static method in class org.agrona.collections.ArrayUtil
Add an element to an array resulting in a new array.
add(Integer) - Method in class org.agrona.collections.IntHashSet
add(int) - Method in class org.agrona.collections.IntHashSet
Primitive specialised overload of {this#add(Integer)}
add(E) - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
add(E) - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
add(long) - Method in class org.agrona.concurrent.status.AtomicCounter
Add an increment to the counter that will not lose updates across threads.
add(SelectionKey) - Method in class org.agrona.nio.NioSelectedKeySet
addAll(Collection<? extends Integer>) - Method in class org.agrona.collections.IntHashSet
addAll(Collection<? extends E>) - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
addAll(Collection<? extends E>) - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
addedCount() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
addedCount() - Method in interface org.agrona.concurrent.Pipe
The number of items added to this container since creation.
addIntOrdered(int, int) - Method in interface org.agrona.concurrent.AtomicBuffer
Add a value to a given index with ordered store semantics.
addIntOrdered(long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
addIntOrdered(int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
addLongOrdered(int, long) - Method in interface org.agrona.concurrent.AtomicBuffer
Add a value to a given index with ordered store semantics.
addLongOrdered(long, long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
addLongOrdered(int, long) - Method in class org.agrona.concurrent.UnsafeBuffer
 
addOrdered(long) - Method in class org.agrona.concurrent.status.AtomicCounter
Add an increment to the counter with ordered store semantics.
address(ByteBuffer) - Static method in class org.agrona.BufferUtil
Get the address at which the underlying buffer storage begins.
addressOffset() - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
addressOffset() - Method in class org.agrona.concurrent.UnsafeBuffer
 
addressOffset() - Method in interface org.agrona.DirectBuffer
Reads the underlying offset to to the memory address.
addressOffset() - Method in class org.agrona.ExpandableArrayBuffer
 
Agent - Interface in org.agrona.concurrent
 
agent() - Method in class org.agrona.concurrent.AgentRunner
The Agent who's lifecycle is being managed.
AgentRunner - Class in org.agrona.concurrent
Base agent runner that is responsible for lifecycle of an Agent and ensuring exceptions are handled.
AgentRunner(IdleStrategy, ErrorHandler, AtomicCounter, Agent) - Constructor for class org.agrona.concurrent.AgentRunner
Create an agent passing in IdleStrategy
align(int, int) - Static method in class org.agrona.BitUtil
Align a value to the next multiple up of alignment.
ALIGNMENT - Static variable in class org.agrona.concurrent.ringbuffer.RecordDescriptor
Alignment as a multiple of bytes for each record.
ALIGNMENT - Static variable in class org.agrona.concurrent.UnsafeBuffer
Buffer alignment to ensure atomic word accesses.
allocate(String) - Method in class org.agrona.concurrent.status.CountersManager
Allocate a new counter with a given label.
allocate(String, int, Consumer<MutableDirectBuffer>) - Method in class org.agrona.concurrent.status.CountersManager
Allocate a new counter with a given label.
allocateDirectAligned(int, int) - Static method in class org.agrona.BufferUtil
Allocate a new direct ByteBuffer that is aligned on a given alignment boundary.
apply(int, int) - Method in interface org.agrona.collections.BiInt2ObjectMap.EntryFunction
A map entry
ARRAY_BASE_OFFSET - Static variable in class org.agrona.BufferUtil
 
ArrayUtil - Class in org.agrona.collections
Utility class for operating on arrays as if they were collections.
ArrayUtil() - Constructor for class org.agrona.collections.ArrayUtil
 
AtomicBuffer - Interface in org.agrona.concurrent
Abstraction over a range of buffer types that allows type to be accessed with memory ordering semantics.
AtomicCounter - Class in org.agrona.concurrent.status
Atomic counter that is backed by an AtomicBuffer that can be read across threads and processes.
AtomicLongPosition - Class in org.agrona.concurrent.status
Position that is backed by an AtomicLong that is useful for tests.
AtomicLongPosition() - Constructor for class org.agrona.concurrent.status.AtomicLongPosition
 
available() - Method in class org.agrona.io.DirectBufferInputStream
 
await() - Method in class org.agrona.concurrent.SigIntBarrier
Await the reception of the SIGINT signal.
await() - Method in class org.agrona.console.ContinueBarrier
Await for input that matches the provided command.

B

BackoffIdleStrategy - Class in org.agrona.concurrent
 
BackoffIdleStrategy(long, long, long, long) - Constructor for class org.agrona.concurrent.BackoffIdleStrategy
Create a set of state tracking idle behavior
BiInt2ObjectMap<V> - Class in org.agrona.collections
Map that takes two part int key and associates with an object.
BiInt2ObjectMap() - Constructor for class org.agrona.collections.BiInt2ObjectMap
Construct an empty map
BiInt2ObjectMap(int, float) - Constructor for class org.agrona.collections.BiInt2ObjectMap
Construct a map that sets it initial capacity and load factor.
BiInt2ObjectMap.EntryConsumer<V> - Interface in org.agrona.collections
Handler for a map entry
BiInt2ObjectMap.EntryFunction<V> - Interface in org.agrona.collections
Creates new values based upon keys
BitUtil - Class in org.agrona
Miscellaneous useful functions for dealing with low level bits and bytes.
BitUtil() - Constructor for class org.agrona.BitUtil
 
BLOCK_SIZE - Static variable in class org.agrona.IoUtil
Size in bytes of a file page.
boundsCheck(byte[], long, int) - Static method in class org.agrona.BufferUtil
Bounds check the access range and throw a IndexOutOfBoundsException if exceeded.
boundsCheck(ByteBuffer, long, int) - Static method in class org.agrona.BufferUtil
Bounds check the access range and throw a IndexOutOfBoundsException if exceeded.
boundsCheck(long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
boundsCheck(int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
boundsCheck(int, int) - Method in interface org.agrona.DirectBuffer
Check that a given length of bytes is within the bounds from a given index.
boundsCheck(int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
BroadcastBufferDescriptor - Class in org.agrona.concurrent.broadcast
Layout of the broadcast buffer.
BroadcastBufferDescriptor() - Constructor for class org.agrona.concurrent.broadcast.BroadcastBufferDescriptor
 
BroadcastReceiver - Class in org.agrona.concurrent.broadcast
Receive messages broadcast from a BroadcastTransmitter via an underlying buffer.
BroadcastReceiver(AtomicBuffer) - Constructor for class org.agrona.concurrent.broadcast.BroadcastReceiver
Construct a new broadcast receiver based on an underlying AtomicBuffer.
BroadcastTransmitter - Class in org.agrona.concurrent.broadcast
Transmit messages via an underlying broadcast buffer to zero or more BroadcastReceivers.
BroadcastTransmitter(AtomicBuffer) - Constructor for class org.agrona.concurrent.broadcast.BroadcastTransmitter
Construct a new broadcast transmitter based on an underlying AtomicBuffer.
buffer - Variable in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
buffer() - Method in class org.agrona.concurrent.broadcast.BroadcastReceiver
The underlying buffer containing the broadcast message stream.
buffer() - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Get the underlying buffer used by the RingBuffer for storage.
buffer() - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Get the underlying buffer used by the RingBuffer for storage.
buffer() - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
Get the underlying buffer used by the RingBuffer for storage.
buffer() - Method in class org.agrona.io.DirectBufferInputStream
The underlying buffer being wrapped.
buffer() - Method in class org.agrona.io.DirectBufferOutputStream
The underlying buffer being wrapped.
buffer() - Method in class org.agrona.io.ExpandableDirectBufferOutputStream
The underlying buffer being wrapped.
BUFFER_ARRAY_BASE - Static variable in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
BufferUtil - Class in org.agrona
Common functions for buffer implementations.
BufferUtil() - Constructor for class org.agrona.BufferUtil
 
BusySpinIdleStrategy - Class in org.agrona.concurrent
Busy spin strategy targeted at lowest possible latency.
BusySpinIdleStrategy() - Constructor for class org.agrona.concurrent.BusySpinIdleStrategy
 
byteArray() - Method in class org.agrona.concurrent.UnsafeBuffer
 
byteArray() - Method in interface org.agrona.DirectBuffer
Get the underlying byte[] if one exists.
byteArray() - Method in class org.agrona.ExpandableArrayBuffer
 
byteBuffer() - Method in class org.agrona.concurrent.UnsafeBuffer
 
byteBuffer() - Method in interface org.agrona.DirectBuffer
Get the underlying ByteBuffer if one exists.
byteBuffer() - Method in class org.agrona.ExpandableArrayBuffer
 

C

CACHE_LINE_LENGTH - Static variable in class org.agrona.BitUtil
Length of the data blocks used by the CPU cache sub-system in bytes.
cacheHits() - Method in class org.agrona.collections.Int2ObjectCache
The number of times a cache hit has occurred on the Int2ObjectCache.get(int) method.
cacheMisses() - Method in class org.agrona.collections.Int2ObjectCache
The number of times a cache miss has occurred on the Int2ObjectCache.get(int) method.
cachePuts() - Method in class org.agrona.collections.Int2ObjectCache
The number of items that have been put in the cache.
calculateMaxMessageLength(int) - Static method in class org.agrona.concurrent.broadcast.RecordDescriptor
Calculate the maximum supported message length for a buffer of given capacity.
calculateShiftForScale(int) - Static method in class org.agrona.BitUtil
Calculate the shift value to scale a number based on how refs are compressed or not.
cancel() - Method in class org.agrona.TimerWheel.Timer
Cancel pending timer.
capacity() - Method in class org.agrona.collections.BiInt2ObjectMap
Get the total capacity for the map to which the load factor with be a fraction of.
capacity() - Method in class org.agrona.collections.Int2ObjectCache
Get the total capacity for the map to which the load factor with be a fraction of.
capacity() - Method in class org.agrona.collections.Int2ObjectHashMap
Get the total capacity for the map to which the load factor with be a fraction of.
capacity() - Method in class org.agrona.collections.IntHashSet
Get the total capacity for the set to which the load factor with be a fraction of.
capacity() - Method in class org.agrona.collections.IntLruCache
 
capacity - Variable in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
capacity() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
capacity() - Method in class org.agrona.concurrent.broadcast.BroadcastReceiver
Get the capacity of the underlying broadcast buffer.
capacity() - Method in class org.agrona.concurrent.broadcast.BroadcastTransmitter
Get the capacity of the underlying broadcast buffer.
capacity() - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
capacity() - Method in interface org.agrona.concurrent.Pipe
The maximum capacity of this container to hold items.
capacity() - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Get the capacity of the ring-buffer in bytes for exchange.
capacity() - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Get the capacity of the ring-buffer in bytes for exchange.
capacity() - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
Get the capacity of the ring-buffer in bytes for exchange.
capacity() - Method in class org.agrona.concurrent.UnsafeBuffer
 
capacity() - Method in interface org.agrona.DirectBuffer
Get the capacity of the underlying buffer.
capacity() - Method in class org.agrona.ExpandableArrayBuffer
 
capacity() - Method in class org.agrona.nio.NioSelectedKeySet
Capacity of the current set
CharSequenceJavaFileObject - Class in org.agrona.generation
 
CharSequenceJavaFileObject(String, CharSequence) - Constructor for class org.agrona.generation.CharSequenceJavaFileObject
 
checkCapacity(int) - Static method in class org.agrona.concurrent.broadcast.BroadcastBufferDescriptor
Check the the buffer capacity is the correct size.
checkCapacity(int) - Static method in class org.agrona.concurrent.ringbuffer.RingBufferDescriptor
Check the the buffer capacity is the correct size (a power of 2 + RingBufferDescriptor.TRAILER_LENGTH).
checkedSubstitute(String) - Method in class org.agrona.generation.PrimitiveExpander.Substitution
 
checkFileExists(File, String) - Static method in class org.agrona.IoUtil
Check that a file exists and throw an exception if not.
checkLimit(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
checkLimit(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
checkLimit(int) - Method in interface org.agrona.DirectBuffer
Check that a given limit is not greater than the capacity of a buffer from a given offset.
checkLimit(int) - Method in class org.agrona.ExpandableArrayBuffer
 
checkTypeId(int) - Static method in class org.agrona.concurrent.broadcast.RecordDescriptor
Check that and message id is in the valid range.
checkTypeId(int) - Static method in class org.agrona.concurrent.ringbuffer.RecordDescriptor
Check that and message id is in the valid range.
claimRecord(int) - Method in class org.agrona.concurrent.RecordBuffer
Claim a record in the buffer.
ClassFileManager<M extends javax.tools.JavaFileManager> - Class in org.agrona.generation
 
ClassFileManager(M) - Constructor for class org.agrona.generation.ClassFileManager
 
clear() - Method in class org.agrona.collections.BiInt2ObjectMap
Clear out the map of all entries.
clear() - Method in class org.agrona.collections.Int2IntHashMap
clear() - Method in class org.agrona.collections.Int2ObjectCache
Clear down all items in the cache.
clear() - Method in class org.agrona.collections.Int2ObjectCache.KeySet
 
clear() - Method in class org.agrona.collections.Int2ObjectHashMap
clear() - Method in class org.agrona.collections.Int2ObjectHashMap.KeySet
 
clear() - Method in class org.agrona.collections.IntHashSet
clear() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
clear() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
clear() - Method in class org.agrona.generation.StringWriterOutputManager
 
clock() - Method in class org.agrona.TimerWheel
Get the NanoClock used by this timer wheel.
close(AutoCloseable) - Static method in class org.agrona.CloseHelper
Close a AutoCloseable dealing with nulls and exceptions.
close() - Method in class org.agrona.collections.IntLruCache
 
close() - Method in class org.agrona.concurrent.AgentRunner
Stop the running Agent and cleanup.
close() - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
close() - Method in class org.agrona.concurrent.status.AtomicCounter
Free the counter slot for reuse.
close() - Method in class org.agrona.concurrent.status.AtomicLongPosition
 
close() - Method in interface org.agrona.concurrent.status.ReadablePosition
 
close() - Method in class org.agrona.concurrent.status.UnsafeBufferPosition
 
close() - Method in class org.agrona.nio.TransportPoller
Close NioSelector down.
CloseHelper - Class in org.agrona
 
CloseHelper() - Constructor for class org.agrona.CloseHelper
 
CollectionUtil - Class in org.agrona.collections
Utility functions for collection objects.
CollectionUtil() - Constructor for class org.agrona.collections.CollectionUtil
 
commit(int) - Method in class org.agrona.concurrent.RecordBuffer
Commit a claimed record into the buffer.
compact() - Method in class org.agrona.collections.BiInt2ObjectMap
Compact the backing arrays by rehashing with a capacity just larger than current size and giving consideration to the load factor.
compact() - Method in class org.agrona.collections.Int2IntHashMap
Compact the backing arrays by rehashing with a capacity just larger than current size and giving consideration to the load factor.
compact() - Method in class org.agrona.collections.Int2ObjectHashMap
Compact the Map backing arrays by rehashing with a capacity just larger than current size and giving consideration to the load factor.
compact() - Method in class org.agrona.collections.IntHashSet
Compact the backing arrays by rehashing with a capacity just larger than current size and giving consideration to the load factor.
compareAndSetInt(int, int, int) - Method in interface org.agrona.concurrent.AtomicBuffer
Atomic compare and set of a int given an expected value.
compareAndSetInt(long, int, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
compareAndSetInt(int, int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
compareAndSetLong(int, long, long) - Method in interface org.agrona.concurrent.AtomicBuffer
Atomic compare and set of a long given an expected value.
compareAndSetLong(long, long, long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
compareAndSetLong(int, long, long) - Method in class org.agrona.concurrent.UnsafeBuffer
 
compareTo(DirectBuffer) - Method in class org.agrona.concurrent.UnsafeBuffer
 
compareTo(DirectBuffer) - Method in class org.agrona.ExpandableArrayBuffer
 
compile(DiagnosticCollector<JavaFileObject>, JavaCompiler.CompilationTask) - Static method in class org.agrona.generation.CompilerUtil
 
compileAndLoad(String, DiagnosticCollector<JavaFileObject>, JavaFileManager, JavaCompiler.CompilationTask) - Static method in class org.agrona.generation.CompilerUtil
 
compileInMemory(String, Map<String, CharSequence>) - Static method in class org.agrona.generation.CompilerUtil
Compile a Map of source files in-memory resulting in a Class which is named.
compileOnDisk(String, Map<String, CharSequence>) - Static method in class org.agrona.generation.CompilerUtil
Compile a Map of source files on disk resulting in a Class which is named.
CompilerUtil - Class in org.agrona.generation
Utilities for compiling Java source files at runtime.
CompilerUtil() - Constructor for class org.agrona.generation.CompilerUtil
 
CompositeAgent - Class in org.agrona.concurrent
Compose several agents into one so a thread can be shared.
CompositeAgent(List<? extends Agent>) - Constructor for class org.agrona.concurrent.CompositeAgent
 
CompositeAgent(Agent...) - Constructor for class org.agrona.concurrent.CompositeAgent
 
computeDelayInMs() - Method in class org.agrona.TimerWheel
Compute delay in milliseconds until next tick.
computeIfAbsent(int, int, BiInt2ObjectMap.EntryFunction<? extends V>) - Method in class org.agrona.collections.BiInt2ObjectMap
If the specified key is not already associated with a value (or is mapped to null), attempts to compute its value using the given mapping function and enters it into this map unless null.
computeIfAbsent(int, IntFunction<? extends V>) - Method in class org.agrona.collections.Int2ObjectCache
Get a value for a given key, or if it does ot exist then default the value via a IntFunction and put it in the cache.
computeIfAbsent(int, IntFunction<? extends V>) - Method in class org.agrona.collections.Int2ObjectHashMap
Get a value for a given key, or if it does ot exist then default the value via a IntFunction and put it in the map.
CONSUMER_HEARTBEAT_OFFSET - Static variable in class org.agrona.concurrent.ringbuffer.RingBufferDescriptor
Offset within the trailer for where the consumer heartbeat time value is stored.
consumerHeartbeatTime(long) - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Set the time of the last consumer heartbeat.
consumerHeartbeatTime() - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
The time of the last consumer heartbeat.
consumerHeartbeatTime(long) - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Set the time of the last consumer heartbeat.
consumerHeartbeatTime() - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
The time of the last consumer heartbeat.
consumerHeartbeatTime(long) - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
Set the time of the last consumer heartbeat.
consumerHeartbeatTime() - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
The time of the last consumer heartbeat.
consumerPosition() - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
The position in bytes from start up for the consumers.
consumerPosition() - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
The position in bytes from start up for the consumers.
consumerPosition() - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
The position in bytes from start up for the consumers.
contains(Object) - Method in class org.agrona.collections.Int2IntHashMap.KeySet
contains(int) - Method in class org.agrona.collections.Int2IntHashMap.KeySet
 
contains(Object) - Method in class org.agrona.collections.Int2IntHashMap.Values
contains(int) - Method in class org.agrona.collections.Int2IntHashMap.Values
 
contains(Object) - Method in class org.agrona.collections.Int2ObjectCache.KeySet
 
contains(int) - Method in class org.agrona.collections.Int2ObjectCache.KeySet
 
contains(Object) - Method in class org.agrona.collections.Int2ObjectHashMap.KeySet
 
contains(int) - Method in class org.agrona.collections.Int2ObjectHashMap.KeySet
 
contains(Object) - Method in class org.agrona.collections.IntHashSet
contains(int) - Method in class org.agrona.collections.IntHashSet
contains(Object) - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
contains(Object) - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
contains(Object) - Method in class org.agrona.nio.NioSelectedKeySet
containsAll(Collection<?>) - Method in class org.agrona.collections.IntHashSet
containsAll(IntHashSet) - Method in class org.agrona.collections.IntHashSet
IntHashSet specialised variant of {this#containsAll(Collection)}.
containsAll(Collection<?>) - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
containsAll(Collection<?>) - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
containsKey(int) - Method in class org.agrona.collections.Int2IntHashMap
Int primitive specialised containsKey.
containsKey(Object) - Method in class org.agrona.collections.Int2IntHashMap
containsKey(Object) - Method in class org.agrona.collections.Int2ObjectCache
containsKey(int) - Method in class org.agrona.collections.Int2ObjectCache
Overloaded version of Map.containsKey(Object) that takes a primitive int key.
containsKey(Object) - Method in class org.agrona.collections.Int2ObjectHashMap
containsKey(int) - Method in class org.agrona.collections.Int2ObjectHashMap
Overloaded version of Map.containsKey(Object) that takes a primitive int key.
containsValue(int) - Method in class org.agrona.collections.Int2IntHashMap
 
containsValue(Object) - Method in class org.agrona.collections.Int2IntHashMap
containsValue(Object) - Method in class org.agrona.collections.Int2ObjectCache
containsValue(Object) - Method in class org.agrona.collections.Int2ObjectHashMap
ContinueBarrier - Class in org.agrona.console
Barrier to block the calling thread until a command is given on the command line.
ContinueBarrier(String) - Constructor for class org.agrona.console.ContinueBarrier
Create a barrier that will display the provided label and interact via System.out, System.in and Scanner.
copy(IntHashSet) - Method in class org.agrona.collections.IntHashSet
CopyBroadcastReceiver - Class in org.agrona.concurrent.broadcast
Receiver that copies messages that have been broadcast to enable a simpler API for the client.
CopyBroadcastReceiver(BroadcastReceiver) - Constructor for class org.agrona.concurrent.broadcast.CopyBroadcastReceiver
Wrap a BroadcastReceiver to simplify the API for receiving messages.
CORRELATION_COUNTER_OFFSET - Static variable in class org.agrona.concurrent.ringbuffer.RingBufferDescriptor
Offset within the trailer for where the correlation counter value is stored.
COUNTER_LENGTH - Static variable in class org.agrona.concurrent.status.CountersReader
Length of the space allocated to a counter that includes padding to avoid false sharing.
counterOffset(int) - Static method in class org.agrona.concurrent.status.CountersReader
The offset in the counter buffer for a given counterId.
CountersManager - Class in org.agrona.concurrent.status
Manages the allocation and freeing of counters that are normally stored in a memory-mapped file.
CountersManager(AtomicBuffer, AtomicBuffer) - Constructor for class org.agrona.concurrent.status.CountersManager
Create a new counter buffer manager over two buffers.
CountersReader - Class in org.agrona.concurrent.status
Reads the counters metadata and values buffers.
CountersReader(AtomicBuffer, AtomicBuffer) - Constructor for class org.agrona.concurrent.status.CountersReader
Construct a reader over buffers containing the values and associated metadata.
CountersReader.MetaData - Interface in org.agrona.concurrent.status
Callback function for consuming metadata records of counters.
createEmptyFile(File, long) - Static method in class org.agrona.IoUtil
Create an empty file, fill with 0s, and return the FileChannel
createOutput(String) - Method in interface org.agrona.generation.OutputManager
Create a new output destination based on a name.
createOutput(String) - Method in class org.agrona.generation.PackageOutputManager
Create a new output which will be a Java source file in the given package.
createOutput(String) - Method in class org.agrona.generation.StringWriterOutputManager
 

D

DEFAULT_INITIAL_CAPACITY - Static variable in class org.agrona.collections.IntHashSet
The initial capacity used when none is specified in the constructor.
DEFAULT_KEY_FUNC - Static variable in class org.agrona.concurrent.status.CountersManager
Default function to set a key when none is supplied.
DEFAULT_LOAD_FACTOR - Static variable in class org.agrona.collections.IntHashSet
The load factor used when none is specified in the constructor.
DEFAULT_TYPE_ID - Static variable in class org.agrona.concurrent.status.CountersManager
Default type id of a counter when none is supplied.
delete(File, boolean) - Static method in class org.agrona.IoUtil
Recursively delete a file or directory tree.
delete() - Method in interface org.agrona.ManagedResource
Delete any resources held.
deleteIfExists(File) - Static method in class org.agrona.IoUtil
Delete file only if it already exists.
DID_NOT_CLAIM_RECORD - Static variable in class org.agrona.concurrent.RecordBuffer
 
difference(IntHashSet) - Method in class org.agrona.collections.IntHashSet
Fast Path set difference for comparison with another IntHashSet.
DirectBuffer - Interface in org.agrona
Abstraction over a range of buffer types that allows fields to be read in native typed fashion.
DirectBufferInputStream - Class in org.agrona.io
An InputStream that wraps a DirectBuffer.
DirectBufferInputStream() - Constructor for class org.agrona.io.DirectBufferInputStream
 
DirectBufferInputStream(DirectBuffer) - Constructor for class org.agrona.io.DirectBufferInputStream
 
DirectBufferInputStream(DirectBuffer, int, int) - Constructor for class org.agrona.io.DirectBufferInputStream
 
DirectBufferOutputStream - Class in org.agrona.io
OutputStream that wraps an underlying MutableDirectBuffer.
DirectBufferOutputStream() - Constructor for class org.agrona.io.DirectBufferOutputStream
 
DirectBufferOutputStream(MutableDirectBuffer) - Constructor for class org.agrona.io.DirectBufferOutputStream
 
DirectBufferOutputStream(MutableDirectBuffer, int, int) - Constructor for class org.agrona.io.DirectBufferOutputStream
 
DISABLE_BOUNDS_CHECKS_PROP_NAME - Static variable in class org.agrona.concurrent.UnsafeBuffer
 
DistinctErrorLog - Class in org.agrona.concurrent.errors
Distinct record of error observations.
DistinctErrorLog(AtomicBuffer, EpochClock) - Constructor for class org.agrona.concurrent.errors.DistinctErrorLog
Create a new error log that will be written to a provided AtomicBuffer.
DistinctErrorLog.DistinctObservation - Class in org.agrona.concurrent.errors
 
DistinctObservation(Throwable, int) - Constructor for class org.agrona.concurrent.errors.DistinctErrorLog.DistinctObservation
 
DoNotSub - Annotation Type in org.agrona.generation
A marker annotation to tell the primitive expander not to substitute The line in question
doWork() - Method in interface org.agrona.concurrent.Agent
An agent should implement this method to do its work.
doWork() - Method in class org.agrona.concurrent.CompositeAgent
 
drain(Consumer<E>) - Method in class org.agrona.concurrent.ManyToManyConcurrentArrayQueue
 
drain(Consumer<E>) - Method in class org.agrona.concurrent.ManyToOneConcurrentArrayQueue
 
drain(Consumer<E>) - Method in class org.agrona.concurrent.OneToOneConcurrentArrayQueue
 
drain(Consumer<E>) - Method in interface org.agrona.concurrent.Pipe
Invoke a Consumer callback on each elements to drain the collection of elements until it is empty.
drainTo(Collection<? super E>, int) - Method in class org.agrona.concurrent.ManyToManyConcurrentArrayQueue
 
drainTo(Collection<? super E>, int) - Method in class org.agrona.concurrent.ManyToOneConcurrentArrayQueue
 
drainTo(Collection<? super E>, int) - Method in class org.agrona.concurrent.OneToOneConcurrentArrayQueue
 
drainTo(Collection<? super E>, int) - Method in interface org.agrona.concurrent.Pipe
Drain available elements into the provided Collection up to a provided maximum limit of elements.

E

element() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
element() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
ENCODED_ERROR_OFFSET - Static variable in class org.agrona.concurrent.errors.DistinctErrorLog
Offset within a record at which the encoded exception field begins.
encodedMsgOffset(int) - Static method in class org.agrona.concurrent.ringbuffer.RecordDescriptor
The offset from the beginning of a record at which the encoded message begins.
ensureCapacity(T[], int) - Static method in class org.agrona.collections.ArrayUtil
Ensure an array has the required capacity.
ensureDirectoryExists(File, String) - Static method in class org.agrona.IoUtil
Create a directory if it doesn't already exist.
ensureDirectoryIsRecreated(File, String, BiConsumer<String, String>) - Static method in class org.agrona.IoUtil
Create a directory, removing previous directory if it already exists.
EntryIterator() - Constructor for class org.agrona.collections.Int2ObjectCache.EntryIterator
 
EntryIterator() - Constructor for class org.agrona.collections.Int2ObjectHashMap.EntryIterator
 
entrySet() - Method in class org.agrona.collections.Int2IntHashMap
entrySet() - Method in class org.agrona.collections.Int2ObjectCache
entrySet() - Method in class org.agrona.collections.Int2ObjectHashMap
EpochClock - Interface in org.agrona.concurrent
Retrieves the number of milliseconds since 1 Jan 1970 UTC.
equals(Object) - Method in class org.agrona.collections.IntHashSet
equals(Object) - Method in class org.agrona.concurrent.UnsafeBuffer
 
equals(Object) - Method in class org.agrona.ExpandableArrayBuffer
 
ErrorConsumer - Interface in org.agrona.concurrent.errors
 
ErrorHandler - Interface in org.agrona
Callback interface for handling an error/exception that has occurred when processing an operation or event.
ErrorLogReader - Class in org.agrona.concurrent.errors
Reader for the log created by a DistinctErrorLog.
ErrorLogReader() - Constructor for class org.agrona.concurrent.errors.ErrorLogReader
 
evenHash(int, int) - Static method in class org.agrona.collections.Hashing
Generate an even hash for a int value.
evenHash(long, int) - Static method in class org.agrona.collections.Hashing
Generate an even hash for a long value.
ExpandableArrayBuffer - Class in org.agrona
Expandable MutableDirectBuffer that is backed by an array.
ExpandableArrayBuffer() - Constructor for class org.agrona.ExpandableArrayBuffer
ExpandableArrayBuffer(int) - Constructor for class org.agrona.ExpandableArrayBuffer
Create an ExpandableArrayBuffer with a provided initial length.
ExpandableDirectBufferOutputStream - Class in org.agrona.io
OutputStream that wraps an underlying expandable version of a MutableDirectBuffer.
ExpandableDirectBufferOutputStream() - Constructor for class org.agrona.io.ExpandableDirectBufferOutputStream
 
ExpandableDirectBufferOutputStream(MutableDirectBuffer) - Constructor for class org.agrona.io.ExpandableDirectBufferOutputStream
 
ExpandableDirectBufferOutputStream(MutableDirectBuffer, int) - Constructor for class org.agrona.io.ExpandableDirectBufferOutputStream
 
expireTimers() - Method in class org.agrona.TimerWheel
Process timers and execute any expired timers.

F

fill(FileChannel, long, long, byte) - Static method in class org.agrona.IoUtil
Fill a region of a file with a given byte value.
findNext() - Method in class org.agrona.collections.IntIterator
 
findNextPositivePowerOfTwo(int) - Static method in class org.agrona.BitUtil
Fast method of finding the next power of 2 greater than or equal to the supplied value.
FIRST_OBSERVATION_TIMESTAMP_OFFSET - Static variable in class org.agrona.concurrent.errors.DistinctErrorLog
Offset within a record at which the first observation timestamp field begins.
forEach(Consumer<V>) - Method in class org.agrona.collections.BiInt2ObjectMap
Iterate over the contents of the map
forEach(BiInt2ObjectMap.EntryConsumer<V>) - Method in class org.agrona.collections.BiInt2ObjectMap
Iterate over the contents of the map
forEach(BiConsumer<? super Integer, ? super Integer>) - Method in class org.agrona.collections.Int2IntHashMap
forEach(RecordBuffer.RecordHandler) - Method in class org.agrona.concurrent.RecordBuffer
Read each record out of the buffer in turn.
forEach(IntObjConsumer<String>) - Method in class org.agrona.concurrent.status.CountersReader
Iterate over all labels in the label buffer.
forEach(CountersReader.MetaData) - Method in class org.agrona.concurrent.status.CountersReader
Iterate over all the metadata in the buffer.
forEach(ToIntFunction<SelectionKey>) - Method in class org.agrona.nio.NioSelectedKeySet
Iterate over the key set and apply the given function.
free(int) - Method in class org.agrona.concurrent.status.CountersManager
Free the counter identified by counterId.
fromHex(String) - Static method in class org.agrona.BitUtil
Generate a byte array from a string that is the hex representation of the given byte array.
fromHexByteArray(byte[]) - Static method in class org.agrona.BitUtil
Generate a byte array from the hex representation of the given byte array.
FULL_LABEL_LENGTH - Static variable in class org.agrona.concurrent.status.CountersReader
Length of a counter label length including length prefix.

G

generateRandomisedId() - Static method in class org.agrona.BitUtil
Generate a randomized integer over [Integer.MIN_VALUE, Integer.MAX_VALUE] suitable for use as an Aeron Id.
get(int, int) - Method in class org.agrona.collections.BiInt2ObjectMap
Retrieve a value from the map.
get(int) - Method in class org.agrona.collections.Int2IntHashMap
 
get(Object) - Method in class org.agrona.collections.Int2IntHashMap
get(Object) - Method in class org.agrona.collections.Int2ObjectCache
get(int) - Method in class org.agrona.collections.Int2ObjectCache
Overloaded version of Map.get(Object) that takes a primitive int key.
get(Object) - Method in class org.agrona.collections.Int2ObjectHashMap
get(int) - Method in class org.agrona.collections.Int2ObjectHashMap
Overloaded version of Map.get(Object) that takes a primitive int key.
get(int) - Method in class org.agrona.concurrent.RecordBuffer
Search for the first record with the specified key.
get() - Method in class org.agrona.concurrent.status.AtomicCounter
Get the latest value for the counter.
get() - Method in class org.agrona.concurrent.status.AtomicLongPosition
 
get() - Method in interface org.agrona.concurrent.status.Position
Get the current position of a component without memory ordering semantics.
get() - Method in class org.agrona.concurrent.status.UnsafeBufferPosition
 
getAndAddInt(int, int) - Method in interface org.agrona.concurrent.AtomicBuffer
Atomically add a delta to a value at a location returning the previous contents.
getAndAddInt(long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getAndAddInt(int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getAndAddLong(int, long) - Method in interface org.agrona.concurrent.AtomicBuffer
Atomically add a delta to a value at a location returning the previous contents.
getAndAddLong(long, long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getAndAddLong(int, long) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getAndSetInt(int, int) - Method in interface org.agrona.concurrent.AtomicBuffer
Atomically exchange a value at a location returning the previous contents.
getAndSetInt(long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getAndSetInt(int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getAndSetLong(int, long) - Method in interface org.agrona.concurrent.AtomicBuffer
Atomically exchange a value at a location returning the previous contents.
getAndSetLong(long, long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getAndSetLong(int, long) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getByte(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getByte(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getByte(int) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getByte(int) - Method in class org.agrona.ExpandableArrayBuffer
 
getBytes(long, byte[]) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getBytes(long, byte[], long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getBytes(long, ByteBuffer, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getBytes(int, byte[]) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getBytes(int, byte[], int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getBytes(int, MutableDirectBuffer, int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getBytes(int, ByteBuffer, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getBytes(int, ByteBuffer, int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getBytes(int, byte[]) - Method in interface org.agrona.DirectBuffer
Get from the underlying buffer into a supplied byte array.
getBytes(int, byte[], int, int) - Method in interface org.agrona.DirectBuffer
Get bytes from the underlying buffer into a supplied byte array.
getBytes(int, MutableDirectBuffer, int, int) - Method in interface org.agrona.DirectBuffer
Get bytes from this DirectBuffer into the provided MutableDirectBuffer at given indices.
getBytes(int, ByteBuffer, int) - Method in interface org.agrona.DirectBuffer
Get from the underlying buffer into a supplied ByteBuffer current Buffer.position().
getBytes(int, ByteBuffer, int, int) - Method in interface org.agrona.DirectBuffer
Get from the underlying buffer into a supplied ByteBuffer at a offset.
getBytes(int, byte[]) - Method in class org.agrona.ExpandableArrayBuffer
 
getBytes(int, byte[], int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
getBytes(int, MutableDirectBuffer, int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
getBytes(int, ByteBuffer, int) - Method in class org.agrona.ExpandableArrayBuffer
 
getBytes(int, ByteBuffer, int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
getBytes() - Method in class org.agrona.generation.JavaClassObject
 
getByteVolatile(int) - Method in interface org.agrona.concurrent.AtomicBuffer
Get the value at a given index with volatile semantics.
getByteVolatile(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getByteVolatile(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getChar(long, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getChar(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getChar(int, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getChar(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getChar(int, ByteOrder) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getChar(int) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getChar(int, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
getChar(int) - Method in class org.agrona.ExpandableArrayBuffer
 
getCharContent(boolean) - Method in class org.agrona.generation.CharSequenceJavaFileObject
 
getCharVolatile(int) - Method in interface org.agrona.concurrent.AtomicBuffer
Get the value at a given index with volatile semantics.
getCharVolatile(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getCharVolatile(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getClassLoader(JavaFileManager.Location) - Method in class org.agrona.generation.ClassFileManager
 
getCounterValue(int) - Method in class org.agrona.concurrent.status.CountersReader
Get the value for a given counter id as a volatile read.
getDouble(long, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getDouble(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getDouble(int, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getDouble(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getDouble(int, ByteOrder) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getDouble(int) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getDouble(int, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
getDouble(int) - Method in class org.agrona.ExpandableArrayBuffer
 
getFloat(long, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getFloat(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getFloat(int, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getFloat(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getFloat(int, ByteOrder) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getFloat(int) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getFloat(int, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
getFloat(int) - Method in class org.agrona.ExpandableArrayBuffer
 
getInt(long, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getInt(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getInt(int, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getInt(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getInt(int, ByteOrder) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getInt(int) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getInt(int, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
getInt(int) - Method in class org.agrona.ExpandableArrayBuffer
 
getIntVolatile(int) - Method in interface org.agrona.concurrent.AtomicBuffer
Get the value at a given index with volatile semantics.
getIntVolatile(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getIntVolatile(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getJavaFileForOutput(JavaFileManager.Location, String, JavaFileObject.Kind, FileObject) - Method in class org.agrona.generation.ClassFileManager
 
getKey() - Method in class org.agrona.collections.Int2ObjectCache.EntryIterator
 
getKey() - Method in class org.agrona.collections.Int2ObjectHashMap.EntryIterator
 
getKind() - Method in class org.agrona.generation.JavaClassObject
 
getLong(long, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getLong(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getLong(int, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getLong(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getLong(int, ByteOrder) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getLong(int) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getLong(int, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
getLong(int) - Method in class org.agrona.ExpandableArrayBuffer
 
getLongVolatile(int) - Method in interface org.agrona.concurrent.AtomicBuffer
Get the value at a given index with volatile semantics.
getLongVolatile(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getLongVolatile(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getOrDefault(Map<K, V>, K, Function<K, V>) - Static method in class org.agrona.collections.CollectionUtil
A getOrDefault that doesn't create garbage if its suppler is non-capturing.
getShort(long, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getShort(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getShort(int, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getShort(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getShort(int, ByteOrder) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getShort(int) - Method in interface org.agrona.DirectBuffer
Get the value at a given index.
getShort(int, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
getShort(int) - Method in class org.agrona.ExpandableArrayBuffer
 
getShortVolatile(int) - Method in interface org.agrona.concurrent.AtomicBuffer
Get the value at a given index with volatile semantics.
getShortVolatile(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getShortVolatile(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getSource(String) - Method in class org.agrona.generation.StringWriterOutputManager
 
getSources() - Method in class org.agrona.generation.StringWriterOutputManager
 
getStringUtf8(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getStringUtf8(long, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getStringUtf8(long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getStringUtf8(int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getStringUtf8(int, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getStringUtf8(int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getStringUtf8(int) - Method in interface org.agrona.DirectBuffer
Get a String from bytes encoded in UTF-8 format that is length prefixed.
getStringUtf8(int, ByteOrder) - Method in interface org.agrona.DirectBuffer
Get a String from bytes encoded in UTF-8 format that is length prefixed.
getStringUtf8(int, int) - Method in interface org.agrona.DirectBuffer
Get part of String from bytes encoded in UTF-8 format that is length prefixed.
getStringUtf8(int) - Method in class org.agrona.ExpandableArrayBuffer
 
getStringUtf8(int, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
getStringUtf8(int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
getStringWithoutLengthUtf8(long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
getStringWithoutLengthUtf8(int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
getStringWithoutLengthUtf8(int, int) - Method in interface org.agrona.DirectBuffer
Get an encoded UTF-8 String from the buffer that does not have a length prefix.
getStringWithoutLengthUtf8(int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
getValue() - Method in class org.agrona.collections.Int2ObjectCache.EntryIterator
 
getValue() - Method in class org.agrona.collections.Int2ObjectHashMap.EntryIterator
 
getVolatile() - Method in class org.agrona.concurrent.status.AtomicLongPosition
 
getVolatile() - Method in interface org.agrona.concurrent.status.ReadablePosition
Get the current position of a component with volatile semantics
getVolatile() - Method in class org.agrona.concurrent.status.UnsafeBufferPosition
 
getWeak() - Method in class org.agrona.concurrent.status.AtomicCounter
Get the value of the counter using weak ordering semantics.

H

hash(int, int) - Static method in class org.agrona.collections.Hashing
Generate a hash for a int value.
hash(long, int) - Static method in class org.agrona.collections.Hashing
Generate a hash for a long value.
hash(int, int, int) - Static method in class org.agrona.collections.Hashing
Generate a hash for two ints.
hashCode() - Method in class org.agrona.collections.IntHashSet
hashCode() - Method in class org.agrona.concurrent.UnsafeBuffer
 
hashCode() - Method in class org.agrona.ExpandableArrayBuffer
 
Hashing - Class in org.agrona.collections
Hashing functions for applying to integers.
Hashing() - Constructor for class org.agrona.collections.Hashing
 
hasNext() - Method in class org.agrona.collections.IntIterator
 
HEAD_CACHE_POSITION_OFFSET - Static variable in class org.agrona.concurrent.ringbuffer.RingBufferDescriptor
Offset within the trailer for where the head cache value is stored.
HEAD_OFFSET - Static variable in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
HEAD_POSITION_OFFSET - Static variable in class org.agrona.concurrent.ringbuffer.RingBufferDescriptor
Offset within the trailer for where the head value is stored.
HEADER_LENGTH - Static variable in class org.agrona.concurrent.broadcast.RecordDescriptor
Length of the record header in bytes.
HEADER_LENGTH - Static variable in class org.agrona.concurrent.ringbuffer.RecordDescriptor
Header length made up of fields for length, type, and then the encoded message.

I

id() - Method in class org.agrona.concurrent.status.AtomicLongPosition
 
id() - Method in interface org.agrona.concurrent.status.ReadablePosition
Identifier for this position.
id() - Method in class org.agrona.concurrent.status.UnsafeBufferPosition
 
idle(int) - Method in class org.agrona.concurrent.BackoffIdleStrategy
Perform current idle action (e.g.
idle() - Method in class org.agrona.concurrent.BackoffIdleStrategy
 
idle(int) - Method in class org.agrona.concurrent.BusySpinIdleStrategy
Note: this implementation will result in no safepoint poll once inlined.
idle() - Method in class org.agrona.concurrent.BusySpinIdleStrategy
 
idle(int) - Method in interface org.agrona.concurrent.IdleStrategy
Perform current idle action (e.g.
idle() - Method in interface org.agrona.concurrent.IdleStrategy
Perform current idle action (e.g.
idle(int) - Method in class org.agrona.concurrent.NoOpIdleStrategy
Note: this implementation will result in no safepoint poll once inlined.
idle() - Method in class org.agrona.concurrent.NoOpIdleStrategy
Note: this implementation will result in no safepoint poll once inlined.
idle(int) - Method in class org.agrona.concurrent.SleepingIdleStrategy
 
idle() - Method in class org.agrona.concurrent.SleepingIdleStrategy
 
idle(int) - Method in class org.agrona.concurrent.YieldingIdleStrategy
 
idle() - Method in class org.agrona.concurrent.YieldingIdleStrategy
 
IdleStrategy - Interface in org.agrona.concurrent
Idle strategy for use by threads when they do not have work to do.
increment() - Method in class org.agrona.concurrent.status.AtomicCounter
Perform an atomic increment that will not lose updates across threads.
INITIAL_CAPACITY - Static variable in class org.agrona.ExpandableArrayBuffer
Initial capacity of the array from which it will double in size on each expansion.
INITIAL_TICK_DEPTH - Static variable in class org.agrona.TimerWheel
 
initialise() - Method in class org.agrona.concurrent.RecordBuffer
Initialise the buffer if you're the first thread to begin writing
Int2IntHashMap - Class in org.agrona.collections
A open addressing with linear probing hash map specialised for primitive key and value pairs.
Int2IntHashMap(int) - Constructor for class org.agrona.collections.Int2IntHashMap
 
Int2IntHashMap(int, float, int) - Constructor for class org.agrona.collections.Int2IntHashMap
 
Int2IntHashMap.IntIterator - Class in org.agrona.collections
 
Int2IntHashMap.KeySet - Class in org.agrona.collections
 
Int2IntHashMap.Values - Class in org.agrona.collections
 
Int2ObjectCache<V> - Class in org.agrona.collections
A cache implementation specialised for int keys using open addressing to probe a set of fixed size.
Int2ObjectCache(int, int, Consumer<V>) - Constructor for class org.agrona.collections.Int2ObjectCache
 
Int2ObjectCache.EntryIterator<V> - Class in org.agrona.collections
 
Int2ObjectCache.KeyIterator - Class in org.agrona.collections
 
Int2ObjectCache.KeySet - Class in org.agrona.collections
 
Int2ObjectCache.ValueIterator<T> - Class in org.agrona.collections
 
Int2ObjectHashMap<V> - Class in org.agrona.collections
Map implementation specialised for int keys using open addressing and linear probing for cache efficient access.
Int2ObjectHashMap() - Constructor for class org.agrona.collections.Int2ObjectHashMap
 
Int2ObjectHashMap(int, float) - Constructor for class org.agrona.collections.Int2ObjectHashMap
Construct a new map allowing a configuration for initial capacity and load factor.
Int2ObjectHashMap.EntryIterator<V> - Class in org.agrona.collections
 
Int2ObjectHashMap.KeyIterator - Class in org.agrona.collections
 
Int2ObjectHashMap.KeySet - Class in org.agrona.collections
 
Int2ObjectHashMap.ValueIterator<T> - Class in org.agrona.collections
 
intForEach(IntIntConsumer) - Method in class org.agrona.collections.Int2IntHashMap
Primitive specialised forEach implementation.
IntHashSet - Class in org.agrona.collections
Open-addressing with linear-probing expandable hash set.
IntHashSet(int) - Constructor for class org.agrona.collections.IntHashSet
 
IntHashSet(int, int) - Constructor for class org.agrona.collections.IntHashSet
 
IntHashSet(int, int, float) - Constructor for class org.agrona.collections.IntHashSet
 
IntIntConsumer - Interface in org.agrona.collections
This is an (int, int) primitive specialisation of a BiConsumer
IntIterator - Class in org.agrona.collections
An iterator for a sequence of primitive values.
IntIterator(int, int[]) - Constructor for class org.agrona.collections.IntIterator
Construct an Iterator over an array of primitives ints.
IntLruCache<E> - Class in org.agrona.collections
A fixed capacity cache of int keyed values that evicts the least-recently-used element when it runs out of space.
IntLruCache(int, IntFunction<E>, Consumer<E>) - Constructor for class org.agrona.collections.IntLruCache
Constructor.
IntObjConsumer<T> - Interface in org.agrona.collections
This is an (int, Object) primitive specialisation of a BiConsumer.
IoUtil - Class in org.agrona
Collection of IO utilities.
IoUtil() - Constructor for class org.agrona.IoUtil
 
isActive() - Method in class org.agrona.TimerWheel.Timer
Is timer active or not
isAligned(long, int) - Static method in class org.agrona.BitUtil
Is an address aligned on a boundary.
isCancelled() - Method in class org.agrona.TimerWheel.Timer
Was timer cancelled or not
isEmpty() - Method in class org.agrona.collections.BiInt2ObjectMap
Is map empty or not.
isEmpty() - Method in class org.agrona.collections.Int2IntHashMap
isEmpty() - Method in class org.agrona.collections.Int2ObjectCache
isEmpty() - Method in class org.agrona.collections.Int2ObjectHashMap
isEmpty() - Method in class org.agrona.collections.IntHashSet
isEmpty() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
isEmpty() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
isEmpty(String) - Static method in class org.agrona.Strings
Is a string null or empty?
isEven(int) - Static method in class org.agrona.BitUtil
Is a number even.
isExpandable() - Method in class org.agrona.concurrent.UnsafeBuffer
 
isExpandable() - Method in class org.agrona.ExpandableArrayBuffer
 
isExpandable() - Method in interface org.agrona.MutableDirectBuffer
Is this buffer expandable to accommodate putting data into it beyond the current capacity?
isExpired() - Method in class org.agrona.TimerWheel.Timer
Has timer expired or not
isInitialised() - Method in class org.agrona.concurrent.RecordBuffer
Check if the buffer has been initialised.
isPowerOfTwo(int) - Static method in class org.agrona.BitUtil
Is a value a positive power of two.
ITERATION_THRESHOLD - Static variable in class org.agrona.nio.TransportPoller
 
iterator() - Method in class org.agrona.collections.Int2IntHashMap.KeySet
iterator() - Method in class org.agrona.collections.Int2IntHashMap.Values
iterator() - Method in class org.agrona.collections.Int2ObjectCache.KeySet
 
iterator() - Method in class org.agrona.collections.Int2ObjectHashMap.KeySet
 
iterator() - Method in class org.agrona.collections.IntHashSet
iterator() - Method in class org.agrona.collections.UnmodifiableCollectionView
iterator() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
iterator() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
iterator() - Method in class org.agrona.nio.NioSelectedKeySet

J

JavaClassObject - Class in org.agrona.generation
 
JavaClassObject(String, JavaFileObject.Kind) - Constructor for class org.agrona.generation.JavaClassObject
 

K

KEY_OFFSET - Static variable in class org.agrona.concurrent.status.CountersReader
Offset in the record at which the key is stored.
KeyIterator() - Constructor for class org.agrona.collections.Int2ObjectCache.KeyIterator
 
KeyIterator() - Constructor for class org.agrona.collections.Int2ObjectHashMap.KeyIterator
 
keys() - Method in class org.agrona.nio.NioSelectedKeySet
Return selected keys.
keySet() - Method in class org.agrona.collections.Int2IntHashMap
keySet() - Method in class org.agrona.collections.Int2ObjectCache
KeySet() - Constructor for class org.agrona.collections.Int2ObjectCache.KeySet
 
keySet() - Method in class org.agrona.collections.Int2ObjectHashMap
KeySet() - Constructor for class org.agrona.collections.Int2ObjectHashMap.KeySet
 

L

LABEL_OFFSET - Static variable in class org.agrona.concurrent.status.CountersReader
Offset in the record at which the label is stored.
LangUtil - Class in org.agrona
Grouping of language level utilities to make programming in Java more convenient.
LangUtil() - Constructor for class org.agrona.LangUtil
 
lappedCount() - Method in class org.agrona.concurrent.broadcast.BroadcastReceiver
Get the number of times the transmitter has lapped this receiver around the buffer.
LAST_OBSERVATION_TIMESTAMP_OFFSET - Static variable in class org.agrona.concurrent.errors.DistinctErrorLog
Offset within a record at which the last observation timestamp field begins.
LATEST_COUNTER_OFFSET - Static variable in class org.agrona.concurrent.broadcast.BroadcastBufferDescriptor
Offset within the trailer for where the latest sequence value is stored.
length() - Method in class org.agrona.concurrent.broadcast.BroadcastReceiver
The length of the next message in the transmission stream.
length() - Method in class org.agrona.io.DirectBufferInputStream
The length of the underlying buffer to use
length() - Method in class org.agrona.io.DirectBufferOutputStream
The length of the underlying buffer to use
LENGTH_OFFSET - Static variable in class org.agrona.concurrent.broadcast.RecordDescriptor
Offset within the record at which the record length field begins.
LENGTH_OFFSET - Static variable in class org.agrona.concurrent.errors.DistinctErrorLog
Offset within a record at which the length field begins.
lengthOffset(int) - Static method in class org.agrona.concurrent.broadcast.RecordDescriptor
The buffer offset at which the message length field begins.
lengthOffset(int) - Static method in class org.agrona.concurrent.ringbuffer.RecordDescriptor
The offset from the beginning of a record at which the message length field begins.
loadFactor() - Method in class org.agrona.collections.BiInt2ObjectMap
Get the load factor beyond which the map will increase size.
loadFactor() - Method in class org.agrona.collections.Int2IntHashMap
Get the load factor applied for resize operations.
loadFactor() - Method in class org.agrona.collections.Int2ObjectHashMap
Get the load factor beyond which the map will increase size.
loadFactor() - Method in class org.agrona.collections.IntHashSet
Get the load factor beyond which the set will increase size.
lookup(int) - Method in class org.agrona.collections.IntLruCache
Looks up an element in the cache, creating a new element if it doesn't exist and evicting the least recently used element if there's no space left in the cache.

M

main(String[]) - Static method in class org.agrona.generation.PrimitiveExpander
 
makeHeader(int, int) - Static method in class org.agrona.concurrent.ringbuffer.RecordDescriptor
Make a 64-bit header from the length and message type id.
ManagedResource - Interface in org.agrona
Implementations of this interface can a resource that need to have external state tracked for deletion.
ManyToManyConcurrentArrayQueue<E> - Class in org.agrona.concurrent
Many producer to many consumer concurrent queue that is array backed.
ManyToManyConcurrentArrayQueue(int) - Constructor for class org.agrona.concurrent.ManyToManyConcurrentArrayQueue
Create a new queue with a bounded capacity.
ManyToOneConcurrentArrayQueue<E> - Class in org.agrona.concurrent
Many producer to one consumer concurrent queue that is array backed.
ManyToOneConcurrentArrayQueue(int) - Constructor for class org.agrona.concurrent.ManyToOneConcurrentArrayQueue
 
ManyToOneConcurrentLinkedQueue<E> - Class in org.agrona.concurrent
Concurrent linked Queue that can be used from many producers and a single consumer.
ManyToOneConcurrentLinkedQueue() - Constructor for class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
ManyToOneRingBuffer - Class in org.agrona.concurrent.ringbuffer
A ring-buffer that supports the exchange of messages from many producers to a single consumer.
ManyToOneRingBuffer(AtomicBuffer) - Constructor for class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Construct a new RingBuffer based on an underlying AtomicBuffer.
map(FileChannel, FileChannel.MapMode, long, long) - Static method in class org.agrona.IoUtil
Map a range of a file and return the address at which the range begins.
mapExistingFile(File, String) - Static method in class org.agrona.IoUtil
Check that file exists, open file, and return MappedByteBuffer for entire file
mapExistingFile(File, String, long, long) - Static method in class org.agrona.IoUtil
Check that file exists, open file, and return MappedByteBuffer for only region specified
mapNewFile(File, long) - Static method in class org.agrona.IoUtil
Create a new file, fill with 0s, and return a MappedByteBuffer for the file
MappedResizeableBuffer - Class in org.agrona.concurrent
Supports regular, byte ordered, and atomic (memory ordered) access to an underlying buffer.
MappedResizeableBuffer(FileChannel, long, long) - Constructor for class org.agrona.concurrent.MappedResizeableBuffer
Attach a view to an off-heap memory region by address.
markSupported() - Method in class org.agrona.io.DirectBufferInputStream
 
MAX_ARRAY_LENGTH - Static variable in class org.agrona.ExpandableArrayBuffer
Maximum length to which the underlying array can grow.
MAX_KEY_LENGTH - Static variable in class org.agrona.concurrent.status.CountersReader
Maximum length a key can be.
MAX_LABEL_LENGTH - Static variable in class org.agrona.concurrent.status.CountersReader
Maximum length of a label not including its length prefix.
maxMsgLength() - Method in class org.agrona.concurrent.broadcast.BroadcastTransmitter
Get the maximum message length that can be transmitted for a buffer.
maxMsgLength() - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
The maximum message length in bytes supported by the underlying ring buffer.
maxMsgLength() - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
The maximum message length in bytes supported by the underlying ring buffer.
maxMsgLength() - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
The maximum message length in bytes supported by the underlying ring buffer.
maxValue() - Method in class org.agrona.collections.Int2IntHashMap
Get the maximum value stored in the map.
MessageHandler - Interface in org.agrona.concurrent
Callback interface for processing of messages that are read from a buffer.
messageTypeId(long) - Static method in class org.agrona.concurrent.ringbuffer.RecordDescriptor
 
METADATA_LENGTH - Static variable in class org.agrona.concurrent.status.CountersReader
Length of a meta data record in bytes.
metaDataBuffer - Variable in class org.agrona.concurrent.status.CountersReader
 
metaDataBuffer() - Method in class org.agrona.concurrent.status.CountersReader
Get the buffer containing the metadata for the counters.
metaDataOffset(int) - Static method in class org.agrona.concurrent.status.CountersReader
The offset in the metadata buffer for a given id.
minValue() - Method in class org.agrona.collections.Int2IntHashMap
Get the minimum value stored in the map.
missingValue() - Method in class org.agrona.collections.Int2IntHashMap
The value to be used as a null marker in the map.
missingValue() - Method in class org.agrona.collections.IntHashSet
The value to be used as a null marker in the set.
msgOffset(int) - Static method in class org.agrona.concurrent.broadcast.RecordDescriptor
The buffer offset at which the encoded message begins.
MutableDirectBuffer - Interface in org.agrona
Abstraction over a range of buffer types that allows fields to be written in native typed fashion.
MutableInteger - Class in org.agrona.collections
Holder for an int value that is mutable.
MutableInteger() - Constructor for class org.agrona.collections.MutableInteger
 

N

NanoClock - Interface in org.agrona.concurrent
Functional interface for return the current time as system wide monotonic tick of 1 nanosecond precision.
nanoTime() - Method in interface org.agrona.concurrent.NanoClock
The number of ticks in nanoseconds the clock has advanced since starting.
nanoTime() - Method in class org.agrona.concurrent.SystemNanoClock
 
NATIVE_BYTE_ORDER - Static variable in class org.agrona.BufferUtil
 
newArray(T[], int) - Static method in class org.agrona.collections.ArrayUtil
Allocate a new array of the same type as another array.
newBlankTimer() - Method in class org.agrona.TimerWheel
Return a blank TimerWheel.Timer suitable for rescheduling.
newCounter(String) - Method in class org.agrona.concurrent.status.CountersManager
Allocate a counter record and wrap it with a new AtomicCounter for use.
newCounter(String, int, Consumer<MutableDirectBuffer>) - Method in class org.agrona.concurrent.status.CountersManager
Allocate a counter record and wrap it with a new AtomicCounter for use.
newTimeout(long, TimeUnit, Runnable) - Method in class org.agrona.TimerWheel
Schedule a new timer that runs task when it expires.
next(int, int) - Static method in class org.agrona.BitUtil
Cycles indices of an array one at a time in a forward fashion
next() - Method in class org.agrona.collections.Int2IntHashMap.IntIterator
 
next() - Method in class org.agrona.collections.Int2ObjectCache.EntryIterator
 
next() - Method in class org.agrona.collections.Int2ObjectCache.KeyIterator
 
next() - Method in class org.agrona.collections.Int2ObjectCache.ValueIterator
 
next() - Method in class org.agrona.collections.Int2ObjectHashMap.EntryIterator
 
next() - Method in class org.agrona.collections.Int2ObjectHashMap.KeyIterator
 
next() - Method in class org.agrona.collections.Int2ObjectHashMap.ValueIterator
 
next() - Method in class org.agrona.collections.IntIterator
 
nextCorrelationId() - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Get the next value that can be used for a correlation id on an message when a response needs to be correlated.
nextCorrelationId() - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Get the next value that can be used for a correlation id on an message when a response needs to be correlated.
nextCorrelationId() - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
Get the next value that can be used for a correlation id on an message when a response needs to be correlated.
nextInt() - Method in class org.agrona.collections.Int2ObjectCache.KeyIterator
 
nextInt() - Method in class org.agrona.collections.Int2ObjectHashMap.KeyIterator
 
nextValue() - Method in class org.agrona.collections.Int2IntHashMap.IntIterator
 
nextValue() - Method in class org.agrona.collections.IntIterator
Strongly typed alternative of Iterator.next() not to avoid boxing.
NioSelectedKeySet - Class in org.agrona.nio
Try to fix handling of HashSet for Selector.
NioSelectedKeySet() - Constructor for class org.agrona.nio.NioSelectedKeySet
Construct a key set with default capacity
NioSelectedKeySet(int) - Constructor for class org.agrona.nio.NioSelectedKeySet
Construct a key set with the given capacity.
NoOpIdleStrategy - Class in org.agrona.concurrent
Low-latency idle strategy to be employed in loops that do significant work on each iteration such that any work in the idle strategy would be wasteful.
NoOpIdleStrategy() - Constructor for class org.agrona.concurrent.NoOpIdleStrategy
 
notNull(Object, String) - Static method in class org.agrona.Verify
Verify that a reference is not null.
NULL_BYTES - Static variable in class org.agrona.BufferUtil
 

O

OBSERVATION_COUNT_OFFSET - Static variable in class org.agrona.concurrent.errors.DistinctErrorLog
Offset within a record at which the observation count field begins.
offer(E) - Method in class org.agrona.concurrent.ManyToManyConcurrentArrayQueue
 
offer(E) - Method in class org.agrona.concurrent.ManyToOneConcurrentArrayQueue
 
offer(E) - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
offer(E) - Method in class org.agrona.concurrent.OneToOneConcurrentArrayQueue
 
offset() - Method in class org.agrona.concurrent.broadcast.BroadcastReceiver
The offset for the beginning of the next message in the transmission stream.
offset - Variable in class org.agrona.concurrent.errors.DistinctErrorLog.DistinctObservation
 
offset() - Method in class org.agrona.io.DirectBufferInputStream
The offset within the underlying buffer at which to start.
offset() - Method in class org.agrona.io.DirectBufferOutputStream
The offset within the underlying buffer at which to start.
offset() - Method in class org.agrona.io.ExpandableDirectBufferOutputStream
The offset within the underlying buffer at which to start.
onClose() - Method in interface org.agrona.concurrent.Agent
To be overridden by Agents that need to do resource cleanup on close.
onClose() - Method in class org.agrona.concurrent.CompositeAgent
 
onError(Throwable) - Method in interface org.agrona.ErrorHandler
Callback to notify of an error that has occurred when processing an operation or event.
OneToOneConcurrentArrayQueue<E> - Class in org.agrona.concurrent
One producer to one consumer concurrent queue that is array backed.
OneToOneConcurrentArrayQueue(int) - Constructor for class org.agrona.concurrent.OneToOneConcurrentArrayQueue
 
OneToOneRingBuffer - Class in org.agrona.concurrent.ringbuffer
A ring-buffer that supports the exchange of messages from a single producer to a single consumer.
OneToOneRingBuffer(AtomicBuffer) - Constructor for class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Construct a new RingBuffer based on an underlying AtomicBuffer.
onMessage(int, MutableDirectBuffer, int, int) - Method in interface org.agrona.concurrent.MessageHandler
Called for the processing of each message read from a buffer in turn.
onRecord(int, int) - Method in interface org.agrona.concurrent.RecordBuffer.RecordHandler
Called once for each committed record in the buffer.
onSpinWait() - Static method in class org.agrona.hints.ThreadHints
Indicates that the caller is momentarily unable to progress, until the occurrence of one or more actions on the part of other activities.
openOutputStream() - Method in class org.agrona.generation.JavaClassObject
 
orderedIncrement() - Method in class org.agrona.concurrent.status.AtomicCounter
Perform an atomic increment that is not safe across threads.
org.agrona - package org.agrona
 
org.agrona.collections - package org.agrona.collections
 
org.agrona.concurrent - package org.agrona.concurrent
 
org.agrona.concurrent.broadcast - package org.agrona.concurrent.broadcast
 
org.agrona.concurrent.errors - package org.agrona.concurrent.errors
 
org.agrona.concurrent.ringbuffer - package org.agrona.concurrent.ringbuffer
 
org.agrona.concurrent.status - package org.agrona.concurrent.status
 
org.agrona.console - package org.agrona.console
 
org.agrona.generation - package org.agrona.generation
 
org.agrona.hints - package org.agrona.hints
This package captures hints that may be used by some runtimes to improve code performance.
org.agrona.io - package org.agrona.io
 
org.agrona.nio - package org.agrona.nio
 
OutputManager - Interface in org.agrona.generation
Abstraction that manages the destination of generated output.

P

p31 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p32 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p33 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p34 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p35 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p36 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p37 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p38 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p39 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p40 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p41 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p42 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p43 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p44 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
p45 - Variable in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
PackageOutputManager - Class in org.agrona.generation
OutputManager for managing the creation of Java source files as the target of code generation.
PackageOutputManager(String, String) - Constructor for class org.agrona.generation.PackageOutputManager
Create a new OutputManager for generating Java source files into a given package.
PADDING_MSG_TYPE_ID - Static variable in class org.agrona.concurrent.broadcast.RecordDescriptor
Message type is padding to prevent fragmentation in the buffer.
PADDING_MSG_TYPE_ID - Static variable in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Record type is padding to prevent fragmentation in the buffer.
PADDING_MSG_TYPE_ID - Static variable in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Record type is padding to prevent fragmentation in the buffer.
parseIntOrDefault(String, int) - Static method in class org.agrona.Strings
Parse an int from a String.
PAUSE_TIME_NS - Static variable in class org.agrona.concurrent.RecordBuffer
 
peek() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
peek() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
persist(Map<String, CharSequence>) - Static method in class org.agrona.generation.CompilerUtil
 
Pipe<E> - Interface in org.agrona.concurrent
A container for items processed in sequence
poll() - Method in class org.agrona.concurrent.ManyToManyConcurrentArrayQueue
 
poll() - Method in class org.agrona.concurrent.ManyToOneConcurrentArrayQueue
 
poll() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
poll() - Method in class org.agrona.concurrent.OneToOneConcurrentArrayQueue
 
position() - Method in class org.agrona.collections.IntIterator
 
Position - Interface in org.agrona.concurrent.status
Reports on how far through a buffer some component has progressed.
position() - Method in class org.agrona.io.DirectBufferOutputStream
The position in the buffer from the offset up to which has been written.
position() - Method in class org.agrona.io.ExpandableDirectBufferOutputStream
The position in the buffer from the offset up to which has been written.
present(Map<?, ?>, Object, String) - Static method in class org.agrona.Verify
Verify that a map contains and entry for a given key.
previous(int, int) - Static method in class org.agrona.BitUtil
Cycles indices of an array one at a time in a backwards fashion
PrimitiveExpander - Class in org.agrona.generation
 
PrimitiveExpander() - Constructor for class org.agrona.generation.PrimitiveExpander
 
PrimitiveExpander.Substitution - Class in org.agrona.generation
 
producerPosition() - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
The position in bytes from start up of the producers.
producerPosition() - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
The position in bytes from start up of the producers.
producerPosition() - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
The position in bytes from start up of the producers.
proposeMax(long) - Method in class org.agrona.concurrent.status.AtomicLongPosition
 
proposeMax(long) - Method in interface org.agrona.concurrent.status.Position
Set the position to the new proposedValue if it is greater than the current proposedValue memory ordering semantics.
proposeMax(long) - Method in class org.agrona.concurrent.status.UnsafeBufferPosition
 
proposeMaxOrdered(long) - Method in class org.agrona.concurrent.status.AtomicLongPosition
 
proposeMaxOrdered(long) - Method in interface org.agrona.concurrent.status.Position
Set the position to the new proposedValue if it is greater than the current proposedValue with ordered atomic memory semantics.
proposeMaxOrdered(long) - Method in class org.agrona.concurrent.status.UnsafeBufferPosition
 
PUBLIC_SELECTED_KEYS_FIELD - Static variable in class org.agrona.nio.TransportPoller
 
put(int, int, V) - Method in class org.agrona.collections.BiInt2ObjectMap
Put a value into the map.
put(int, int) - Method in class org.agrona.collections.Int2IntHashMap
 
put(Integer, Integer) - Method in class org.agrona.collections.Int2IntHashMap
put(Integer, V) - Method in class org.agrona.collections.Int2ObjectCache
put(int, V) - Method in class org.agrona.collections.Int2ObjectCache
Overloaded version of Map.put(Object, Object) that takes a primitive int key.
put(Integer, V) - Method in class org.agrona.collections.Int2ObjectHashMap
put(int, V) - Method in class org.agrona.collections.Int2ObjectHashMap
Overloaded version of Map.put(Object, Object) that takes a primitive int key.
putAll(Map<? extends Integer, ? extends Integer>) - Method in class org.agrona.collections.Int2IntHashMap
putAll(Map<? extends Integer, ? extends V>) - Method in class org.agrona.collections.Int2ObjectCache
putAll(Map<? extends Integer, ? extends V>) - Method in class org.agrona.collections.Int2ObjectHashMap
putByte(long, byte) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putByte(int, byte) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putByte(int, byte) - Method in class org.agrona.ExpandableArrayBuffer
 
putByte(int, byte) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putBytes(long, byte[]) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putBytes(long, byte[], long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putBytes(long, ByteBuffer, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putBytes(long, ByteBuffer, long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putBytes(long, DirectBuffer, int, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putBytes(int, byte[]) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putBytes(int, byte[], int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putBytes(int, ByteBuffer, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putBytes(int, ByteBuffer, int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putBytes(int, DirectBuffer, int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putBytes(int, byte[]) - Method in class org.agrona.ExpandableArrayBuffer
 
putBytes(int, byte[], int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
putBytes(int, ByteBuffer, int) - Method in class org.agrona.ExpandableArrayBuffer
 
putBytes(int, ByteBuffer, int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
putBytes(int, DirectBuffer, int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
putBytes(int, byte[]) - Method in interface org.agrona.MutableDirectBuffer
Put an array of src into the underlying buffer.
putBytes(int, byte[], int, int) - Method in interface org.agrona.MutableDirectBuffer
Put an array into the underlying buffer.
putBytes(int, ByteBuffer, int) - Method in interface org.agrona.MutableDirectBuffer
Put bytes into the underlying buffer for the view.
putBytes(int, ByteBuffer, int, int) - Method in interface org.agrona.MutableDirectBuffer
Put bytes into the underlying buffer for the view.
putBytes(int, DirectBuffer, int, int) - Method in interface org.agrona.MutableDirectBuffer
Put bytes from a source DirectBuffer into this MutableDirectBuffer at given indices.
putByteVolatile(int, byte) - Method in interface org.agrona.concurrent.AtomicBuffer
Put a value to a given index with volatile semantics.
putByteVolatile(long, byte) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putByteVolatile(int, byte) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putChar(long, char, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putChar(long, char) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putChar(int, char, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putChar(int, char) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putChar(int, char, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
putChar(int, char) - Method in class org.agrona.ExpandableArrayBuffer
 
putChar(int, char, ByteOrder) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putChar(int, char) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putCharVolatile(int, char) - Method in interface org.agrona.concurrent.AtomicBuffer
Put a value to a given index with volatile semantics.
putCharVolatile(long, char) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putCharVolatile(int, char) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putDouble(long, double, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putDouble(long, double) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putDouble(int, double, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putDouble(int, double) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putDouble(int, double, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
putDouble(int, double) - Method in class org.agrona.ExpandableArrayBuffer
 
putDouble(int, double, ByteOrder) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putDouble(int, double) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putFloat(long, float, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putFloat(long, float) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putFloat(int, float, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putFloat(int, float) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putFloat(int, float, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
putFloat(int, float) - Method in class org.agrona.ExpandableArrayBuffer
 
putFloat(int, float, ByteOrder) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putFloat(int, float) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putInt(long, int, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putInt(long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putInt(int, int, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putInt(int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putInt(int, int, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
putInt(int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
putInt(int, int, ByteOrder) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putInt(int, int) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putIntOrdered(int, int) - Method in interface org.agrona.concurrent.AtomicBuffer
Put a value to a given index with ordered semantics.
putIntOrdered(long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putIntOrdered(int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putIntVolatile(int, int) - Method in interface org.agrona.concurrent.AtomicBuffer
Put a value to a given index with volatile semantics.
putIntVolatile(long, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putIntVolatile(int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putLong(long, long, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putLong(long, long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putLong(int, long, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putLong(int, long) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putLong(int, long, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
putLong(int, long) - Method in class org.agrona.ExpandableArrayBuffer
 
putLong(int, long, ByteOrder) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putLong(int, long) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putLongOrdered(int, long) - Method in interface org.agrona.concurrent.AtomicBuffer
Put a value to a given index with ordered store semantics.
putLongOrdered(long, long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putLongOrdered(int, long) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putLongVolatile(int, long) - Method in interface org.agrona.concurrent.AtomicBuffer
Put a value to a given index with volatile semantics.
putLongVolatile(long, long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putLongVolatile(int, long) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putShort(long, short, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putShort(long, short) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putShort(int, short, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putShort(int, short) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putShort(int, short, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
putShort(int, short) - Method in class org.agrona.ExpandableArrayBuffer
 
putShort(int, short, ByteOrder) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putShort(int, short) - Method in interface org.agrona.MutableDirectBuffer
Put a value to a given index.
putShortVolatile(int, short) - Method in interface org.agrona.concurrent.AtomicBuffer
Put a value to a given index with volatile semantics.
putShortVolatile(long, short) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putShortVolatile(int, short) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putStringUtf8(long, String) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putStringUtf8(long, String, ByteOrder) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putStringUtf8(long, String, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putStringUtf8(long, String, ByteOrder, int) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putStringUtf8(int, String) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putStringUtf8(int, String, ByteOrder) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putStringUtf8(int, String, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putStringUtf8(int, String, ByteOrder, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putStringUtf8(int, String) - Method in class org.agrona.ExpandableArrayBuffer
 
putStringUtf8(int, String, ByteOrder) - Method in class org.agrona.ExpandableArrayBuffer
 
putStringUtf8(int, String, int) - Method in class org.agrona.ExpandableArrayBuffer
 
putStringUtf8(int, String, ByteOrder, int) - Method in class org.agrona.ExpandableArrayBuffer
 
putStringUtf8(int, String) - Method in interface org.agrona.MutableDirectBuffer
Encode a String as UTF-8 bytes to the buffer with a length prefix.
putStringUtf8(int, String, ByteOrder) - Method in interface org.agrona.MutableDirectBuffer
Encode a String as UTF-8 bytes to the buffer with a length prefix.
putStringUtf8(int, String, int) - Method in interface org.agrona.MutableDirectBuffer
Encode a String as UTF-8 bytes the buffer with a length prefix with a maximum encoded size check.
putStringUtf8(int, String, ByteOrder, int) - Method in interface org.agrona.MutableDirectBuffer
Encode a String as UTF-8 bytes the buffer with a length prefix with a maximum encoded size check.
putStringWithoutLengthUtf8(long, String) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
putStringWithoutLengthUtf8(int, String) - Method in class org.agrona.concurrent.UnsafeBuffer
 
putStringWithoutLengthUtf8(int, String) - Method in class org.agrona.ExpandableArrayBuffer
 
putStringWithoutLengthUtf8(int, String) - Method in interface org.agrona.MutableDirectBuffer
Encode a String as UTF-8 bytes in the buffer without a length prefix.

Q

QueuedPipe<E> - Interface in org.agrona.concurrent
Composed interface for concurrent queues and sequenced containers.
quietClose(AutoCloseable) - Static method in class org.agrona.CloseHelper
Quietly close a AutoCloseable dealing with nulls and exceptions.

R

read(AtomicBuffer, ErrorConsumer) - Static method in class org.agrona.concurrent.errors.ErrorLogReader
Read all the errors in a log since the creation of the log.
read(AtomicBuffer, ErrorConsumer, long) - Static method in class org.agrona.concurrent.errors.ErrorLogReader
Read all the errors in a log since a given timestamp.
read(MessageHandler) - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Read as many messages as are available from the ring buffer.
read(MessageHandler, int) - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Read as many messages as are available from the ring buffer to up a supplied maximum.
read(MessageHandler) - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Read as many messages as are available from the ring buffer.
read(MessageHandler, int) - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Read as many messages as are available from the ring buffer to up a supplied maximum.
read(MessageHandler) - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
Read as many messages as are available from the ring buffer.
read(MessageHandler, int) - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
Read as many messages as are available from the ring buffer to up a supplied maximum.
read() - Method in class org.agrona.io.DirectBufferInputStream
 
read(byte[], int, int) - Method in class org.agrona.io.DirectBufferInputStream
 
ReadablePosition - Interface in org.agrona.concurrent.status
Indicates how far through an abstract task a component has progressed as a counter value.
receive(MessageHandler) - Method in class org.agrona.concurrent.broadcast.CopyBroadcastReceiver
Receive one message from the broadcast buffer.
receiveNext() - Method in class org.agrona.concurrent.broadcast.BroadcastReceiver
Non-blocking receive of next message from the transmission stream.
record(Throwable) - Method in class org.agrona.concurrent.errors.DistinctErrorLog
Record an observation of an error.
RECORD_ALIGNMENT - Static variable in class org.agrona.concurrent.broadcast.RecordDescriptor
Alignment as a multiple of bytes for each record.
RECORD_ALIGNMENT - Static variable in class org.agrona.concurrent.errors.DistinctErrorLog
Alignment to be applied for record beginning.
RECORD_ALLOCATED - Static variable in class org.agrona.concurrent.status.CountersReader
Record currently allocated for use..
RECORD_RECLAIMED - Static variable in class org.agrona.concurrent.status.CountersReader
Record was active and now has been reclaimed.
RECORD_UNUSED - Static variable in class org.agrona.concurrent.status.CountersReader
Record has not been used.
RecordBuffer - Class in org.agrona.concurrent
A record buffer is an off-heap buffer with a series of records and a header that can be written to or read from multiple threads.
RecordBuffer(AtomicBuffer, int, int) - Constructor for class org.agrona.concurrent.RecordBuffer
 
RecordBuffer.RecordHandler - Interface in org.agrona.concurrent
Callback interface for reading elements out of the buffer.
RecordBuffer.RecordWriter - Interface in org.agrona.concurrent
Interface for safely writing to the buffer.
RecordDescriptor - Class in org.agrona.concurrent.broadcast
Description of the structure for a record in the broadcast buffer.
RecordDescriptor() - Constructor for class org.agrona.concurrent.broadcast.RecordDescriptor
 
RecordDescriptor - Class in org.agrona.concurrent.ringbuffer
Description of the record structure for message framing in the a RingBuffer.
RecordDescriptor() - Constructor for class org.agrona.concurrent.ringbuffer.RecordDescriptor
 
recordLength(long) - Static method in class org.agrona.concurrent.ringbuffer.RecordDescriptor
Extract the record length field from a word representing the header.
register(Runnable) - Static method in class org.agrona.concurrent.SigInt
Register a task to be run when a SIGINT is received.
remainingCapacity() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
remainingCapacity() - Method in interface org.agrona.concurrent.Pipe
Get the remaining capacity for elements in the container given the current size.
remove(T[], T) - Static method in class org.agrona.collections.ArrayUtil
Remove an element from an array resulting in a new array if the element was found otherwise the old array.
remove(T[], int) - Static method in class org.agrona.collections.ArrayUtil
 
remove(int, int) - Method in class org.agrona.collections.BiInt2ObjectMap
Remove a value from the map and return the value.
remove(Object) - Method in class org.agrona.collections.Int2IntHashMap
remove(int) - Method in class org.agrona.collections.Int2IntHashMap
 
remove(Object) - Method in class org.agrona.collections.Int2ObjectCache.KeySet
 
remove(Object) - Method in class org.agrona.collections.Int2ObjectCache
remove(int) - Method in class org.agrona.collections.Int2ObjectCache
Overloaded version of Map.remove(Object) that takes a primitive int key.
remove(Object) - Method in class org.agrona.collections.Int2ObjectHashMap.KeySet
 
remove(int) - Method in class org.agrona.collections.Int2ObjectHashMap.KeySet
 
remove(Object) - Method in class org.agrona.collections.Int2ObjectHashMap
remove(int) - Method in class org.agrona.collections.Int2ObjectHashMap
Overloaded version of Map.remove(Object) that takes a primitive int key.
remove(Object) - Method in class org.agrona.collections.IntHashSet
remove(int) - Method in class org.agrona.collections.IntHashSet
An int specialised version of {this#remove(Object)}.
remove() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
remove(Object) - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
remove() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
remove(Object) - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
remove(Object) - Method in class org.agrona.nio.NioSelectedKeySet
remove() - Method in class org.agrona.TimerWheel.Timer
 
removeAll(Collection<?>) - Method in class org.agrona.collections.IntHashSet
removeAll(Collection<?>) - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
removeAll(Collection<?>) - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
removedCount() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
removedCount() - Method in interface org.agrona.concurrent.Pipe
The number of items removed from this container since creation.
replace(int, int) - Method in class org.agrona.collections.Int2IntHashMap
Primitive specialised version of Map.replace(Object, Object)
replace(int, int, int) - Method in class org.agrona.collections.Int2IntHashMap
Primitive specialised version of Map.replace(Object, Object, Object)
replace(int, V) - Method in class org.agrona.collections.Int2ObjectHashMap
Primitive specialised version of Map.replace(Object, Object)
replace(int, V, V) - Method in class org.agrona.collections.Int2ObjectHashMap
Primitive specialised version of Map.replace(Object, Object, Object)
rescheduleTimeout(long, TimeUnit, TimerWheel.Timer) - Method in class org.agrona.TimerWheel
Reschedule an expired timer, reusing the TimerWheel.Timer object.
rescheduleTimeout(long, TimeUnit, TimerWheel.Timer, Runnable) - Method in class org.agrona.TimerWheel
Reschedule an expired timer, reusing the TimerWheel.Timer object.
reset() - Method in class org.agrona.collections.Int2IntHashMap.IntIterator
 
reset() - Method in class org.agrona.concurrent.BackoffIdleStrategy
 
reset() - Method in class org.agrona.concurrent.BusySpinIdleStrategy
 
reset() - Method in interface org.agrona.concurrent.IdleStrategy
Reset the internal state in preparation for entering an idle state again.
reset() - Method in class org.agrona.concurrent.NoOpIdleStrategy
 
reset() - Method in class org.agrona.concurrent.SleepingIdleStrategy
 
reset() - Method in class org.agrona.concurrent.YieldingIdleStrategy
 
reset() - Method in class org.agrona.nio.NioSelectedKeySet
Reset for next iteration.
reset(long, Runnable) - Method in class org.agrona.TimerWheel.Timer
 
resetCounters() - Method in class org.agrona.collections.Int2ObjectCache
Reset the cache statistics counters to zero.
resize(long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
resizeThreshold() - Method in class org.agrona.collections.Int2ObjectHashMap
Get the actual threshold which when reached the map resize.
ResourceConsumer<T> - Interface in org.agrona.generation
 
retainAll(Collection<?>) - Method in class org.agrona.collections.IntHashSet
 
retainAll(Collection<?>) - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
retainAll(Collection<?>) - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
rethrowUnchecked(Throwable) - Static method in class org.agrona.LangUtil
Rethrow an Throwable preserving the stack trace but making it unchecked.
RingBuffer - Interface in org.agrona.concurrent.ringbuffer
Ring-buffer for the concurrent exchanging of binary encoded messages from producer to consumer in a FIFO manner.
RingBufferDescriptor - Class in org.agrona.concurrent.ringbuffer
Layout description for the underlying buffer used by a RingBuffer.
RingBufferDescriptor() - Constructor for class org.agrona.concurrent.ringbuffer.RingBufferDescriptor
 
roleName() - Method in interface org.agrona.concurrent.Agent
Get the name of this agent's role.
roleName() - Method in class org.agrona.concurrent.CompositeAgent
 
run() - Method in class org.agrona.concurrent.AgentRunner
Run an Agent.

S

SELECTED_KEYS_FIELD - Static variable in class org.agrona.nio.TransportPoller
 
selectedKeySet - Variable in class org.agrona.nio.TransportPoller
 
selectNowWithoutProcessing() - Method in class org.agrona.nio.TransportPoller
Explicit call to selectNow but without processing of selected keys.
selector - Variable in class org.agrona.nio.TransportPoller
 
sequenceToBufferOffset(long, long) - Static method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
set(long) - Method in class org.agrona.concurrent.status.AtomicCounter
Set the counter with volatile semantics.
set(long) - Method in class org.agrona.concurrent.status.AtomicLongPosition
 
set(long) - Method in interface org.agrona.concurrent.status.Position
Sets the current position of the component without memory ordering semantics.
set(long) - Method in class org.agrona.concurrent.status.UnsafeBufferPosition
 
setCounterValue(int, long) - Method in class org.agrona.concurrent.status.CountersManager
Set an AtomicCounter value based on counterId.
setMemory(long, int, byte) - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
setMemory(int, int, byte) - Method in class org.agrona.concurrent.UnsafeBuffer
 
setMemory(int, int, byte) - Method in class org.agrona.ExpandableArrayBuffer
 
setMemory(int, int, byte) - Method in interface org.agrona.MutableDirectBuffer
Set a region of memory to a given byte value.
setOrdered(long) - Method in class org.agrona.concurrent.status.AtomicCounter
Set the counter with ordered semantics.
setOrdered(long) - Method in class org.agrona.concurrent.status.AtomicLongPosition
 
setOrdered(long) - Method in interface org.agrona.concurrent.status.Position
Sets the current position of the component with ordered atomic memory semantics.
setOrdered(long) - Method in class org.agrona.concurrent.status.UnsafeBufferPosition
 
setPackageName(String) - Method in class org.agrona.generation.StringWriterOutputManager
 
setValue(V) - Method in class org.agrona.collections.Int2ObjectCache.EntryIterator
 
setValue(V) - Method in class org.agrona.collections.Int2ObjectHashMap.EntryIterator
 
SHARED_HEAD_CACHE_OFFSET - Static variable in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
SHIFT_FOR_SCALE - Static variable in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
SHOULD_BOUNDS_CHECK - Static variable in class org.agrona.concurrent.UnsafeBuffer
 
SigInt - Class in org.agrona.concurrent
Utility to allow the registration of a SIGINT handler that hides the unsupported Signal class.
SigInt() - Constructor for class org.agrona.concurrent.SigInt
 
SigIntBarrier - Class in org.agrona.concurrent
One time barrier for blocking a thread until a SIGINT signal is received from the operating system.
SigIntBarrier() - Constructor for class org.agrona.concurrent.SigIntBarrier
Construct and register the barrier ready for use.
size() - Method in class org.agrona.collections.BiInt2ObjectMap
Return the number of unique entries in the map.
size() - Method in class org.agrona.collections.Int2IntHashMap
size() - Method in class org.agrona.collections.Int2IntHashMap.Values
size() - Method in class org.agrona.collections.Int2ObjectCache.KeySet
 
size() - Method in class org.agrona.collections.Int2ObjectCache
size() - Method in class org.agrona.collections.Int2ObjectHashMap.KeySet
 
size() - Method in class org.agrona.collections.Int2ObjectHashMap
size() - Method in class org.agrona.collections.IntHashSet
size() - Method in class org.agrona.collections.UnmodifiableCollectionView
size() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
size() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
Size can be considered an approximation on a moving list.
size() - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Size of the backlog of bytes in the buffer between producers and consumers.
size() - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Size of the backlog of bytes in the buffer between producers and consumers.
size() - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
Size of the backlog of bytes in the buffer between producers and consumers.
size() - Method in class org.agrona.nio.NioSelectedKeySet
SIZE_OF_BOOLEAN - Static variable in class org.agrona.BitUtil
Size of a boolean in bytes
SIZE_OF_BYTE - Static variable in class org.agrona.BitUtil
Size of a byte in bytes
SIZE_OF_CHAR - Static variable in class org.agrona.BitUtil
Size of a char in bytes
SIZE_OF_DOUBLE - Static variable in class org.agrona.BitUtil
Size of a double in bytes
SIZE_OF_FLOAT - Static variable in class org.agrona.BitUtil
Size of a a float in bytes
SIZE_OF_INT - Static variable in class org.agrona.BitUtil
Size of an int in bytes
SIZE_OF_LONG - Static variable in class org.agrona.BitUtil
Size of a long in bytes
SIZE_OF_SHORT - Static variable in class org.agrona.BitUtil
Size of a short in bytes
skip(long) - Method in class org.agrona.io.DirectBufferInputStream
 
SleepingIdleStrategy - Class in org.agrona.concurrent
When idle this strategy is to sleep for a specified period.
SleepingIdleStrategy(long) - Constructor for class org.agrona.concurrent.SleepingIdleStrategy
Constructed a new strategy that will sleep for a given period when idle.
startOnThread(AgentRunner) - Static method in class org.agrona.concurrent.AgentRunner
Start the given agent runner on a new thread.
Strings - Class in org.agrona
Utility functions for using Strings.
Strings() - Constructor for class org.agrona.Strings
 
StringWriterOutputManager - Class in org.agrona.generation
 
StringWriterOutputManager() - Constructor for class org.agrona.generation.StringWriterOutputManager
 
substitute(String) - Method in class org.agrona.generation.PrimitiveExpander.Substitution
 
sum(List<V>, ToIntFunction<V>) - Static method in class org.agrona.collections.CollectionUtil
Garbage free sum function.
SystemEpochClock - Class in org.agrona.concurrent
Implementation that calls System.currentTimeMillis().
SystemEpochClock() - Constructor for class org.agrona.concurrent.SystemEpochClock
 
SystemNanoClock - Class in org.agrona.concurrent
A NanoClock the delegates to System.nanoTime().
SystemNanoClock() - Constructor for class org.agrona.concurrent.SystemNanoClock
 

T

TAIL_COUNTER_OFFSET - Static variable in class org.agrona.concurrent.broadcast.BroadcastBufferDescriptor
Offset within the trailer for where the tail value is stored.
TAIL_INTENT_COUNTER_OFFSET - Static variable in class org.agrona.concurrent.broadcast.BroadcastBufferDescriptor
Offset within the trailer for where the tail intended value is stored.
TAIL_OFFSET - Static variable in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
TAIL_POSITION_OFFSET - Static variable in class org.agrona.concurrent.ringbuffer.RingBufferDescriptor
Offset within the trailer for where the tail value is stored.
ThreadHints - Class in org.agrona.hints
This class captures possible hints that may be used by some runtimes to improve code performance.
throwable - Variable in class org.agrona.concurrent.errors.DistinctErrorLog.DistinctObservation
 
time() - Method in interface org.agrona.concurrent.EpochClock
Time in milliseconds since the 1 Jan 1970 UTC.
time() - Method in class org.agrona.concurrent.SystemEpochClock
 
timeOfLastStateChange(long) - Method in interface org.agrona.ManagedResource
Set the time of the last state change.
timeOfLastStateChange() - Method in interface org.agrona.ManagedResource
Get the time of the last state change.
Timer() - Constructor for class org.agrona.TimerWheel.Timer
 
Timer(long, Runnable) - Constructor for class org.agrona.TimerWheel.Timer
 
TimerWheel - Class in org.agrona
Timer Wheel (NOT thread safe)
TimerWheel(long, TimeUnit, int) - Constructor for class org.agrona.TimerWheel
Construct a timer wheel for use in scheduling timers.
TimerWheel(NanoClock, long, TimeUnit, int) - Constructor for class org.agrona.TimerWheel
Construct a timer wheel for use in scheduling timers.
TimerWheel.Timer - Class in org.agrona
 
TimerWheel.TimerState - Enum in org.agrona
 
tmpDirName() - Static method in class org.agrona.IoUtil
Return the system property for java.io.tmpdir ensuring a File.separator is at the end.
toArray(T[]) - Method in class org.agrona.collections.IntHashSet
toArray() - Method in class org.agrona.collections.IntHashSet
toArray() - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
toArray(T[]) - Method in class org.agrona.concurrent.AbstractConcurrentArrayQueue
 
toArray() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
toArray(T[]) - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
toHex(byte[], int, int) - Static method in class org.agrona.BitUtil
Generate a string that is the hex representation of a given byte array.
toHex(byte[]) - Static method in class org.agrona.BitUtil
Generate a string that is the hex representation of a given byte array.
toHexByteArray(byte[]) - Static method in class org.agrona.BitUtil
Generate a byte array that is a hex representation of a given byte array.
toHexByteArray(byte[], int, int) - Static method in class org.agrona.BitUtil
Generate a byte array that is a hex representation of a given byte array.
toString() - Method in class org.agrona.collections.Int2IntHashMap
toString() - Method in class org.agrona.collections.Int2ObjectCache
toString() - Method in class org.agrona.collections.Int2ObjectHashMap
toString() - Method in class org.agrona.collections.IntHashSet
toString() - Method in class org.agrona.concurrent.ManyToOneConcurrentLinkedQueue
 
toString() - Method in class org.agrona.TimerWheel.Timer
 
TRAILER_LENGTH - Static variable in class org.agrona.concurrent.broadcast.BroadcastBufferDescriptor
Total size of the trailer
TRAILER_LENGTH - Static variable in class org.agrona.concurrent.ringbuffer.RingBufferDescriptor
Total length of the trailer in bytes.
transmit(int, DirectBuffer, int, int) - Method in class org.agrona.concurrent.broadcast.BroadcastTransmitter
Transmit a message to BroadcastReceivers via the broadcast buffer.
TransportPoller - Class in org.agrona.nio
Implements the common functionality for a transport poller.
TransportPoller() - Constructor for class org.agrona.nio.TransportPoller
 
TYPE_ID_OFFSET - Static variable in class org.agrona.concurrent.status.CountersReader
Offset in the record at which the type id field is stored.
TYPE_OFFSET - Static variable in class org.agrona.concurrent.broadcast.RecordDescriptor
Offset within the record at which the message type field begins.
typeId() - Method in class org.agrona.concurrent.broadcast.BroadcastReceiver
Type of the message received.
typeOffset(int) - Static method in class org.agrona.concurrent.broadcast.RecordDescriptor
The buffer offset at which the message type field begins.
typeOffset(int) - Static method in class org.agrona.concurrent.ringbuffer.RecordDescriptor
The offset from the beginning of a record at which the message type field begins.

U

unblock() - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Unblock a multi-producer ring buffer where a producer has died during the act of offering.
unblock() - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Unblock a multi-producer ring buffer where a producer has died during the act of offering.
unblock() - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
Unblock a multi-producer ring buffer where a producer has died during the act of offering.
UNKNOWN_INDEX - Static variable in class org.agrona.collections.ArrayUtil
 
unmap(MappedByteBuffer) - Static method in class org.agrona.IoUtil
Unmap a MappedByteBuffer without waiting for the next GC cycle.
unmap(FileChannel, long, long) - Static method in class org.agrona.IoUtil
Unmap a region of a file.
unmap(ByteBuffer) - Static method in class org.agrona.IoUtil
Unmap a ByteBuffer without waiting for the next GC cycle if its memory mapped.
UnmodifiableCollectionView<V,E> - Class in org.agrona.collections
An unmodifiable view of a collection that maps each element in an underlying collection into a view.
UnmodifiableCollectionView(Function<E, V>, Collection<E>) - Constructor for class org.agrona.collections.UnmodifiableCollectionView
 
UNSAFE - Static variable in class org.agrona.UnsafeAccess
 
UnsafeAccess - Class in org.agrona
 
UnsafeAccess() - Constructor for class org.agrona.UnsafeAccess
 
UnsafeBuffer - Class in org.agrona.concurrent
Supports regular, byte ordered, and atomic (memory ordered) access to an underlying buffer.
UnsafeBuffer(byte[]) - Constructor for class org.agrona.concurrent.UnsafeBuffer
Attach a view to a byte[] for providing direct access.
UnsafeBuffer(byte[], int, int) - Constructor for class org.agrona.concurrent.UnsafeBuffer
Attach a view to a byte[] for providing direct access.
UnsafeBuffer(ByteBuffer) - Constructor for class org.agrona.concurrent.UnsafeBuffer
Attach a view to a ByteBuffer for providing direct access, the ByteBuffer can be heap based or direct.
UnsafeBuffer(ByteBuffer, int, int) - Constructor for class org.agrona.concurrent.UnsafeBuffer
Attach a view to a ByteBuffer for providing direct access, the ByteBuffer can be heap based or direct.
UnsafeBuffer(DirectBuffer) - Constructor for class org.agrona.concurrent.UnsafeBuffer
Attach a view to an existing DirectBuffer
UnsafeBuffer(DirectBuffer, int, int) - Constructor for class org.agrona.concurrent.UnsafeBuffer
Attach a view to an existing DirectBuffer
UnsafeBuffer(long, int) - Constructor for class org.agrona.concurrent.UnsafeBuffer
Attach a view to an off-heap memory region by address.
UnsafeBufferPosition - Class in org.agrona.concurrent.status
Reports a position by recording it in an UnsafeBuffer.
UnsafeBufferPosition(UnsafeBuffer, int) - Constructor for class org.agrona.concurrent.status.UnsafeBufferPosition
Map a position over a buffer.
UnsafeBufferPosition(UnsafeBuffer, int, CountersManager) - Constructor for class org.agrona.concurrent.status.UnsafeBufferPosition
Map a position over a buffer and this indicator owns the counter for reclamation.

V

validate() - Method in class org.agrona.concurrent.broadcast.BroadcastReceiver
Validate that the current received record is still valid and has not been overwritten.
validateLoadFactor(float) - Static method in class org.agrona.collections.CollectionUtil
Validate that a load factor is greater than 0 and less than 1.0.
validatePositivePowerOfTwo(int) - Static method in class org.agrona.collections.CollectionUtil
Validate that a number is a power of two.
value - Variable in class org.agrona.collections.MutableInteger
 
ValueIterator() - Constructor for class org.agrona.collections.Int2ObjectCache.ValueIterator
 
ValueIterator() - Constructor for class org.agrona.collections.Int2ObjectHashMap.ValueIterator
 
valueOf(String) - Static method in enum org.agrona.TimerWheel.TimerState
Returns the enum constant of this type with the specified name.
values() - Method in class org.agrona.collections.Int2IntHashMap
values() - Method in class org.agrona.collections.Int2ObjectCache
values() - Method in class org.agrona.collections.Int2ObjectHashMap
values() - Static method in enum org.agrona.TimerWheel.TimerState
Returns an array containing the constants of this enum type, inthe order they are declared.
valuesBuffer - Variable in class org.agrona.concurrent.status.CountersReader
 
valuesBuffer() - Method in class org.agrona.concurrent.status.CountersReader
Get the buffer containing the values for the counters.
Verify - Class in org.agrona
Various verification checks to be applied in code.
Verify() - Constructor for class org.agrona.Verify
 
verifyAlignment() - Method in interface org.agrona.concurrent.AtomicBuffer
Verify that the underlying buffer is correctly aligned to prevent word tearing and other ordering issues.
verifyAlignment() - Method in class org.agrona.concurrent.MappedResizeableBuffer
 
verifyAlignment() - Method in class org.agrona.concurrent.UnsafeBuffer
 
verifyNull(Object, String) - Static method in class org.agrona.Verify
Verify that a reference is null.

W

withOutput(String, ResourceConsumer<Writer>) - Method in interface org.agrona.generation.OutputManager
 
withRecord(int, RecordBuffer.RecordWriter) - Method in class org.agrona.concurrent.RecordBuffer
High level and safe way of writing a record to the buffer.
wrap(long, long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
Remap the buffer using the existing file based on a new offset and length
wrap(FileChannel, long, long) - Method in class org.agrona.concurrent.MappedResizeableBuffer
Remap the buffer based on a new file, offset and a length
wrap(byte[]) - Method in class org.agrona.concurrent.UnsafeBuffer
 
wrap(byte[], int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
wrap(ByteBuffer) - Method in class org.agrona.concurrent.UnsafeBuffer
 
wrap(ByteBuffer, int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
wrap(DirectBuffer) - Method in class org.agrona.concurrent.UnsafeBuffer
 
wrap(DirectBuffer, int, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
wrap(long, int) - Method in class org.agrona.concurrent.UnsafeBuffer
 
wrap(byte[]) - Method in interface org.agrona.DirectBuffer
Attach a view to a byte[] for providing direct access.
wrap(byte[], int, int) - Method in interface org.agrona.DirectBuffer
Attach a view to a byte[] for providing direct access.
wrap(ByteBuffer) - Method in interface org.agrona.DirectBuffer
Attach a view to a ByteBuffer for providing direct access, the ByteBuffer can be heap based or direct.
wrap(ByteBuffer, int, int) - Method in interface org.agrona.DirectBuffer
Attach a view to a ByteBuffer for providing direct access.
wrap(DirectBuffer) - Method in interface org.agrona.DirectBuffer
Attach a view to an existing DirectBuffer
wrap(DirectBuffer, int, int) - Method in interface org.agrona.DirectBuffer
Attach a view to a DirectBuffer for providing direct access.
wrap(long, int) - Method in interface org.agrona.DirectBuffer
Attach a view to an off-heap memory region by address.
wrap(byte[]) - Method in class org.agrona.ExpandableArrayBuffer
 
wrap(byte[], int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
wrap(ByteBuffer) - Method in class org.agrona.ExpandableArrayBuffer
 
wrap(ByteBuffer, int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
wrap(DirectBuffer) - Method in class org.agrona.ExpandableArrayBuffer
 
wrap(DirectBuffer, int, int) - Method in class org.agrona.ExpandableArrayBuffer
 
wrap(long, int) - Method in class org.agrona.ExpandableArrayBuffer
 
wrap(DirectBuffer) - Method in class org.agrona.io.DirectBufferInputStream
 
wrap(DirectBuffer, int, int) - Method in class org.agrona.io.DirectBufferInputStream
 
wrap(MutableDirectBuffer) - Method in class org.agrona.io.DirectBufferOutputStream
 
wrap(MutableDirectBuffer, int, int) - Method in class org.agrona.io.DirectBufferOutputStream
 
wrap(MutableDirectBuffer) - Method in class org.agrona.io.ExpandableDirectBufferOutputStream
Wrap a given buffer beginning with an offset of 0.
wrap(MutableDirectBuffer, int) - Method in class org.agrona.io.ExpandableDirectBufferOutputStream
Wrap a given buffer beginning at an offset.
write(int, DirectBuffer, int, int) - Method in class org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer
Non-blocking write of an message to an underlying ring-buffer.
write(int, DirectBuffer, int, int) - Method in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
Non-blocking write of an message to an underlying ring-buffer.
write(int, DirectBuffer, int, int) - Method in interface org.agrona.concurrent.ringbuffer.RingBuffer
Non-blocking write of an message to an underlying ring-buffer.
write(int) - Method in class org.agrona.io.DirectBufferOutputStream
Write a byte to buffer.
write(byte[], int, int) - Method in class org.agrona.io.DirectBufferOutputStream
Write a byte[] to the buffer.
write(int) - Method in class org.agrona.io.ExpandableDirectBufferOutputStream
Write a byte to buffer.
write(byte[], int, int) - Method in class org.agrona.io.ExpandableDirectBufferOutputStream
Write a byte[] to the buffer.
writeRecord(int) - Method in interface org.agrona.concurrent.RecordBuffer.RecordWriter
Write an updated record within this callback.

Y

YieldingIdleStrategy - Class in org.agrona.concurrent
IdleStrategy that will call Thread.yield() when the work count is zero.
YieldingIdleStrategy() - Constructor for class org.agrona.concurrent.YieldingIdleStrategy
 
A B C D E F G H I J K L M N O P Q R S T U V W Y 

Copyright © 2014 - 2016 Real Logic Ltd. All Rights Reserved.



NOTHING
NOTHING
Add the Maven Dependecy to your project: maven dependecy for com.amazonaws : aws-java-sdk : 1.3.14