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

Class AbstractSpaceReplicationEntryEventHandler

java.lang.Object

com.gigaspaces.internal.cluster.node.handlers.AbstractReplicationEntryEventHandler

com.gigaspaces.internal.cluster.node.impl.handlers.AbstractSpaceReplicationEntryEventHandler

All Implemented Interfaces:

IReplicationInEntryHandler, IReplicationInEvictEntryHandler

Direct Known Subclasses:

ActiveActiveSpaceReplicationEntryEventHandler, PrimaryBackupSpaceReplicationEntryEventHandler

public abstract class AbstractSpaceReplicationEntryEventHandler
extends AbstractReplicationEntryEventHandler
implements IReplicationInEvictEntryHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected final SpaceEngine	_engine
protected final ReplicationInExceptionHandler	_exceptionHandler

Constructor Summary

Constructors

Constructor	Description
AbstractSpaceReplicationEntryEventHandler(SpaceEngine engine, ReplicationInExceptionHandler exceptionHandler)

Method Summary

Modifier and Type	Method	Description
void	changeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, Object id, int routingHash, int version, int previousVersion, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntry)
protected void	changeEntryInSpace(IReplicationInContext context, Transaction txn, String uid, int version, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntry, long timeToLive, boolean twoPhaseCommit, String typeName)
protected ExtendedAnswerHolder	executeUpdateOperation(IReplicationInContext context, Transaction txn, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion, long lease, boolean twoPhaseCommit, int updateModifiers)
protected ConflictingOperationPolicy	getConflictingOperationPolicy()
protected boolean	ignoreOperation(boolean isTransient)
void	inEvictEntry(IReplicationInContext context, String uid, boolean isTransient, OperationID operationID)
protected void	postChangeExecution(IReplicationInContext context, IEntryData previousEntryData, IEntryData modifiedEntryData)
protected void	postRemoveExecution(IReplicationInContext context, AnswerPacket aPacket)
protected void	postUpdateExecution(IReplicationInContext context, IEntryData previousEntryData, IEntryData currentEntryData)
void	removeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
void	removeEntryByUid(IReplicationInContext context, Transaction transaction, boolean twoPhaseCommit, String uid, boolean isTransient, OperationID operationID, String typeName)
protected void	removeEntryFromSpace(IReplicationInContext context, Transaction txn, ITemplatePacket template, boolean twoPhaseCommit)
protected abstract boolean	shouldChangeEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, boolean isTransient, int version)
protected abstract boolean	shouldEvictEntryFromSpace(boolean isTransient)
protected abstract boolean	shouldRemoveEntryFromSpace(boolean isTransient)
protected abstract boolean	shouldUpdateEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
void	updateEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion)
protected void	updateEntryInSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion, long lease, boolean twoPhaseCommit)
protected abstract ExtendedAnswerHolder	updateOrWrite(IReplicationInContext context, Transaction txn, IEntryPacket entry, long lease, int modifiers)
void	writeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
protected void	writeEntryIntoSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, long lease, boolean twoPhaseCommit)

Methods inherited from class com.gigaspaces.internal.cluster.node.handlers.AbstractReplicationEntryEventHandler

afterConsumption, beforeConsume, inChangeEntry, inRemoveEntry, inRemoveEntryByUID, inUpdateEntry, inWriteEntry

Methods inherited from class java.lang.Object

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

Field Details

_engine

protected final SpaceEngine _engine

_exceptionHandler

protected final ReplicationInExceptionHandler _exceptionHandler

Constructor Details

AbstractSpaceReplicationEntryEventHandler

public AbstractSpaceReplicationEntryEventHandler(SpaceEngine engine,
 ReplicationInExceptionHandler exceptionHandler)

Method Details

getConflictingOperationPolicy

protected ConflictingOperationPolicy getConflictingOperationPolicy()

ignoreOperation

protected boolean ignoreOperation(boolean isTransient)

writeEntry

public void writeEntry(IReplicationInContext context,
 Transaction txn,
 boolean twoPhaseCommit,
 IEntryPacket entry)
                throws Exception

Specified by:

writeEntry in class AbstractReplicationEntryEventHandler

Throws:

Exception

updateEntry

public void updateEntry(IReplicationInContext context,
 Transaction txn,
 boolean twoPhaseCommit,
 IEntryPacket entry,
 IEntryPacket previousEntry,
 boolean partialUpdate,
 boolean overrideVersion)
                 throws Exception

Specified by:

updateEntry in class AbstractReplicationEntryEventHandler

Throws:

Exception

removeEntry

public void removeEntry(IReplicationInContext context,
 Transaction txn,
 boolean twoPhaseCommit,
 IEntryPacket entry)
                 throws Exception

