summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/OutputInterceptor.cpp
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2009-06-08 16:43:28 +0000
committerAndrew Stitcher <astitcher@apache.org>2009-06-08 16:43:28 +0000
commit0d9a9a82bc754e8ee12c5b7b4c8befd7b5b5c12b (patch)
treed2c6337515ec0d27c2880c7d642046360d2ddac3 /cpp/src/qpid/cluster/OutputInterceptor.cpp
parent477ef3c8435165fa70d6a19c195e4b14c4e6073f (diff)
downloadqpid-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.cpp5
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);