com.gigaspaces.internal.server.space.redolog.storage.bytebuffer

Class ByteBufferRedoLogFileStorage<T>

java.lang.Object

com.gigaspaces.internal.server.space.redolog.storage.bytebuffer.ByteBufferRedoLogFileStorage<T>

All Implemented Interfaces:

IStorageSegmentsMediator, IRedoLogFileStorage<T>, IRedoLogFileStorageStatistics

public class ByteBufferRedoLogFileStorage<T>
extends Object
implements IRedoLogFileStorage<T>, IStorageSegmentsMediator

An implementation of redo log file storage which is based on an underlying byte buffer storages provider which simulated an endless byte buffer

Since:

7.1

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ByteBufferRedoLogFileStorage.ByteArrayResource A resource for byte array, ensure capacity must be called each time this resource is taken

Constructor Summary

Constructors

Constructor and Description
ByteBufferRedoLogFileStorage(IByteBufferStorageFactory byteBufferStorageProvider)
ByteBufferRedoLogFileStorage(IByteBufferStorageFactory byteBufferStorageProvider, ByteBufferRedoLogFileConfig<T> config)

Method Summary

Modifier and Type	Method and Description
void	allocatedNewResource(StorageSegment.SegmentCursor resource)
void	appendBatch(List<T> replicationPackets) Adds a batch of packets that will be stored at the end of the list
void	close() Close the storage and clears its resources, the storage can no longer be used.
void	deleteFirstBatch(long batchSize) Delete a batch from the start of the list
long	getExternalPacketsCount()
long	getMemoryPacketsCount()
long	getSpaceUsed()
boolean	isEmpty()
StorageReadOnlyIterator<T>	readOnlyIterator()
StorageReadOnlyIterator<T>	readOnlyIterator(long fromIndex)
List<T>	removeFirstBatch(int batchSize) Removes a batch from the start of the list
long	size() This method should not assume a reader lock is obtained when accessing it
void	validateIntegrity() Peforms an integrity check that verifies the storage state and data is not compromised

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteBufferRedoLogFileStorage

public ByteBufferRedoLogFileStorage(IByteBufferStorageFactory byteBufferStorageProvider)

ByteBufferRedoLogFileStorage

public ByteBufferRedoLogFileStorage(IByteBufferStorageFactory byteBufferStorageProvider,
                                    ByteBufferRedoLogFileConfig<T> config)

Method Detail

appendBatch

public void appendBatch(List<T> replicationPackets)
                 throws StorageException,
                        StorageFullException

Description copied from interface: IRedoLogFileStorage

Adds a batch of packets that will be stored at the end of the list

Specified by:

appendBatch in interface IRedoLogFileStorage<T>

Parameters:

replicationPackets - packets to store

Throws:

StorageException

StorageFullException

deleteFirstBatch

public void deleteFirstBatch(long batchSize)
                      throws StorageException

Description copied from interface: IRedoLogFileStorage

Delete a batch from the start of the list

Specified by:

deleteFirstBatch in interface IRedoLogFileStorage<T>

Parameters:

batchSize - batch size to delete

Throws:

StorageException

removeFirstBatch

public List<T> removeFirstBatch(int batchSize)
                         throws StorageException

Description copied from interface: IRedoLogFileStorage

Removes a batch from the start of the list

Specified by:

removeFirstBatch in interface IRedoLogFileStorage<T>

Parameters:

batchSize - batch size to remove

Returns:

removed batch

Throws:

StorageException

readOnlyIterator

public StorageReadOnlyIterator<T> readOnlyIterator()
                                            throws StorageException

Specified by:

readOnlyIterator in interface IRedoLogFileStorage<T>

Returns:

read only iterator that starts from the begining of the list

Throws:

StorageException

readOnlyIterator

public StorageReadOnlyIterator<T> readOnlyIterator(long fromIndex)
                                            throws StorageException

Specified by:

readOnlyIterator in interface IRedoLogFileStorage<T>

Parameters:

fromIndex - index to start iterating from

Returns:

read only iterator that starts from the specified index

Throws:

StorageException

size

public long size()
          throws StorageException

Description copied from interface: IRedoLogFileStorage

This method should not assume a reader lock is obtained when accessing it

Specified by:

size in interface IRedoLogFileStorage<T>

Returns:

number of packets in the storage

Throws:

StorageException

isEmpty

public boolean isEmpty()
                throws StorageException

Specified by:

isEmpty in interface IRedoLogFileStorage<T>

Returns:

true if the storage has no packets

Throws:

StorageException

getSpaceUsed

public long getSpaceUsed()

Specified by:

getSpaceUsed in interface IRedoLogFileStorageStatistics

Returns:

used space in bytes

getExternalPacketsCount

public long getExternalPacketsCount()

Specified by:

getExternalPacketsCount in interface IRedoLogFileStorageStatistics

Returns:

number of packets held outside of jvm memory

getMemoryPacketsCount

public long getMemoryPacketsCount()

Specified by:

getMemoryPacketsCount in interface IRedoLogFileStorageStatistics

Returns:

number of packets held in jvm memory

close

public void close()

Description copied from interface: IRedoLogFileStorage

Close the storage and clears its resources, the storage can no longer be used.

Specified by:

close in interface IRedoLogFileStorage<T>

allocatedNewResource

public void allocatedNewResource(StorageSegment.SegmentCursor resource)

Specified by:

allocatedNewResource in interface IStorageSegmentsMediator

validateIntegrity

public void validateIntegrity()
                       throws ByteBufferStorageCompromisedException

Peforms an integrity check that verifies the storage state and data is not compromised

Specified by:

validateIntegrity in interface IRedoLogFileStorage<T>

Throws:

ByteBufferStorageCompromisedException