diff options
Diffstat (limited to 'cpp/src/qpid/broker')
| -rw-r--r-- | cpp/src/qpid/broker/Connection.cpp | 4 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/Exchange.cpp | 2 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/Queue.cpp | 2 |
3 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/qpid/broker/Connection.cpp b/cpp/src/qpid/broker/Connection.cpp index 5d4ebad4b9..38affad51f 100644 --- a/cpp/src/qpid/broker/Connection.cpp +++ b/cpp/src/qpid/broker/Connection.cpp @@ -107,7 +107,7 @@ void Connection::recordFromServer(framing::AMQFrame& frame) if (mgmtObject != 0) { mgmtObject->inc_framesToClient(); - mgmtObject->inc_bytesToClient(frame.size()); + mgmtObject->inc_bytesToClient(frame.encodedSize()); } } @@ -116,7 +116,7 @@ void Connection::recordFromClient(framing::AMQFrame& frame) if (mgmtObject != 0) { mgmtObject->inc_framesFromClient(); - mgmtObject->inc_bytesFromClient(frame.size()); + mgmtObject->inc_bytesFromClient(frame.encodedSize()); } } diff --git a/cpp/src/qpid/broker/Exchange.cpp b/cpp/src/qpid/broker/Exchange.cpp index 553fb8f374..4824fa5742 100644 --- a/cpp/src/qpid/broker/Exchange.cpp +++ b/cpp/src/qpid/broker/Exchange.cpp @@ -111,7 +111,7 @@ uint32_t Exchange::encodedSize() const return name.size() + 1/*short string size*/ + 1 /*durable*/ + getType().size() + 1/*short string size*/ - + args.size(); + + args.encodedSize(); } ManagementObject* Exchange::GetManagementObject (void) const diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index 735a116cf2..c899a5befa 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/cpp/src/qpid/broker/Queue.cpp @@ -648,7 +648,7 @@ void Queue::encode(framing::Buffer& buffer) const uint32_t Queue::encodedSize() const { - return name.size() + 1/*short string size octet*/ + settings.size(); + return name.size() + 1/*short string size octet*/ + settings.encodedSize(); } Queue::shared_ptr Queue::decode(QueueRegistry& queues, framing::Buffer& buffer) |