You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2015/07/10 00:12:27 UTC
[47/50] qpid-proton git commit: PROTON-940: calculate the incoming
window before sending the Begin frame to ensure it is initialised,
which supresses the need for a subsequent Flow as seen previously
PROTON-940: calculate the incoming window before sending the Begin frame to ensure it is initialised, which supresses the need for a subsequent Flow as seen previously
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/2b41931d
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/2b41931d
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/2b41931d
Branch: refs/heads/cjansen-cpp-client
Commit: 2b41931dbb49730ddba92c42e40113899371c2d7
Parents: ed31367
Author: Robert Gemmell <ro...@apache.org>
Authored: Thu Jul 9 14:25:02 2015 +0100
Committer: Robert Gemmell <ro...@apache.org>
Committed: Thu Jul 9 14:38:50 2015 +0100
----------------------------------------------------------------------
.../java/org/apache/qpid/proton/engine/impl/TransportImpl.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/2b41931d/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 7d285b1..9cc73ce 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
@@ -841,6 +841,9 @@ public class TransportImpl extends EndpointImpl
{
begin.setRemoteChannel(UnsignedShort.valueOf((short) transportSession.getRemoteChannel()));
}
+
+ transportSession.updateIncomingWindow();
+
begin.setHandleMax(transportSession.getHandleMax());
begin.setIncomingWindow(transportSession.getIncomingWindowSize());
begin.setOutgoingWindow(transportSession.getOutgoingWindowSize());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org