Specified by:

removeEntry in class AbstractReplicationEntryEventHandler

Throws:

Exception

removeEntryByUid

public void removeEntryByUid(IReplicationInContext context,
 Transaction transaction,
 boolean twoPhaseCommit,
 String uid,
 boolean isTransient,
 OperationID operationID,
 String typeName)
                      throws Exception

Specified by:

removeEntryByUid in class AbstractReplicationEntryEventHandler

Throws:

Exception

changeEntry

public void changeEntry(IReplicationInContext context,
 Transaction txn,
 boolean twoPhaseCommit,
 String typeName,
 String uid,
 Object id,
 int routingHash,
 int version,
 int previousVersion,
 long timeToLive,
 Collection<SpaceEntryMutator> mutators,
 boolean isTransient,
 OperationID operationID,
 IEntryData previousEntry)
                 throws Exception

Specified by:

changeEntry in class AbstractReplicationEntryEventHandler

Throws:

Exception

changeEntryInSpace

protected void changeEntryInSpace(IReplicationInContext context,
 Transaction txn,
 String uid,
 int version,
 Collection<SpaceEntryMutator> mutators,
 boolean isTransient,
 OperationID operationID,
 IEntryData previousEntry,
 long timeToLive,
 boolean twoPhaseCommit,
 String typeName)
                           throws Exception

Throws:

Exception

postChangeExecution

protected void postChangeExecution(IReplicationInContext context,
 IEntryData previousEntryData,
 IEntryData modifiedEntryData)

inEvictEntry

public void inEvictEntry(IReplicationInContext context,
 String uid,
 boolean isTransient,
 OperationID operationID)
                  throws Exception

Specified by:

inEvictEntry in interface IReplicationInEvictEntryHandler

Throws:

Exception

writeEntryIntoSpace

protected void writeEntryIntoSpace(IReplicationInContext context,
 Transaction txn,
 IEntryPacket entry,
 long lease,
 boolean twoPhaseCommit)
                            throws Exception

Throws:

Exception

updateEntryInSpace

protected void updateEntryInSpace(IReplicationInContext context,
 Transaction txn,
 IEntryPacket entry,
 IEntryPacket previousEntry,
 boolean partialUpdate,
 boolean overrideVersion,
 long lease,
 boolean twoPhaseCommit)
                           throws UnusableEntryException,
UnknownTypeException,
TransactionException,
RemoteException

Throws:

UnusableEntryException

UnknownTypeException

TransactionException

RemoteException

executeUpdateOperation

protected ExtendedAnswerHolder executeUpdateOperation(IReplicationInContext context,
 Transaction txn,
 IEntryPacket entry,
 IEntryPacket previousEntry,
 boolean partialUpdate,
 boolean overrideVersion,
 long lease,
 boolean twoPhaseCommit,
 int updateModifiers)
                                               throws UnusableEntryException,
UnknownTypeException,
TransactionException,
RemoteException,
InterruptedException

Throws:

UnusableEntryException

UnknownTypeException

TransactionException

RemoteException

InterruptedException

postUpdateExecution

protected void postUpdateExecution(IReplicationInContext context,
 IEntryData previousEntryData,
 IEntryData currentEntryData)

removeEntryFromSpace

protected void removeEntryFromSpace(IReplicationInContext context,
 Transaction txn,
 ITemplatePacket template,
 boolean twoPhaseCommit)
                             throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

postRemoveExecution

protected void postRemoveExecution(IReplicationInContext context,
 AnswerPacket aPacket)

updateOrWrite

protected abstract ExtendedAnswerHolder updateOrWrite(IReplicationInContext context,
 Transaction txn,
 IEntryPacket entry,
 long lease,
 int modifiers)
                                               throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException,
InterruptedException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

InterruptedException

shouldUpdateEntryInSpace

protected abstract boolean shouldUpdateEntryInSpace(IReplicationInContext context,
 Transaction txn,
 boolean twoPhaseCommit,
 IEntryPacket entry)
                                             throws Exception

Throws:

Exception

shouldChangeEntryInSpace

protected abstract boolean shouldChangeEntryInSpace(IReplicationInContext context,
 Transaction txn,
 boolean twoPhaseCommit,
 String typeName,
 String uid,
 boolean isTransient,
 int version)
                                             throws Exception

Throws:

Exception

shouldRemoveEntryFromSpace

protected abstract boolean shouldRemoveEntryFromSpace(boolean isTransient)

shouldEvictEntryFromSpace

protected abstract boolean shouldEvictEntryFromSpace(boolean isTransient)