diff options
| author | Alan Conway <aconway@apache.org> | 2009-04-15 17:45:45 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2009-04-15 17:45:45 +0000 |
| commit | b73dada8c6e7ce38c48b11ff8b79c821d9dee0c1 (patch) | |
| tree | 82b14fa8a183edc6e76e745aeb6b27aa3b1218f0 /cpp/src/qpid/cluster/Multicaster.cpp | |
| parent | f608cd0f72d98d60f92165ac0efd6c70efcd870c (diff) | |
| download | qpid-python-b73dada8c6e7ce38c48b11ff8b79c821d9dee0c1.tar.gz | |
Cleaned up some un-necessary #include dependencies.
Removed un-used LatencyMetric hack.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@765285 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/Multicaster.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/Multicaster.cpp | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/cpp/src/qpid/cluster/Multicaster.cpp b/cpp/src/qpid/cluster/Multicaster.cpp index f0738ab08f..3b9d3ac990 100644 --- a/cpp/src/qpid/cluster/Multicaster.cpp +++ b/cpp/src/qpid/cluster/Multicaster.cpp @@ -22,7 +22,6 @@ #include "Multicaster.h" #include "Cpg.h" #include "qpid/log/Statement.h" -#include "qpid/sys/LatencyMetric.h" #include "qpid/framing/AMQBody.h" #include "qpid/framing/AMQFrame.h" @@ -64,7 +63,6 @@ void Multicaster::mcast(const Event& e) { return; } } - QPID_LATENCY_INIT(e); queue.push(e); } @@ -73,7 +71,6 @@ void Multicaster::sendMcast(PollableEventQueue::Queue& values) { try { PollableEventQueue::Queue::iterator i = values.begin(); while( i != values.end()) { - QPID_LATENCY_RECORD("mcast send queue", *i); iovec iov = i->toIovec(); if (!cpg.mcast(&iov, 1)) { // cpg didn't send because of CPG flow control. @@ -97,9 +94,4 @@ void Multicaster::release() { holdingQueue.clear(); } -void Multicaster::selfDeliver(const Event& e) { - sys::Mutex::ScopedLock l(lock); - QPID_LATENCY_RECORD("cpg self deliver", e); -} - }} // namespace qpid::cluster |