summaryrefslogtreecommitdiff
path: root/cpp/lib/broker/BrokerMessageMessage.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2007-03-15 19:22:02 +0000
committerAlan Conway <aconway@apache.org>2007-03-15 19:22:02 +0000
commit6bc8ab8e4b209b841969544fc735361335040906 (patch)
tree90b8a4b3f0ec4fdf2c3a0ac02b27768b953a3be1 /cpp/lib/broker/BrokerMessageMessage.cpp
parentf92c42ffe7662d1d0e2863c6e143567b25ae2024 (diff)
downloadqpid-python-6bc8ab8e4b209b841969544fc735361335040906.tar.gz
Changed u_int<n>_t to uint<n>_t for posix compliance.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@518733 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/lib/broker/BrokerMessageMessage.cpp')
-rw-r--r--cpp/lib/broker/BrokerMessageMessage.cpp26
1 files changed, 13 insertions, 13 deletions
diff --git a/cpp/lib/broker/BrokerMessageMessage.cpp b/cpp/lib/broker/BrokerMessageMessage.cpp
index 72efe6ea40..3449078d70 100644
--- a/cpp/lib/broker/BrokerMessageMessage.cpp
+++ b/cpp/lib/broker/BrokerMessageMessage.cpp
@@ -65,7 +65,7 @@ MessageMessage::MessageMessage(
void MessageMessage::transferMessage(
framing::ChannelAdapter& channel,
const std::string& consumerTag,
- u_int32_t framesize)
+ uint32_t framesize)
{
const framing::Content& body = transfer->getBody();
@@ -77,11 +77,11 @@ void MessageMessage::transferMessage(
for(Reference::Appends::const_iterator a = reference->getAppends().begin();
a != reference->getAppends().end();
++a) {
- u_int32_t sizeleft = (*a)->size();
+ uint32_t sizeleft = (*a)->size();
const string& content = (*a)->getBytes();
// Calculate overhead bytes
// Assume that the overhead is constant as the reference name doesn't change
- u_int32_t overhead = sizeleft - content.size();
+ uint32_t overhead = sizeleft - content.size();
string::size_type contentStart = 0;
while (sizeleft) {
string::size_type contentSize = sizeleft <= framesize ? sizeleft : framesize-overhead;
@@ -167,8 +167,8 @@ void MessageMessage::transferMessage(
void MessageMessage::deliver(
framing::ChannelAdapter& channel,
const std::string& consumerTag,
- u_int64_t /*deliveryTag*/,
- u_int32_t framesize)
+ uint64_t /*deliveryTag*/,
+ uint32_t framesize)
{
transferMessage(channel, consumerTag, framesize);
}
@@ -176,9 +176,9 @@ void MessageMessage::deliver(
void MessageMessage::sendGetOk(
const framing::MethodContext& context,
const std::string& destination,
- u_int32_t /*messageCount*/,
- u_int64_t /*deliveryTag*/,
- u_int32_t framesize)
+ uint32_t /*messageCount*/,
+ uint64_t /*deliveryTag*/,
+ uint32_t framesize)
{
framing::ChannelAdapter* channel = context.channel;
transferMessage(*channel, destination, framesize);
@@ -189,7 +189,7 @@ bool MessageMessage::isComplete()
return true;
}
-u_int64_t MessageMessage::contentSize() const
+uint64_t MessageMessage::contentSize() const
{
if (transfer->getBody().isInline())
return transfer->getBody().getValue().size();
@@ -211,25 +211,25 @@ bool MessageMessage::isPersistent()
return transfer->getDeliveryMode() == PERSISTENT;
}
-u_int32_t MessageMessage::encodedSize()
+uint32_t MessageMessage::encodedSize()
{
THROW_QPID_ERROR(INTERNAL_ERROR, "Unfinished");
return 0; // FIXME aconway 2007-02-05:
}
-u_int32_t MessageMessage::encodedHeaderSize()
+uint32_t MessageMessage::encodedHeaderSize()
{
THROW_QPID_ERROR(INTERNAL_ERROR, "Unfinished");
return 0; // FIXME aconway 2007-02-05:
}
-u_int32_t MessageMessage::encodedContentSize()
+uint32_t MessageMessage::encodedContentSize()
{
THROW_QPID_ERROR(INTERNAL_ERROR, "Unfinished");
return 0; // FIXME aconway 2007-02-05:
}
-u_int64_t MessageMessage::expectedContentSize()
+uint64_t MessageMessage::expectedContentSize()
{
THROW_QPID_ERROR(INTERNAL_ERROR, "Unfinished");
return 0; // FIXME aconway 2007-02-05: