From 0de6858e9548e84aebc148747be92a811ba33636 Mon Sep 17 00:00:00 2001
From: vharseko <vharseko@3a-systems.ru>
Date: Wed, 12 Jul 2023 16:41:15 +0000
Subject: [PATCH] Restore IT test for server-legacy and fix many errors (#279)
---
opendj-server-legacy/src/test/java/org/opends/server/replication/server/ReplicationServerTest.java | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ReplicationServerTest.java b/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ReplicationServerTest.java
index 51000ba..fde94fb 100644
--- a/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ReplicationServerTest.java
+++ b/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ReplicationServerTest.java
@@ -486,7 +486,7 @@
try
{
/* Open a sender session */
- server = openReplicationSession(TEST_ROOT_DN, 5, 100, replicationServerPort, 100000);
+ server = openReplicationSession(TEST_ROOT_DN, 5, 100, replicationServerPort, 300000);
reader = new BrokerReader(server, TOTAL_MSG);
/* Start the client threads. */
@@ -850,6 +850,7 @@
InetSocketAddress serverAddr =
new HostPort("localhost", replicationServerPort).toInetSocketAddress();
Socket socket = new Socket();
+ socket.setReuseAddress(true);
socket.setReceiveBufferSize(1000000);
socket.setTcpNoDelay(true);
int timeoutMS = MultimasterReplication.getConnectionTimeoutMS();
@@ -1097,9 +1098,9 @@
{
// Create and connect client1 to changelog1
// and client2 to changelog2
- broker1 = openReplicationSession(TEST_ROOT_DN, brokerIds[0], 100, changelogPorts[0], 1000);
broker2 = openReplicationSession(TEST_ROOT_DN, brokerIds[1], 100, changelogPorts[1], 1000);
-
+ broker1 = openReplicationSession(TEST_ROOT_DN, brokerIds[0], 100, changelogPorts[0], 1000);
+
// - Test messages between clients by publishing now
CSNGenerator csnGen = new CSNGenerator(brokerIds[0], TimeThread.getTime());
--
Gitblit v1.10.0