From 1c59d6c7d4e33c5b88fbe0692c1d50c0eab74c4a Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 20 Feb 2014 14:08:01 +0000
Subject: [PATCH] OPENDJ-1271 (CR-3008) dsreplication pre-external-initialization task fails with STOPPED_BY_ERROR
---
opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerHandler.java | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerHandler.java b/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerHandler.java
index 6f0d924..4928623 100644
--- a/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerHandler.java
+++ b/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerHandler.java
@@ -444,7 +444,7 @@
if (getProtocolVersion() >= ProtocolVersion.REPLICATION_PROTOCOL_V4)
{
// List should only contain RS info for sender
- RSInfo rsInfo = inTopoMsg.getRsList().get(0);
+ RSInfo rsInfo = inTopoMsg.getRsInfos().get(0);
weight = rsInfo.getWeight();
}
@@ -579,7 +579,7 @@
public void processTopoInfoFromRS(TopologyMsg topoMsg)
{
// List should only contain RS info for sender
- final RSInfo rsInfo = topoMsg.getRsList().get(0);
+ final RSInfo rsInfo = topoMsg.getRsInfos().get(0);
generationId = rsInfo.getGenerationId();
groupId = rsInfo.getGroupId();
weight = rsInfo.getWeight();
@@ -589,7 +589,7 @@
clearRemoteLSHandlers();
// Creates the new structure according to the message received.
- for (DSInfo dsInfo : topoMsg.getDsList())
+ for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
{
// For each DS connected to the peer RS
DSInfo clonedDSInfo = dsInfo.cloneWithReplicationServerId(serverId);
--
Gitblit v1.10.0