[qpid-dispatch] branch master updated: DISPATCH-1780: mark request complete in order to get subsequent requests

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[qpid-dispatch] branch master updated: DISPATCH-1780: mark request complete in order to get subsequent requests

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

gsim pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git


The following commit(s) were added to refs/heads/master by this push:
     new efe9dcb  DISPATCH-1780: mark request complete in order to get subsequent requests
efe9dcb is described below

commit efe9dcb5f92ed19d13d400580c49734eac1c3297
Author: Gordon Sim <[hidden email]>
AuthorDate: Wed Jan 13 20:57:25 2021 +0000

    DISPATCH-1780: mark request complete in order to get subsequent requests
---
 src/adaptors/http1/http1_server.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/adaptors/http1/http1_server.c b/src/adaptors/http1/http1_server.c
index 6377d8f..28358d6 100644
--- a/src/adaptors/http1/http1_server.c
+++ b/src/adaptors/http1/http1_server.c
@@ -1147,6 +1147,8 @@ void qdr_http1_server_core_delivery_update(qdr_http1_adaptor_t      *adaptor,
     }
     if (hconn->cfg.aggregation != QD_AGGREGATION_NONE) {
         _server_request_t *hreq = (_server_request_t*)hbase;
+        qd_message_set_send_complete(qdr_delivery_message(hreq->request_dlv));
+        qdr_link_complete_sent_message(qdr_http1_adaptor->core, hconn->out_link);
         _accept_and_settle_request(hreq);
         hreq->request_acked = true;
         qd_log(adaptor->log, QD_LOG_DEBUG, "[C%"PRIu64"][L%"PRIu64"] request accepted", hconn->conn_id, hconn->in_link_id);


---------------------------------------------------------------------
To unsubscribe, e-mail: [hidden email]
For additional commands, e-mail: [hidden email]