diff options
author | Alan Conway <aconway@apache.org> | 2007-03-15 19:22:02 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2007-03-15 19:22:02 +0000 |
commit | 6bc8ab8e4b209b841969544fc735361335040906 (patch) | |
tree | 90b8a4b3f0ec4fdf2c3a0ac02b27768b953a3be1 /cpp/lib/broker/BrokerChannel.cpp | |
parent | f92c42ffe7662d1d0e2863c6e143567b25ae2024 (diff) | |
download | qpid-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/BrokerChannel.cpp')
-rw-r--r-- | cpp/lib/broker/BrokerChannel.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/cpp/lib/broker/BrokerChannel.cpp b/cpp/lib/broker/BrokerChannel.cpp index 47f6686b9e..5673a2c42a 100644 --- a/cpp/lib/broker/BrokerChannel.cpp +++ b/cpp/lib/broker/BrokerChannel.cpp @@ -49,8 +49,8 @@ using namespace qpid::sys; Channel::Channel( Connection& con, ChannelId id, - u_int32_t _framesize, MessageStore* const _store, - u_int64_t _stagingThreshold + uint32_t _framesize, MessageStore* const _store, + uint64_t _stagingThreshold ) : ChannelAdapter(id, &con.getOutput(), con.getVersion()), connection(con), @@ -130,7 +130,7 @@ void Channel::deliver( Mutex::ScopedLock locker(deliveryLock); // Key the delivered messages to the id of the request in which they're sent - u_int64_t deliveryTag = getNextSendRequestId(); + uint64_t deliveryTag = getNextSendRequestId(); if(ackExpected){ unacked.push_back(DeliveryRecord(msg, queue, consumerTag, deliveryTag)); @@ -239,14 +239,14 @@ void Channel::ack(){ } // Used by Basic -void Channel::ack(u_int64_t deliveryTag, bool multiple){ +void Channel::ack(uint64_t deliveryTag, bool multiple){ if (multiple) ack(0, deliveryTag); else ack(deliveryTag, deliveryTag); } -void Channel::ack(u_int64_t firstTag, u_int64_t lastTag){ +void Channel::ack(uint64_t firstTag, uint64_t lastTag){ if(transactional){ accumulatedAck.update(firstTag, lastTag); @@ -300,7 +300,7 @@ bool Channel::get(Queue::shared_ptr queue, const string& destination, bool ackEx Message::shared_ptr msg = queue->dequeue(); if(msg){ Mutex::ScopedLock locker(deliveryLock); - u_int64_t myDeliveryTag = getNextSendRequestId(); + uint64_t myDeliveryTag = getNextSendRequestId(); msg->sendGetOk(MethodContext(this, msg->getRespondTo()), destination, queue->getMessageCount() + 1, myDeliveryTag, @@ -315,7 +315,7 @@ bool Channel::get(Queue::shared_ptr queue, const string& destination, bool ackEx } void Channel::deliver(Message::shared_ptr& msg, const string& consumerTag, - u_int64_t deliveryTag) + uint64_t deliveryTag) { msg->deliver(*this, consumerTag, deliveryTag, framesize); } |