diff options
| author | Alan Conway <aconway@apache.org> | 2009-08-14 12:56:31 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2009-08-14 12:56:31 +0000 |
| commit | 2c25d5df48b3f365bf7e027efde26edf255f081e (patch) | |
| tree | b443ccec05f4801dfe25536b694fdd4f3720b82a /cpp/src/qpid/cluster/Cluster.cpp | |
| parent | 401ab61bdc05fa510c47bd3c7c7b3711c24cf591 (diff) | |
| download | qpid-python-2c25d5df48b3f365bf7e027efde26edf255f081e.tar.gz | |
Revert "Batch multiple events into a single CPG multicast."
This reverts svn revision 803713: Batch multiple events into a single CPG multicast.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@804206 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/Cluster.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/Cluster.cpp | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/cpp/src/qpid/cluster/Cluster.cpp b/cpp/src/qpid/cluster/Cluster.cpp index 7bdc066767..e35d3e4175 100644 --- a/cpp/src/qpid/cluster/Cluster.cpp +++ b/cpp/src/qpid/cluster/Cluster.cpp @@ -323,11 +323,9 @@ void Cluster::deliver( { MemberId from(nodeid, pid); framing::Buffer buf(static_cast<char*>(msg), msg_len); - while (buf.available()) { - Event e(Event::decodeCopy(from, buf)); - LATENCY_TRACK(if (e.getConnectionId().getMember() == self) mcast.cpgLatency.finish()); - deliverEvent(e); - } + Event e(Event::decodeCopy(from, buf)); + LATENCY_TRACK(if (e.getConnectionId().getMember() == self) mcast.cpgLatency.finish()); + deliverEvent(e); } LATENCY_TRACK(sys::LatencyTracker<const char*> eventQueueLatencyTracker("EventQueue");) |