From 108675f4a8f5c17479561333068b9591971dc810 Mon Sep 17 00:00:00 2001
From: Jean-Noël Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 16 Nov 2016 15:13:16 +0000
Subject: [PATCH] various code cleanups
---
opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/LogTest.java | 29 +----------------------------
1 files changed, 1 insertions(+), 28 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 c8d7fd8..5c084ca 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
@@ -11,7 +11,7 @@
* Header, with the fields enclosed by brackets [] replaced by your own identifying
* information: "Portions Copyright [year] [name of copyright owner]".
*
- * Copyright 2014-2015 ForgeRock AS.
+ * Copyright 2014-2016 ForgeRock AS.
*/
package org.opends.server.replication.server.changelog.file;
@@ -22,7 +22,6 @@
import static org.opends.server.replication.server.changelog.file.LogFileTest.*;
import java.io.File;
-import java.util.concurrent.atomic.AtomicReference;
import org.opends.server.DirectoryServerTestCase;
import org.opends.server.TestCaseUtils;
@@ -534,30 +533,4 @@
assertThat(cursor.next()).isFalse();
assertThat(cursor.getRecord()).isNull();
}
-
- /** Returns a thread that write N records to the provided log. */
- private Thread getWriteLogThread(final Log<String, String> writeLog, final String recordPrefix,
- final AtomicReference<ChangelogException> exceptionRef)
- {
- return new Thread() {
- @Override
- public void run()
- {
- for (int i = 1; i <= 30; i++)
- {
- Record<String, String> record = Record.from(
- String.format("nk%s%03d", recordPrefix, i), "v" + recordPrefix + i);
- try
- {
- writeLog.append(record);
- }
- catch (ChangelogException e)
- {
- // keep the first exception only
- exceptionRef.compareAndSet(null, e);
- }
- }
- }
- };
- }
}
--
Gitblit v1.10.0