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:36 UTC
lucene-solr:master: For simulated queries count also buffered updates.
Repository: lucene-solr
Updated Branches:
refs/heads/master 9481c1f62 -> 918b11c7c
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/918b11c7
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/918b11c7
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/918b11c7
Branch: refs/heads/master
Commit: 918b11c7ce6585411556645dcbdfe5408ac562f7
Parents: 9481c1f
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:24:29 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/918b11c7/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 18e20e0..8b14682 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
@@ -1617,6 +1617,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<>();