diff options
author | Andrew Stitcher <astitcher@apache.org> | 2009-06-08 16:43:28 +0000 |
---|---|---|
committer | Andrew Stitcher <astitcher@apache.org> | 2009-06-08 16:43:28 +0000 |
commit | 0d9a9a82bc754e8ee12c5b7b4c8befd7b5b5c12b (patch) | |
tree | d2c6337515ec0d27c2880c7d642046360d2ddac3 /cpp/src/qpid/cluster/OutputInterceptor.cpp | |
parent | 477ef3c8435165fa70d6a19c195e4b14c4e6073f (diff) | |
download | qpid-python-0d9a9a82bc754e8ee12c5b7b4c8befd7b5b5c12b.tar.gz |
Fix of the previous client heartbeat changes:
- Changes to the cluster code were previously missed
- It's neater and more correct to reset the traffic
timeout for all connection traffic, not just traffic
in a session
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@782696 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/OutputInterceptor.cpp')
-rw-r--r-- | cpp/src/qpid/cluster/OutputInterceptor.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/cluster/OutputInterceptor.cpp b/cpp/src/qpid/cluster/OutputInterceptor.cpp index f898957351..b5fa595577 100644 --- a/cpp/src/qpid/cluster/OutputInterceptor.cpp +++ b/cpp/src/qpid/cluster/OutputInterceptor.cpp @@ -64,6 +64,11 @@ void OutputInterceptor::activateOutput() { sendDoOutput(sendMax); } +void OutputInterceptor::abort() { + sys::Mutex::ScopedLock l(lock); + next->abort(); +} + void OutputInterceptor::giveReadCredit(int32_t credit) { sys::Mutex::ScopedLock l(lock); next->giveReadCredit(credit); |