Skip to content

Commit

Permalink
DAOS-14532 gurt: Replace environment APIs hook
Browse files Browse the repository at this point in the history
fix clang-format issue.

Allow-unstable-test: true
Features: mpiio dfuse
Required-githooks: true
Signed-off-by: Cedric Koch-Hofer <cedric.koch-hofer@intel.com>
  • Loading branch information
kanard38 authored and knard-intel committed Jan 19, 2024
1 parent f0602f0 commit 198bfe4
Show file tree
Hide file tree
Showing 3 changed files with 52 additions and 54 deletions.
76 changes: 38 additions & 38 deletions src/cart/crt_init.c
Original file line number Diff line number Diff line change
Expand Up @@ -19,42 +19,42 @@ struct crt_plugin_gdata crt_plugin_gdata;
static bool g_prov_settings_applied[CRT_PROV_COUNT];

/* List of the environment variables used in CaRT */
static const char *crt_env_names[] = {"D_PROVIDER",
"D_INTERFACE",
"D_DOMAIN",
"D_PORT",
"CRT_PHY_ADDR_STR",
"D_LOG_STDERR_IN_LOG",
"D_LOG_SIZE",
"D_LOG_FILE",
"D_LOG_FILE_APPEND_PID",
"D_LOG_MASK",
"DD_MASK",
"DD_STDERR",
"DD_SUBSYS",
"CRT_TIMEOUT",
"CRT_ATTACH_INFO_PATH",
"OFI_PORT",
"OFI_INTERFACE",
"OFI_DOMAIN",
"CRT_CREDIT_EP_CTX",
"CRT_CTX_SHARE_ADDR",
"CRT_CTX_NUM",
"D_FI_CONFIG",
"FI_UNIVERSE_SIZE",
"CRT_ENABLE_MEM_PIN",
"FI_OFI_RXM_USE_SRX",
"D_LOG_FLUSH",
"CRT_MRC_ENABLE",
"CRT_SECONDARY_PROVIDER",
"D_PROVIDER_AUTH_KEY",
"D_PORT_AUTO_ADJUST",
"D_POLL_TIMEOUT",
"D_LOG_FILE_APPEND_RANK",
"D_QUOTA_RPCS",
"D_POST_INIT",
"D_POST_INCR",
"DAOS_SIGNAL_REGISTER"};
static const char *crt_env_names[] = {"D_PROVIDER",
"D_INTERFACE",
"D_DOMAIN",
"D_PORT",
"CRT_PHY_ADDR_STR",
"D_LOG_STDERR_IN_LOG",
"D_LOG_SIZE",
"D_LOG_FILE",
"D_LOG_FILE_APPEND_PID",
"D_LOG_MASK",
"DD_MASK",
"DD_STDERR",
"DD_SUBSYS",
"CRT_TIMEOUT",
"CRT_ATTACH_INFO_PATH",
"OFI_PORT",
"OFI_INTERFACE",
"OFI_DOMAIN",
"CRT_CREDIT_EP_CTX",
"CRT_CTX_SHARE_ADDR",
"CRT_CTX_NUM",
"D_FI_CONFIG",
"FI_UNIVERSE_SIZE",
"CRT_ENABLE_MEM_PIN",
"FI_OFI_RXM_USE_SRX",
"D_LOG_FLUSH",
"CRT_MRC_ENABLE",
"CRT_SECONDARY_PROVIDER",
"D_PROVIDER_AUTH_KEY",
"D_PORT_AUTO_ADJUST",
"D_POLL_TIMEOUT",
"D_LOG_FILE_APPEND_RANK",
"D_QUOTA_RPCS",
"D_POST_INIT",
"D_POST_INCR",
"DAOS_SIGNAL_REGISTER"};

