diff options
Diffstat (limited to 'cpp/src/qpid/cluster')
| -rw-r--r-- | cpp/src/qpid/cluster/Event.cpp | 2 | ||||
| -rw-r--r-- | cpp/src/qpid/cluster/OutputInterceptor.cpp | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/cluster/Event.cpp b/cpp/src/qpid/cluster/Event.cpp index f7389c1922..3f2b5443d2 100644 --- a/cpp/src/qpid/cluster/Event.cpp +++ b/cpp/src/qpid/cluster/Event.cpp @@ -50,7 +50,7 @@ Event Event::delivered(const MemberId& m, void* d, size_t s) { Event Event::control(const framing::AMQBody& body, const ConnectionId& cid, uint32_t id) { framing::AMQFrame f(body); - Event e(CONTROL, cid, f.size(), id); + Event e(CONTROL, cid, f.encodedSize(), id); Buffer buf(e); f.encode(buf); return e; diff --git a/cpp/src/qpid/cluster/OutputInterceptor.cpp b/cpp/src/qpid/cluster/OutputInterceptor.cpp index e69992517c..cc1af255e4 100644 --- a/cpp/src/qpid/cluster/OutputInterceptor.cpp +++ b/cpp/src/qpid/cluster/OutputInterceptor.cpp @@ -40,7 +40,7 @@ void OutputInterceptor::send(framing::AMQFrame& f) { Locker l(lock); next->send(f); if (!parent.isCatchUp()) - sent += f.size(); + sent += f.encodedSize(); } void OutputInterceptor::activateOutput() { |