From 77498c27bcfeb4151b8b8cc42a2e7ee4512c8439 Mon Sep 17 00:00:00 2001
From: Matthew Swift <matthew.swift@forgerock.com>
Date: Wed, 17 Dec 2014 22:59:42 +0000
Subject: [PATCH] OPENDJ-1602 (CR-5566) New pluggable storage based backend
---
opendj3-server-dev/src/server/org/opends/server/backends/jeb/BackendImpl.java | 53 -----------------------------------------------------
1 files changed, 0 insertions(+), 53 deletions(-)
diff --git a/opendj3-server-dev/src/server/org/opends/server/backends/jeb/BackendImpl.java b/opendj3-server-dev/src/server/org/opends/server/backends/jeb/BackendImpl.java
index 556d614..544ae50 100644
--- a/opendj3-server-dev/src/server/org/opends/server/backends/jeb/BackendImpl.java
+++ b/opendj3-server-dev/src/server/org/opends/server/backends/jeb/BackendImpl.java
@@ -27,16 +27,12 @@
package org.opends.server.backends.jeb;
import java.io.File;
-import java.io.FileInputStream;
-import java.io.FilenameFilter;
import java.io.IOException;
import java.util.*;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.logging.Level;
-import java.util.zip.Adler32;
-import java.util.zip.CheckedInputStream;
import org.forgerock.i18n.LocalizableMessage;
import org.forgerock.i18n.slf4j.LocalizedLogger;
@@ -153,50 +149,6 @@
}
}
- /**
- * This method will attempt to checksum the current JE db environment by
- * computing the Adler-32 checksum on the latest JE log file available.
- *
- * @return The checksum of JE db environment or zero if checksum failed.
- */
- private long checksumDbEnv() {
-
- File parentDirectory = getFileForPath(cfg.getDBDirectory());
- File backendDirectory = new File(parentDirectory, cfg.getBackendId());
-
- List<File> jdbFiles = new ArrayList<File>();
- if(backendDirectory.isDirectory())
- {
- jdbFiles =
- Arrays.asList(backendDirectory.listFiles(new FilenameFilter() {
- @Override
- public boolean accept(File dir, String name) {
- return name.endsWith(".jdb");
- }
- }));
- }
-
- if ( !jdbFiles.isEmpty() ) {
- Collections.sort(jdbFiles, Collections.reverseOrder());
- FileInputStream fis = null;
- try {
- fis = new FileInputStream(jdbFiles.get(0).toString());
- CheckedInputStream cis = new CheckedInputStream(fis, new Adler32());
- byte[] tempBuf = new byte[8192];
- while (cis.read(tempBuf) >= 0) {
- }
-
- return cis.getChecksum().getValue();
- } catch (Exception e) {
- logger.traceException(e);
- } finally {
- close(fis);
- }
- }
-
- return 0;
- }
-
/** {@inheritDoc} */
@Override
public void configureBackend(LocalDBBackendCfg cfg) throws ConfigException
@@ -212,9 +164,6 @@
public void initializeBackend()
throws ConfigException, InitializationException
{
- // Checksum this db environment and register its offline state id/checksum.
- DirectoryServer.registerOfflineBackendStateID(getBackendID(), checksumDbEnv());
-
if (mustOpenRootContainer())
{
rootContainer = initializeRootContainer(parseConfigEntry(cfg));
@@ -310,8 +259,6 @@
logger.error(ERR_JEB_DATABASE_EXCEPTION, e.getMessage());
}
- // Checksum this db environment and register its offline state id/checksum.
- DirectoryServer.registerOfflineBackendStateID(getBackendID(), checksumDbEnv());
DirectoryServer.deregisterAlertGenerator(this);
// Make sure the thread counts are zero for next initialization.
--
Gitblit v1.10.0