From 5b48543bbfa188f541999471975ea82f7b30ed8e Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 03 Dec 2014 10:58:51 +0000
Subject: [PATCH] OPENDJ-1602 New pluggable storage based backend

---
 opendj3-server-dev/src/server/org/opends/server/backends/jeb/Index.java |   31 +++----------------------------
 1 files changed, 3 insertions(+), 28 deletions(-)

diff --git a/opendj3-server-dev/src/server/org/opends/server/backends/jeb/Index.java b/opendj3-server-dev/src/server/org/opends/server/backends/jeb/Index.java
index 9fd944d..f1e85ba 100644
--- a/opendj3-server-dev/src/server/org/opends/server/backends/jeb/Index.java
+++ b/opendj3-server-dev/src/server/org/opends/server/backends/jeb/Index.java
@@ -195,19 +195,7 @@
    */
   public boolean insertID(IndexBuffer buffer, ByteString keyBytes, EntryID entryID)
   {
-    final BufferedIndexValues values = getBufferedIndexValues(buffer, keyBytes);
-
-    if(values.deletedIDs != null && values.deletedIDs.contains(entryID))
-    {
-      values.deletedIDs.remove(entryID);
-      return true;
-    }
-
-    if(values.addedIDs == null)
-    {
-      values.addedIDs = new EntryIDSet(keyBytes, null);
-    }
-    values.addedIDs.add(entryID);
+    getBufferedIndexValues(buffer, keyBytes).addEntryID(keyBytes, entryID);
     return true;
   }
 
@@ -662,22 +650,9 @@
    *         count is exceeded. False if it already exists in the entry ID set
    *         for the given key.
    */
-  public boolean removeID(IndexBuffer buffer, ByteString keyBytes,
-                          EntryID entryID)
+  public boolean removeID(IndexBuffer buffer, ByteString keyBytes, EntryID entryID)
   {
-    BufferedIndexValues values = getBufferedIndexValues(buffer, keyBytes);
-
-    if(values.addedIDs != null && values.addedIDs.contains(entryID))
-    {
-      values.addedIDs.remove(entryID);
-      return true;
-    }
-
-    if(values.deletedIDs == null)
-    {
-      values.deletedIDs = new EntryIDSet(keyBytes, null);
-    }
-    values.deletedIDs.add(entryID);
+    getBufferedIndexValues(buffer, keyBytes).deleteEntryID(keyBytes, entryID);
     return true;
   }
 

--
Gitblit v1.10.0