com.gigaspaces.internal.cluster.node.impl.directPersistency.embeddedSyncList

Class EmbeddedSyncSegment

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.directPersistency.embeddedSyncList.EmbeddedSyncSegment

public class EmbeddedSyncSegment
extends Object

The synchronizing direct-persistency embedded segment handler

Since:

11.0

Author:

yechielf

Field Summary

Fields

Modifier and Type	Field and Description
static long	EMBEDDED_SYNC_SLEEP_TIME
static int	MIN_SIZE_TO_ITER
static int	SHORT_SLEEP_QUEUE_SIZE

Method Summary

Modifier and Type	Method and Description
void	add(IEmbeddedSyncOpInfo op)
void	afterInitializedBlobStoreIO()
void	close()
EmbeddedSyncHandler	getEmbeddedHandler()
Iterator<IEmbeddedSyncOpInfo>	getEmbeddedRecordsIterator()
EmbeddedSyncListTransferredInfoHandler	getInfoHandlerOfSegment()
int	getSegmentNumber()
void	initialize()
boolean	transferIfPossible(IEmbeddedSyncOpInfo oi)

Methods inherited from class java.lang.Object

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

Field Detail

EMBEDDED_SYNC_SLEEP_TIME

public static final long EMBEDDED_SYNC_SLEEP_TIME

See Also:

Constant Field Values

SHORT_SLEEP_QUEUE_SIZE

public static final int SHORT_SLEEP_QUEUE_SIZE

See Also:

Constant Field Values

MIN_SIZE_TO_ITER

public static final int MIN_SIZE_TO_ITER

See Also:

Constant Field Values

Method Detail

initialize

public void initialize()

afterInitializedBlobStoreIO

public void afterInitializedBlobStoreIO()

add

public void add(IEmbeddedSyncOpInfo op)

getEmbeddedHandler

public EmbeddedSyncHandler getEmbeddedHandler()

transferIfPossible

public boolean transferIfPossible(IEmbeddedSyncOpInfo oi)

getSegmentNumber

public int getSegmentNumber()

getInfoHandlerOfSegment

public EmbeddedSyncListTransferredInfoHandler getInfoHandlerOfSegment()

getEmbeddedRecordsIterator

public Iterator<IEmbeddedSyncOpInfo> getEmbeddedRecordsIterator()

close

public void close()