diff options
| author | Alan Conway <aconway@apache.org> | 2008-12-08 12:04:02 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-12-08 12:04:02 +0000 |
| commit | 75b79a3b11abf1def01f765f21cc781d54996153 (patch) | |
| tree | 562f4e54aeb76bc2606477bcb53e2688c0188c3d /cpp/src/qpid/cluster/OutputInterceptor.cpp | |
| parent | a90b506a12e71b1fa3bbaf0b0a95d62c42d3fd3d (diff) | |
| download | qpid-python-75b79a3b11abf1def01f765f21cc781d54996153.tar.gz | |
src/qpid/cluster/OutputInterceptor.cpp: revert locking.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724330 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/OutputInterceptor.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/OutputInterceptor.cpp | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/cpp/src/qpid/cluster/OutputInterceptor.cpp b/cpp/src/qpid/cluster/OutputInterceptor.cpp index 37b5b1a3e6..bdb6dea791 100644 --- a/cpp/src/qpid/cluster/OutputInterceptor.cpp +++ b/cpp/src/qpid/cluster/OutputInterceptor.cpp @@ -76,12 +76,10 @@ void OutputInterceptor::deliverDoOutput(size_t requested) { // Run the real doOutput() till we have added the requested data or there's nothing to output. sent = 0; - { - sys::Mutex::ScopedUnlock u(lock); do { + sys::Mutex::ScopedUnlock u(lock); moreOutput = parent.getBrokerConnection().doOutput(); } while (sent < requested && moreOutput); - } sent += buf; // Include buffered data in the sent total. QPID_LOG(trace, "Delivered doOutput: requested=" << requested << " output=" << sent << " more=" << moreOutput); |