From 2246119784cdfb6f882eba79ed96d2dd9f56f8f9 Mon Sep 17 00:00:00 2001
From: mrossign <mrossign@localhost>
Date: Thu, 30 Oct 2008 16:30:36 +0000
Subject: [PATCH] Fix for #3543: Replication protocol incompatibility between v1 and v2: cannot upgrade a running replicated topology from v1 to v2
---
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ProtocolWindowTest.java | 53 -----------------------------------------------------
1 files changed, 0 insertions(+), 53 deletions(-)
diff --git a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ProtocolWindowTest.java b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ProtocolWindowTest.java
index c8014f4..8382644 100644
--- a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ProtocolWindowTest.java
+++ b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ProtocolWindowTest.java
@@ -33,7 +33,6 @@
import java.net.ServerSocket;
import java.net.SocketTimeoutException;
-import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
@@ -50,10 +49,8 @@
import org.opends.server.protocols.internal.InternalClientConnection;
import org.opends.server.protocols.internal.InternalSearchOperation;
import org.opends.server.protocols.ldap.LDAPFilter;
-import org.opends.server.replication.common.ServerState;
import org.opends.server.replication.plugin.ReplicationBroker;
import org.opends.server.replication.protocol.AddMsg;
-import org.opends.server.replication.protocol.ProtocolVersion;
import org.opends.server.replication.protocol.ReplicationMsg;
import org.opends.server.replication.server.ReplServerFakeConfiguration;
import org.opends.server.replication.server.ReplicationServer;
@@ -353,56 +350,6 @@
}
}
- @Test(enabled=true)
- public void protocolVersion() throws Exception
- {
- logError(Message.raw(
- Category.SYNC, Severity.INFORMATION,
- "Starting Replication ProtocolWindowTest : protocolVersion"));
-
- ReplicationBroker broker = null;
-
- try
- {
- // Test : Make a broker degrade its version when connecting to an old
- // replication server.
- ProtocolVersion.resetCurrentVersion();
-
- broker = new ReplicationBroker(null,
- new ServerState(),
- baseDn,
- (short) 13, 0, 0, 0, 0, 1000, 0,
- ReplicationTestCase.getGenerationId(baseDn),
- getReplSessionSecurity(), (byte)1);
-
-
- // Check broker hard-coded version
- short pversion = broker.getProtocolVersion();
- assertEquals(pversion, ProtocolVersion.getCurrentVersion());
-
- // Connect the broker to the replication server
- ProtocolVersion.setCurrentVersion(ProtocolVersion.REPLICATION_PROTOCOL_V1);
- ArrayList<String> servers = new ArrayList<String>(1);
- servers.add("localhost:" + replServerPort);
- broker.start(servers);
- TestCaseUtils.sleep(3000); // wait for connection established
-
- // Check broker negociated version
- pversion = broker.getProtocolVersion();
- assertEquals(pversion, ProtocolVersion.REPLICATION_PROTOCOL_V1);
-
- logError(Message.raw(
- Category.SYNC, Severity.INFORMATION,
- "Ending Replication ProtocolWindowTest : protocolVersion"));
- } finally
- {
- if (broker != null)
- broker.stop();
-
- ProtocolVersion.resetCurrentVersion();
- }
- }
-
/**
* Clean up the environment.
*
--
Gitblit v1.10.0