[lucene-solr] branch reference_impl updated: @270 Still do the interrupt to prevent the sleep in sendThread cleanup.

[ma...@apache.org]

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

markrmiller pushed a commit to branch reference_impl
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git


The following commit(s) were added to refs/heads/reference_impl by this push:
     new c16f938  @270 Still do the interrupt to prevent the sleep in sendThread cleanup.
c16f938 is described below

commit c16f938c78445748c3f46ab181b31482453d1091
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Tue Jul 21 00:05:30 2020 -0500

    @270 Still do the interrupt to prevent the sleep in sendThread cleanup.
---
 solr/solrj/src/java/org/apache/solr/common/cloud/SolrZooKeeper.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/solr/solrj/src/java/org/apache/solr/common/cloud/SolrZooKeeper.java b/solr/solrj/src/java/org/apache/solr/common/cloud/SolrZooKeeper.java
index 6358982..bd2b1e1 100644
--- a/solr/solrj/src/java/org/apache/solr/common/cloud/SolrZooKeeper.java
+++ b/solr/solrj/src/java/org/apache/solr/common/cloud/SolrZooKeeper.java
@@ -112,6 +112,9 @@ public class SolrZooKeeper extends ZooKeeper {
     try (ParWork worker = new ParWork(this, true)) {
       worker.collect(() -> {
         try {
+          ZooKeeperExposed exposed = new ZooKeeperExposed(this, cnxn);
+          exposed.intteruptSendThread();
+//        exposed.intteruptSendThread();
           SolrZooKeeper.super.close();
         } catch (InterruptedException e) {
           ParWork.propegateInterrupt(e);