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

Class ByteBufferRedoLogFileStorage<T extends IReplicationOrderedPacket>

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 IReplicationOrderedPacket>
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	Description
class	ByteBufferRedoLogFileStorage.ByteArrayResource	A resource for byte array, ensure capacity must be called each time this resource is taken

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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	deleteOldestPackets(long packetsCount)	Delete a batch from the start of the list
long	getCacheWeight()
long	getDiscardedPacketsCount()
long	getExternalPacketsCount()
long	getExternalStoragePacketsWeight()
long	getMemoryPacketsCount()
long	getMemoryPacketsWeight()
long	getSpaceUsed()
long	getWeight()
boolean	isEmpty()
CompactionResult	performCompaction(long from, long to)
StorageReadOnlyIterator<T>	readOnlyIterator(long fromIndex)
WeightedBatch<T>	removeFirstBatch(int batchCapacity, long lastCompactionRangeEndKey)	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()	Performs 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

Methods inherited from interface com.gigaspaces.internal.server.space.redolog.storage.IRedoLogFileStorage

getOldest, getOldestKey, removeOldest

Constructor Details

ByteBufferRedoLogFileStorage

public ByteBufferRedoLogFileStorage(IByteBufferStorageFactory byteBufferStorageProvider)

ByteBufferRedoLogFileStorage

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

Method Details

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 extends IReplicationOrderedPacket>

Parameters:

replicationPackets - packets to store

Throws:

StorageException

StorageFullException

deleteOldestPackets

public void deleteOldestPackets(long packetsCount)
                         throws StorageException

Description copied from interface: IRedoLogFileStorage

Delete a batch from the start of the list

Specified by:

deleteOldestPackets in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Parameters:

packetsCount - number of packets to delete

Throws:

StorageException

removeFirstBatch

public WeightedBatch<T> removeFirstBatch(int batchCapacity,
 long lastCompactionRangeEndKey)
                                  throws StorageException

Description copied from interface: IRedoLogFileStorage

Removes a batch from the start of the list

Specified by:

removeFirstBatch in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Parameters:

batchCapacity - WeightToRemove to remove

lastCompactionRangeEndKey - packets with keys larger than this cannot be discarded

Returns:

removed batch

Throws:

StorageException

readOnlyIterator

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

Specified by:

readOnlyIterator in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

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 extends IReplicationOrderedPacket>

Returns:

number of packets in the storage

Throws:

StorageException

isEmpty

public boolean isEmpty()
                throws StorageException

Specified by:

isEmpty in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

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

getMemoryPacketsWeight

public long getMemoryPacketsWeight()

Specified by:

getMemoryPacketsWeight in interface IRedoLogFileStorageStatistics

Returns:

total weight of packets held in memory

getExternalStoragePacketsWeight

public long getExternalStoragePacketsWeight()

Specified by:

getExternalStoragePacketsWeight in interface IRedoLogFileStorageStatistics

Returns:

total weight of packets held in external storage

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 extends IReplicationOrderedPacket>

getWeight

public long getWeight()

Specified by:

getWeight in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

getDiscardedPacketsCount

public long getDiscardedPacketsCount()

Specified by:

getDiscardedPacketsCount in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

performCompaction

public CompactionResult performCompaction(long from,
 long to)

Specified by:

performCompaction in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

getCacheWeight

public long getCacheWeight()

Specified by:

getCacheWeight in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

allocatedNewResource

public void allocatedNewResource(StorageSegment.SegmentCursor resource)

Specified by:

allocatedNewResource in interface IStorageSegmentsMediator

validateIntegrity

public void validateIntegrity()
                       throws ByteBufferStorageCompromisedException

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

Specified by:

validateIntegrity in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Throws:

ByteBufferStorageCompromisedException