diff options
author | Alan Conway <aconway@apache.org> | 2006-10-11 15:50:15 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2006-10-11 15:50:15 +0000 |
commit | 2bcadbb42a6fb2f096c1fc0a4b957d64a5024ef6 (patch) | |
tree | 886eb0659c6f28c2f1d26de7d5fd29fff0072dc5 /cpp/client/src/Channel.cpp | |
parent | 9fc2b6c5f0848d65f1bf20e62279c055d12a1d40 (diff) | |
download | qpid-python-2bcadbb42a6fb2f096c1fc0a4b957d64a5024ef6.tar.gz |
Turned up gcc warnings, fixed warnings in code, enabled -Werror.
Note: #include "qpid_test_plugin.h" instead of <cppunit/TestPlugin.h>
Works around warning from a cppunit macro.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@462834 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/client/src/Channel.cpp')
-rw-r--r-- | cpp/client/src/Channel.cpp | 26 |
1 files changed, 16 insertions, 10 deletions
diff --git a/cpp/client/src/Channel.cpp b/cpp/client/src/Channel.cpp index e965f7e5dd..cf2f5bc081 100644 --- a/cpp/client/src/Channel.cpp +++ b/cpp/client/src/Channel.cpp @@ -26,11 +26,16 @@ using namespace qpid::client; using namespace qpid::framing; using namespace qpid::concurrent; -Channel::Channel(bool _transactional, u_int16_t _prefetch) : id(0), incoming(0), con(0), out(0), - prefetch(_prefetch), - transactional(_transactional), - dispatcher(0), - closed(true){ +Channel::Channel(bool _transactional, u_int16_t _prefetch) : + id(0), + con(0), + dispatcher(0), + out(0), + incoming(0), + closed(true), + prefetch(_prefetch), + transactional(_transactional) +{ threadFactory = new ThreadFactoryImpl(); dispatchMonitor = new MonitorImpl(); retrievalMonitor = new MonitorImpl(); @@ -46,8 +51,8 @@ Channel::~Channel(){ delete threadFactory; } -void Channel::setPrefetch(u_int16_t prefetch){ - this->prefetch = prefetch; +void Channel::setPrefetch(u_int16_t _prefetch){ + prefetch = _prefetch; if(con != 0 && out != 0){ setQos(); } @@ -114,7 +119,9 @@ void Channel::deleteQueue(Queue& queue, bool ifunused, bool ifempty, bool synch) void Channel::bind(const Exchange& exchange, const Queue& queue, const std::string& key, const FieldTable& args, bool synch){ string e = exchange.getName(); string q = queue.getName(); - AMQFrame* frame = new AMQFrame(id, new QueueBindBody(0, q, e, (string&) key,!synch, (FieldTable&) args)); + // TODO aconway 2006-10-10: not const correct, get rid of const_cast. + // + AMQFrame* frame = new AMQFrame(id, new QueueBindBody(0, q, e, key,!synch, const_cast<FieldTable&>(args))); if(synch){ sendAndReceive(frame, queue_bind_ok); }else{ @@ -160,7 +167,6 @@ void Channel::cancel(std::string& tag, bool synch){ } void Channel::cancelAll(){ - int count(consumers.size()); for(consumer_iterator i = consumers.begin(); i != consumers.end(); i = consumers.begin()){ Consumer* c = i->second; if((c->ackMode == LAZY_ACK || c->ackMode == AUTO_ACK) && c->lastDeliveryTag > 0){ @@ -306,7 +312,7 @@ void Channel::handleContent(AMQContentBody::shared_ptr body){ } } -void Channel::handleHeartbeat(AMQHeartbeatBody::shared_ptr body){ +void Channel::handleHeartbeat(AMQHeartbeatBody::shared_ptr /*body*/){ THROW_QPID_ERROR(PROTOCOL_ERROR + 504, "Channel received heartbeat"); } |