Repository: hadoop Updated Branches: refs/heads/HDFS-8707 821f9717e -> d8ffe0a34
HDFS-12104: libhdfs++: Make sure all steps in SaslProtocol end up calling AuthComplete. Contributed by James Clampffer. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d8ffe0a3 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d8ffe0a3 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d8ffe0a3 Branch: refs/heads/HDFS-8707 Commit: d8ffe0a34e056f183416e72c5a782e1f2a922b0e Parents: 821f971 Author: James Clampffer <[email protected]> Authored: Mon Jul 10 12:09:30 2017 -0400 Committer: James Clampffer <[email protected]> Committed: Mon Jul 10 12:09:30 2017 -0400 ---------------------------------------------------------------------- .../src/main/native/libhdfspp/lib/rpc/sasl_protocol.cc | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/d8ffe0a3/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/rpc/sasl_protocol.cc ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/rpc/sasl_protocol.cc b/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/rpc/sasl_protocol.cc index 49abe58..3d40c0f 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/rpc/sasl_protocol.cc +++ b/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/rpc/sasl_protocol.cc @@ -87,6 +87,7 @@ void SaslProtocol::Authenticate(std::function<void(const Status & status, const // We cheat here since this is always called while holding the RpcConnection's lock std::shared_ptr<RpcConnection> connection = connection_.lock(); if (!connection) { + AuthComplete(Status::AuthenticationFailed("Lost RPC Connection"), AuthInfo()); return; } @@ -335,6 +336,7 @@ bool SaslProtocol::SendSaslMessage(RpcSaslProto & message) std::shared_ptr<RpcConnection> connection = connection_.lock(); if (!connection) { LOG_DEBUG(kRPC, << "Tried sending a SASL Message but the RPC connection was gone"); + AuthComplete(Status::AuthenticationFailed("Lost RPC Connection"), AuthInfo()); return false; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
