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

Class AbstractTransactionReplicationPacketData

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractList<E>

java.util.AbstractSequentialList<E>

java.util.LinkedList<IReplicationTransactionalPacketEntryData>

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

All Implemented Interfaces:

ITransactionInContext, IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>, IReplicationPacketData<IReplicationTransactionalPacketEntryData>, ISwapExternalizable, SmartExternalizable, Externalizable, Serializable, Cloneable, Iterable<IReplicationTransactionalPacketEntryData>, Collection<IReplicationTransactionalPacketEntryData>, Deque<IReplicationTransactionalPacketEntryData>, List<IReplicationTransactionalPacketEntryData>, Queue<IReplicationTransactionalPacketEntryData>

Direct Known Subclasses:

AbstractPrepareDependentTransactionReplicationPacketData, TransactionOnePhaseReplicationPacketData, TransactionPrepareReplicationPacketData

public abstract class AbstractTransactionReplicationPacketData
extends LinkedList<IReplicationTransactionalPacketEntryData>
implements IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>, ITransactionInContext

Base class for transaction replication packet data

Since:

9.0

Author:

eitany

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractTransactionReplicationPacketData.FilterIterable

Field Summary

Fields inherited from class java.util.AbstractList

modCount

Constructor Summary

Constructors

Constructor	Description
AbstractTransactionReplicationPacketData()
AbstractTransactionReplicationPacketData(boolean fromGateway)
AbstractTransactionReplicationPacketData(ServerTransaction transaction, boolean fromGateway)

Method Summary

Modifier and Type	Method	Description
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.
IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>	clone()
boolean	equals(Object o)
protected String	getCustomToString()
TransactionParticipantDataImpl	getMetaData()
MVCCGenerationsState	getMvccCommittedGeneration()
OperationID	getOperationID()
Object	getRecoveryFilteringId()
IReplicationPacketEntryData	getSingleEntryData()
ServerTransaction	getTransaction()
int	getWeight()
boolean	hasMvccCommittedGeneration()
boolean	hasPersistentMembers()
boolean	hasTransientMembers()
boolean	isFromGateway()
boolean	isMvccRevertGeneration()
boolean	isSingleEntryData()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
void	setHasPersistentMembersFlag()
void	setHasTransientMembersFlag()
void	setMetaData(TransactionParticipantDataImpl metaData)
void	setMvccCommittedGeneration(MVCCGenerationsState mvccGenerationsState)
void	setMvccCommittedGenerationFlag()
void	setMvccRevertGenerationFlag()
void	setWeight(int weight)
Iterable<IReplicationFilterEntry>	toFilterEntries(SpaceTypeManager spaceTypeManager)
String	toString()
void	unsetHasTransientMembersFlag()
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)
protected void	writeTransaction(ObjectOutput out)

Methods inherited from class java.util.LinkedList

add, add, addAll, addAll, addFirst, addLast, clear, contains, descendingIterator, element, get, getFirst, getLast, indexOf, lastIndexOf, listIterator, offer, offerFirst, offerLast, peek, peekFirst, peekLast, poll, pollFirst, pollLast, pop, push, remove, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, set, size, spliterator, toArray, toArray

Methods inherited from class java.util.AbstractSequentialList

iterator

Methods inherited from class java.util.AbstractList

hashCode, listIterator, removeRange, subList

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

parallelStream, removeIf, stream, toArray

Methods inherited from interface java.util.Deque

iterator

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

createEmptyMultipleEntryData, execute, isPartOfBlobstoreBulk

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

getMultipleOperationType, isMultiParticipantData, requiresRecoveryFiltering, supportsReplicationFilter

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.List

containsAll, hashCode, isEmpty, iterator, listIterator, removeAll, replaceAll, retainAll, sort, subList

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

AbstractTransactionReplicationPacketData

public AbstractTransactionReplicationPacketData()

AbstractTransactionReplicationPacketData

public AbstractTransactionReplicationPacketData(ServerTransaction transaction,
 boolean fromGateway)

AbstractTransactionReplicationPacketData

public AbstractTransactionReplicationPacketData(boolean fromGateway)

Method Details

getOperationID

public OperationID getOperationID()

Specified by:

getOperationID in interface ITransactionInContext

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

writeTransaction

protected void writeTransaction(ObjectOutput out)
                         throws IOException

Throws:

IOException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Throws:

IOException

ClassNotFoundException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Throws:

IOException

clone

public IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData> clone()

Specified by:

clone in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

Overrides:

clone in class LinkedList<IReplicationTransactionalPacketEntryData>

isSingleEntryData

public boolean isSingleEntryData()

Specified by:

isSingleEntryData in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

isFromGateway

public boolean isFromGateway()

Specified by:

isFromGateway in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

Returns:

Gets whether this packet was received from gateway replication

getSingleEntryData

public IReplicationPacketEntryData getSingleEntryData()

Specified by:

getSingleEntryData in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

setMetaData

public void setMetaData(TransactionParticipantDataImpl metaData)

getMetaData

public TransactionParticipantDataImpl getMetaData()

Specified by:

getMetaData in interface ITransactionInContext

getTransaction

public ServerTransaction getTransaction()

Specified by:

getTransaction in interface ITransactionInContext

beforeDelayedReplication

public boolean beforeDelayedReplication()

Description copied from interface: IReplicationPacketData

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<IReplicationTransactionalPacketEntryData>

toFilterEntries

public Iterable<IReplicationFilterEntry> toFilterEntries(SpaceTypeManager spaceTypeManager)

Specified by:

toFilterEntries in interface IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>

toString

public String toString()

Overrides:

toString in class AbstractCollection<IReplicationTransactionalPacketEntryData>

getCustomToString

protected String getCustomToString()

setHasTransientMembersFlag

public void setHasTransientMembersFlag()

unsetHasTransientMembersFlag

public void unsetHasTransientMembersFlag()

setHasPersistentMembersFlag

public void setHasPersistentMembersFlag()

hasTransientMembers

public boolean hasTransientMembers()

hasPersistentMembers

public boolean hasPersistentMembers()

setMvccCommittedGenerationFlag

public void setMvccCommittedGenerationFlag()

hasMvccCommittedGeneration

public boolean hasMvccCommittedGeneration()

setMvccRevertGenerationFlag

public void setMvccRevertGenerationFlag()

isMvccRevertGeneration

public boolean isMvccRevertGeneration()

getRecoveryFilteringId

public Object getRecoveryFilteringId()

Specified by:

getRecoveryFilteringId in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

setWeight

public void setWeight(int weight)

Specified by:

setWeight in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

getWeight

public int getWeight()

Specified by:

getWeight in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

setMvccCommittedGeneration

public void setMvccCommittedGeneration(MVCCGenerationsState mvccGenerationsState)

getMvccCommittedGeneration

public MVCCGenerationsState getMvccCommittedGeneration()

equals

public boolean equals(Object o)

Specified by:

equals in interface Collection<IReplicationTransactionalPacketEntryData>

Specified by:

equals in interface List<IReplicationTransactionalPacketEntryData>

Overrides:

equals in class AbstractList<IReplicationTransactionalPacketEntryData>