Package 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	Description
static final long	EMBEDDED_SYNC_SLEEP_TIME
static final int	MIN_SIZE_TO_ITER
static final int	SHORT_SLEEP_QUEUE_SIZE

Method Summary

Modifier and Type	Method	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 Details

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 Details

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()