You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2015/10/23 18:04:23 UTC
usergrid git commit: Added more logging statements
Repository: usergrid
Updated Branches:
refs/heads/2.1-release 8b4faf722 -> d35fea563
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/2.1-release
Commit: d35fea5636acfd384f0b35069cdc59e515ec0372
Parents: 8b4faf7
Author: Todd Nine <tn...@apigee.com>
Authored: Fri Oct 23 10:04:21 2015 -0600
Committer: Todd Nine <tn...@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;