diff options
Diffstat (limited to 'cpp/src/qpid/framing')
28 files changed, 53 insertions, 53 deletions
diff --git a/cpp/src/qpid/framing/AMQBody.h b/cpp/src/qpid/framing/AMQBody.h index f3bf65470c..93f4319575 100644 --- a/cpp/src/qpid/framing/AMQBody.h +++ b/cpp/src/qpid/framing/AMQBody.h @@ -52,7 +52,7 @@ class AMQBody virtual void encode(Buffer& buffer) const = 0; virtual void decode(Buffer& buffer, uint32_t=0) = 0; - virtual uint32_t size() const = 0; + virtual uint32_t encodedSize() const = 0; virtual void print(std::ostream& out) const = 0; virtual void accept(AMQBodyConstVisitor&) const = 0; diff --git a/cpp/src/qpid/framing/AMQCommandControlBody.h b/cpp/src/qpid/framing/AMQCommandControlBody.h index 388fb48299..d12b70a168 100644 --- a/cpp/src/qpid/framing/AMQCommandControlBody.h +++ b/cpp/src/qpid/framing/AMQCommandControlBody.h @@ -43,7 +43,7 @@ template <class T> class AMQCommandControlBody : public AMQBody, public T virtual void decode(Buffer& buffer, uint32_t=0) { Codec::decode(buffer.getIterator(), static_cast<T&>(*this)); } - virtual uint32_t size() const { + virtual uint32_t encodedSize() const { Codec::size(buffer.getIterator(), static_cast<const T&>(*this)); } diff --git a/cpp/src/qpid/framing/AMQContentBody.cpp b/cpp/src/qpid/framing/AMQContentBody.cpp index 59f3619ef2..85fb95739b 100644 --- a/cpp/src/qpid/framing/AMQContentBody.cpp +++ b/cpp/src/qpid/framing/AMQContentBody.cpp @@ -27,7 +27,7 @@ qpid::framing::AMQContentBody::AMQContentBody(){ qpid::framing::AMQContentBody::AMQContentBody(const string& _data) : data(_data){ } -uint32_t qpid::framing::AMQContentBody::size() const{ +uint32_t qpid::framing::AMQContentBody::encodedSize() const{ return data.size(); } void qpid::framing::AMQContentBody::encode(Buffer& buffer) const{ @@ -39,6 +39,6 @@ void qpid::framing::AMQContentBody::decode(Buffer& buffer, uint32_t _size){ void qpid::framing::AMQContentBody::print(std::ostream& out) const { - out << "content (" << size() << " bytes)"; + out << "content (" << encodedSize() << " bytes)"; out << " " << data.substr(0,16) << "..."; } diff --git a/cpp/src/qpid/framing/AMQContentBody.h b/cpp/src/qpid/framing/AMQContentBody.h index 5d530a1b9a..288f1549a9 100644 --- a/cpp/src/qpid/framing/AMQContentBody.h +++ b/cpp/src/qpid/framing/AMQContentBody.h @@ -39,7 +39,7 @@ public: inline uint8_t type() const { return CONTENT_BODY; }; inline const string& getData() const { return data; } inline string& getData() { return data; } - uint32_t size() const; + uint32_t encodedSize() const; void encode(Buffer& buffer) const; void decode(Buffer& buffer, uint32_t size); void print(std::ostream& out) const; diff --git a/cpp/src/qpid/framing/AMQDataBlock.h b/cpp/src/qpid/framing/AMQDataBlock.h index 9b6fdfd966..0b1f459627 100644 --- a/cpp/src/qpid/framing/AMQDataBlock.h +++ b/cpp/src/qpid/framing/AMQDataBlock.h @@ -32,7 +32,7 @@ public: virtual ~AMQDataBlock() {} virtual void encode(Buffer& buffer) const = 0; virtual bool decode(Buffer& buffer) = 0; - virtual uint32_t size() const = 0; + virtual uint32_t encodedSize() const = 0; }; } diff --git a/cpp/src/qpid/framing/AMQFrame.cpp b/cpp/src/qpid/framing/AMQFrame.cpp index 662b3574ff..98a1354811 100644 --- a/cpp/src/qpid/framing/AMQFrame.cpp +++ b/cpp/src/qpid/framing/AMQFrame.cpp @@ -37,8 +37,8 @@ void AMQFrame::setBody(const AMQBody& b) { body = new BodyHolder(b); } void AMQFrame::setMethod(ClassId c, MethodId m) { body = new BodyHolder(c,m); } -uint32_t AMQFrame::size() const { - return frameOverhead() + body->size(); +uint32_t AMQFrame::encodedSize() const { + return frameOverhead() + body->encodedSize(); } uint32_t AMQFrame::frameOverhead() { @@ -60,7 +60,7 @@ void AMQFrame::encode(Buffer& buffer) const uint8_t flags = (bof ? 0x08 : 0) | (eof ? 0x04 : 0) | (bos ? 0x02 : 0) | (eos ? 0x01 : 0); buffer.putOctet(flags); buffer.putOctet(getBody()->type()); - buffer.putShort(size()); + buffer.putShort(encodedSize()); buffer.putOctet(0); buffer.putOctet(0x0f & track); buffer.putShort(channel); diff --git a/cpp/src/qpid/framing/AMQFrame.h b/cpp/src/qpid/framing/AMQFrame.h index 331a57e08d..ddfe438806 100644 --- a/cpp/src/qpid/framing/AMQFrame.h +++ b/cpp/src/qpid/framing/AMQFrame.h @@ -78,7 +78,7 @@ class AMQFrame : public AMQDataBlock void encode(Buffer& buffer) const; bool decode(Buffer& buffer); - uint32_t size() const; + uint32_t encodedSize() const; // 0-10 terminology: first/last frame (in segment) first/last segment (in assembly) diff --git a/cpp/src/qpid/framing/AMQHeaderBody.cpp b/cpp/src/qpid/framing/AMQHeaderBody.cpp index 724c288705..276418b208 100644 --- a/cpp/src/qpid/framing/AMQHeaderBody.cpp +++ b/cpp/src/qpid/framing/AMQHeaderBody.cpp @@ -22,8 +22,8 @@ #include "qpid/Exception.h" #include "qpid/log/Statement.h" -uint32_t qpid::framing::AMQHeaderBody::size() const { - return properties.size(); +uint32_t qpid::framing::AMQHeaderBody::encodedSize() const { + return properties.encodedSize(); } void qpid::framing::AMQHeaderBody::encode(Buffer& buffer) const { @@ -52,7 +52,7 @@ uint64_t qpid::framing::AMQHeaderBody::getContentLength() const void qpid::framing::AMQHeaderBody::print(std::ostream& out) const { - out << "header (" << size() << " bytes)"; + out << "header (" << encodedSize() << " bytes)"; out << "; properties={"; properties.print(out); out << "}"; diff --git a/cpp/src/qpid/framing/AMQHeaderBody.h b/cpp/src/qpid/framing/AMQHeaderBody.h index c69a768291..7ddb7d89cf 100644 --- a/cpp/src/qpid/framing/AMQHeaderBody.h +++ b/cpp/src/qpid/framing/AMQHeaderBody.h @@ -41,9 +41,9 @@ class AMQHeaderBody : public AMQBody template <class T> struct OptProps { boost::optional<T> props; }; template <class Base, class T> struct PropSet : public Base, public OptProps<T> { - uint32_t size() const { + uint32_t encodedSize() const { const boost::optional<T>& p=this->OptProps<T>::props; - return (p ? p->size() : 0) + Base::size(); + return (p ? p->encodedSize() : 0) + Base::encodedSize(); } void encode(Buffer& buffer) const { const boost::optional<T>& p=this->OptProps<T>::props; @@ -68,7 +68,7 @@ class AMQHeaderBody : public AMQBody }; struct Empty { - uint32_t size() const { return 0; } + uint32_t encodedSize() const { return 0; } void encode(Buffer&) const {}; bool decode(Buffer&, uint32_t, uint16_t) const { return false; }; void print(std::ostream&) const {} @@ -83,7 +83,7 @@ public: inline uint8_t type() const { return HEADER_BODY; } - uint32_t size() const; + uint32_t encodedSize() const; void encode(Buffer& buffer) const; void decode(Buffer& buffer, uint32_t size); uint64_t getContentLength() const; diff --git a/cpp/src/qpid/framing/AMQHeartbeatBody.h b/cpp/src/qpid/framing/AMQHeartbeatBody.h index a2701c3398..7b42b46e5c 100644 --- a/cpp/src/qpid/framing/AMQHeartbeatBody.h +++ b/cpp/src/qpid/framing/AMQHeartbeatBody.h @@ -32,7 +32,7 @@ class AMQHeartbeatBody : public AMQBody { public: virtual ~AMQHeartbeatBody(); - inline uint32_t size() const { return 0; } + inline uint32_t encodedSize() const { return 0; } inline uint8_t type() const { return HEARTBEAT_BODY; } inline void encode(Buffer& ) const {} inline void decode(Buffer& , uint32_t /*size*/) {} diff --git a/cpp/src/qpid/framing/AMQMethodBody.h b/cpp/src/qpid/framing/AMQMethodBody.h index da28ee3aa9..cc7489ddd9 100644 --- a/cpp/src/qpid/framing/AMQMethodBody.h +++ b/cpp/src/qpid/framing/AMQMethodBody.h @@ -54,7 +54,7 @@ class AMQMethodBody : public AMQBody { return amqpClassId()==T::CLASS_ID && amqpMethodId()==T::METHOD_ID; } - virtual uint32_t size() const = 0; + virtual uint32_t encodedSize() const = 0; virtual uint8_t type() const { return METHOD_BODY; } virtual bool isSync() const { return false; /*only ModelMethods can have the sync flag set*/ } diff --git a/cpp/src/qpid/framing/Array.cpp b/cpp/src/qpid/framing/Array.cpp index f0b6331ff3..bcee85f472 100644 --- a/cpp/src/qpid/framing/Array.cpp +++ b/cpp/src/qpid/framing/Array.cpp @@ -42,11 +42,11 @@ Array::Array(const std::vector<std::string>& in) } -uint32_t Array::size() const { +uint32_t Array::encodedSize() const { //note: size is only included when used as a 'top level' type uint32_t len(4/*size*/ + 1/*type*/ + 4/*count*/); for(ValueVector::const_iterator i = values.begin(); i != values.end(); ++i) { - len += (*i)->getData().size(); + len += (*i)->getData().encodedSize(); } return len; } @@ -65,7 +65,7 @@ std::ostream& operator<<(std::ostream& out, const Array& t) { } void Array::encode(Buffer& buffer) const{ - buffer.putLong(size() - 4);//size added only when array is a top-level type + buffer.putLong(encodedSize() - 4);//size added only when array is a top-level type buffer.putOctet(typeOctet); buffer.putLong(count()); for (ValueVector::const_iterator i = values.begin(); i!=values.end(); ++i) { @@ -87,9 +87,9 @@ void Array::decode(Buffer& buffer){ FieldValue dummy; dummy.setType(typeOctet); available = buffer.available(); - if (available < count * dummy.getData().size()) { + if (available < count * dummy.getData().encodedSize()) { throw IllegalArgumentException(QPID_MSG("Not enough data for array, expected " - << count << " items of " << dummy.getData().size() + << count << " items of " << dummy.getData().encodedSize() << " bytes each but only " << available << " bytes available")); } diff --git a/cpp/src/qpid/framing/Array.h b/cpp/src/qpid/framing/Array.h index 2cbd4c0b29..b18b86fa35 100644 --- a/cpp/src/qpid/framing/Array.h +++ b/cpp/src/qpid/framing/Array.h @@ -39,7 +39,7 @@ class Array typedef boost::shared_ptr<FieldValue> ValuePtr; typedef std::vector<ValuePtr> ValueVector; - uint32_t size() const; + uint32_t encodedSize() const; void encode(Buffer& buffer) const; void decode(Buffer& buffer); diff --git a/cpp/src/qpid/framing/BodyHolder.cpp b/cpp/src/qpid/framing/BodyHolder.cpp index 1b2f74de2c..b30a52a38e 100644 --- a/cpp/src/qpid/framing/BodyHolder.cpp +++ b/cpp/src/qpid/framing/BodyHolder.cpp @@ -64,12 +64,12 @@ void BodyHolder::decode(uint8_t type, Buffer& buffer, uint32_t size) { get()->decode(buffer, size); } -uint32_t BodyHolder::size() const { +uint32_t BodyHolder::encodedSize() const { const AMQMethodBody* method=getMethod(); if (method) - return sizeof(ClassId)+sizeof(MethodId)+method->size(); + return sizeof(ClassId)+sizeof(MethodId)+method->encodedSize(); else - return get()->size(); + return get()->encodedSize(); } }} // namespace qpid::framing diff --git a/cpp/src/qpid/framing/BodyHolder.h b/cpp/src/qpid/framing/BodyHolder.h index f843961a32..0a35bb5e99 100644 --- a/cpp/src/qpid/framing/BodyHolder.h +++ b/cpp/src/qpid/framing/BodyHolder.h @@ -69,7 +69,7 @@ class BodyHolder : public RefCounted void encode(Buffer&) const; void decode(uint8_t frameType, Buffer&, uint32_t=0); - uint32_t size() const; + uint32_t encodedSize() const; /** Return body pointer or 0 if empty. */ AMQBody* get() { return blob.get(); } diff --git a/cpp/src/qpid/framing/FieldTable.cpp b/cpp/src/qpid/framing/FieldTable.cpp index 1658a0bf9b..290983e304 100644 --- a/cpp/src/qpid/framing/FieldTable.cpp +++ b/cpp/src/qpid/framing/FieldTable.cpp @@ -31,11 +31,11 @@ namespace framing { FieldTable::~FieldTable() {} -uint32_t FieldTable::size() const { +uint32_t FieldTable::encodedSize() const { uint32_t len(4/*size field*/ + 4/*count field*/); for(ValueMap::const_iterator i = values.begin(); i != values.end(); ++i) { // shortstr_len_byte + key size + value size - len += 1 + (i->first).size() + (i->second)->size(); + len += 1 + (i->first).size() + (i->second)->encodedSize(); } return len; } @@ -161,7 +161,7 @@ bool FieldTable::getDouble(const std::string& name, double& value) const { } void FieldTable::encode(Buffer& buffer) const{ - buffer.putLong(size() - 4); + buffer.putLong(encodedSize() - 4); buffer.putLong(values.size()); for (ValueMap::const_iterator i = values.begin(); i!=values.end(); ++i) { buffer.putShortString(i->first); diff --git a/cpp/src/qpid/framing/FieldTable.h b/cpp/src/qpid/framing/FieldTable.h index 1b6ef0a124..6dcc2ea7b4 100644 --- a/cpp/src/qpid/framing/FieldTable.h +++ b/cpp/src/qpid/framing/FieldTable.h @@ -52,7 +52,7 @@ class FieldTable typedef ValueMap::iterator iterator; ~FieldTable(); - uint32_t size() const; + uint32_t encodedSize() const; void encode(Buffer& buffer) const; void decode(Buffer& buffer); diff --git a/cpp/src/qpid/framing/FieldValue.h b/cpp/src/qpid/framing/FieldValue.h index 232c4a5cad..17f858989e 100644 --- a/cpp/src/qpid/framing/FieldValue.h +++ b/cpp/src/qpid/framing/FieldValue.h @@ -65,7 +65,7 @@ class FieldValue { class Data { public: virtual ~Data() {}; - virtual uint32_t size() const = 0; + virtual uint32_t encodedSize() const = 0; virtual void encode(Buffer& buffer) = 0; virtual void decode(Buffer& buffer) = 0; virtual bool operator==(const Data&) const = 0; @@ -83,7 +83,7 @@ class FieldValue { void setType(uint8_t type); uint8_t getType(); Data& getData() { return *data; } - uint32_t size() const { return 1 + data->size(); }; + uint32_t encodedSize() const { return 1 + data->encodedSize(); }; bool empty() const { return data.get() == 0; } void encode(Buffer& buffer); void decode(Buffer& buffer); @@ -137,7 +137,7 @@ class FixedWidthValue : public FieldValue::Data { } octets[0] = (uint8_t) (0xFF & v); } - uint32_t size() const { return width; } + uint32_t encodedSize() const { return width; } void encode(Buffer& buffer) { buffer.putRawData(octets, width); } void decode(Buffer& buffer) { buffer.getRawData(octets, width); } bool operator==(const Data& d) const { @@ -168,7 +168,7 @@ template <> class FixedWidthValue<0> : public FieldValue::Data { public: // Implicit default constructor is fine - uint32_t size() const { return 0; } + uint32_t encodedSize() const { return 0; } void encode(Buffer&) {}; void decode(Buffer&) {}; bool operator==(const Data& d) const { @@ -186,7 +186,7 @@ class VariableWidthValue : public FieldValue::Data { VariableWidthValue() {} VariableWidthValue(const std::vector<uint8_t>& data) : octets(data) {} VariableWidthValue(const uint8_t* start, const uint8_t* end) : octets(start, end) {} - uint32_t size() const { return lenwidth + octets.size(); } + uint32_t encodedSize() const { return lenwidth + octets.size(); } void encode(Buffer& buffer) { buffer.putUInt<lenwidth>(octets.size()); buffer.putRawData(&octets[0], octets.size()); @@ -219,7 +219,7 @@ class EncodedValue : public FieldValue::Data { T& getValue() { return value; } const T& getValue() const { return value; } - uint32_t size() const { return value.size(); } + uint32_t encodedSize() const { return value.encodedSize(); } void encode(Buffer& buffer) { value.encode(buffer); diff --git a/cpp/src/qpid/framing/HeaderProperties.h b/cpp/src/qpid/framing/HeaderProperties.h index d66c1d00d6..39c448fc3c 100644 --- a/cpp/src/qpid/framing/HeaderProperties.h +++ b/cpp/src/qpid/framing/HeaderProperties.h @@ -33,7 +33,7 @@ namespace framing { public: inline virtual ~HeaderProperties(){} virtual uint8_t classId() const = 0; - virtual uint32_t size() const = 0; + virtual uint32_t encodedSize() const = 0; virtual void encode(Buffer& buffer) const = 0; virtual void decode(Buffer& buffer, uint32_t size) = 0; }; diff --git a/cpp/src/qpid/framing/ModelMethod.h b/cpp/src/qpid/framing/ModelMethod.h index 8e4361e761..afbdf7b6e2 100644 --- a/cpp/src/qpid/framing/ModelMethod.h +++ b/cpp/src/qpid/framing/ModelMethod.h @@ -35,7 +35,7 @@ public: virtual ~ModelMethod() {} virtual void encodeHeader(Buffer& buffer) const { header.encode(buffer); } virtual void decodeHeader(Buffer& buffer, uint32_t size=0) { header.decode(buffer, size); } - virtual uint32_t headerSize() const { return header.size(); } + virtual uint32_t headerSize() const { return header.encodedSize(); } virtual bool isSync() const { return header.getSync(); } virtual void setSync(bool on) const { header.setSync(on); } Header& getHeader() { return header; } diff --git a/cpp/src/qpid/framing/ProtocolInitiation.h b/cpp/src/qpid/framing/ProtocolInitiation.h index 43e32da4cf..6584fee55c 100644 --- a/cpp/src/qpid/framing/ProtocolInitiation.h +++ b/cpp/src/qpid/framing/ProtocolInitiation.h @@ -41,7 +41,7 @@ public: virtual ~ProtocolInitiation(); virtual void encode(Buffer& buffer) const; virtual bool decode(Buffer& buffer); - inline virtual uint32_t size() const { return 8; } + inline virtual uint32_t encodedSize() const { return 8; } inline uint8_t getMajor() const { return version.getMajor(); } inline uint8_t getMinor() const { return version.getMinor(); } inline ProtocolVersion getVersion() const { return version; } diff --git a/cpp/src/qpid/framing/SendContent.cpp b/cpp/src/qpid/framing/SendContent.cpp index a62e4eeb72..f390106dee 100644 --- a/cpp/src/qpid/framing/SendContent.cpp +++ b/cpp/src/qpid/framing/SendContent.cpp @@ -34,13 +34,13 @@ void qpid::framing::SendContent::operator()(const AMQFrame& f) real frame size, hence substract -1 from frameOverhead()*/ uint16_t maxContentSize = maxFrameSize - (AMQFrame::frameOverhead() - 1); const AMQContentBody* body(f.castBody<AMQContentBody>()); - if (body->size() > maxContentSize) { + if (body->encodedSize() > maxContentSize) { uint32_t offset = 0; - for (int chunk = body->size() / maxContentSize; chunk > 0; chunk--) { - sendFragment(*body, offset, maxContentSize, first && offset == 0, last && offset + maxContentSize == body->size()); + for (int chunk = body->encodedSize() / maxContentSize; chunk > 0; chunk--) { + sendFragment(*body, offset, maxContentSize, first && offset == 0, last && offset + maxContentSize == body->encodedSize()); offset += maxContentSize; } - uint32_t remainder = body->size() % maxContentSize; + uint32_t remainder = body->encodedSize() % maxContentSize; if (remainder) { sendFragment(*body, offset, remainder, first && offset == 0, last); } diff --git a/cpp/src/qpid/framing/SequenceNumber.cpp b/cpp/src/qpid/framing/SequenceNumber.cpp index 7caaf5440b..cac4e6681e 100644 --- a/cpp/src/qpid/framing/SequenceNumber.cpp +++ b/cpp/src/qpid/framing/SequenceNumber.cpp @@ -90,7 +90,7 @@ void SequenceNumber::decode(Buffer& buffer) value = buffer.getLong(); } -uint32_t SequenceNumber::size() const { +uint32_t SequenceNumber::encodedSize() const { return 4; } diff --git a/cpp/src/qpid/framing/SequenceNumber.h b/cpp/src/qpid/framing/SequenceNumber.h index aacd77501b..930e146863 100644 --- a/cpp/src/qpid/framing/SequenceNumber.h +++ b/cpp/src/qpid/framing/SequenceNumber.h @@ -56,7 +56,7 @@ class SequenceNumber void encode(Buffer& buffer) const; void decode(Buffer& buffer); - uint32_t size() const; + uint32_t encodedSize() const; template <class S> void serialize(S& s) { s(value); } }; diff --git a/cpp/src/qpid/framing/SequenceSet.cpp b/cpp/src/qpid/framing/SequenceSet.cpp index 9610b9180c..2046fac3e1 100644 --- a/cpp/src/qpid/framing/SequenceSet.cpp +++ b/cpp/src/qpid/framing/SequenceSet.cpp @@ -56,7 +56,7 @@ void SequenceSet::decode(Buffer& buffer) } } -uint32_t SequenceSet::size() const { +uint32_t SequenceSet::encodedSize() const { return 2 /*size field*/ + (rangesSize() * RANGE_SIZE); } diff --git a/cpp/src/qpid/framing/SequenceSet.h b/cpp/src/qpid/framing/SequenceSet.h index 99e7cb4b21..8d97d03c4b 100644 --- a/cpp/src/qpid/framing/SequenceSet.h +++ b/cpp/src/qpid/framing/SequenceSet.h @@ -39,7 +39,7 @@ class SequenceSet : public RangeSet<SequenceNumber> { void encode(Buffer& buffer) const; void decode(Buffer& buffer); - uint32_t size() const; + uint32_t encodedSize() const; bool contains(const SequenceNumber& s) const; void add(const SequenceNumber& s); diff --git a/cpp/src/qpid/framing/Uuid.h b/cpp/src/qpid/framing/Uuid.h index e3e309a56c..310d95a6cc 100644 --- a/cpp/src/qpid/framing/Uuid.h +++ b/cpp/src/qpid/framing/Uuid.h @@ -64,8 +64,8 @@ struct Uuid : public boost::array<uint8_t, 16> { // boost::array gives us ==, < etc. void encode(framing::Buffer& buf) const; - void decode(framing::Buffer& buf); + uint32_t encodedSize() const { return size(); } /** String value in format 1b4e28ba-2fa1-11d2-883f-b9a761bde3fb. */ std::string str(); diff --git a/cpp/src/qpid/framing/frame_functors.h b/cpp/src/qpid/framing/frame_functors.h index 8ae3d15b4f..d2064d6a57 100644 --- a/cpp/src/qpid/framing/frame_functors.h +++ b/cpp/src/qpid/framing/frame_functors.h @@ -36,7 +36,7 @@ class SumFrameSize uint64_t size; public: SumFrameSize() : size(0) {} - void operator()(const AMQFrame& f) { size += f.size(); } + void operator()(const AMQFrame& f) { size += f.encodedSize(); } uint64_t getSize() { return size; } }; @@ -45,7 +45,7 @@ class SumBodySize uint64_t size; public: SumBodySize() : size(0) {} - void operator()(const AMQFrame& f) { size += f.getBody()->size(); } + void operator()(const AMQFrame& f) { size += f.getBody()->encodedSize(); } uint64_t getSize() { return size; } }; |