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 <rob...@apache.org> Authored: Thu Jul 9 14:25:02 2015 +0100 Committer: Robert Gemmell <rob...@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-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
