com.gigaspaces.internal.cluster.node.impl.packets.data.operations

Class UpdateReplicationPacketData

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractReplicationPacketSingleEntryData

com.gigaspaces.internal.cluster.node.impl.packets.data.operations.SingleReplicationPacketData

com.gigaspaces.internal.cluster.node.impl.packets.data.operations.UpdateReplicationPacketData

All Implemented Interfaces:

IExecutableReplicationPacketData<IReplicationPacketEntryData>, IReplicationPacketData<IReplicationPacketEntryData>, IReplicationPacketEntryData, IReplicationTransactionalPacketEntryData, ISwapExternalizable, Externalizable, Serializable, Cloneable, Iterable<IReplicationPacketEntryData>, Collection<IReplicationPacketEntryData>

Direct Known Subclasses:

PartialUpdateReplicationPacketData

public class UpdateReplicationPacketData
extends SingleReplicationPacketData
implements IReplicationTransactionalPacketEntryData

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractReplicationPacketSingleEntryData

AbstractReplicationPacketSingleEntryData.SingleEntryIterator, AbstractReplicationPacketSingleEntryData.SingleFilterIterable

Field Summary

Fields

Modifier and Type	Field and Description
protected IEntryData	_currentEntryData
protected short	_flags
protected IEntryData	_previousEntryData

Constructor Summary

Constructors

Constructor and Description
UpdateReplicationPacketData()
UpdateReplicationPacketData(IEntryPacket entry, boolean fromGateway, boolean overrideVersion, IEntryData previousEntryData, short flags, long expirationTime, IEntryData currentEntryData)

Method Summary

