Package 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	Description
SynchronizingData(org.slf4j.Logger logger, boolean isDirectPersistencySync, String memberName)

Method Summary

Modifier and Type	Method	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 Details

SynchronizingData

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

Method Details

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)