summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-10-07 17:24:24 +0000
committerAlan Conway <aconway@apache.org>2008-10-07 17:24:24 +0000
commita653ebe5bdfad1d44a576d2ab23f7e6ea80ba96f (patch)
treecf778054e9316b643d84c95dbe88ba72810f49cf /cpp/src/qpid/client
parent4eb2dca5b9ae07228f542cd798b44cc44ea96c09 (diff)
downloadqpid-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.cpp4
-rw-r--r--cpp/src/qpid/client/RdmaConnector.cpp6
-rw-r--r--cpp/src/qpid/client/SessionImpl.cpp6
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");
}
}