From 2ed3ee723fab71228c360e58b22b26e870778341 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Mon, 04 May 2015 12:59:29 +0000
Subject: [PATCH] Fix continuous integration build failure:
---
opendj-server-legacy/src/main/java/org/opends/server/backends/persistit/PersistItStorage.java | 15 +--------------
1 files changed, 1 insertions(+), 14 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/backends/persistit/PersistItStorage.java b/opendj-server-legacy/src/main/java/org/opends/server/backends/persistit/PersistItStorage.java
index c1e9d80..1b0c08f 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/backends/persistit/PersistItStorage.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/backends/persistit/PersistItStorage.java
@@ -46,8 +46,6 @@
import java.util.ListIterator;
import java.util.Map;
import java.util.NoSuchElementException;
-import java.util.Queue;
-import java.util.concurrent.ConcurrentLinkedDeque;
import org.forgerock.i18n.LocalizableMessage;
import org.forgerock.i18n.slf4j.LocalizedLogger;
@@ -249,29 +247,18 @@
private final class ImporterImpl implements Importer
{
private final Map<TreeName, Tree> trees = new HashMap<TreeName, Tree>();
- private final Queue<Map<TreeName, Exchange>> allExchanges = new ConcurrentLinkedDeque<>();
private final ThreadLocal<Map<TreeName, Exchange>> exchanges = new ThreadLocal<Map<TreeName, Exchange>>()
{
@Override
protected Map<TreeName, Exchange> initialValue()
{
- final Map<TreeName, Exchange> value = new HashMap<>();
- allExchanges.add(value);
- return value;
+ return new HashMap<TreeName, Exchange>();
}
};
@Override
public void close()
{
- for (Map<TreeName, Exchange> map : allExchanges)
- {
- for (Exchange exchange : map.values())
- {
- db.releaseExchange(exchange);
- }
- map.clear();
- }
PersistItStorage.this.close();
}
--
Gitblit v1.10.0