commit 15eaa8c49912f0dde2c8f385cbf03aab546b35ed
author Noble Paul <noble.paul@gmail.com> Thu Jun 23 15:08:15 2022 +1000
committer Noble Paul <noble.paul@gmail.com> Thu Jun 23 15:08:15 2022 +1000
tree 5c17d24eb6d92672c7ca6aa0943152a239fdf2cc
parent c7bcff29d98c5a0c99c144d5ffcf24be8a6a629a

optimize wait for state

solr/core/src/java/org/apache/solr/cloud/ZkController.java

diff --git a/solr/core/src/java/org/apache/solr/cloud/ZkController.java b/solr/core/src/java/org/apache/solr/cloud/ZkController.java
index fbb0662..503f09d 100644
--- a/solr/core/src/java/org/apache/solr/cloud/ZkController.java
+++ b/solr/core/src/java/org/apache/solr/cloud/ZkController.java
@@ -50,6 +50,7 @@
 import java.util.concurrent.atomic.AtomicReference;
 
 import com.google.common.base.Strings;
+import com.google.common.base.Supplier;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.solr.client.solrj.cloud.SolrCloudManager;
 import org.apache.solr.client.solrj.impl.CloudSolrClient;
@@ -1657,14 +1658,18 @@
       }
       DocCollection coll = zkStateReader.getCollection(collection);
       if (forcePublish || sendToOverseer(coll, coreNodeName)) {
+
+
         overseerJobQueue.offer(Utils.toJSON(m));
       } else {
         if (log.isDebugEnabled()) {
           log.debug("bypassed overseer for message : {}", Utils.toJSONString(m));
         }
+        Timer.TLInst.start("prs flipState()");
         PerReplicaStates perReplicaStates = PerReplicaStates.fetch(coll.getZNode(), zkClient, coll.getPerReplicaStates());
         PerReplicaStatesOps.flipState(coreNodeName, state, perReplicaStates)
             .persist(coll.getZNode(), zkClient);
+        Timer.TLInst.end("prs flipState()");
       }
     } finally {
       MDCLoggingContext.clear();