nl.renarj.jasdb.core.storage.datablocks.impl

Class DataBlockImpl

java.lang.Object

nl.renarj.jasdb.core.storage.datablocks.impl.DataBlockImpl

All Implemented Interfaces:

Block, DataBlock

public class DataBlockImpl
extends Object
implements DataBlock

Author:

Renze de Vries

Nested Class Summary

Nested classes/interfaces inherited from interface nl.renarj.jasdb.core.storage.datablocks.DataBlock

DataBlock.WriteResult

Field Summary

Fields

Modifier and Type	Field and Description
static int	STREAM_HEADER_SPACE

Constructor Summary

Constructors

Constructor and Description
DataBlockImpl(long position, DataBlockFactory dataBlockFactory, MappedByteBuffer mappedByteBuffer)

Method Summary

Modifier and Type	Method and Description
int	available()
int	capacity() The capacity of the block available for storage, this is excluding the size of the header.
void	close()
void	flush()
MappedByteBuffer	getBuffer()
DataBlockHeader	getHeader()
ReadWriteLock	getLockManager()
long	getPosition()
DataBlockResult<byte[]>	loadBytes(int offset) Load bytes from the datablock, providing an offset from the start of the block.
DataBlockResult<byte[]>	loadBytes(long absolutePosition)
DataBlockResult<Long>	loadLong(int offset)
DataBlockResult<Long>	loadLong(long absolutePosition)
DataBlock	loadNext()
DataBlockResult<BlockDataInputStream>	loadStream(int offset)
DataBlockResult<BlockDataInputStream>	loadStream(long absolutePosition)
void	reset()
int	size() Returns the data size of the block on the disk including the size of the header.
String	toString()
DataBlock.WriteResult	writeBytes(byte[] bytes)
DataBlock.WriteResult	writeDataStream(InputStream stream, boolean isDelegate)
DataBlock.WriteResult	writeLong(long value)
DataBlock.WriteResult	writeStream(InputStream stream)

Methods inherited from class java.lang.Object

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

Field Detail

STREAM_HEADER_SPACE

public static final int STREAM_HEADER_SPACE

See Also:

Constant Field Values

Constructor Detail

DataBlockImpl

public DataBlockImpl(long position,
                     DataBlockFactory dataBlockFactory,
                     MappedByteBuffer mappedByteBuffer)

Method Detail

loadNext

public DataBlock loadNext()
                   throws JasDBStorageException

Specified by:

loadNext in interface DataBlock

Throws:

JasDBStorageException

getPosition

public long getPosition()

Specified by:

getPosition in interface Block

getHeader

public DataBlockHeader getHeader()

Specified by:

getHeader in interface DataBlock

reset

public void reset()

Specified by:

reset in interface DataBlock

available

public int available()

Specified by:

available in interface DataBlock

loadBytes

public DataBlockResult<byte[]> loadBytes(int offset)
                                  throws JasDBStorageException

Description copied from interface: DataBlock

Load bytes from the datablock, providing an offset from the start of the block. If the offset exceeds the block size it will start loading from the block chain.

Specified by:

loadBytes in interface DataBlock

Parameters:

offset - The offset to start loading the data from

Returns:

The bytes loaded fully into memory

Throws:

JasDBStorageException - If unable to load the bytes from the block

loadBytes

public DataBlockResult<byte[]> loadBytes(long absolutePosition)
                                  throws JasDBStorageException

Specified by:

loadBytes in interface DataBlock

Throws:

JasDBStorageException

loadStream

public DataBlockResult<BlockDataInputStream> loadStream(long absolutePosition)
                                                 throws JasDBStorageException

Specified by:

loadStream in interface DataBlock

Throws:

JasDBStorageException

getBuffer

public MappedByteBuffer getBuffer()

Specified by:

getBuffer in interface DataBlock

getLockManager

public ReadWriteLock getLockManager()

Specified by:

getLockManager in interface DataBlock

capacity

public int capacity()

Description copied from interface: DataBlock

The capacity of the block available for storage, this is excluding the size of the header.

Specified by:

capacity in interface DataBlock

Returns:

The storage capacity of the block

size

public int size()

Description copied from interface: DataBlock

Returns the data size of the block on the disk including the size of the header.

Specified by:

size in interface DataBlock

Returns:

The size of the data block on the disk including header

loadStream

public DataBlockResult<BlockDataInputStream> loadStream(int offset)
                                                 throws JasDBStorageException

Specified by:

loadStream in interface DataBlock

Throws:

JasDBStorageException

loadLong

public DataBlockResult<Long> loadLong(int offset)
                               throws JasDBStorageException

Specified by:

loadLong in interface DataBlock

Throws:

JasDBStorageException

loadLong

public DataBlockResult<Long> loadLong(long absolutePosition)
                               throws JasDBStorageException

Specified by:

loadLong in interface DataBlock

Throws:

JasDBStorageException

writeBytes

public DataBlock.WriteResult writeBytes(byte[] bytes)
                                 throws JasDBStorageException

Specified by:

writeBytes in interface DataBlock

Throws:

JasDBStorageException

writeStream

public DataBlock.WriteResult writeStream(InputStream stream)
                                  throws JasDBStorageException

Specified by:

writeStream in interface DataBlock

Throws:

JasDBStorageException

writeDataStream

public DataBlock.WriteResult writeDataStream(InputStream stream,
                                             boolean isDelegate)
                                      throws JasDBStorageException

Throws:

JasDBStorageException

writeLong

public DataBlock.WriteResult writeLong(long value)
                                throws JasDBStorageException

Specified by:

writeLong in interface DataBlock

Throws:

JasDBStorageException

close

public void close()
           throws JasDBStorageException

Specified by:

close in interface Block

Throws:

JasDBStorageException

flush

public void flush()
           throws JasDBStorageException

Specified by:

flush in interface DataBlock

Throws:

JasDBStorageException

toString

public String toString()

Overrides:

toString in class Object