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

Class EmbeddedSyncHandler

java.lang.Object

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

public class EmbeddedSyncHandler
extends Object

The synchronizing direct-persistency embedded list handler

Since:

11.0

Author:

yechielf

Constructor Summary

Constructors

Constructor	Description
EmbeddedSyncHandler(DirectPersistencySyncHandler mainSyncHandler)

Method Summary

Modifier and Type	Method	Description
void	afterInitializedBlobStoreIO()
void	afterRecovery()
void	beforeEmbeddedSyncOp(DirectPersistencyMultipleUidsOpInfo originalOpInfo, Set<String> phantoms)
void	beforeEmbeddedSyncOp(DirectPersistencySingleUidOpInfo originalOpInfo, boolean phantom)
void	close()
Iterator<String>	getEmbeddedListForRecovery()
EmbeddedRelevantGenerationIdsHandler	getGensHandler()
InitialLoadHandler	getInitialLoadHandler()
DirectPersistencySyncHandler	getMainSyncHandler()
int	getNumSegments()
PhantomsHandler	getPhantomsHandler()
EmbeddedSyncSegment	getSegment(int num)
static Serializable	getStorageKeyForPhantom(String uid)
void	initialize()
void	onEmbeddedOpFromInitialLoad(DirectPersistencyMultipleUidsOpInfo originalOpInfo, Set<String> phantoms)
void	onEmbeddedOpFromInitialLoad(DirectPersistencySingleUidOpInfo originalOpInfo, boolean phantom)
void	onEmbeddedSyncOp(DirectPersistencyMultipleUidsOpInfo originalOpInfo)
void	onEmbeddedSyncOp(DirectPersistencySingleUidOpInfo originalOpInfo)
void	onSpaceOpRemovePhantomIfExists(String uid)

Methods inherited from class java.lang.Object

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

Constructor Details

EmbeddedSyncHandler

public EmbeddedSyncHandler(DirectPersistencySyncHandler mainSyncHandler)

Method Details

afterInitializedBlobStoreIO

public void afterInitializedBlobStoreIO()

initialize

public void initialize()

getStorageKeyForPhantom

public static Serializable getStorageKeyForPhantom(String uid)

beforeEmbeddedSyncOp

public void beforeEmbeddedSyncOp(DirectPersistencySingleUidOpInfo originalOpInfo,
 boolean phantom)

beforeEmbeddedSyncOp

public void beforeEmbeddedSyncOp(DirectPersistencyMultipleUidsOpInfo originalOpInfo,
 Set<String> phantoms)

onEmbeddedSyncOp

public void onEmbeddedSyncOp(DirectPersistencySingleUidOpInfo originalOpInfo)

onEmbeddedSyncOp

public void onEmbeddedSyncOp(DirectPersistencyMultipleUidsOpInfo originalOpInfo)

onEmbeddedOpFromInitialLoad

public void onEmbeddedOpFromInitialLoad(DirectPersistencySingleUidOpInfo originalOpInfo,
 boolean phantom)

onEmbeddedOpFromInitialLoad

public void onEmbeddedOpFromInitialLoad(DirectPersistencyMultipleUidsOpInfo originalOpInfo,
 Set<String> phantoms)

getMainSyncHandler

public DirectPersistencySyncHandler getMainSyncHandler()

getNumSegments

public int getNumSegments()

getSegment

public EmbeddedSyncSegment getSegment(int num)

getGensHandler

public EmbeddedRelevantGenerationIdsHandler getGensHandler()

onSpaceOpRemovePhantomIfExists

public void onSpaceOpRemovePhantomIfExists(String uid)

getPhantomsHandler

public PhantomsHandler getPhantomsHandler()

getInitialLoadHandler

public InitialLoadHandler getInitialLoadHandler()

afterRecovery

public void afterRecovery()

getEmbeddedListForRecovery

public Iterator<String> getEmbeddedListForRecovery()

close

public void close()