summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Connection.cpp
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2009-11-17 21:08:10 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2009-11-17 21:08:10 +0000
commit520f9d2bd95379fbbcc83e8812bfaa531387f937 (patch)
tree3592f0ac60ac67dcedfea3f54881096cb92490ba /cpp/src/qpid/broker/Connection.cpp
parent86562de96c2d63ca37e8c5435d29ae877fe34929 (diff)
downloadqpid-python-520f9d2bd95379fbbcc83e8812bfaa531387f937.tar.gz
QPID-2188 , support for maxConnections, limit is set to broker
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@881517 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Connection.cpp')
-rw-r--r--cpp/src/qpid/broker/Connection.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Connection.cpp b/cpp/src/qpid/broker/Connection.cpp
index 7aa632c5a5..17de83e033 100644
--- a/cpp/src/qpid/broker/Connection.cpp
+++ b/cpp/src/qpid/broker/Connection.cpp
@@ -102,6 +102,7 @@ Connection::Connection(ConnectionOutputHandler* out_, Broker& broker_, const std
}
ConnectionState::setUrl(mgmtId);
}
+ if (!isShadow()) broker.getConnectionCounter().inc_connectionCount();
}
void Connection::requestIOProcessing(boost::function0<void> callback)
@@ -125,6 +126,8 @@ Connection::~Connection()
heartbeatTimer->cancel();
if (timeoutTimer)
timeoutTimer->cancel();
+
+ if (!isShadow()) broker.getConnectionCounter().dec_connectionCount();
}
void Connection::received(framing::AMQFrame& frame) {