qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject [28/50] [abbrv] qpid-proton git commit: PROTON-1077: adjust the receivers transport credit state by the same delta as the link credit state when deliveryCount advances to keep them in sync
Date Wed, 30 Dec 2015 21:13:16 GMT
PROTON-1077: adjust the receivers transport credit state by the same delta as the link credit
state when deliveryCount advances to keep them in sync


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

Branch: refs/heads/go1
Commit: a8d87bb3c6d54458d7041d38374feb8b7cf30667
Parents: a4a21be
Author: Robert Gemmell <robbie@apache.org>
Authored: Tue Dec 15 13:00:41 2015 +0000
Committer: Robert Gemmell <robbie@apache.org>
Committed: Tue Dec 15 15:21:21 2015 +0000

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


http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a8d87bb3/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java
b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java
index fcaec28..29d97c4 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java
@@ -48,7 +48,7 @@ class TransportReceiver extends TransportLink<ReceiverImpl>
         if(delta > 0)
         {
             getLink().addCredit(-delta);
-            setLinkCredit(getRemoteLinkCredit());
+            addCredit(-delta);
             setDeliveryCount(getRemoteDeliveryCount());
             getLink().setDrained(getLink().getDrained() + delta);
         }


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


Mime
View raw message