From 0107a1af4a4325c502fe2632c7d0f4dcf3da98ba Mon Sep 17 00:00:00 2001
From: mrossign <mrossign@localhost>
Date: Tue, 16 Dec 2008 17:03:47 +0000
Subject: [PATCH] Assured Replication: - all unit tests for safe data mode - assured replication code corrections (thanks to safe data unit tests) => Still every unit tests for safe read mode to do...
---
opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java b/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
index 1301a82..fa95572 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
@@ -831,7 +831,7 @@
broker.getRsServerId());
break;
default:
- // Should no happen
+ // Should not happen
}
throw new TimeoutException("No ack received for message cn: " + cn +
@@ -914,8 +914,8 @@
{
// Some problems detected: message not correclty reached every requested
// servers. Log problem
- Message errorMsg = ERR_DS_RECEIVED_ACK_ERROR.get(serviceID,
- update.toString(), ack.errorsToString());
+ Message errorMsg = NOTE_DS_RECEIVED_ACK_ERROR.get(serviceID,
+ Short.toString(serverID), update.toString(), ack.errorsToString());
logError(errorMsg);
List<Short> failedServers = ack.getFailedServers();
@@ -954,7 +954,7 @@
}
break;
default:
- // Should no happen
+ // Should not happen
}
} else
{
@@ -969,7 +969,7 @@
assuredSdAcknowledgedUpdates.incrementAndGet();
break;
default:
- // Should no happen
+ // Should not happen
}
}
}
@@ -2393,7 +2393,7 @@
assuredSdSentUpdates.incrementAndGet();
break;
default:
- // Should no happen
+ // Should not happen
}
// Now wait for ack matching the sent assured update
--
Gitblit v1.10.0