com.gigaspaces.internal.server.space.redolog

Class FixedSizeSwapRedoLogFile<T extends IReplicationOrderedPacket>

java.lang.Object

com.gigaspaces.internal.server.space.redolog.FixedSizeSwapRedoLogFile<T>

All Implemented Interfaces:

IRedoLogFileStatistics, IRedoLogFile<T>, ReadOnlyIterable<T>, Iterable<T>

public class FixedSizeSwapRedoLogFile<T extends IReplicationOrderedPacket>
extends Object
implements IRedoLogFile<T>

A swap based implementation of the IRedoLogFile interface, A fixed number of packets can be held in the memory and once this number is exeeded the other packets are stored in a provided INonBatchRedoLogFileStorage

Since:

7.1

Author:

eitany

Constructor Summary

Constructors

Constructor and Description
FixedSizeSwapRedoLogFile(FixedSizeSwapRedoLogFileConfig config, String name) Constructs a fixed size swap redo log file

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	deleteOldestPackets(long packetsCount) 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.
long	getExternalStoragePacketsCount()
long	getExternalStorageSpaceUsed()
long	getMemoryPacketCount()
long	getMemoryPacketsCount()
MemoryRedoLogFile<T>	getMemoryRedoLogFile()
T	getOldest()
long	getStoragePacketCount()
long	getWeight()
boolean	isEmpty()
Iterator<T>	iterator()
ReadOnlyIterator<T>	readOnlyIterator()
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 class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

FixedSizeSwapRedoLogFile

public FixedSizeSwapRedoLogFile(FixedSizeSwapRedoLogFileConfig config,
                                String name)

Constructs a fixed size swap redo log file

Method Detail

add

public void add(T replicationPacket)

Description copied from interface: IRedoLogFile

Add a replication packet to the file as the latest packet

Specified by:

add in interface IRedoLogFile<T extends IReplicationOrderedPacket>

Parameters:

replicationPacket - packet to add

getOldest

public T getOldest()

Specified by:

getOldest in interface IRedoLogFile<T extends IReplicationOrderedPacket>

Returns:

Gets the oldest replication packet in the file

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface IRedoLogFile<T extends IReplicationOrderedPacket>

Returns:

true if the file has no replication packets stored

readOnlyIterator

public ReadOnlyIterator<T> readOnlyIterator(long fromIndex)

Specified by:

readOnlyIterator in interface IRedoLogFile<T extends IReplicationOrderedPacket>

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

removeOldest

public T removeOldest()

Description copied from interface: IRedoLogFile

Remove and returns the oldest replication packet in the file

Specified by:

removeOldest in interface IRedoLogFile<T extends IReplicationOrderedPacket>

Returns:

returns the oldest replication packet in the file

size

public long size()

Specified by:

size in interface IRedoLogFileStatistics

Specified by:

size in interface IRedoLogFile<T extends IReplicationOrderedPacket>

Returns:

the number of replication packets held in the file

getApproximateSize

public long getApproximateSize()

Description copied from interface: IRedoLogFile

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.

Specified by:

getApproximateSize in interface IRedoLogFile<T extends IReplicationOrderedPacket>

Returns:

an approximation of the replication packets held in the file

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T extends IReplicationOrderedPacket>

readOnlyIterator

public ReadOnlyIterator<T> readOnlyIterator()

Specified by:

readOnlyIterator in interface ReadOnlyIterable<T extends IReplicationOrderedPacket>

Returns:

a read only iterator over the specified object

deleteOldestPackets

public void deleteOldestPackets(long packetsCount)

Description copied from interface: IRedoLogFile

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

Specified by:

deleteOldestPackets in interface IRedoLogFile<T extends IReplicationOrderedPacket>

Parameters:

packetsCount - number of oldest packets to delete

getMemoryPacketCount

public long getMemoryPacketCount()

getStoragePacketCount

public long getStoragePacketCount()

getExternalStorageSpaceUsed

public long getExternalStorageSpaceUsed()

Specified by:

getExternalStorageSpaceUsed in interface IRedoLogFileStatistics

Returns:

used space in bytes which is external to the jvm

getExternalStoragePacketsCount

public long getExternalStoragePacketsCount()

Specified by:

getExternalStoragePacketsCount in interface IRedoLogFileStatistics

Returns:

number of packets held in storage

getMemoryPacketsCount

public long getMemoryPacketsCount()

Specified by:

getMemoryPacketsCount in interface IRedoLogFileStatistics

Returns:

number of packets held in memory

validateIntegrity

public void validateIntegrity()
                       throws RedoLogFileCompromisedException

Description copied from interface: IRedoLogFile

Validates the integrity of the redo log file

Specified by:

validateIntegrity in interface IRedoLogFile<T extends IReplicationOrderedPacket>

Throws:

RedoLogFileCompromisedException

close

public void close()

Description copied from interface: IRedoLogFile

Closes the redo log file

Specified by:

close in interface IRedoLogFile<T extends IReplicationOrderedPacket>

getWeight

public long getWeight()

Specified by:

getWeight in interface IRedoLogFile<T extends IReplicationOrderedPacket>

getMemoryRedoLogFile

public MemoryRedoLogFile<T> getMemoryRedoLogFile()