From a5c5efbf8ca56c059709953f7fedb647dadaed06 Mon Sep 17 00:00:00 2001
From: ludovicp <ludovicp@localhost>
Date: Thu, 27 May 2010 15:28:09 +0000
Subject: [PATCH] Fix for issues #3395 and #3998. The changes improves the replica initialization protocol, especially flow control and handling connection outage.
---
opends/src/server/org/opends/server/replication/server/ServerReader.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ServerReader.java b/opends/src/server/org/opends/server/replication/server/ServerReader.java
index 8121a0d..0e0d14c 100644
--- a/opends/src/server/org/opends/server/replication/server/ServerReader.java
+++ b/opends/src/server/org/opends/server/replication/server/ServerReader.java
@@ -22,7 +22,7 @@
* CDDL HEADER END
*
*
- * Copyright 2006-2009 Sun Microsystems, Inc.
+ * Copyright 2006-2010 Sun Microsystems, Inc.
*/
package org.opends.server.replication.server;
@@ -100,9 +100,7 @@
ReplicationMsg msg = session.receive();
if (debugEnabled())
- {
TRACER.debugInfo("In " + getName() + " receives " + msg);
- }
if (msg instanceof AckMsg)
{
@@ -187,6 +185,11 @@
InitializeRequestMsg initializeMsg =
(InitializeRequestMsg) msg;
handler.process(initializeMsg);
+ } else if (msg instanceof InitializeRcvAckMsg)
+ {
+ InitializeRcvAckMsg initializeRcvAckMsg =
+ (InitializeRcvAckMsg) msg;
+ handler.process(initializeRcvAckMsg);
} else if (msg instanceof InitializeTargetMsg)
{
InitializeTargetMsg initializeMsg = (InitializeTargetMsg) msg;
--
Gitblit v1.10.0