/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil -*- */ /* * Copyright (c) 2004-2008 The Trustees of Indiana University and Indiana * University Research and Technology * Corporation. All rights reserved. * Copyright (c) 2004-2012 The University of Tennessee and The University * of Tennessee Research Foundation. All rights * reserved. * Copyright (c) 2004-2005 High Performance Computing Center Stuttgart, * University of Stuttgart. All rights reserved. * Copyright (c) 2004-2005 The Regents of the University of California. * All rights reserved. * Copyright (c) 2008-2013 Cisco Systems, Inc. All rights reserved. * Copyright (c) 2012-2015 Los Alamos National Security, LLC. All rights * reserved. * Copyright (c) 2016-2020 Intel, Inc. All rights reserved. * Copyright (c) 2021-2023 Nanook Consulting. All rights reserved. * $COPYRIGHT$ * * Additional copyrights may follow * * $HEADER$ */ #include "src/include/pmix_config.h" #include "src/mca/base/pmix_base.h" #include "src/mca/base/pmix_mca_base_var_enum.h" #include "src/util/pmix_argv.h" #include "src/util/pmix_error.h" #include #include #include static void pmix_mca_base_var_enum_constructor(pmix_mca_base_var_enum_t *enumerator); static void pmix_mca_base_var_enum_destructor(pmix_mca_base_var_enum_t *enumerator); PMIX_CLASS_INSTANCE(pmix_mca_base_var_enum_t, pmix_object_t, pmix_mca_base_var_enum_constructor, pmix_mca_base_var_enum_destructor); static void pmix_mca_base_var_enum_flag_constructor(pmix_mca_base_var_enum_flag_t *enumerator); static void pmix_mca_base_var_enum_flag_destructor(pmix_mca_base_var_enum_flag_t *enumerator); PMIX_CLASS_INSTANCE(pmix_mca_base_var_enum_flag_t, pmix_object_t, pmix_mca_base_var_enum_flag_constructor, pmix_mca_base_var_enum_flag_destructor); static int enum_dump(pmix_mca_base_var_enum_t *self, char **out); static int enum_get_count(pmix_mca_base_var_enum_t *self, int *count); static int enum_get_value(pmix_mca_base_var_enum_t *self, int index, int *value, const char **string_value); static int pmix_mca_base_var_enum_bool_get_count(pmix_mca_base_var_enum_t *enumerator, int *count) { (void) enumerator; *count = 2; return PMIX_SUCCESS; } static int pmix_mca_base_var_enum_bool_get_value(pmix_mca_base_var_enum_t *self, int index, int *value, const char **string_value) { (void) self; if (1 < index) { return PMIX_ERR_VALUE_OUT_OF_BOUNDS; } *value = index ? 1 : 0; *string_value = index ? "true" : "false"; return PMIX_SUCCESS; } static int pmix_mca_base_var_enum_bool_vfs(pmix_mca_base_var_enum_t *self, const char *string_value, int *value) { (void) self; char *tmp; int v; /* skip whitespace */ string_value += strspn(string_value, " \t\n\v\f\r"); v = strtol(string_value, &tmp, 10); if (*tmp != '\0') { if (0 == strcmp(string_value, "true") || 0 == strcmp(string_value, "t") || 0 == strcmp(string_value, "enabled") || 0 == strcmp(string_value, "yes")) { v = 1; } else if (0 == strcmp(string_value, "false") || 0 == strcmp(string_value, "f") || 0 == strcmp(string_value, "disabled") || 0 == strcmp(string_value, "no")) { v = 0; } else { return PMIX_ERR_VALUE_OUT_OF_BOUNDS; } } *value = !!v; return PMIX_SUCCESS; } static int pmix_mca_base_var_enum_bool_sfv(pmix_mca_base_var_enum_t *self, const int value, char **string_value) { (void) self; if (string_value) { *string_value = strdup(value ? "true" : "false"); } return PMIX_SUCCESS; } static int pmix_mca_base_var_enum_bool_dump(pmix_mca_base_var_enum_t *self, char **out) { (void) self; *out = strdup("0: f|false|disabled|no, 1: t|true|enabled|yes"); return *out ? PMIX_SUCCESS : PMIX_ERR_OUT_OF_RESOURCE; } pmix_mca_base_var_enum_t pmix_mca_base_var_enum_bool = {.super = PMIX_OBJ_STATIC_INIT(pmix_object_t), .enum_is_static = true, .enum_name = "boolean", .get_count = pmix_mca_base_var_enum_bool_get_count, .get_value = pmix_mca_base_var_enum_bool_get_value, .value_from_string = pmix_mca_base_var_enum_bool_vfs, .string_from_value = pmix_mca_base_var_enum_bool_sfv, .dump = pmix_mca_base_var_enum_bool_dump}; /* verbosity enumerator */ static pmix_mca_base_var_enum_value_t verbose_values[] = {{PMIX_MCA_BASE_VERBOSE_NONE, "none"}, {PMIX_MCA_BASE_VERBOSE_ERROR, "error"}, {PMIX_MCA_BASE_VERBOSE_COMPONENT, "component"}, {PMIX_MCA_BASE_VERBOSE_WARN, "warn"}, {PMIX_MCA_BASE_VERBOSE_INFO, "info"}, {PMIX_MCA_BASE_VERBOSE_TRACE, "trace"}, {PMIX_MCA_BASE_VERBOSE_DEBUG, "debug"}, {PMIX_MCA_BASE_VERBOSE_MAX, "max"}, {-1, NULL}}; static int pmix_mca_base_var_enum_verbose_vfs(pmix_mca_base_var_enum_t *self, const char *string_value, int *value) { (void) self; char *tmp; int v; /* skip whitespace */ string_value += strspn(string_value, " \t\n\v\f\r"); v = strtol(string_value, &tmp, 10); if (*tmp != '\0') { for (int i = 0; verbose_values[i].string; ++i) { if (0 == strcmp(verbose_values[i].string, string_value)) { *value = verbose_values[i].value; return PMIX_SUCCESS; } } return PMIX_ERR_NOT_FOUND; } else if (v < PMIX_MCA_BASE_VERBOSE_NONE) { v = PMIX_MCA_BASE_VERBOSE_NONE; } else if (v > PMIX_MCA_BASE_VERBOSE_MAX) { v = PMIX_MCA_BASE_VERBOSE_MAX; } *value = v; return PMIX_SUCCESS; } static int pmix_mca_base_var_enum_verbose_sfv(pmix_mca_base_var_enum_t *self, const int value, char **string_value) { (void) self; int ret; if (value < 0 || value > 100) { return PMIX_ERR_VALUE_OUT_OF_BOUNDS; } for (int i = 0; verbose_values[i].string; ++i) { if (verbose_values[i].value == value) { *string_value = strdup(verbose_values[i].string); return PMIX_SUCCESS; } } if (string_value) { ret = asprintf(string_value, "%d", value); if (0 > ret) { return PMIX_ERR_OUT_OF_RESOURCE; } } return PMIX_SUCCESS; } static int pmix_mca_base_var_enum_verbose_dump(pmix_mca_base_var_enum_t *self, char **out) { char *tmp; int ret; ret = enum_dump(self, out); if (PMIX_SUCCESS != ret) { return ret; } ret = asprintf(&tmp, "%s, 0 - 100", *out); free(*out); if (0 > ret) { *out = NULL; return PMIX_ERR_OUT_OF_RESOURCE; } *out = tmp; return PMIX_SUCCESS; } pmix_mca_base_var_enum_t pmix_mca_base_var_enum_verbose = { .super = PMIX_OBJ_STATIC_INIT(pmix_object_t), .enum_is_static = true, .enum_name = "verbosity", .get_count = enum_get_count, .get_value = enum_get_value, .value_from_string = pmix_mca_base_var_enum_verbose_vfs, .string_from_value = pmix_mca_base_var_enum_verbose_sfv, .dump = pmix_mca_base_var_enum_verbose_dump, .enum_value_count = 8, .enum_values = verbose_values, }; int pmix_mca_base_var_enum_create(const char *name, const pmix_mca_base_var_enum_value_t *values, pmix_mca_base_var_enum_t **enumerator) { pmix_mca_base_var_enum_t *new_enum; int i; *enumerator = NULL; new_enum = PMIX_NEW(pmix_mca_base_var_enum_t); if (NULL == new_enum) { return PMIX_ERR_OUT_OF_RESOURCE; } new_enum->enum_name = strdup(name); if (NULL == new_enum->enum_name) { return PMIX_ERR_OUT_OF_RESOURCE; } for (i = 0; values[i].string; ++i) ; new_enum->enum_value_count = i; /* make a copy of the values */ new_enum->enum_values = calloc(new_enum->enum_value_count + 1, sizeof(*new_enum->enum_values)); if (NULL == new_enum->enum_values) { PMIX_RELEASE(new_enum); return PMIX_ERR_OUT_OF_RESOURCE; } for (i = 0; i < new_enum->enum_value_count; ++i) { new_enum->enum_values[i].value = values[i].value; new_enum->enum_values[i].string = strdup(values[i].string); } *enumerator = new_enum; return PMIX_SUCCESS; } int pmix_mca_base_var_enum_create_flag(const char *name, const pmix_mca_base_var_enum_value_flag_t *flags, pmix_mca_base_var_enum_flag_t **enumerator) { pmix_mca_base_var_enum_flag_t *new_enum; int i; *enumerator = NULL; new_enum = PMIX_NEW(pmix_mca_base_var_enum_flag_t); if (NULL == new_enum) { return PMIX_ERR_OUT_OF_RESOURCE; } new_enum->super.enum_name = strdup(name); if (NULL == new_enum->super.enum_name) { return PMIX_ERR_OUT_OF_RESOURCE; } for (i = 0; flags[i].string; ++i) ; new_enum->super.enum_value_count = i; /* make a copy of the values */ new_enum->enum_flags = calloc(new_enum->super.enum_value_count + 1, sizeof(*new_enum->enum_flags)); if (NULL == new_enum->enum_flags) { PMIX_RELEASE(new_enum); return PMIX_ERR_OUT_OF_RESOURCE; } #if PMIX_ENABLE_DEBUG int all_flags = 0; #endif for (i = 0; i < new_enum->super.enum_value_count; ++i) { new_enum->enum_flags[i].flag = flags[i].flag; new_enum->enum_flags[i].string = strdup(flags[i].string); new_enum->enum_flags[i].conflicting_flag = flags[i].conflicting_flag; /* ensure flags are only set a single bit, doesn't conflict with itself, and * hasn't already been specified. */ assert(!(flags[i].flag & (flags[i].flag - 1))); assert(!(flags[i].flag & flags[i].conflicting_flag)); #if PMIX_ENABLE_DEBUG assert(!(all_flags & flags[i].flag)); #endif assert(flags[i].flag); #if PMIX_ENABLE_DEBUG all_flags |= flags[i].flag; #endif } *enumerator = new_enum; return PMIX_SUCCESS; } static int enum_dump(pmix_mca_base_var_enum_t *self, char **out) { int i; char *tmp; int ret; *out = NULL; if (NULL == self) { return PMIX_ERROR; } tmp = NULL; for (i = 0; i < self->enum_value_count && self->enum_values[i].string; ++i) { ret = asprintf(out, "%s%s%d:\"%s\"", tmp ? tmp : "", tmp ? ", " : "", self->enum_values[i].value, self->enum_values[i].string); if (tmp) free(tmp); if (0 > ret) { return PMIX_ERR_OUT_OF_RESOURCE; } tmp = *out; } return PMIX_SUCCESS; } static int enum_get_count(pmix_mca_base_var_enum_t *self, int *count) { *count = self->enum_value_count; return PMIX_SUCCESS; } static int enum_get_value(pmix_mca_base_var_enum_t *self, int index, int *value, const char **string_value) { int count, ret; ret = self->get_count(self, &count); if (PMIX_SUCCESS != ret) { return ret; } if (index >= count) { return PMIX_ERR_VALUE_OUT_OF_BOUNDS; } if (value) { *value = self->enum_values[index].value; } if (string_value) { *string_value = strdup(self->enum_values[index].string); } return PMIX_SUCCESS; } static int enum_value_from_string(pmix_mca_base_var_enum_t *self, const char *string_value, int *value_out) { int value, count, ret, i; bool is_int; char *tmp; ret = self->get_count(self, &count); if (PMIX_SUCCESS != ret) { return ret; } value = strtol(string_value, &tmp, 0); /* Check if the string is an integer */ is_int = tmp[0] == '\0'; for (i = 0; i < count; ++i) { if ((is_int && value == self->enum_values[i].value) || 0 == strcasecmp(string_value, self->enum_values[i].string)) { break; } } if (i == count) { return PMIX_ERR_VALUE_OUT_OF_BOUNDS; } *value_out = self->enum_values[i].value; return PMIX_SUCCESS; } static int enum_string_from_value(pmix_mca_base_var_enum_t *self, const int value, char **string_value) { int count, ret, i; ret = self->get_count(self, &count); if (PMIX_SUCCESS != ret) { return ret; } for (i = 0; i < count; ++i) { if (value == self->enum_values[i].value) { break; } } if (i == count) { return PMIX_ERR_VALUE_OUT_OF_BOUNDS; } if (string_value) { *string_value = strdup(self->enum_values[i].string); } return PMIX_SUCCESS; } static void pmix_mca_base_var_enum_constructor(pmix_mca_base_var_enum_t *enumerator) { memset((char *) enumerator + sizeof(enumerator->super), 0, sizeof(*enumerator) - sizeof(enumerator->super)); enumerator->get_value = enum_get_value; enumerator->get_count = enum_get_count; enumerator->value_from_string = enum_value_from_string; enumerator->string_from_value = enum_string_from_value; enumerator->dump = enum_dump; enumerator->enum_is_static = false; } static void pmix_mca_base_var_enum_destructor(pmix_mca_base_var_enum_t *enumerator) { if (enumerator->enum_name) { free(enumerator->enum_name); } /* release the copy of the values */ if (enumerator->enum_values) { for (int i = 0; i < enumerator->enum_value_count; ++i) { free((void *) enumerator->enum_values[i].string); } free(enumerator->enum_values); } } static int enum_get_value_flag(pmix_mca_base_var_enum_t *self, int index, int *value, const char **string_value) { pmix_mca_base_var_enum_flag_t *flag_enum = (pmix_mca_base_var_enum_flag_t *) self; int count, ret; ret = self->get_count(self, &count); if (PMIX_SUCCESS != ret) { return ret; } if (index >= count) { return PMIX_ERR_VALUE_OUT_OF_BOUNDS; } if (value) { *value = flag_enum->enum_flags[index].flag; } if (string_value) { *string_value = strdup(flag_enum->enum_flags[index].string); } return PMIX_SUCCESS; } static int enum_value_from_string_flag(pmix_mca_base_var_enum_t *self, const char *string_value, int *value_out) { pmix_mca_base_var_enum_flag_t *flag_enum = (pmix_mca_base_var_enum_flag_t *) self; int value, count, ret, flag; char **flags; bool is_int; char *tmp; ret = self->get_count(self, &count); if (PMIX_SUCCESS != ret) { return ret; } flags = PMIx_Argv_split(string_value, ','); if (NULL == flags) { return PMIX_ERR_BAD_PARAM; } flag = 0; for (int i = 0; flags[i]; ++i) { value = strtol(flags[i], &tmp, 0); is_int = tmp[0] == '\0'; bool found = false, conflict = false; for (int j = 0; j < count; ++j) { if ((is_int && (value == flag_enum->enum_flags[i].flag)) || 0 == strcasecmp(flags[i], flag_enum->enum_flags[i].string)) { found = true; if (flag & flag_enum->enum_flags[i].conflicting_flag) { conflict = true; } else { flag |= flag_enum->enum_flags[i].flag; } break; } } if (!found || conflict) { PMIx_Argv_free(flags); return !found ? PMIX_ERR_VALUE_OUT_OF_BOUNDS : PMIX_ERR_BAD_PARAM; } } PMIx_Argv_free(flags); *value_out = flag; return PMIX_SUCCESS; } static int enum_string_from_value_flag(pmix_mca_base_var_enum_t *self, const int value, char **string_value) { pmix_mca_base_var_enum_flag_t *flag_enum = (pmix_mca_base_var_enum_flag_t *) self; int count, ret, current; char *out = NULL, *tmp; ret = self->get_count(self, &count); if (PMIX_SUCCESS != ret) { return ret; } current = value; for (int i = 0; i < count; ++i) { if (!(flag_enum->enum_flags[i].flag & current)) { continue; } tmp = out; ret = asprintf(&out, "%s%s%s", tmp ? tmp : "", tmp ? "," : "", flag_enum->enum_flags[i].string); free(tmp); if (0 > ret) { return PMIX_ERR_OUT_OF_RESOURCE; } if (value & flag_enum->enum_flags[i].conflicting_flag) { free(out); return PMIX_ERR_BAD_PARAM; } current &= ~flag_enum->enum_flags[i].flag; } if (current) { free(out); return PMIX_ERR_VALUE_OUT_OF_BOUNDS; } if (string_value) { *string_value = out ? out : strdup(""); } else { free(out); } return PMIX_SUCCESS; } static int enum_dump_flag(pmix_mca_base_var_enum_t *self, char **out) { pmix_mca_base_var_enum_flag_t *flag_enum = (pmix_mca_base_var_enum_flag_t *) self; char *tmp; int ret; *out = NULL; if (NULL == self) { return PMIX_ERROR; } *out = strdup("Comma-delimited list of: "); if (NULL == *out) { return PMIX_ERR_OUT_OF_RESOURCE; } for (int i = 0; i < self->enum_value_count; ++i) { tmp = *out; ret = asprintf(out, "%s%s0x%x:\"%s\"", tmp, i ? ", " : " ", flag_enum->enum_flags[i].flag, flag_enum->enum_flags[i].string); free(tmp); if (0 > ret) { return PMIX_ERR_OUT_OF_RESOURCE; } } return PMIX_SUCCESS; } static void pmix_mca_base_var_enum_flag_constructor(pmix_mca_base_var_enum_flag_t *enumerator) { enumerator->enum_flags = NULL; enumerator->super.get_value = enum_get_value_flag; enumerator->super.get_count = enum_get_count; enumerator->super.value_from_string = enum_value_from_string_flag; enumerator->super.string_from_value = enum_string_from_value_flag; enumerator->super.dump = enum_dump_flag; enumerator->super.enum_is_static = false; } static void pmix_mca_base_var_enum_flag_destructor(pmix_mca_base_var_enum_flag_t *enumerator) { /* release the copy of the values */ if (enumerator->enum_flags) { for (int i = 0; i < enumerator->super.enum_value_count; ++i) { free((void *) enumerator->enum_flags[i].string); } free(enumerator->enum_flags); } }