You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ma...@apache.org on 2020/09/03 21:44:16 UTC

[lucene-solr] branch reference_impl_dev updated: @729 Change order.

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

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


The following commit(s) were added to refs/heads/reference_impl_dev by this push:
     new 456b6aa  @729 Change order.
456b6aa is described below

commit 456b6aabd572777067b70decff3077037e50d114
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Thu Sep 3 16:44:04 2020 -0500

    @729 Change order.
---
 .../src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java
index 628820c..f9a48f6 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java
@@ -856,7 +856,7 @@ public class Http2SolrClient extends SolrClient {
     // wait for async requests
     private final Phaser phaser = new ThePhaser(1);
     // maximum outstanding requests left
-    private final Request.QueuedListener queuedListener;
+    private final Request.BeginListener queuedListener;
     private final Response.CompleteListener completeListener;
 
     AsyncTracker() {
@@ -906,12 +906,12 @@ public class Http2SolrClient extends SolrClient {
       if (log.isDebugEnabled()) {
         log.debug("Registered new party");
       }
-      phaser.register();
       try {
         available.acquire();
       } catch (InterruptedException ignored) {
         ParWork.propegateInterrupt(ignored);
       }
+      phaser.register();
     }
 
     private static class ThePhaser extends Phaser {