usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From toddn...@apache.org
Subject [09/50] [abbrv] usergrid git commit: Added more logging statements
Date Fri, 30 Oct 2015 23:32:43 GMT
Added more logging statements


Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/d35fea56
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/d35fea56
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/d35fea56

Branch: refs/heads/master
Commit: d35fea5636acfd384f0b35069cdc59e515ec0372
Parents: 8b4faf7
Author: Todd Nine <tnine@apigee.com>
Authored: Fri Oct 23 10:04:21 2015 -0600
Committer: Todd Nine <tnine@apigee.com>
Committed: Fri Oct 23 10:04:21 2015 -0600

----------------------------------------------------------------------
 .../corepersistence/results/ObservableQueryExecutor.java      | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/usergrid/blob/d35fea56/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java
b/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java
index 7b31d19..7a32dce 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java
@@ -23,6 +23,9 @@ package org.apache.usergrid.corepersistence.results;
 import java.util.Iterator;
 import java.util.NoSuchElementException;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import org.apache.usergrid.corepersistence.pipeline.read.ResultsPage;
 import org.apache.usergrid.persistence.Results;
 
@@ -39,6 +42,7 @@ import rx.Observable;
 public abstract class ObservableQueryExecutor<T> implements QueryExecutor {
 
 
+    private static final Logger logger = LoggerFactory.getLogger( ObservableQueryExecutor.class
);
 
     private Results results;
     private Optional<String> cursor;
@@ -131,9 +135,12 @@ public abstract class ObservableQueryExecutor<T> implements QueryExecutor
{
             observable = buildNewResultsPage( cursor ).map( resultsPage -> createResultsInternal(
resultsPage ) ).defaultIfEmpty(
             new Results() );
 
+        logger.trace( "Trying to load results page" );
         //take the first from our observable
         final Results resultsPage = observable.take(1).toBlocking().first();
 
+        logger.trace( "Results page loaded {}", resultsPage );
+
         //set the results for the iterator
         this.results = resultsPage;
 


Mime
View raw message