feat(security): init kerberos

include/dsn/c/app_model.h

@@ -61,18 +61,18 @@ extern DSN_API bool dsn_mimic_app(const char *app_role, int index);
  start the system with given configuration
 
  \param config           the configuration file for this run
- \param sleep_after_init whether to sleep after rDSN initialization, default is false
+ \param is_server whether it is server or not, default is false
 
  \return true if it succeeds, false if it fails.
  */
-extern DSN_API bool dsn_run_config(const char *config, bool sleep_after_init DEFAULT(false));
+extern DSN_API bool dsn_run_config(const char *config, bool is_server DEFAULT(false));
 
 /*!
  start the system with given arguments
 
  \param argc             argc in C main convention
  \param argv             argv in C main convention
- \param sleep_after_init whether to sleep after rDSN initialization, default is false
+ \param is_server whether it is server or not, default is false
 
  \return true if it succeeds, false if it fails.
 
@@ -89,7 +89,7 @@ extern DSN_API bool dsn_run_config(const char *config, bool sleep_after_init DEF
 
  Note the argc, argv folllows the C main convention that argv[0] is the executable name.
  */
-extern DSN_API void dsn_run(int argc, char **argv, bool sleep_after_init DEFAULT(false));
+extern DSN_API void dsn_run(int argc, char **argv, bool is_server DEFAULT(false));
 
 /*!
  exit the process with the given exit code

include/dsn/utility/error_code.h

@@ -121,4 +121,5 @@ DEFINE_ERR_CODE(ERR_ZOOKEEPER_OPERATION)
 DEFINE_ERR_CODE(ERR_CHILD_REGISTERED)
 DEFINE_ERR_CODE(ERR_INGESTION_FAILED)
 
+DEFINE_ERR_CODE(ERR_KRB5_INTERNAL)
 } // namespace dsn

include/dsn/utility/time_utils.h

@@ -61,13 +61,21 @@ inline void time_ms_to_date(uint64_t ts_ms, char *str, int len)
     strftime(str, len, "%Y-%m-%d", get_localtime(ts_ms, &tmp));
 }
 
-// get date string with format of 'yyyy-MM-dd hh:mm:ss' from given timestamp
+// get date string with format of 'yyyy-MM-dd hh:mm:ss' from given timestamp(ms)
 inline void time_ms_to_date_time(uint64_t ts_ms, char *str, int len)
 {
     struct tm tmp;
     strftime(str, len, "%Y-%m-%d %H:%M:%S", get_localtime(ts_ms, &tmp));
 }
 
+// get date string with format of 'yyyy-MM-dd hh:mm:ss' from given timestamp(s)
+inline std::string time_s_to_date_time(uint64_t unix_seconds)
+{
+    char buffer[128];
+    utils::time_ms_to_date_time(unix_seconds * 1000, buffer, 128);
+    return std::string(buffer);
+}
+
 // parse hour/min/sec from the given timestamp
 inline void time_ms_to_date_time(uint64_t ts_ms, int32_t &hour, int32_t &min, int32_t &sec)
 {
@@ -78,12 +86,16 @@ inline void time_ms_to_date_time(uint64_t ts_ms, int32_t &hour, int32_t &min, in
     sec = ret->tm_sec;
 }
 
+// get current physical timestamp in ns
 inline uint64_t get_current_physical_time_ns()
 {
     auto now = std::chrono::high_resolution_clock::now();
     return std::chrono::duration_cast<std::chrono::nanoseconds>(now.time_since_epoch()).count();
 }
 
+// get current physical timestamp in s
+inline uint64_t get_current_physical_time_s() { return get_current_physical_time_ns() * 1e-9; }
+
 // get unix timestamp of today's zero o'clock.
 // eg. `1525881600` returned when called on May 10, 2018, CST
 inline int64_t get_unix_sec_today_midnight()

src/runtime/CMakeLists.txt

@@ -30,5 +30,5 @@ add_library(dsn_runtime STATIC
         tracer.cpp
         zlocks.cpp
         )
-target_link_libraries(dsn_runtime dsn_utils)
+target_link_libraries(dsn_runtime dsn_utils sasl2 gssapi_krb5 krb5)
 install(TARGETS dsn_runtime DESTINATION "lib")

src/runtime/security/init.cpp

@@ -0,0 +1,63 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+#include "kinit_context.h"
+
+#include <dsn/dist/fmt_logging.h>
+
+namespace dsn {
+namespace security {
+extern char *FLAGS_krb5_config;
+extern char *FLAGS_krb5_keytab;
+
+/***
+ * set kerberos envs(for more details:
+ * https://web.mit.edu/kerberos/krb5-1.12/doc/admin/env_variables.html)
+ */
+void set_krb5_env(bool is_server)
+{
+    setenv("KRB5CCNAME", is_server ? "MEMORY:pegasus-server" : "MEMORY:pegasus-client", 1);
+    setenv("KRB5_CONFIG", FLAGS_krb5_config, 1);
+    setenv("KRB5_KTNAME", FLAGS_krb5_keytab, 1);
+    setenv("KRB5RCACHETYPE", "none", 1);
+}
+
+error_s init_kerberos(bool is_server)
+{
+    // set kerberos env
+    set_krb5_env(is_server);
+
+    // kinit -k -t <keytab_file> <principal>
+    return kinit_context::instance().kinit();
+}
+
+bool init(bool is_server)
+{
+    error_s err = init_kerberos(is_server);
+    if (!err.is_ok()) {
+        derror_f("initialize kerberos failed, with err = {}", err.description());
+        return false;
+    }
+    ddebug("initialize kerberos succeed");
+
+    // TODO(zlw): init sasl
+
+    return true;
+}
+
+} // namespace security
+} // namespace dsn

src/runtime/security/init.h

@@ -0,0 +1,27 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+#pragma once
+
+#include <dsn/utility/errors.h>
+
+namespace dsn {
+namespace security {
+// init security(kerberos and sasl)
+bool init(bool is_server);
+} // namespace security
+} // namespace dsn