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

Class ByteBufferRedoLogFileConfig<T>

java.lang.Object

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

public class ByteBufferRedoLogFileConfig<T>
extends Object

A configuration object for ByteBufferRedoLogFileStorage

Since:

7.1

Author:

eitany

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_BUFFER_SIZE
static final int	DEFAULT_MAX_BUFFER_SIZE
static final int	DEFAULT_MAX_SCAN
static final int	DEFAULT_MAX_STORAGE_CURSORS
static final long	DEFAULT_SEGMENT_SIZE
static final long	DEFAULT_SWAP_SIZE
static final long	UNLIMITED

Constructor Summary

Constructors

Constructor	Description
ByteBufferRedoLogFileConfig()

Method Summary

Modifier and Type	Method	Description
int	getMaxOpenStorageCursors()
int	getMaxScanLength()
long	getMaxSizePerSegment()
long	getMaxSwapSize()
IPacketStreamSerializer<T>	getPacketStreamSerializer()
int	getWriterBufferSize()
int	getWriterMaxBufferSize()
void	setMaxOpenStorageCursors(int maxOpenStorageReaders)	Set max allows open storage readers (usually translate to maximum allowed open file descriptors)
void	setMaxScanLength(int maxScanLength)
void	setMaxSizePerSegment(long maxSizePerSegment)	Sets the maximum size of each segment of the storage
void	setMaxSwapSize(long maxSwapSize)	Sets the maximum size in bytes of the entire storage, -1 states unlimited
void	setPacketStreamSerializer(IPacketStreamSerializer<T> packetStreamSerializer)
void	setWriterBufferSize(int writerBufferSize)	Sets the write buffer init size in bytes
void	setWriterMaxBufferSize(int writerMaxBufferSize)	Sets the maximum size if the write buffer in bytes

Methods inherited from class java.lang.Object

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

Field Details

UNLIMITED

public static final long UNLIMITED

See Also:

• Constant Field Values

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

• Constant Field Values

DEFAULT_MAX_BUFFER_SIZE

public static final int DEFAULT_MAX_BUFFER_SIZE

See Also:

• Constant Field Values

DEFAULT_SWAP_SIZE

public static final long DEFAULT_SWAP_SIZE

See Also:

• Constant Field Values

DEFAULT_SEGMENT_SIZE

public static final long DEFAULT_SEGMENT_SIZE

See Also:

• Constant Field Values

DEFAULT_MAX_SCAN

public static final int DEFAULT_MAX_SCAN

See Also:

• Constant Field Values

DEFAULT_MAX_STORAGE_CURSORS

public static final int DEFAULT_MAX_STORAGE_CURSORS

See Also:

• Constant Field Values

Constructor Details

ByteBufferRedoLogFileConfig

public ByteBufferRedoLogFileConfig()

Method Details

getWriterBufferSize

public int getWriterBufferSize()

getWriterMaxBufferSize

public int getWriterMaxBufferSize()

setWriterBufferSize

public void setWriterBufferSize(int writerBufferSize)

Sets the write buffer init size in bytes

setWriterMaxBufferSize

public void setWriterMaxBufferSize(int writerMaxBufferSize)

Sets the maximum size if the write buffer in bytes

setMaxSwapSize

public void setMaxSwapSize(long maxSwapSize)

Sets the maximum size in bytes of the entire storage, -1 states unlimited

getMaxSwapSize

public long getMaxSwapSize()

setMaxSizePerSegment

public void setMaxSizePerSegment(long maxSizePerSegment)

Sets the maximum size of each segment of the storage

Parameters:

maxSizePerSegment - maximum size in bytes, must be a positive non zero number

getMaxSizePerSegment

public long getMaxSizePerSegment()

setMaxScanLength

public void setMaxScanLength(int maxScanLength)

getMaxScanLength

public int getMaxScanLength()

setMaxOpenStorageCursors

public void setMaxOpenStorageCursors(int maxOpenStorageReaders)

Set max allows open storage readers (usually translate to maximum allowed open file descriptors)

getMaxOpenStorageCursors

public int getMaxOpenStorageCursors()

getPacketStreamSerializer

public IPacketStreamSerializer<T> getPacketStreamSerializer()

setPacketStreamSerializer

public void setPacketStreamSerializer(IPacketStreamSerializer<T> packetStreamSerializer)