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

gmurthy pushed a commit to branch dev-protocol-adaptors-2
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git


The following commit(s) were added to refs/heads/dev-protocol-adaptors-2 by 
this push:
     new d393716  DISPATCH-1743: Prevent qdr_http_flow from calling 
route_delivery() if in_dlv already created
d393716 is described below

commit d39371648377f82a8ce5355f5dda85edbe882fe0
Author: Ganesh Murthy <gmur...@apache.org>
AuthorDate: Wed Nov 11 16:51:56 2020 -0500

    DISPATCH-1743: Prevent qdr_http_flow from calling route_delivery() if 
in_dlv already created
---
 src/adaptors/http2/http2_adaptor.c | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/adaptors/http2/http2_adaptor.c 
b/src/adaptors/http2/http2_adaptor.c
index e518f34..304e9c4 100644
--- a/src/adaptors/http2/http2_adaptor.c
+++ b/src/adaptors/http2/http2_adaptor.c
@@ -1250,8 +1250,10 @@ static void qdr_http_flow(void *context, qdr_link_t 
*link, int credit)
         if (! stream_data)
             return;
         stream_data->in_link_credit += credit;
-        if (route_delivery(stream_data, 
qd_message_receive_complete(stream_data->message))) {
-            qd_log(http2_adaptor->log_source, QD_LOG_TRACE, "[C%"PRIu64"] 
qdr_http_flow, delivery routed successfully", 
stream_data->session_data->conn->conn_id);
+        if (!stream_data->in_dlv) {
+            if (route_delivery(stream_data, 
qd_message_receive_complete(stream_data->message))) {
+                qd_log(http2_adaptor->log_source, QD_LOG_TRACE, "[C%"PRIu64"] 
qdr_http_flow, delivery routed successfully", 
stream_data->session_data->conn->conn_id);
+            }
         }
     }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org

Reply via email to