Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-10685: libhdfs++: return explicit error when non-secured client connects to secured server. Contributed by Kai Jiang.

This commit is contained in:
James 2017-01-11 10:54:50 -05:00 committed by James Clampffer
parent 69d55340f8
commit 58de2df860
4 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/include/hdfspp/status.h
View File

@ -43,6 +43,7 @@ class Status {
static Status Exception(const char *exception_class_name, const char *exception_details); static Status Exception(const char *exception_class_name, const char *exception_details);
static Status Error(const char *error_message); static Status Error(const char *error_message);
static Status AuthenticationFailed(); static Status AuthenticationFailed();
static Status AuthenticationFailed(const char *msg);
static Status Canceled(); static Status Canceled();
static Status PathNotFound(const char *msg); static Status PathNotFound(const char *msg);
static Status InvalidOffset(const char *msg); static Status InvalidOffset(const char *msg);

11
hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/common/status.cc
View File

@ -131,7 +131,16 @@ Status Status::Error(const char *error_message) {
} }
Status Status::AuthenticationFailed() { Status Status::AuthenticationFailed() {
return Status(kAuthenticationFailed, "Authentication failed"); return Status::AuthenticationFailed(nullptr);
}
Status Status::AuthenticationFailed(const char *msg) {
std::string formatted = "AuthenticationFailed";
if(msg) {
formatted += ": ";
formatted += msg;
}
return Status(kAuthenticationFailed, formatted.c_str());
} }
Status Status::Canceled() { Status Status::Canceled() {

2
hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/rpc/cyrus_sasl_engine.cc
View File

@ -91,7 +91,7 @@ Status make_status(int rc) {
if (rc != SASL_OK && if (rc != SASL_OK &&
rc != SASL_CONTINUE && rc != SASL_CONTINUE &&
rc != SASL_INTERACT) { rc != SASL_INTERACT) {
return Status::Error(errStr(rc).c_str()); return Status::AuthenticationFailed(errStr(rc).c_str());
} }
return Status::OK(); return Status::OK();
} }

4
hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/rpc/rpc_connection.cc
View File

@ -293,8 +293,12 @@ Status RpcConnection::HandleRpcResponse(std::shared_ptr<Response> response) {
auto req = RemoveFromRunningQueue(h.callid()); auto req = RemoveFromRunningQueue(h.callid());
if (!req) { if (!req) {
LOG_WARN(kRPC, << "RPC response with Unknown call id " << h.callid()); LOG_WARN(kRPC, << "RPC response with Unknown call id " << h.callid());
if((int32_t)h.callid() == RpcEngine::kCallIdSasl) {
return Status::AuthenticationFailed("You have an unsecured client connecting to a secured server");
} else {
return Status::Error("Rpc response with unknown call id"); return Status::Error("Rpc response with unknown call id");
} }
}
Status status; Status status;
if(event_handlers_) { if(event_handlers_) {