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

Class PrimaryBackupSpaceReplicationEntryEventHandler

java.lang.Object

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

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

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

All Implemented Interfaces:

IReplicationInEntryHandler, IReplicationInEvictEntryHandler

Direct Known Subclasses:

BlobstorePrimaryBackupSpaceReplicationEntryEventHandler, PrimaryBackupSpaceReplicationEvictionProtectionEntryEventHandler

public class PrimaryBackupSpaceReplicationEntryEventHandler
extends AbstractSpaceReplicationEntryEventHandler

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.handlers.AbstractSpaceReplicationEntryEventHandler

_engine, _exceptionHandler

Constructor Summary

Constructors

Constructor and Description
PrimaryBackupSpaceReplicationEntryEventHandler(SpaceEngine engine, boolean isCentralAndExternalDB)

Method Summary

Modifier and Type	Method and Description
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 void	postChangeExecution(IReplicationInContext context, IEntryData previousEntryData, IEntryData modifiedEntryData)
protected void	postRemoveExecution(IReplicationInContext context, AnswerPacket aPacket)
protected void	postUpdateExecution(IReplicationInContext context, IEntryData previousEntryData, IEntryData currentEntryData)
protected void	removeEntryFromSpace(IReplicationInContext context, Transaction txn, ITemplatePacket template, boolean twoPhaseCommit)
protected boolean	shouldChangeEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, boolean isTransient, int version)
protected boolean	shouldEvictEntryFromSpace(boolean isTransient)
protected boolean	shouldRemoveEntryFromSpace(boolean isTransient)
protected boolean	shouldUpdateEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
protected void	updateEntryInSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion, long lease, boolean twoPhaseCommit)
protected ExtendedAnswerHolder	updateOrWrite(IReplicationInContext context, Transaction transaction, IEntryPacket entryPacket, long lease, int updateModifiers)
protected void	writeEntryIntoSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, long lease, boolean twoPhaseCommit)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.handlers.AbstractSpaceReplicationEntryEventHandler

changeEntry, executeUpdateOperation, getConflictingOperationPolicy, ignoreOperation, inEvictEntry, removeEntry, removeEntryByUid, updateEntry, writeEntry

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

Constructor Detail

PrimaryBackupSpaceReplicationEntryEventHandler

public PrimaryBackupSpaceReplicationEntryEventHandler(SpaceEngine engine,
                                                      boolean isCentralAndExternalDB)

Method Detail

writeEntryIntoSpace

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

Overrides:

writeEntryIntoSpace in class AbstractSpaceReplicationEntryEventHandler

Throws:

Exception

updateOrWrite

protected ExtendedAnswerHolder updateOrWrite(IReplicationInContext context,
                                             Transaction transaction,
                                             IEntryPacket entryPacket,
                                             long lease,
                                             int updateModifiers)
                                      throws TransactionException,
                                             UnusableEntryException,
                                             UnknownTypeException,
                                             RemoteException,
                                             InterruptedException

Specified by:

updateOrWrite in class AbstractSpaceReplicationEntryEventHandler

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

InterruptedException

shouldUpdateEntryInSpace

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

Specified by:

shouldUpdateEntryInSpace in class AbstractSpaceReplicationEntryEventHandler

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

Overrides:

updateEntryInSpace in class AbstractSpaceReplicationEntryEventHandler

Throws:

UnusableEntryException

UnknownTypeException

TransactionException

RemoteException

postUpdateExecution

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

Overrides:

postUpdateExecution in class AbstractSpaceReplicationEntryEventHandler

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

Overrides:

changeEntryInSpace in class AbstractSpaceReplicationEntryEventHandler

Throws:

Exception

postChangeExecution

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

Overrides:

postChangeExecution in class AbstractSpaceReplicationEntryEventHandler

shouldChangeEntryInSpace

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

Specified by:

shouldChangeEntryInSpace in class AbstractSpaceReplicationEntryEventHandler

removeEntryFromSpace

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

Overrides:

removeEntryFromSpace in class AbstractSpaceReplicationEntryEventHandler

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

postRemoveExecution

protected void postRemoveExecution(IReplicationInContext context,
                                   AnswerPacket aPacket)

Overrides:

postRemoveExecution in class AbstractSpaceReplicationEntryEventHandler

shouldRemoveEntryFromSpace

protected boolean shouldRemoveEntryFromSpace(boolean isTransient)

Specified by:

shouldRemoveEntryFromSpace in class AbstractSpaceReplicationEntryEventHandler

shouldEvictEntryFromSpace

protected boolean shouldEvictEntryFromSpace(boolean isTransient)

Specified by:

shouldEvictEntryFromSpace in class AbstractSpaceReplicationEntryEventHandler