net.openhft.chronicle.bytes.ref

Class TextIntArrayReference

java.lang.Object

net.openhft.chronicle.core.io.AbstractCloseable

net.openhft.chronicle.bytes.ref.AbstractReference

net.openhft.chronicle.bytes.ref.TextIntArrayReference

All Implemented Interfaces:

Closeable, AutoCloseable, Byteable, DynamicallySized, ByteableIntArrayValues, net.openhft.chronicle.core.io.ManagedCloseable, net.openhft.chronicle.core.io.Monitorable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, net.openhft.chronicle.core.io.SingleThreadedChecked, net.openhft.chronicle.core.values.IntArrayValues

public class TextIntArrayReference
extends AbstractReference
implements ByteableIntArrayValues

Fixed-width text array of 32-bit integers for diagnostics.

The bytes encode capacity, used and zero-padded values. Locking relies on the locked flag in each entry.

Magic constants such as FALSE and TRUE hold the lock state.

Debugging aid; not for high performance operations.

Field Summary

Fields inherited from class net.openhft.chronicle.bytes.ref.AbstractReference

bytesStore, offset

Fields inherited from class net.openhft.chronicle.core.io.AbstractCloseable

closedHere, DISABLE_DISCARD_WARNING, WARN_NS

Fields inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

INIT, TMP

Fields inherited from interface net.openhft.chronicle.core.io.SingleThreadedChecked

DISABLE_SINGLE_THREADED_CHECK

Constructor Summary

Constructors

Constructor and Description
TextIntArrayReference()

Method Summary

Modifier and Type	Method and Description
void	bindValueAt(long index, net.openhft.chronicle.core.values.IntValue value)
void	bytesStore(@NotNull BytesStore bytes, long offset, long length) Sets the underlying BytesStore together with the offset and length.
ByteableIntArrayValues	capacity(long arrayLength) Sets the capacity of the array as a count of elements, not bytes.
boolean	compareAndSet(long index, int expected, int value)
long	getCapacity()
long	getUsed()
int	getValueAt(long index)
int	getVolatileValueAt(long index)
boolean	isNull()
long	maxSize()
static long	peakLength(@NotNull BytesStore<?,?> bytes, long offset) Determines the length of the array in the text format represented in the given BytesStore.
void	reset()
void	setMaxUsed(long usedAtLeast)
void	setOrderedValueAt(long index, int value)
void	setValueAt(long index, int value)
long	sizeInBytes(long capacity) Calculates the size in bytes needed for storing an array with the specified capacity.
@NotNull String	toString() Returns a String representation of this TextIntArrayReference.
static void	write(@NotNull Bytes<?> bytes, long capacity) Writes an array of integers to the specified Bytes instance in a text format.

Methods inherited from class net.openhft.chronicle.bytes.ref.AbstractReference

acceptNewBytesStore, address, bytesStore, lock, offset, performClose, tryLock, unmonitor

Methods inherited from class net.openhft.chronicle.core.io.AbstractCloseable

assertCloseable, assertCloseablesClosed, close, createdHere, disableCloseableTracing, enableCloseableTracing, gcAndWaitForCloseablesToClose, isClosed, isClosing, isInUserThread, referenceId, shouldPerformCloseInBackground, shouldWaitForClosed, singleThreadedCheckDisabled, singleThreadedCheckDisabled, singleThreadedCheckReset, threadSafetyCheck, throwExceptionIfClosed, throwExceptionIfClosedInSetter, waitForCloseablesToClose, waitForClosed, warnAndCloseIfNotClosed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface net.openhft.chronicle.core.io.Closeable

close, closeQuietly, closeQuietly

Methods inherited from interface net.openhft.chronicle.core.io.QueryCloseable

isClosed, isClosing

Methods inherited from interface net.openhft.chronicle.bytes.Byteable

address, bytesStore, lock, offset, tryLock

Methods inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

referenceName, temporary

Methods inherited from interface net.openhft.chronicle.core.io.Monitorable

unmonitor

Constructor Detail

TextIntArrayReference

public TextIntArrayReference()

Method Detail

write

public static void write(@NotNull
                         @NotNull Bytes<?> bytes,
                         long capacity)
                  throws IllegalStateException,
                         BufferOverflowException

Writes an array of integers to the specified Bytes instance in a text format.

Parameters:

bytes - the Bytes instance to write to.

capacity - the capacity of the array to be written.

Throws:

BufferOverflowException - If there's not enough space in the buffer to write the array.

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

