summaryrefslogtreecommitdiff
path: root/cpp/src
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src')
-rw-r--r--cpp/src/qpid/broker/Connection.cpp3
-rw-r--r--cpp/src/qpid/broker/Connection.h5
-rw-r--r--cpp/src/qpid/broker/SaslAuthenticator.cpp1
-rw-r--r--cpp/src/qpid/cluster/Connection.cpp2
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) {