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

Class DirectPersistencySyncHandler

java.lang.Object

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

All Implemented Interfaces:

IDirectPersistencySyncHandler

public class DirectPersistencySyncHandler
extends Object
implements IDirectPersistencySyncHandler

The synchronizing direct-persistency handler

Since:

10.2

Author:

yechielf

Constructor Summary

Constructors

Constructor	Description
DirectPersistencySyncHandler(SpaceEngine engine)

Method Summary

Modifier and Type	Method	Description
void	afterInitializedBlobStoreIO(IDirectPersistencyIoHandler ioHandler)
void	afterInsertingToRedolog(IReplicationOutContext context, long redoKey)
void	afterOperationPersisted(IDirectPersistencyOpInfo e)
void	afterRecovery()
boolean	afterRecoveryStarted()
void	beforeDirectPersistencyOp(IReplicationOutContext replContext, IEntryHolder entryHolder, boolean phantom)
void	beforeDirectPersistencyOp(IReplicationOutContext replContext, List<String> uids, Set<String> phantoms, Map<String,IEntryHolder> entryHolderMap)
void	close()
IReplicationGroupBacklog	getBackLog()
long	getCurrentGenerationId()
EmbeddedSyncHandler	getEmbeddedSyncHandler()
Iterator<String>	getEntriesForRecovery()
long	getLastConfirmed()
DirectPersistencyListHandler	getListHandler()
org.slf4j.Logger	getLogger()
Lock	getReadLock()
SpaceEngine	getSpaceEngine()
void	initialize()
boolean	isEmbeddedListUsed()
boolean	isOverflow()
void	onEmbeddedListRecordTransferEnd(IDirectPersistencyOpInfo o)
void	onEmbeddedListRecordTransferStart(IDirectPersistencyOpInfo o, boolean onlyIfNotExists)
void	onEmbeddedOpFromInitialLoad(String uid, long gen, long seq, boolean phantom)
void	onEmbeddedOpFromInitialLoad(List<String> uids, long gen, long seq, Set<String> phantoms)
void	setBackLog(IReplicationGroupBacklog backlog)
void	setLastConfirmed(long confirmed)

Methods inherited from class java.lang.Object

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

Constructor Details

DirectPersistencySyncHandler

public DirectPersistencySyncHandler(SpaceEngine engine)

Method Details

initialize

public void initialize()

Specified by:

initialize in interface IDirectPersistencySyncHandler

afterInitializedBlobStoreIO

public void afterInitializedBlobStoreIO(IDirectPersistencyIoHandler ioHandler)

Specified by:

afterInitializedBlobStoreIO in interface IDirectPersistencySyncHandler

getCurrentGenerationId

public long getCurrentGenerationId()

Specified by:

getCurrentGenerationId in interface IDirectPersistencySyncHandler

isOverflow

public boolean isOverflow()

Specified by:

isOverflow in interface IDirectPersistencySyncHandler

beforeDirectPersistencyOp

public void beforeDirectPersistencyOp(IReplicationOutContext replContext,
 IEntryHolder entryHolder,
 boolean phantom)

Specified by:

beforeDirectPersistencyOp in interface IDirectPersistencySyncHandler

beforeDirectPersistencyOp

public void beforeDirectPersistencyOp(IReplicationOutContext replContext,
 List<String> uids,
 Set<String> phantoms,
 Map<String,IEntryHolder> entryHolderMap)

Specified by:

beforeDirectPersistencyOp in interface IDirectPersistencySyncHandler

onEmbeddedOpFromInitialLoad

public void onEmbeddedOpFromInitialLoad(String uid,
 long gen,
 long seq,
 boolean phantom)

Specified by:

onEmbeddedOpFromInitialLoad in interface IDirectPersistencySyncHandler

onEmbeddedOpFromInitialLoad

public void onEmbeddedOpFromInitialLoad(List<String> uids,
 long gen,
 long seq,
 Set<String> phantoms)

Specified by:

onEmbeddedOpFromInitialLoad in interface IDirectPersistencySyncHandler

onEmbeddedListRecordTransferStart

public void onEmbeddedListRecordTransferStart(IDirectPersistencyOpInfo o,
 boolean onlyIfNotExists)

Specified by:

onEmbeddedListRecordTransferStart in interface IDirectPersistencySyncHandler

onEmbeddedListRecordTransferEnd

public void onEmbeddedListRecordTransferEnd(IDirectPersistencyOpInfo o)

Specified by:

onEmbeddedListRecordTransferEnd in interface IDirectPersistencySyncHandler

getEntriesForRecovery

public Iterator<String> getEntriesForRecovery()

Specified by:

getEntriesForRecovery in interface IDirectPersistencySyncHandler

afterRecovery

public void afterRecovery()

Specified by:

afterRecovery in interface IDirectPersistencySyncHandler

afterInsertingToRedolog

public void afterInsertingToRedolog(IReplicationOutContext context,
 long redoKey)

Specified by:

afterInsertingToRedolog in interface IDirectPersistencySyncHandler

afterOperationPersisted

public void afterOperationPersisted(IDirectPersistencyOpInfo e)

Specified by:

afterOperationPersisted in interface IDirectPersistencySyncHandler

setBackLog

public void setBackLog(IReplicationGroupBacklog backlog)

Specified by:

setBackLog in interface IDirectPersistencySyncHandler

getBackLog

public IReplicationGroupBacklog getBackLog()

Specified by:

getBackLog in interface IDirectPersistencySyncHandler

getLogger

public org.slf4j.Logger getLogger()

getListHandler

public DirectPersistencyListHandler getListHandler()

Specified by:

getListHandler in interface IDirectPersistencySyncHandler

getLastConfirmed

public long getLastConfirmed()

Specified by:

getLastConfirmed in interface IDirectPersistencySyncHandler

setLastConfirmed

public void setLastConfirmed(long confirmed)

Specified by:

setLastConfirmed in interface IDirectPersistencySyncHandler

getReadLock

public Lock getReadLock()

afterRecoveryStarted

public boolean afterRecoveryStarted()

close

public void close()

Specified by:

close in interface IDirectPersistencySyncHandler

getSpaceEngine

public SpaceEngine getSpaceEngine()

Specified by:

getSpaceEngine in interface IDirectPersistencySyncHandler

isEmbeddedListUsed

public boolean isEmbeddedListUsed()

Specified by:

isEmbeddedListUsed in interface IDirectPersistencySyncHandler

getEmbeddedSyncHandler

public EmbeddedSyncHandler getEmbeddedSyncHandler()

Specified by:

getEmbeddedSyncHandler in interface IDirectPersistencySyncHandler