Modifier and Type	Method and Description
void	batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback)
boolean	beforeDelayedReplication() If the replication of this packet is delayed due to being asynchronous by nature or the target was disconnected when the replication packet was generated, this method is called before the actual replication and the implementor can modify the packet accordingly, mostly relevant for time to live update.
UpdateReplicationPacketData	clone()
protected void	deserializePreviousEntryData(ObjectInput in)
void	execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
boolean	filterIfNotPresentInReplicaState()
long	getExpirationTime()
protected int	getFilterObjectType(IServerTypeDesc serverTypeDesc)
protected ReplicationOperationType	getFilterReplicationOpType()
short	getFlags()
IEntryData	getMainEntryData()
ReplicationSingleOperationType	getOperationType()
IEntryPacket	getPreviousEntryPacket()
IEntryData	getSecondaryEntryData()
boolean	isOverrideVersion()
boolean	isSerializeFullContent()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
protected void	readPreviousEntryData(ObjectInput in)
protected void	restoreCurrentEntryData()
void	serializeFullContent()
protected void	serializePreviousEntryData(ObjectOutput out)
String	toString()
void	writeExternal(ObjectOutput out)
protected void	writePreviousEntryData(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.SingleReplicationPacketData

cloneWithEntryPacket, containsFullEntryData, getEntryPacket, getOperationId, getOrderCode, getTypeDescriptor, getUid, isTransient, toFilterEntry, updateEntryPacketTimeToLiveIfNeeded

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractReplicationPacketSingleEntryData

add, addAll, clear, contains, containsAll, createEmptyMultipleEntryData, deserializeEntryData, getBlobstoreBulkId, getCustomContent, getMainTypeName, getMultipleOperationType, getRecoveryFilteringId, getSingleEntryData, isEmpty, isFromGateway, isMultiParticipantData, isPartOfBlobstoreBulk, isSingleEntryData, iterator, remove, removeAll, requiresRecoveryDuplicationProtection, requiresRecoveryFiltering, retainAll, serializeEntryData, setBlobstoreBulkId, size, supportsReplicationFilter, toArray, toArray, toFilterEntries, updateTimeToLiveIfNeeded

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationTransactionalPacketEntryData

toFilterEntry

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationPacketEntryData

containsFullEntryData, getOperationId, getOrderCode, getUid, isFromGateway, isTransient, requiresRecoveryDuplicationProtection

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

_flags

protected short _flags

_currentEntryData

protected transient IEntryData _currentEntryData

_previousEntryData

protected transient IEntryData _previousEntryData

Constructor Detail

UpdateReplicationPacketData

public UpdateReplicationPacketData()

UpdateReplicationPacketData

public UpdateReplicationPacketData(IEntryPacket entry,
                                   boolean fromGateway,
                                   boolean overrideVersion,
                                   IEntryData previousEntryData,
                                   short flags,
                                   long expirationTime,
                                   IEntryData currentEntryData)

Method Detail

execute

public void execute(IReplicationInContext context,
                    IReplicationInFacade inReplicationHandler,
                    ReplicationPacketDataMediator dataMediator)
             throws Exception

Specified by:

execute in interface IExecutableReplicationPacketData<IReplicationPacketEntryData>

Throws:

Exception

executeTransactional

public void executeTransactional(IReplicationInContext context,
                                 ITransactionalExecutionCallback transactionExecutionCallback,
                                 Transaction transaction,
                                 boolean twoPhaseCommit)
                          throws Exception

Specified by:

executeTransactional in interface IReplicationTransactionalPacketEntryData

Throws:

Exception

batchExecuteTransactional

public void batchExecuteTransactional(IReplicationInBatchContext context,
                                      ITransactionalBatchExecutionCallback executionCallback)
                               throws Exception

Specified by:

batchExecuteTransactional in interface IReplicationTransactionalPacketEntryData

Throws:

Exception

beforeDelayedReplication

public boolean beforeDelayedReplication()

Description copied from interface: IReplicationTransactionalPacketEntryData

If the replication of this packet is delayed due to being asynchronous by nature or the target was disconnected when the replication packet was generated, this method is called before the actual replication and the implementor can modify the packet accordingly, mostly relevant for time to live update. If the method returns false the packet is no longer relevant and it is discarded

Specified by:

beforeDelayedReplication in interface IReplicationPacketData<IReplicationPacketEntryData>

Specified by:

beforeDelayedReplication in interface IReplicationTransactionalPacketEntryData

getFilterObjectType

protected int getFilterObjectType(IServerTypeDesc serverTypeDesc)

Specified by:

getFilterObjectType in class SingleReplicationPacketData

getFilterReplicationOpType

protected ReplicationOperationType getFilterReplicationOpType()

Specified by:

getFilterReplicationOpType in class SingleReplicationPacketData

getOperationType

public ReplicationSingleOperationType getOperationType()

Specified by:

getOperationType in interface IReplicationPacketEntryData

toString

public String toString()

Overrides:

toString in class Object

clone

public UpdateReplicationPacketData clone()

Specified by:

clone in interface IReplicationPacketData<IReplicationPacketEntryData>

Specified by:

clone in interface IReplicationTransactionalPacketEntryData

Overrides:

clone in class SingleReplicationPacketData

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class SingleReplicationPacketData

Throws:

IOException

ClassNotFoundException

deserializePreviousEntryData

protected void deserializePreviousEntryData(ObjectInput in)
                                     throws IOException,
                                            ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class SingleReplicationPacketData

Throws:

IOException

writePreviousEntryData

protected void writePreviousEntryData(ObjectOutput out)
                               throws IOException

Throws:

IOException

readPreviousEntryData

protected void readPreviousEntryData(ObjectInput in)
                              throws IOException,
                                     ClassNotFoundException

Throws:

IOException

ClassNotFoundException

serializePreviousEntryData

protected void serializePreviousEntryData(ObjectOutput out)
                                   throws IOException

Throws:

IOException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Overrides:

readFromSwap in class SingleReplicationPacketData

Throws:

IOException

ClassNotFoundException

restoreCurrentEntryData

protected void restoreCurrentEntryData()

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Overrides:

writeToSwap in class SingleReplicationPacketData

Throws:

IOException

getMainEntryData

public IEntryData getMainEntryData()

Overrides:

getMainEntryData in class SingleReplicationPacketData

getSecondaryEntryData

public IEntryData getSecondaryEntryData()

Overrides:

getSecondaryEntryData in class SingleReplicationPacketData

getPreviousEntryPacket

public IEntryPacket getPreviousEntryPacket()

filterIfNotPresentInReplicaState

public boolean filterIfNotPresentInReplicaState()

Specified by:

filterIfNotPresentInReplicaState in interface IReplicationPacketEntryData

serializeFullContent

public void serializeFullContent()

isSerializeFullContent

public boolean isSerializeFullContent()

isOverrideVersion

public boolean isOverrideVersion()

getFlags

public short getFlags()

getExpirationTime

public long getExpirationTime()