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 2010/03/25 14:21:45 UTC
svn commit: r927385 - /qpid/trunk/qpid/cpp/src/qpid/cluster/UpdateClient.cpp
Author: aconway
Date: Thu Mar 25 13:21:45 2010
New Revision: 927385
URL: http://svn.apache.org/viewvc?rev=927385&view=rev
Log:
Fix "Ignoring frame while closing connection" warnings in a cluster broker giving an update.
Modified:
qpid/trunk/qpid/cpp/src/qpid/cluster/UpdateClient.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/UpdateClient.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/cluster/UpdateClient.cpp?rev=927385&r1=927384&r2=927385&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/cluster/UpdateClient.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/cluster/UpdateClient.cpp Thu Mar 25 13:21:45 2010
@@ -399,7 +399,10 @@ void UpdateClient::updateSession(broker:
SequenceNumber received = ss->receiverGetReceived().command;
if (inProgress)
--received;
-
+
+ // Sync the session to ensure all responses from broker have been processed.
+ shadowSession.sync();
+
// Reset command-sequence state.
proxy.sessionState(
ss->senderGetReplayPoint().command,
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org