From acdb57af871cbfef3a768b2dd765246063129d5d Mon Sep 17 00:00:00 2001
From: Robert Godfrey <rgodfrey@apache.org>
Date: Sat, 8 Nov 2014 12:56:12 +0000
Subject: QPID-6221 : [Java Broker] Detect low disk space conditions and
 enforce flow control

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1637558 13f79535-47bb-0310-9956-ffa450edef68
---
 .../qpid/server/store/berkeleydb/BDBConfigurationStore.java  |  7 ++++++-
 .../apache/qpid/server/store/berkeleydb/BDBMessageStore.java |  6 ++++++
 .../virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java      | 12 ------------
 3 files changed, 12 insertions(+), 13 deletions(-)

(limited to 'qpid/java/bdbstore/src')

diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java
index 5550381c9c..409679c2de 100644
--- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java
+++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java
@@ -35,7 +35,6 @@ import java.util.concurrent.atomic.AtomicBoolean;
 import com.sleepycat.je.Cursor;
 import com.sleepycat.je.Database;
 import com.sleepycat.je.DatabaseEntry;
-import com.sleepycat.je.DatabaseException;
 import com.sleepycat.je.LockMode;
 import com.sleepycat.je.OperationStatus;
 import com.sleepycat.je.Transaction;
@@ -569,6 +568,12 @@ public class BDBConfigurationStore implements MessageStoreProvider, DurableConfi
             return ((FileBasedSettings)_parent).getStorePath();
         }
 
+        @Override
+        public File getStoreLocationAsFile()
+        {
+            return new File(getStoreLocation());
+        }
+
         @Override
         protected long getPersistentSizeLowThreshold()
         {
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
index 66e98ac314..2f00d9852c 100644
--- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
+++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
@@ -165,4 +165,10 @@ public class BDBMessageStore extends AbstractBDBMessageStore
     {
         return ((FileBasedSettings)_parent).getStorePath();
     }
+
+    @Override
+    public File getStoreLocationAsFile()
+    {
+        return new File(getStoreLocation());
+    }
 }
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java
index 97b166a9d0..e7c247f1a5 100644
--- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java
+++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java
@@ -412,18 +412,6 @@ public class BDBHAReplicaVirtualHost extends AbstractConfiguredObject<BDBHARepli
         return null;
     }
 
-    @Override
-    public void block()
-    {
-        throwUnsupportedForReplica();
-    }
-
-    @Override
-    public void unblock()
-    {
-        throwUnsupportedForReplica();
-    }
-
     @Override
     public boolean getDefaultDeadLetterQueueEnabled()
     {
-- 
cgit v1.2.1