opends/src/server/org/opends/server/synchronization/AckMessage.java
@@ -113,7 +113,6 @@ /* put the type of the operation */ resultByteArray[0] = MSG_TYPE_ACK; resultByteArray[pos++] = 0; /* put the ChangeNumber */ byte[] changeNumberByte; opends/src/server/org/opends/server/synchronization/AttrInfo.java
@@ -28,7 +28,6 @@ import java.util.ArrayList; import java.util.LinkedHashSet; import java.util.Set; import org.opends.server.types.AttributeValue; @@ -68,6 +67,8 @@ */ public AttrInfo() { this.deleteTime = null; this.lastUpdateTime = null; this.valuesInfo = new ArrayList<ValueInfo>(); } @@ -148,11 +149,9 @@ * Change historical information after a delete of a set of values. * * @param values values that were deleted * @param options options for the values * @param CN time when the delete was done * @param CN time when the delete was done */ void delete(LinkedHashSet<AttributeValue> values, Set<String> options, ChangeNumber CN) void delete(LinkedHashSet<AttributeValue> values, ChangeNumber CN) { for (AttributeValue val : values) { opends/src/server/org/opends/server/synchronization/ChangeNumber.java
@@ -153,7 +153,12 @@ public static int compare(ChangeNumber CN1, ChangeNumber CN2) { if (CN1 == null) return -1; { if (CN2 == null) return 0; else return -1; } else if (CN2 == null) return 1; else if (CN1.timeStamp < CN2.timeStamp) opends/src/server/org/opends/server/synchronization/Historical.java
@@ -257,8 +257,7 @@ if (modAttr.getValues().isEmpty()) attrInfo.delete(changeNumber); else attrInfo.delete(modAttr.getValues(), modAttr.getOptions(), changeNumber); attrInfo.delete(modAttr.getValues(), changeNumber); break; case ADD: opends/src/server/org/opends/server/synchronization/ValueInfo.java
@@ -62,8 +62,15 @@ @Override public boolean equals(Object obj) { ValueInfo objVal = (ValueInfo) obj; return (value.equals(objVal.value)); if (obj instanceof ValueInfo) { ValueInfo objVal = (ValueInfo) obj; return (value.equals(objVal.getValue())); } else { return false; } } /**