root/opal/mca/pmix/pmix4x/pmix/src/mca/preg/base/preg_base_select.c

DEFINITIONS

1. pmix_preg_base_select

   1 /*
   2  * Copyright (c) 2004-2008 The Trustees of Indiana University and Indiana
   3  *                         University Research and Technology
   4  *                         Corporation.  All rights reserved.
   5  * Copyright (c) 2004-2005 The University of Tennessee and The University
   6  *                         of Tennessee Research Foundation.  All rights
   7  *                         reserved.
   8  * Copyright (c) 2004-2005 High Performance Computing Center Stuttgart,
   9  *                         University of Stuttgart.  All rights reserved.
  10  * Copyright (c) 2004-2005 The Regents of the University of California.
  11  *                         All rights reserved.
  12  * Copyright (c) 2016-2017 Intel, Inc. All rights reserved.
  13  * $COPYRIGHT$
  14  *
  15  * Additional copyrights may follow
  16  *
  17  * $HEADER$
  18  */
  19 
  20 #include <src/include/pmix_config.h>
  21 #include <pmix_common.h>
  22 
  23 #include <string.h>
  24 
  25 #include "src/mca/mca.h"
  26 #include "src/mca/base/base.h"
  27 #include "src/util/error.h"
  28 #include "src/util/show_help.h"
  29 
  30 #include "src/mca/preg/base/base.h"
  31 
  32 static bool selected = false;
  33 
  34 /* Function for selecting a prioritized list of components
  35  * from all those that are available. */
  36 int pmix_preg_base_select(void)
  37 {
  38     pmix_mca_base_component_list_item_t *cli = NULL;
  39     pmix_mca_base_component_t *component = NULL;
  40     pmix_mca_base_module_t *module = NULL;
  41     pmix_preg_module_t *nmodule;
  42     pmix_preg_base_active_module_t *newmodule, *mod;
  43     int rc, priority;
  44     bool inserted;
  45 
  46     if (selected) {
  47         /* ensure we don't do this twice */
  48         return PMIX_SUCCESS;
  49     }
  50     selected = true;
  51 
  52     /* Query all available components and ask if they have a module */
  53     PMIX_LIST_FOREACH(cli, &pmix_preg_base_framework.framework_components, pmix_mca_base_component_list_item_t) {
  54         component = (pmix_mca_base_component_t *) cli->cli_component;
  55 
  56         pmix_output_verbose(5, pmix_preg_base_framework.framework_output,
  57                             "mca:preg:select: checking available component %s", component->pmix_mca_component_name);
  58 
  59         /* If there's no query function, skip it */
  60         if (NULL == component->pmix_mca_query_component) {
  61             pmix_output_verbose(5, pmix_preg_base_framework.framework_output,
  62                                 "mca:preg:select: Skipping component [%s]. It does not implement a query function",
  63                                 component->pmix_mca_component_name );
  64             continue;
  65         }
  66 
  67         /* Query the component */
  68         pmix_output_verbose(5, pmix_preg_base_framework.framework_output,
  69                             "mca:preg:select: Querying component [%s]",
  70                             component->pmix_mca_component_name);
  71         rc = component->pmix_mca_query_component(&module, &priority);
  72 
  73         /* If no module was returned, then skip component */
  74         if (PMIX_SUCCESS != rc || NULL == module) {
  75             pmix_output_verbose(5, pmix_preg_base_framework.framework_output,
  76                                 "mca:preg:select: Skipping component [%s]. Query failed to return a module",
  77                                 component->pmix_mca_component_name );
  78             continue;
  79         }
  80 
  81         /* If we got a module, keep it */
  82         nmodule = (pmix_preg_module_t*) module;
  83         /* add to the list of selected modules */
  84         newmodule = PMIX_NEW(pmix_preg_base_active_module_t);
  85         newmodule->pri = priority;
  86         newmodule->module = nmodule;
  87         newmodule->component = (pmix_mca_base_component_t*)cli->cli_component;
  88 
  89         /* maintain priority order */
  90         inserted = false;
  91         PMIX_LIST_FOREACH(mod, &pmix_preg_globals.actives, pmix_preg_base_active_module_t) {
  92             if (priority > mod->pri) {
  93                 pmix_list_insert_pos(&pmix_preg_globals.actives,
  94                                      (pmix_list_item_t*)mod, &newmodule->super);
  95                 inserted = true;
  96                 break;
  97             }
  98         }
  99         if (!inserted) {
 100             /* must be lowest priority - add to end */
 101             pmix_list_append(&pmix_preg_globals.actives, &newmodule->super);
 102         }
 103     }
 104 
 105     /* if no modules were found, then that's an error as we require at least one */
 106     if (0 == pmix_list_get_size(&pmix_preg_globals.actives)) {
 107         pmix_show_help("help-pmix-runtime.txt", "no-plugins", true, "PREG");
 108         return PMIX_ERR_SILENT;
 109     }
 110 
 111     if (4 < pmix_output_get_verbosity(pmix_preg_base_framework.framework_output)) {
 112         pmix_output(0, "Final preg priorities");
 113         /* show the prioritized list */
 114         PMIX_LIST_FOREACH(mod, &pmix_preg_globals.actives, pmix_preg_base_active_module_t) {
 115             pmix_output(0, "\tpreg: %s Priority: %d", mod->component->pmix_mca_component_name, mod->pri);
 116         }
 117     }
 118 
 119     return PMIX_SUCCESS;;
 120 }