net.openhft.chronicle.bytes.ref

Class AbstractReference

java.lang.Object

net.openhft.chronicle.core.io.AbstractCloseable

net.openhft.chronicle.bytes.ref.AbstractReference

All Implemented Interfaces:

Closeable, AutoCloseable, Byteable, 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

Direct Known Subclasses:

BinaryBooleanReference, BinaryIntArrayReference, BinaryIntReference, BinaryLongArrayReference, BinaryLongReference, TextBooleanReference, TextIntArrayReference, TextIntReference, TextLongArrayReference, TextLongReference

public abstract class AbstractReference
extends net.openhft.chronicle.core.io.AbstractCloseable
implements Byteable, net.openhft.chronicle.core.io.Closeable

Base class for references backed by a BytesStore.

acceptNewBytesStore(BytesStore) reserves the store and performClose() releases it. Subclasses must call throwExceptionIfClosed...() before mutating state.

unmonitor() propagates to the wrapped store.

See Also:

BytesStore, Byteable, Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected @Nullable BytesStore	bytesStore BytesStore associated with this reference
protected long	offset Offset within the BytesStore for this reference

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

Modifier	Constructor and Description
protected	AbstractReference() Constructor initializes the reference assuming thread safety.

Method Summary

Modifier and Type	Method and Description
protected void	acceptNewBytesStore(@NotNull BytesStore<?,?> bytes) Updates the BytesStore for this reference, releasing any previous BytesStore
long	address() Retrieves the memory address for reading.
@Nullable BytesStore<?,?>	bytesStore() Returns the BytesStore that backs this reference, or null if none is set.
void	bytesStore(@NotNull BytesStore bytes, long offset, long length) Sets the underlying BytesStore together with the offset and length.
FileLock	lock(boolean shared) Attempts to lock a region in the file in either shared or exclusive mode.
long	offset() Returns the byte offset relative to the start of the associated store.
protected void	performClose() Closes this reference, releasing any associated BytesStore
FileLock	tryLock(boolean shared) Attempts to lock a region in the file in either shared or exclusive mode, but does not block waiting for the lock.
void	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, toString, 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.bytes.Byteable

maxSize

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.core.io.ReferenceOwner

referenceName, temporary

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

unmonitor

Field Detail

bytesStore

@Nullable
protected @Nullable BytesStore bytesStore

BytesStore associated with this reference

offset

protected long offset

Offset within the BytesStore for this reference

Constructor Detail

AbstractReference

protected AbstractReference()

Constructor initializes the reference assuming thread safety.

Method Detail

bytesStore

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

Sets the underlying BytesStore together with the offset and length.

Specified by:

bytesStore in interface Byteable

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:

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

BufferOverflowException - if the region exceeds the store capacity

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

bytesStore

@Nullable
public @Nullable BytesStore<?,?> bytesStore()

Returns the BytesStore that backs this reference, or null if none is set.

Specified by:

bytesStore in interface Byteable

Returns:

current backing BytesStore or null if unmapped

offset

public long offset()

Returns the byte offset relative to the start of the associated store.

Specified by:

offset in interface Byteable

Returns:

offset within the current BytesStore

acceptNewBytesStore

protected void acceptNewBytesStore(@NotNull
                                   @NotNull BytesStore<?,?> bytes)
                            throws IllegalStateException

Updates the BytesStore for this reference, releasing any previous BytesStore

Parameters:

bytes - the new BytesStore

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

performClose

protected void performClose()

Closes this reference, releasing any associated BytesStore

Specified by:

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

address

public long address()
             throws IllegalStateException,
                    BufferUnderflowException

Retrieves the memory address for reading.

Specified by:

address in interface Byteable

Returns:

the memory address

Throws:

BufferUnderflowException - If the buffer does not have enough content

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

lock

public FileLock lock(boolean shared)
              throws IOException

Attempts to lock a region in the file in either shared or exclusive mode.

Specified by:

lock in interface Byteable

Parameters:

shared - if true the lock will be shared, otherwise it will be exclusive.

Returns:

a FileLock object representing the locked region

Throws:

IOException - If an I/O error occurs

tryLock

public FileLock tryLock(boolean shared)
                 throws IOException

Attempts to lock a region in the file in either shared or exclusive mode, but does not block waiting for the lock.

Specified by:

tryLock in interface Byteable

Parameters:

shared - if true the lock will be shared, otherwise it will be exclusive.

Returns:

a FileLock object representing the locked region or null if the lock could not be acquired

Throws:

IOException - If an I/O error occurs

unmonitor

public void unmonitor()

Specified by:

unmonitor in interface net.openhft.chronicle.core.io.Monitorable

Overrides:

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