qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rob...@apache.org
Subject qpid-proton git commit: PROTON-1300: remove redundant setLinkCredit(0) call to avoid minor confusion
Date Mon, 12 Sep 2016 17:58:21 GMT
Repository: qpid-proton
Updated Branches:
  refs/heads/master a52c331bf -> eda1601de


PROTON-1300: remove redundant setLinkCredit(0) call to avoid minor confusion


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

Branch: refs/heads/master
Commit: eda1601deb560ccd9bd5a11f2442d86d37a4d517
Parents: a52c331
Author: Robert Gemmell <robbie@apache.org>
Authored: Mon Sep 12 18:57:19 2016 +0100
Committer: Robert Gemmell <robbie@apache.org>
Committed: Mon Sep 12 18:57:19 2016 +0100

----------------------------------------------------------------------
 .../java/org/apache/qpid/proton/engine/impl/TransportImpl.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/eda1601d/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
index b8003ac..9a5fcbd 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
@@ -477,9 +477,8 @@ public class TransportImpl extends EndpointImpl
                         TransportSender transportLink = sender.getTransportLink();
                         TransportSession transportSession = sender.getSession().getTransportSession();
                         UnsignedInteger credits = transportLink.getLinkCredit();
-                        transportLink.setLinkCredit(UnsignedInteger.valueOf(0));
-                        transportLink.setDeliveryCount(transportLink.getDeliveryCount().add(credits));
                         transportLink.setLinkCredit(UnsignedInteger.ZERO);
+                        transportLink.setDeliveryCount(transportLink.getDeliveryCount().add(credits));
                         sender.setDrained(0);
 
                         writeFlow(transportSession, transportLink);


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


Mime
View raw message