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/protocol/ReplicationMessage.java | 4 ++++
1 files changed, 4 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/protocol/ReplicationMessage.java b/opends/src/server/org/opends/server/replication/protocol/ReplicationMessage.java
index 3cd873d..15847ed 100644
--- a/opends/src/server/org/opends/server/replication/protocol/ReplicationMessage.java
+++ b/opends/src/server/org/opends/server/replication/protocol/ReplicationMessage.java
@@ -52,6 +52,7 @@
static final byte MSG_TYPE_ENTRY = 12;
static final byte MSG_TYPE_DONE = 13;
static final byte MSG_TYPE_ERROR = 14;
+ static final byte MSG_TYPE_WINDOW_PROBE = 15;
// Adding a new type of message here probably requires to
// change accordingly generateMsg method below
@@ -136,6 +137,9 @@
case MSG_TYPE_ERROR:
msg = new ErrorMessage(buffer);
break;
+ case MSG_TYPE_WINDOW_PROBE:
+ msg = new WindowProbe(buffer);
+ break;
default:
throw new DataFormatException("received message with unknown type");
}
--
Gitblit v1.10.0