From 8fdf1768757fba933e7ce63ac6381eacec41f0c6 Mon Sep 17 00:00:00 2001
From: Yannick Lecaillez <ylecaillez@forgerock.com>
Date: Wed, 09 Dec 2015 17:41:58 +0000
Subject: [PATCH] OPENDJ-2476: Purge of file-based changelog is very slow and the changelog size is growing.
---
opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/LogTest.java | 44 ++++++--------------------------------------
1 files changed, 6 insertions(+), 38 deletions(-)
diff --git a/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/LogTest.java b/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/LogTest.java
index 89de646..4a9d34f 100644
--- a/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/LogTest.java
+++ b/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/LogTest.java
@@ -187,13 +187,13 @@
{ "key010", GREATER_THAN_OR_EQUAL_TO_KEY, ON_MATCHING_KEY, 10, 10 },
{ "key011", GREATER_THAN_OR_EQUAL_TO_KEY, ON_MATCHING_KEY, -1, -1 },
- { "key000", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, 1, 10 },
- { "key001", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, 2, 10 },
- { "key004", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, 5, 10 },
+ { "key000", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, 1, 10 },
+ { "key001", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, 2, 10 },
+ { "key004", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, 5, 10 },
{ "key0050", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, 6, 10 },
- { "key009", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, 10, 10 },
- { "key010", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, -1, -1 },
- { "key011", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, -1, -1 },
+ { "key009", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, 10, 10 },
+ { "key010", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, -1, -1 },
+ { "key011", GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY, -1, -1 },
};
}
@@ -277,38 +277,6 @@
}
}
- @Test
- public void testTwoConcurrentWrite() throws Exception
- {
- try (Log<String, String> writeLog1 = openLog(LogFileTest.RECORD_PARSER);
- Log<String, String> writeLog2 = openLog(LogFileTest.RECORD_PARSER))
- {
- writeLog1.append(Record.from("key020", "starting record"));
- AtomicReference<ChangelogException> exceptionRef = new AtomicReference<>();
- Thread write1 = getWriteLogThread(writeLog1, "a", exceptionRef);
- Thread write2 = getWriteLogThread(writeLog2, "b", exceptionRef);
- write1.run();
- write2.run();
-
- write1.join();
- write2.join();
- if (exceptionRef.get() != null)
- {
- throw exceptionRef.get();
- }
- writeLog1.syncToFileSystem();
-
- try (DBCursor<Record<String, String>> cursor = writeLog1.getCursor("key020"))
- {
- for (int i = 1; i <= 61; i++)
- {
- assertThat(cursor.next()).isTrue();
- }
- assertThat(cursor.getRecord()).isIn(Record.from("nkb030", "vb30"), Record.from("nka030", "va30"));
- }
- }
- }
-
/**
* This test should be disabled.
* Enable it locally when you need to have an rough idea of write performance.
--
Gitblit v1.10.0