You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by jh...@apache.org on 2017/07/10 16:10:09 UTC

hadoop git commit: HDFS-12104: libhdfs++: Make sure all steps in SaslProtocol end up calling AuthComplete. Contributed by James Clampffer.

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 <ja...@hp.com>
Authored: Mon Jul 10 12:09:30 2017 -0400
Committer: James Clampffer <ja...@hp.com>
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: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org