You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2007/09/17 16:08:17 UTC
svn commit: r576448 -
/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Session.cpp
Author: gsim
Date: Mon Sep 17 07:08:17 2007
New Revision: 576448
URL: http://svn.apache.org/viewvc?rev=576448&view=rev
Log:
Fix for race between flush and delivery.
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Session.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Session.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Session.cpp?rev=576448&r1=576447&r2=576448&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Session.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Session.cpp Mon Sep 17 07:08:17 2007
@@ -535,7 +535,13 @@
void Session::ConsumerImpl::flush()
{
+ //need to prevent delivery after requestDispatch returns but
+ //before credit is reduced to zero; TODO: come up with better
+ //implementation of flush.
+ Mutex::ScopedLock l(lock);
queue->requestDispatch(this, true);
+ byteCredit = 0;
+ msgCredit = 0;
}
void Session::ConsumerImpl::stop()