From 121886bc0c92389610408e3b415abb992ad8a212 Mon Sep 17 00:00:00 2001
From: "Brian S. O'Neill" <bronee@gmail.com>
Date: Wed, 4 May 2011 00:20:02 +0000
Subject: Add support for Query controller and timeouts; remove vestigial
 support for interrupts.

---
 .../carbonado/repo/logging/LoggingQuery.java       | 94 ++++++++++++++++++++++
 1 file changed, 94 insertions(+)

(limited to 'src/main/java/com/amazon/carbonado/repo/logging')

diff --git a/src/main/java/com/amazon/carbonado/repo/logging/LoggingQuery.java b/src/main/java/com/amazon/carbonado/repo/logging/LoggingQuery.java
index 08be6e3..5dc4d3b 100644
--- a/src/main/java/com/amazon/carbonado/repo/logging/LoggingQuery.java
+++ b/src/main/java/com/amazon/carbonado/repo/logging/LoggingQuery.java
@@ -164,6 +164,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.fetch();
     }
 
+    @Override
+    public Cursor<S> fetch(Controller controller) throws FetchException {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.fetch(controller) on " + this + ", controller: " + controller);
+        }
+        return mQuery.fetch(controller);
+    }
+
     @Override
     public Cursor<S> fetchSlice(long from, Long to) throws FetchException {
         Log log = mStorage.mLog;
@@ -174,6 +183,16 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.fetchSlice(from, to);
     }
 
+    @Override
+    public Cursor<S> fetchSlice(long from, Long to, Controller controller) throws FetchException {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.fetchSlice(start, to, controller) on " + this +
+                      ", from: " + from + ", to: " + to + ", controller: " + controller);
+        }
+        return mQuery.fetchSlice(from, to, controller);
+    }
+
     @Override
     public <T extends S> Cursor<S> fetchAfter(T start) throws FetchException {
         Log log = mStorage.mLog;
@@ -183,6 +202,18 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.fetchAfter(start);
     }
 
+    @Override
+    public <T extends S> Cursor<S> fetchAfter(T start, Controller controller)
+        throws FetchException
+    {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.fetchAfter(start, controller) on " + this + ", start: " + start
+                      + ", controller: " + controller);
+        }
+        return mQuery.fetchAfter(start, controller);
+    }
+
     @Override
     public S loadOne() throws FetchException {
         Log log = mStorage.mLog;
@@ -192,6 +223,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.loadOne();
     }
 
+    @Override
+    public S loadOne(Controller controller) throws FetchException {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.loadOne() on " + this + ", controller: " + controller);
+        }
+        return mQuery.loadOne(controller);
+    }
+
     @Override
     public S tryLoadOne() throws FetchException {
         Log log = mStorage.mLog;
@@ -201,6 +241,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.tryLoadOne();
     }
 
+    @Override
+    public S tryLoadOne(Controller controller) throws FetchException {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.tryLoadOne(controller) on " + this + ", controller: " + controller);
+        }
+        return mQuery.tryLoadOne(controller);
+    }
+
     @Override
     public void deleteOne() throws PersistException {
         Log log = mStorage.mLog;
@@ -210,6 +259,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         mQuery.deleteOne();
     }
 
+    @Override
+    public void deleteOne(Controller controller) throws PersistException {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.deleteOne(controller) on " + this + ", controller: " + controller);
+        }
+        mQuery.deleteOne(controller);
+    }
+
     @Override
     public boolean tryDeleteOne() throws PersistException {
         Log log = mStorage.mLog;
@@ -219,6 +277,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.tryDeleteOne();
     }
 
+    @Override
+    public boolean tryDeleteOne(Controller controller) throws PersistException {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.tryDeleteOne(controller) on " + this + ", controller: " + controller);
+        }
+        return mQuery.tryDeleteOne(controller);
+    }
+
     @Override
     public void deleteAll() throws PersistException {
         Log log = mStorage.mLog;
@@ -228,6 +295,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         mQuery.deleteAll();
     }
 
+    @Override
+    public void deleteAll(Controller controller) throws PersistException {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.deleteAll(controller) on " + this + ", controller: " + controller);
+        }
+        mQuery.deleteAll(controller);
+    }
+
     @Override
     public long count() throws FetchException {
         Log log = mStorage.mLog;
@@ -237,6 +313,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.count();
     }
 
+    @Override
+    public long count(Controller controller) throws FetchException {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.count(controller) on " + this + ", controller: " + controller);
+        }
+        return mQuery.count(controller);
+    }
+
     @Override
     public boolean exists() throws FetchException {
         Log log = mStorage.mLog;
@@ -246,6 +331,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.exists();
     }
 
+    @Override
+    public boolean exists(Controller controller) throws FetchException {
+        Log log = mStorage.mLog;
+        if (log.isEnabled()) {
+            log.write("Query.exists(controller) on " + this + ", controller: " + controller);
+        }
+        return mQuery.exists(controller);
+    }
+
     @Override
     public boolean printNative() {
         return mQuery.printNative();
-- 
cgit v1.2.3