You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ab...@apache.org on 2018/09/28 18:24:02 UTC
lucene-solr:branch_7x: For simulated queries count also buffered
updates.
Repository: lucene-solr
Updated Branches:
refs/heads/branch_7x 6f23bd37f -> 8316021f3
For simulated queries count also buffered updates.
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/8316021f
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/8316021f
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/8316021f
Branch: refs/heads/branch_7x
Commit: 8316021f3a9256caabe3d8d34b26afa6c5fda2a3
Parents: 6f23bd3
Author: Andrzej Bialecki <ab...@apache.org>
Authored: Fri Sep 28 20:23:02 2018 +0200
Committer: Andrzej Bialecki <ab...@apache.org>
Committed: Fri Sep 28 20:23:02 2018 +0200
----------------------------------------------------------------------
.../solr/cloud/autoscaling/sim/SimClusterStateProvider.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/8316021f/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/SimClusterStateProvider.java
----------------------------------------------------------------------
diff --git a/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/SimClusterStateProvider.java b/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/SimClusterStateProvider.java
index d944339..792ead5 100644
--- a/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/SimClusterStateProvider.java
+++ b/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/SimClusterStateProvider.java
@@ -1590,6 +1590,10 @@ public class SimClusterStateProvider implements ClusterStateProvider {
ReplicaInfo ri = getReplicaInfo(r);
Number numDocs = (Number)ri.getVariable("SEARCHER.searcher.numDocs", 0L);
count.addAndGet(numDocs.longValue());
+ AtomicLong bufferedUpdates = (AtomicLong)sliceProperties.get(collection).get(s.getName()).get(BUFFERED_UPDATES);
+ if (bufferedUpdates != null) {
+ count.addAndGet(bufferedUpdates.get());
+ }
}
QueryResponse rsp = new QueryResponse();
NamedList<Object> values = new NamedList<>();