com.gigaspaces.internal.server.space.redolog

Interface IRedoLogFile<T>

All Superinterfaces:

IRedoLogFileStatistics, Iterable<T>, ReadOnlyIterable<T>

All Known Implementing Classes:

FixedSizeSwapRedoLogFile, MemoryRedoLogFile

public interface IRedoLogFile<T>
extends Iterable<T>, ReadOnlyIterable<T>, IRedoLogFileStatistics

Acts as the redo log packets storage MemoryRedoLog Implementor should support concurrent readers or a single writer, in other words, the implementor can assume access to this structure are guarded with a reader writer lock according to the operation type An exception is getApproximateSize() method which should not assume a reader lock is held.

Since:

7.1

Author:

eitany

Method Summary

Modifier and Type	Method and Description
void	add(T replicationPacket) Add a replication packet to the file as the latest packet
void	close() Closes the redo log file
void	deleteOldestBatch(long batchSize) Deletes the oldest packets, starting from the oldest up until the specified batch size
long	getApproximateSize() Gets an approximation of the number of replication packets held in the file, implementation of this method should not assume a reader lock is held and hence can return a result which is not accurate if it cannot do so without a lock.
T	getOldest()
boolean	isEmpty()
ReadOnlyIterator<T>	readOnlyIterator(long fromIndex)
T	removeOldest() Remove and returns the oldest replication packet in the file
long	size()
void	validateIntegrity() Validates the integrity of the redo log file

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface com.gigaspaces.internal.utils.collections.ReadOnlyIterable

readOnlyIterator

Methods inherited from interface com.gigaspaces.cluster.replication.IRedoLogFileStatistics

getExternalStoragePacketsCount, getExternalStorageSpaceUsed, getMemoryPacketsCount

Method Detail

removeOldest

T removeOldest()

Remove and returns the oldest replication packet in the file

Returns:

returns the oldest replication packet in the file

getOldest

T getOldest()

Returns:

Gets the oldest replication packet in the file

add

void add(T replicationPacket)

Add a replication packet to the file as the latest packet

Parameters:

replicationPacket - packet to add

size

long size()

Specified by:

size in interface IRedoLogFileStatistics

Returns:

the number of replication packets held in the file

getApproximateSize

long getApproximateSize()

Gets an approximation of the number of replication packets held in the file, implementation of this method should not assume a reader lock is held and hence can return a result which is not accurate if it cannot do so without a lock.

Returns:

an approximation of the replication packets held in the file

isEmpty

boolean isEmpty()

Returns:

true if the file has no replication packets stored

readOnlyIterator

ReadOnlyIterator<T> readOnlyIterator(long fromIndex)

Parameters:

fromIndex - index to start from

Returns:

read only iterator over the packets in the file that will start from the given index, where 0 specified the oldest packet

deleteOldestBatch

void deleteOldestBatch(long batchSize)

Deletes the oldest packets, starting from the oldest up until the specified batch size

Parameters:

batchSize - number of oldest packets to delete

validateIntegrity

void validateIntegrity()
                throws RedoLogFileCompromisedException

Validates the integrity of the redo log file

Throws:

RedoLogFileCompromisedException

close

void close()

Closes the redo log file