qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tr...@apache.org
Subject qpid-dispatch git commit: DISPATCH_882 - Removed unneeded rejection of aborted deliveries.
Date Tue, 05 Dec 2017 15:49:40 GMT
Repository: qpid-dispatch
Updated Branches:
  refs/heads/master d5f279b8b -> 16d60e787


DISPATCH_882 - Removed unneeded rejection of aborted deliveries.


Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/16d60e78
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/16d60e78
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/16d60e78

Branch: refs/heads/master
Commit: 16d60e78759ff425a77a5996df24f90393e0d355
Parents: d5f279b
Author: Ted Ross <tross@redhat.com>
Authored: Tue Dec 5 10:49:06 2017 -0500
Committer: Ted Ross <tross@redhat.com>
Committed: Tue Dec 5 10:49:06 2017 -0500

----------------------------------------------------------------------
 src/router_node.c | 8 --------
 1 file changed, 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/16d60e78/src/router_node.c
----------------------------------------------------------------------
diff --git a/src/router_node.c b/src/router_node.c
index fc9235a..a3a5934 100644
--- a/src/router_node.c
+++ b/src/router_node.c
@@ -1370,12 +1370,6 @@ static uint64_t CORE_link_deliver(void *context, qdr_link_t *link,
qdr_delivery_
 
     if (send_complete) {
         if (qd_message_aborted(msg_out)) {
-
-            // This message has been aborted.  When a sender aborts a message
-            // the message is implicitly settled.  The caller will need to tell
-            // the core that the delivery has been rejected and settled.
-            update = PN_REJECTED;
-
             // Aborted messages must be settled locally
             // Settling does not produce any disposition to message sender.
             if (pdlv) {
@@ -1384,7 +1378,6 @@ static uint64_t CORE_link_deliver(void *context, qdr_link_t *link, qdr_delivery_
                 pn_link_advance(plink);
                 pn_delivery_settle(pdlv);
             }
-
         } else {
             if (!settled && remote_snd_settled) {
                 // The caller must tell the core that the delivery has been
@@ -1399,7 +1392,6 @@ static uint64_t CORE_link_deliver(void *context, qdr_link_t *link, qdr_delivery_
                 if (pdlv)
                     pn_delivery_settle(pdlv);
             }
-
         }
     }
     return update;


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


Mime
View raw message