diff options
| author | Alan Conway <aconway@apache.org> | 2008-10-07 17:24:24 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-10-07 17:24:24 +0000 |
| commit | a653ebe5bdfad1d44a576d2ab23f7e6ea80ba96f (patch) | |
| tree | cf778054e9316b643d84c95dbe88ba72810f49cf /cpp/src/qpid/client | |
| parent | 4eb2dca5b9ae07228f542cd798b44cc44ea96c09 (diff) | |
| download | qpid-python-a653ebe5bdfad1d44a576d2ab23f7e6ea80ba96f.tar.gz | |
Rename size() to encodedSize() for encoded types to allow std collection interfaces for types like FieldTable and Array.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@702551 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client')
| -rw-r--r-- | cpp/src/qpid/client/Connector.cpp | 4 | ||||
| -rw-r--r-- | cpp/src/qpid/client/RdmaConnector.cpp | 6 | ||||
| -rw-r--r-- | cpp/src/qpid/client/SessionImpl.cpp | 6 |
3 files changed, 8 insertions, 8 deletions
diff --git a/cpp/src/qpid/client/Connector.cpp b/cpp/src/qpid/client/Connector.cpp index 6449088f92..fe7793c432 100644 --- a/cpp/src/qpid/client/Connector.cpp +++ b/cpp/src/qpid/client/Connector.cpp @@ -318,7 +318,7 @@ void TCPConnector::Writer::write(sys::AsynchIO&) { size_t bytesWritten(0); for (size_t i = 0; i < lastEof; ++i) { AMQFrame& frame = frames[i]; - uint32_t size = frame.size(); + uint32_t size = frame.encodedSize(); if (size > encode.available()) writeOne(); assert(size <= encode.available()); frame.encode(encode); @@ -368,7 +368,7 @@ void TCPConnector::writeDataBlock(const AMQDataBlock& data) { AsynchIO::BufferBase* buff = new Buff(maxFrameSize); framing::Buffer out(buff->bytes, buff->byteCount); data.encode(out); - buff->dataCount = data.size(); + buff->dataCount = data.encodedSize(); aio->queueWrite(buff); } diff --git a/cpp/src/qpid/client/RdmaConnector.cpp b/cpp/src/qpid/client/RdmaConnector.cpp index 1a85cbb4bc..98fe762f31 100644 --- a/cpp/src/qpid/client/RdmaConnector.cpp +++ b/cpp/src/qpid/client/RdmaConnector.cpp @@ -349,7 +349,7 @@ void RdmaConnector::Writer::write(Rdma::AsynchIO&) { size_t bytesWritten = 0; while (aio->writable() && aio->bufferAvailable() && !frames.empty()) { const AMQFrame* frame = &frames.front(); - uint32_t size = frame->size(); + uint32_t size = frame->encodedSize(); while (size <= encode.available()) { frame->encode(encode); frames.pop_front(); @@ -358,7 +358,7 @@ void RdmaConnector::Writer::write(Rdma::AsynchIO&) { if (frames.empty()) break; frame = &frames.front(); - size = frame->size(); + size = frame->encodedSize(); } lastEof -= framesEncoded; writeOne(); @@ -392,7 +392,7 @@ void RdmaConnector::writeDataBlock(const AMQDataBlock& data) { Rdma::Buffer* buff = aio->getBuffer(); framing::Buffer out(buff->bytes, buff->byteCount); data.encode(out); - buff->dataCount = data.size(); + buff->dataCount = data.encodedSize(); aio->queueWrite(buff); } diff --git a/cpp/src/qpid/client/SessionImpl.cpp b/cpp/src/qpid/client/SessionImpl.cpp index 3d73d92bd4..3e1ea8b724 100644 --- a/cpp/src/qpid/client/SessionImpl.cpp +++ b/cpp/src/qpid/client/SessionImpl.cpp @@ -427,13 +427,13 @@ void SessionImpl::handleIn(AMQFrame& frame) // network thread void SessionImpl::handleOut(AMQFrame& frame) // user thread { - connection->expand(frame.size(), true); + connection->expand(frame.encodedSize(), true); channel.handle(frame); } void SessionImpl::proxyOut(AMQFrame& frame) // network thread { - connection->expand(frame.size(), false); + connection->expand(frame.encodedSize(), false); channel.handle(frame); } @@ -523,7 +523,7 @@ void SessionImpl::commandPoint(const framing::SequenceNumber& id, uint64_t offse void SessionImpl::expected(const framing::SequenceSet& commands, const framing::Array& fragments) { - if (!commands.empty() || fragments.size()) { + if (!commands.empty() || fragments.encodedSize()) { throw NotImplementedException("Session resumption not yet supported"); } } |
