diff options
author | Michael Goulish <mgoulish@apache.org> | 2012-01-05 14:56:52 +0000 |
---|---|---|
committer | Michael Goulish <mgoulish@apache.org> | 2012-01-05 14:56:52 +0000 |
commit | ae66de1155adb70f1b55e18bc096e3e107489a5d (patch) | |
tree | 485ffc501cec50b80146bf2e449d9b279d663f06 /cpp/src | |
parent | 47b2ee30c1a05389f605ee90e2dfd9d19fe00101 (diff) | |
download | qpid-python-ae66de1155adb70f1b55e18bc096e3e107489a5d.tar.gz |
QPID-3438
Remove unnecessary changes to broker. The cluster code does not really need
to know that the cnx error was due to auth failure. Any failure before the cnx
has opened should cause the cnx to be removed from the 'local' map, or a cnx leak
will occur.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1227616 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
-rw-r--r-- | cpp/src/qpid/broker/Connection.cpp | 3 | ||||
-rw-r--r-- | cpp/src/qpid/broker/Connection.h | 5 | ||||
-rw-r--r-- | cpp/src/qpid/broker/SaslAuthenticator.cpp | 1 | ||||
-rw-r--r-- | cpp/src/qpid/cluster/Connection.cpp | 2 |
4 files changed, 1 insertions, 10 deletions
diff --git a/cpp/src/qpid/broker/Connection.cpp b/cpp/src/qpid/broker/Connection.cpp index 9df49b3ff1..8451f35cb0 100644 --- a/cpp/src/qpid/broker/Connection.cpp +++ b/cpp/src/qpid/broker/Connection.cpp @@ -100,8 +100,7 @@ Connection::Connection(ConnectionOutputHandler* out_, errorListener(0), objectId(objectId_), shadow(shadow_), - outboundTracker(*this), - securityFailed(false) + outboundTracker(*this) { outboundTracker.wrap(out); if (isLink) diff --git a/cpp/src/qpid/broker/Connection.h b/cpp/src/qpid/broker/Connection.h index e4dea33494..742783c052 100644 --- a/cpp/src/qpid/broker/Connection.h +++ b/cpp/src/qpid/broker/Connection.h @@ -207,13 +207,8 @@ class Connection : public sys::ConnectionInputHandler, void sent(const framing::AMQFrame& f); - bool securityFailed; - public: - bool securityFailure ( ) const { return securityFailed; } - void securityFailure ( bool failed ) { securityFailed = failed; } - qmf::org::apache::qpid::broker::Connection* getMgmtObject() { return mgmtObject; } }; diff --git a/cpp/src/qpid/broker/SaslAuthenticator.cpp b/cpp/src/qpid/broker/SaslAuthenticator.cpp index 54692a2781..d7adbd68ab 100644 --- a/cpp/src/qpid/broker/SaslAuthenticator.cpp +++ b/cpp/src/qpid/broker/SaslAuthenticator.cpp @@ -450,7 +450,6 @@ void CyrusAuthenticator::processAuthenticationStep(int code, const char *challen client.secure(challenge_str); } else { - connection.securityFailure ( true ); std::string uid; //save error detail before trying to retrieve username as error in doing so will overwrite it std::string errordetail = sasl_errdetail(sasl_conn); diff --git a/cpp/src/qpid/cluster/Connection.cpp b/cpp/src/qpid/cluster/Connection.cpp index 88a2806877..f77b6fc748 100644 --- a/cpp/src/qpid/cluster/Connection.cpp +++ b/cpp/src/qpid/cluster/Connection.cpp @@ -742,9 +742,7 @@ void Connection::connectionError(const std::string& msg) { cluster.flagError(*this, ERROR_TYPE_CONNECTION, msg); } else - if ( connection->securityFailure() ) { cluster.eraseLocal(self); - } } void Connection::addQueueListener(const std::string& q, uint32_t listener) { |