IllegalStateException

peakLength

public static long peakLength(@NotNull
                              @NotNull BytesStore<?,?> bytes,
                              long offset)
                       throws IllegalStateException

Determines the length of the array in the text format represented in the given BytesStore.

Parameters:

bytes - the BytesStore containing the text representation.

offset - the offset at which the text representation starts.

Returns:

the length of the array in text format.

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

IllegalStateException

getUsed

public long getUsed()
             throws IllegalStateException

Specified by:

getUsed in interface net.openhft.chronicle.core.values.IntArrayValues

Throws:

IllegalStateException

setMaxUsed

public void setMaxUsed(long usedAtLeast)
                throws IllegalStateException

Specified by:

setMaxUsed in interface net.openhft.chronicle.core.values.IntArrayValues

Throws:

IllegalStateException

getCapacity

public long getCapacity()

Specified by:

getCapacity in interface net.openhft.chronicle.core.values.IntArrayValues

capacity

public ByteableIntArrayValues capacity(long arrayLength)

Description copied from interface: ByteableIntArrayValues

Sets the capacity of the array as a count of elements, not bytes.

Specified by:

capacity in interface ByteableIntArrayValues

Parameters:

arrayLength - the desired element count

Returns:

this instance for chaining

getValueAt

public int getValueAt(long index)
               throws IllegalStateException

Specified by:

getValueAt in interface net.openhft.chronicle.core.values.IntArrayValues

Throws:

IllegalStateException

setValueAt

public void setValueAt(long index,
                       int value)
                throws IllegalStateException

Specified by:

setValueAt in interface net.openhft.chronicle.core.values.IntArrayValues

Throws:

IllegalStateException

bindValueAt

public void bindValueAt(long index,
                        net.openhft.chronicle.core.values.IntValue value)

Specified by:

bindValueAt in interface net.openhft.chronicle.core.values.IntArrayValues

getVolatileValueAt

public int getVolatileValueAt(long index)
                       throws IllegalStateException

Specified by:

getVolatileValueAt in interface net.openhft.chronicle.core.values.IntArrayValues

Throws:

IllegalStateException

setOrderedValueAt

public void setOrderedValueAt(long index,
                              int value)
                       throws IllegalStateException

Specified by:

setOrderedValueAt in interface net.openhft.chronicle.core.values.IntArrayValues

Throws:

IllegalStateException

compareAndSet

public boolean compareAndSet(long index,
                             int expected,
                             int value)
                      throws IllegalStateException

Specified by:

compareAndSet in interface net.openhft.chronicle.core.values.IntArrayValues

Throws:

IllegalStateException

bytesStore

public void bytesStore(@NotNull
                       @NotNull BytesStore bytes,
                       long offset,
                       long length)
                throws IllegalStateException,
                       IllegalArgumentException,
                       BufferOverflowException

Description copied from class: AbstractReference

Sets the underlying BytesStore together with the offset and length.

Specified by:

bytesStore in interface Byteable

Overrides:

bytesStore in class AbstractReference

Parameters:

bytes - the BytesStore providing the backing memory

offset - the non-negative offset within the store

length - the number of bytes this reference spans

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - if the store is closed

net.openhft.chronicle.core.io.ThreadingIllegalStateException - if accessed from the wrong thread

IllegalArgumentException - if length does not match Byteable.maxSize()

BufferOverflowException - if the region exceeds the store capacity

IllegalStateException

isNull

public boolean isNull()

Specified by:

isNull in interface net.openhft.chronicle.core.values.IntArrayValues

reset

public void reset()
           throws IllegalStateException

Specified by:

reset in interface net.openhft.chronicle.core.values.IntArrayValues

Throws:

IllegalStateException

maxSize

public long maxSize()

Specified by:

maxSize in interface Byteable

Returns:

fixed byte size represented by this object

toString

@NotNull
public @NotNull String toString()

Returns a String representation of this TextIntArrayReference.

Overrides:

toString in class net.openhft.chronicle.core.io.AbstractCloseable

Returns:

A String representation.

sizeInBytes

public long sizeInBytes(long capacity)

Calculates the size in bytes needed for storing an array with the specified capacity.

Specified by:

sizeInBytes in interface ByteableIntArrayValues

Specified by:

sizeInBytes in interface net.openhft.chronicle.core.values.IntArrayValues

Parameters:

capacity - The capacity of the array.

Returns:

The size in bytes needed to store the array.