[solr] branch jira/solr16636_test updated: added more debugging 5

[noble]

This is an automated email from the ASF dual-hosted git repository.

noble pushed a commit to branch jira/solr16636_test
in repository https://gitbox.apache.org/repos/asf/solr.git


The following commit(s) were added to refs/heads/jira/solr16636_test by this 
push:
     new ce7abb9d55a  added more debugging 5
ce7abb9d55a is described below

commit ce7abb9d55a5a002927b92bab3961099eac866c2
Author: Noble Paul <noble.p...@gmail.com>
AuthorDate: Thu Feb 23 11:45:50 2023 +1100

     added more debugging 5
---
 .../java/org/apache/solr/common/cloud/ZkStateReader.java  | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git 
a/solr/solrj-zookeeper/src/java/org/apache/solr/common/cloud/ZkStateReader.java 
b/solr/solrj-zookeeper/src/java/org/apache/solr/common/cloud/ZkStateReader.java
index 015cf81aba0..693380bfbe5 100644
--- 
a/solr/solrj-zookeeper/src/java/org/apache/solr/common/cloud/ZkStateReader.java
+++ 
b/solr/solrj-zookeeper/src/java/org/apache/solr/common/cloud/ZkStateReader.java
@@ -1699,7 +1699,12 @@ public class ZkStateReader implements SolrCloseable {
     if (c == null) return null;
     Stat stat = null;
     try {
+      long start = System.currentTimeMillis();
       stat = zkClient.exists(collectionPath, null, false);
+      long timeTaken = System.currentTimeMillis() - start;
+      if(timeTaken > 5) {
+        log.info("zkClient.exists({}):  {}", collectionPath,timeTaken );
+      }
     } catch (InterruptedException ie) {
       Thread.currentThread().interrupt();
       return null;
@@ -1933,7 +1938,12 @@ public class ZkStateReader implements SolrCloseable {
         };
 
     try {
+      long start = System.currentTimeMillis();
       registerCollectionStateWatcher(collection, watcher);
+      long timeTaken = System.currentTimeMillis() - start;
+      if(timeTaken>5) {
+        log.info("registerCollectionStateWatcher {}ms", timeTaken);
+      }
       // wait for the watcher predicate to return true, or time out
       if (!latch.await(wait, unit))
         throw new TimeoutException(
@@ -2014,7 +2024,12 @@ public class ZkStateReader implements SolrCloseable {
         };
 
     try {
+      long start = System.currentTimeMillis();
       registerDocCollectionWatcher(collection, watcher);
+      long timeTaken = System.currentTimeMillis() - start;
+      if(timeTaken>5) {
+        log.info("registerCollectionStateWatcher {}ms", timeTaken);
+      }
       // wait for the watcher predicate to return true, or time out
       if (!latch.await(wait, unit))
         throw new TimeoutException(