summaryrefslogtreecommitdiff
path: root/cpp/lib/broker/BrokerChannel.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/BrokerChannel.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/BrokerChannel.cpp')
-rw-r--r--cpp/lib/broker/BrokerChannel.cpp14
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);
}