From 23b1e20ff9fe938572a0b62ec5a12f12154445df Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Wed, 04 Jul 2007 15:12:04 +0000
Subject: [PATCH] The problem was that the publisher thread is stuck waiting for the window to re-open on a connection that has been closed without notifying the publisher.
---
opends/src/server/org/opends/server/replication/server/ServerReader.java | 8 +++++++-
1 files changed, 7 insertions(+), 1 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 41fb483..16373fc 100644
--- a/opends/src/server/org/opends/server/replication/server/ServerReader.java
+++ b/opends/src/server/org/opends/server/replication/server/ServerReader.java
@@ -45,6 +45,7 @@
import org.opends.server.replication.protocol.ReplicationMessage;
import org.opends.server.replication.protocol.UpdateMessage;
import org.opends.server.replication.protocol.WindowMessage;
+import org.opends.server.replication.protocol.WindowProbe;
import org.opends.server.types.ErrorLogCategory;
import org.opends.server.types.ErrorLogSeverity;
import org.opends.server.loggers.debug.DebugTracer;
@@ -159,6 +160,11 @@
ErrorMessage errorMsg = (ErrorMessage) msg;
handler.process(errorMsg);
}
+ else if (msg instanceof WindowProbe)
+ {
+ WindowProbe windowProbeMsg = (WindowProbe) msg;
+ handler.process(windowProbeMsg);
+ }
else if (msg == null)
{
/*
@@ -184,7 +190,7 @@
String message = getMessage(msgID, handler.toString());
logError(ErrorLogCategory.SYNCHRONIZATION,
ErrorLogSeverity.NOTICE,
- message + e.getMessage(), msgID);
+ message + ": " + e.getMessage(), msgID);
} catch (ClassNotFoundException e)
{
/*
--
Gitblit v1.10.0