From bb3ff35a43da138d3c8299dcac1e42350c69a61d Mon Sep 17 00:00:00 2001
From: Fabio Pistolesi <fabio.pistolesi@forgerock.com>
Date: Wed, 06 Jan 2016 15:03:42 +0000
Subject: [PATCH] OPENDJ-2580 File-based changelog growing and filling up the disk when using modrate
---
opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/FileChangeNumberIndexDBTest.java | 12 ++++--------
1 files changed, 4 insertions(+), 8 deletions(-)
diff --git a/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/FileChangeNumberIndexDBTest.java b/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/FileChangeNumberIndexDBTest.java
index 73bfced..94aa58d 100644
--- a/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/FileChangeNumberIndexDBTest.java
+++ b/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/FileChangeNumberIndexDBTest.java
@@ -32,6 +32,7 @@
import org.forgerock.opendj.config.server.ConfigException;
import org.forgerock.opendj.ldap.ByteString;
import org.opends.server.TestCaseUtils;
+import org.opends.server.admin.std.server.ReplicationServerCfg;
import org.opends.server.replication.ReplicationTestCase;
import org.opends.server.replication.common.CSN;
import org.opends.server.replication.server.ReplServerFakeConfiguration;
@@ -235,9 +236,9 @@
assertEquals(oldest.getCSN(), newest.getCSN());
}
- private class FakeRS extends ReplicationServer
+ private static class FakeRS extends ReplicationServer
{
- FakeRS(ReplServerFakeConfiguration cfg) throws ConfigException
+ FakeRS(ReplicationServerCfg cfg) throws ConfigException
{
super(cfg);
}
@@ -255,12 +256,7 @@
final int port = TestCaseUtils.findFreePort();
final ReplServerFakeConfiguration cfg = new ReplServerFakeConfiguration(port, null, 0, 2, 0, 100, null);
cfg.setComputeChangeNumber(true);
- if (mock)
- {
- FakeRS mockRS = new FakeRS(cfg);
- return mockRS;
- }
- return new ReplicationServer(cfg);
+ return mock ? new FakeRS(cfg) : new ReplicationServer(cfg);
}
private void assertCursorReadsInOrder(DBCursor<ChangeNumberIndexRecord> cursor, long... cns)
--
Gitblit v1.10.0