diff options
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) { |