From e95d2b4182b468a4e7d206fb11104098beef3b46 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Fri, 03 Jan 2014 11:25:19 +0000
Subject: [PATCH] OPENDJ-1205 Remove network layer from External ChangeLog implementation
---
opends/src/server/org/opends/server/replication/server/ECLServerWriter.java | 6 ++----
1 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ECLServerWriter.java b/opends/src/server/org/opends/server/replication/server/ECLServerWriter.java
index eca578e..97974ca 100644
--- a/opends/src/server/org/opends/server/replication/server/ECLServerWriter.java
+++ b/opends/src/server/org/opends/server/replication/server/ECLServerWriter.java
@@ -35,7 +35,6 @@
import org.opends.server.replication.protocol.DoneMsg;
import org.opends.server.replication.protocol.ECLUpdateMsg;
import org.opends.server.replication.protocol.Session;
-import org.opends.server.replication.protocol.StartECLSessionMsg;
import org.opends.server.types.DebugLogLevel;
import org.opends.server.types.DirectoryException;
import org.opends.server.types.Entry;
@@ -209,8 +208,7 @@
if (update == null)
{
- if (session != null
- && handler.getSearchPhase() != ECLServerHandler.INIT_PHASE)
+ if (session != null && handler.isInitPhaseDone())
{
// session is null in pusherOnly mode
// Done is used to end phase 1
@@ -218,7 +216,7 @@
handler.getReplicationServerId(), handler.getServerId()));
}
- if (handler.isPersistent() == StartECLSessionMsg.NON_PERSISTENT)
+ if (handler.isNonPersistent())
{ // publishing is normally stopped here...
break;
}
--
Gitblit v1.10.0