static void
crt_lib_init(void) __attribute__((__constructor__));
Expand Down Expand Up @@ -100,8 +100,8 @@ crt_lib_fini(void)
static void
dump_envariables(void)
{
int i;
char *val;
int i;
char *val;

D_INFO("-- ENVARS: --\n");
for (i = 0; i < ARRAY_SIZE(crt_env_names); i++) {
Expand Down
17 changes: 8 additions & 9 deletions src/cart/utils/crt_utils.c
Original file line number Diff line number Diff line change
Expand Up @@ -413,15 +413,15 @@ crtu_dc_mgmt_net_cfg_rank_add(const char *name, crt_group_t *group,
int
crtu_dc_mgmt_net_cfg_setenv(const char *name)
{
int rc;
int rc;
char *crt_phy_addr_str;
char *crt_ctx_share_addr = NULL;
char *cli_srx_set = NULL;
char *crt_timeout = NULL;
char *ofi_interface;
char *ofi_interface_env = NULL;
char *ofi_domain;
char *ofi_domain_env = NULL;
char *cli_srx_set = NULL;
char *crt_timeout = NULL;
char *ofi_interface;
char *ofi_interface_env = NULL;
char *ofi_domain;
char *ofi_domain_env = NULL;
struct dc_mgmt_sys_info crt_net_cfg_info = {0};
Mgmt__GetAttachInfoResp *crt_net_cfg_resp = NULL;

Expand Down Expand Up @@ -465,8 +465,7 @@ crtu_dc_mgmt_net_cfg_setenv(const char *name)
if (rc != 0)
D_GOTO(cleanup, rc = d_errno2der(errno));

D_DEBUG(DB_MGMT, "Using server's value for FI_OFI_RXM_USE_SRX: %s\n",
cli_srx_set);
D_DEBUG(DB_MGMT, "Using server's value for FI_OFI_RXM_USE_SRX: %s\n", cli_srx_set);
} else {
/* Client may not set it if the server hasn't. */
d_agetenv_str(&cli_srx_set, "FI_OFI_RXM_USE_SRX");
Expand Down
13 changes: 6 additions & 7 deletions src/mgmt/cli_mgmt.c
Original file line number Diff line number Diff line change
Expand Up @@ -452,12 +452,12 @@ int dc_mgmt_net_cfg(const char *name)
int rc;
char *crt_phy_addr_str;
char *crt_ctx_share_addr = NULL;
char *cli_srx_set = NULL;
char *cli_srx_set = NULL;
char *crt_timeout = NULL;
char *ofi_interface;
char *ofi_interface_env = NULL;
char *ofi_domain = "";
char *ofi_domain_env = NULL;
char *ofi_domain = "";
char *ofi_domain_env = NULL;
struct dc_mgmt_sys_info info;
Mgmt__GetAttachInfoResp *resp;

Expand Down Expand Up @@ -495,7 +495,7 @@ int dc_mgmt_net_cfg(const char *name)
D_INFO("Setting number of server ranks to %d\n", g_num_serv_ranks);
/* These two are always set */
crt_phy_addr_str = info.provider;
rc = d_setenv("CRT_PHY_ADDR_STR", crt_phy_addr_str, 1);
rc = d_setenv("CRT_PHY_ADDR_STR", crt_phy_addr_str, 1);
if (rc != 0)
D_GOTO(cleanup, rc = d_errno2der(errno));

Expand All @@ -518,8 +518,7 @@ int dc_mgmt_net_cfg(const char *name)
rc = d_setenv("FI_OFI_RXM_USE_SRX", cli_srx_set, 1);
if (rc != 0)
D_GOTO(cleanup, rc = d_errno2der(errno));
D_INFO("Using server's value for FI_OFI_RXM_USE_SRX: %s\n",
cli_srx_set);
D_INFO("Using server's value for FI_OFI_RXM_USE_SRX: %s\n", cli_srx_set);
} else {
/* Client may not set it if the server hasn't. */
d_agetenv_str(&cli_srx_set, "FI_OFI_RXM_USE_SRX");
Expand Down Expand Up @@ -550,7 +549,7 @@ int dc_mgmt_net_cfg(const char *name)
d_agetenv_str(&ofi_domain_env, "OFI_DOMAIN");
if (!ofi_interface_env) {
ofi_interface = info.interface;
rc = d_setenv("OFI_INTERFACE", ofi_interface, 1);
rc = d_setenv("OFI_INTERFACE", ofi_interface, 1);
if (rc != 0)
D_GOTO(cleanup, rc = d_errno2der(errno));

Expand Down

0 comments on commit 198bfe4

Please sign in to comment.