Package com.gigaspaces.internal.cluster.node.impl.replica

Class SpaceCopyIntermediateResult

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.replica.SpaceCopyIntermediateResult

All Implemented Interfaces:

ISpaceCopyIntermediateResult, ISpaceCopyResult

public class SpaceCopyIntermediateResult
extends Object
implements ISpaceCopyIntermediateResult, ISpaceCopyResult

Constructor Summary

Constructors

Constructor	Description
SpaceCopyIntermediateResult()
SpaceCopyIntermediateResult(Map<String,Integer> writtenTypesCount, Map<String,Integer> notifyTemplateTypesCount, Map<String,String> duplicateEntries, int totalCopiedObjects, int blockedByFilterEntries, Exception failureReason, ConcurrentHashSet<EventRegistration> notifyRegistrations)

Method Summary

Modifier and Type	Method	Description
void	addDuplicateEntry(String uid, String className)
void	addRegisteredNotifyTemplate(String templateClassName, GSEventRegistration notifyRegistration)
Exception	getFailureReason()
Set<EventRegistration>	getNotifyRegistrations()
String	getStringDescription(String remoteSpaceMember, String remoteMemberUrl, String spaceName, boolean spaceSyncOperation, long duration)
void	increaseNotifyTemplateTypeCount(String className)
void	increaseWritenTypeCount(String className)
void	incrementBlockedByFilterEntry()
boolean	isEmpty()
boolean	isFailed()
boolean	isSuccessful()
ISpaceCopyIntermediateResult	merge(ISpaceCopyIntermediateResult mergeWith)
ISpaceCopyIntermediateResult	mergeFailure(Exception failureReason)
ISpaceCopyResult	toFinalResult()
SpaceCopyStatus	toOldResult(short operationType, String targetMember)

Methods inherited from class java.lang.Object

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

Constructor Details

SpaceCopyIntermediateResult

public SpaceCopyIntermediateResult()

SpaceCopyIntermediateResult

public SpaceCopyIntermediateResult(Map<String,Integer> writtenTypesCount,
 Map<String,Integer> notifyTemplateTypesCount,
 Map<String,String> duplicateEntries,
 int totalCopiedObjects,
 int blockedByFilterEntries,
 Exception failureReason,
 ConcurrentHashSet<EventRegistration> notifyRegistrations)

Method Details

merge

public ISpaceCopyIntermediateResult merge(ISpaceCopyIntermediateResult mergeWith)

Specified by:

merge in interface ISpaceCopyIntermediateResult

mergeFailure

public ISpaceCopyIntermediateResult mergeFailure(Exception failureReason)

Specified by:

mergeFailure in interface ISpaceCopyIntermediateResult

toFinalResult

public ISpaceCopyResult toFinalResult()

Specified by:

toFinalResult in interface ISpaceCopyIntermediateResult

increaseWritenTypeCount

public void increaseWritenTypeCount(String className)

addDuplicateEntry

public void addDuplicateEntry(String uid,
 String className)

incrementBlockedByFilterEntry

public void incrementBlockedByFilterEntry()

Specified by:

incrementBlockedByFilterEntry in interface ISpaceCopyIntermediateResult

increaseNotifyTemplateTypeCount

public void increaseNotifyTemplateTypeCount(String className)

getFailureReason

public Exception getFailureReason()

Specified by:

getFailureReason in interface ISpaceCopyResult

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface ISpaceCopyResult

isFailed

public boolean isFailed()

Specified by:

isFailed in interface ISpaceCopyResult

isSuccessful

public boolean isSuccessful()

Specified by:

isSuccessful in interface ISpaceCopyResult

getStringDescription

public String getStringDescription(String remoteSpaceMember,
 String remoteMemberUrl,
 String spaceName,
 boolean spaceSyncOperation,
 long duration)

Specified by:

getStringDescription in interface ISpaceCopyResult

addRegisteredNotifyTemplate

public void addRegisteredNotifyTemplate(String templateClassName,
 GSEventRegistration notifyRegistration)

getNotifyRegistrations

public Set<EventRegistration> getNotifyRegistrations()

toOldResult

public SpaceCopyStatus toOldResult(short operationType,
 String targetMember)

Specified by:

toOldResult in interface ISpaceCopyResult