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/04 11:16:13 UTC
[lucene-solr] 07/13: @726 Only track ASYNC requests!
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
commit 5b598296713f65c4ae75af975ef57d7161be5635
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Thu Sep 3 13:07:42 2020 -0500
@726 Only track ASYNC requests!
---
.../apache/solr/client/solrj/impl/Http2SolrClient.java | 16 ++++------------
1 file changed, 4 insertions(+), 12 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 b827705..0c7f803 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
@@ -354,15 +354,11 @@ public class Http2SolrClient extends SolrClient {
InputStreamResponseListener responseListener = new InputStreamResponseListener() {
@Override
public void onComplete(Result result) {
- try {
- super.onComplete(result);
- } finally {
- asyncTracker.completeListener.onComplete(result);
- }
+ super.onComplete(result);
}
};
asyncTracker.register();
- postRequest.onRequestQueued(asyncTracker.queuedListener).send(responseListener);
+ postRequest.send(responseListener);
boolean isXml = ClientUtils.TEXT_XML.equals(requestWriter.getUpdateContentType());
OutStream outStream = new OutStream(collection, origParams, provider, responseListener,
@@ -438,14 +434,10 @@ public class Http2SolrClient extends SolrClient {
InputStreamResponseListener listener = new InputStreamResponseListener() {
@Override
public void onComplete(Result result) {
- try {
- super.onComplete(result);
- } finally {
- asyncTracker.completeListener.onComplete(result);
- }
+ super.onComplete(result);
}
};
- req.onRequestQueued(asyncTracker.queuedListener).send(listener);
+ req.send(listener);
Response response = listener.get(idleTimeout, TimeUnit.MILLISECONDS);
InputStream is = listener.getInputStream();
// nocommit - track this again when streaming use is fixed