com.gigaspaces.internal.cluster.node.impl.backlog

Class SynchronizingData<T extends IReplicationPacketData<?>>

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.backlog.SynchronizingData<T>

public class SynchronizingData<T extends IReplicationPacketData<?>>
extends Object

Constructor Summary

Constructors

Constructor and Description
SynchronizingData(org.slf4j.Logger logger, boolean isDirectPersistencySync)

Method Summary

Modifier and Type	Method and Description
ReplicationChannelDataFilterResult	filterData(Object dataId, long packetKey, ReplicationMultipleOperationType operationType)
boolean	filterEntryData(String uid, long packetKey, boolean filterIfNotPresentInReplicaState)
boolean	isDone(long key)
void	setKeyWhenCopyStageCompleted(long keyWhenCopyStageCompleted)
boolean	updateUidKey(String uid, long currentKey)

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronizingData

public SynchronizingData(org.slf4j.Logger logger,
                         boolean isDirectPersistencySync)

Method Detail

updateUidKey

public boolean updateUidKey(String uid,
                            long currentKey)

Returns:

true if the data with the same uid already exists, otherwise false

isDone

public boolean isDone(long key)

filterEntryData

public boolean filterEntryData(String uid,
                               long packetKey,
                               boolean filterIfNotPresentInReplicaState)

setKeyWhenCopyStageCompleted

public void setKeyWhenCopyStageCompleted(long keyWhenCopyStageCompleted)

filterData

public ReplicationChannelDataFilterResult filterData(Object dataId,
                                                     long packetKey,
                                                     ReplicationMultipleOperationType operationType)