2 files changed, 71 insertions, 0 deletions
diff --git a/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepository.java b/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepository.java
index eb10042..0793f97 100644
--- a/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepository.java
+++ b/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepository.java
@@ -19,6 +19,7 @@
 package com.amazon.carbonado.repo.sleepycat;
 
 import java.io.File;
+import java.io.PrintStream;
 import java.lang.ref.WeakReference;
 import java.util.ArrayList;
 import java.util.Map;
@@ -640,6 +641,8 @@ abstract class BDBRepository<Txn> extends AbstractRepository<Txn>
         setAutoShutdownEnabled(true);
     }
 
+    abstract boolean verify(PrintStream out) throws Exception;
+
     abstract IsolationLevel selectIsolationLevel(Transaction parent, IsolationLevel level);
 
     abstract Txn txn_begin(Txn parent, IsolationLevel level) throws Exception;
diff --git a/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepositoryBuilder.java b/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepositoryBuilder.java
index 2a7a931..4df17f5 100644
--- a/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepositoryBuilder.java
+++ b/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepositoryBuilder.java
@@ -22,6 +22,7 @@ import java.lang.reflect.Constructor;
 
 import java.io.File;
 import java.io.IOException;
+import java.io.PrintStream;
 
 import java.util.Collection;
 import java.util.HashMap;
@@ -173,6 +174,73 @@ public final class BDBRepositoryBuilder extends AbstractRepositoryBuilder {
         return repo;
     }
 
+    /**
+     * Opens the BDB environment, checks if it is corrupt, and then closes it.
+     * Only one process should open the environment for verification. Expect it
+     * to take a long time.
+     *
+     * @param out optional stream to capture any verfication errors
+     * @return true if environment passes verification
+     */
+    public boolean verify(PrintStream out) throws RepositoryException {
+        final StorableCodecFactory codecFactory = mStorableCodecFactory;
+        final String name = mName;
+        final boolean readOnly = mReadOnly;
+        final boolean runCheckpointer = mRunCheckpointer;
+        final boolean runDeadlockDetector = mRunDeadlockDetector;
+        final boolean isPrivate = mPrivate;
+
+        if (mName == null) {
+            // Allow a dummy name for verification.
+            mName = "BDB verification";
+        }
+
+        if (mStorableCodecFactory == null) {
+            mStorableCodecFactory = new CompressedStorableCodecFactory(mCompressionMap);
+        }
+
+        mReadOnly = true;
+        mRunCheckpointer = false;
+        mRunDeadlockDetector = false;
+
+        try {
+            assertReady();
+
+            File homeFile = getEnvironmentHomeFile();
+            if (!homeFile.exists()) {
+                throw new RepositoryException
+                    ("Environment home directory does not exist: " + homeFile);
+            }
+
+            AtomicReference<Repository> rootRef = new AtomicReference<Repository>();
+            BDBRepository repo;
+
+            try {
+                repo = getRepositoryConstructor().newInstance(rootRef, this);
+            } catch (Exception e) {
+                ThrowUnchecked.fireFirstDeclaredCause(e, RepositoryException.class);
+                // Not reached.
+                return false;
+            }
+
+            rootRef.set(repo);
+
+            try {
+                return repo.verify(out);
+            } catch (Exception e) {
+                throw repo.toRepositoryException(e);
+            } finally {
+                repo.close();
+            }
+        } finally {
+            mName = name;
+            mStorableCodecFactory = codecFactory;
+            mReadOnly = readOnly;
+            mRunCheckpointer = runCheckpointer;
+            mRunDeadlockDetector = runDeadlockDetector;
+        }
+    }
+
     public String getName() {
         return mName;
     }