openmpi/src/mca/oob/base/oob_base_init.c

/*
 * $HEADER$
 */

#include "ompi_config.h"

#include <stdio.h>

#include "runtime/runtime.h"
#include "util/output.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/pcm/pcm.h"
#include "mca/oob/oob.h"
#include "mca/oob/base/base.h"


OBJ_CLASS_INSTANCE(
    mca_oob_t,
    ompi_list_item_t,
    NULL,
    NULL
);
OBJ_CLASS_INSTANCE(
    mca_oob_base_info_t,
    ompi_list_item_t,
    NULL,
    NULL
);

ompi_process_name_t mca_oob_name_seed;
ompi_process_name_t mca_oob_name_self;
ompi_process_name_t mca_oob_name_any;                                                                                                                          

/**
 * Function for selecting one module from all those that are
 * available.
 *
 * Call the init function on all available modules.
 */
int mca_oob_base_init(bool *user_threads, bool *hidden_threads)
{
    ompi_list_item_t *item;
    mca_base_component_list_item_t *cli;
    mca_oob_base_info_t * first;
    mca_oob_base_component_t *component;
    mca_oob_t *module;
    extern ompi_list_t mca_oob_base_components;
    ompi_process_name_t *self;

    /* setup local name */
    OBJ_CONSTRUCT(&mca_oob_name_self, ompi_process_name_t);
    self = mca_pcm.pcm_self();
    if(NULL == self) {
        ompi_output(0, "mca_oob_base_init: could not get PCM self pointer");
        return OMPI_ERROR;
    }
    mca_oob_name_self = *self;

    /* setup wildcard name */
    OBJ_CONSTRUCT(&mca_oob_name_any, ompi_process_name_t);
    mca_oob_name_any.cellid = -1;
    mca_oob_name_any.jobid = -1;
    mca_oob_name_any.vpid = -1;

    /* setup seed daemons name */
    OBJ_CONSTRUCT(&mca_oob_name_seed, ompi_process_name_t);

    /* Traverse the list of available modules; call their init functions. */
    for (item = ompi_list_get_first(&mca_oob_base_components);
        item != ompi_list_get_end(&mca_oob_base_components);
        item = ompi_list_get_next(item)) {
        mca_oob_base_info_t *inited;

        cli = (mca_base_component_list_item_t *) item;
        component = (mca_oob_base_component_t *) cli->cli_component;

        if (NULL == component->oob_init) {
            ompi_output_verbose(10, mca_oob_base_output, "mca_oob_base_init: no init function; ignoring component");
        } else {
            module = component->oob_init(user_threads, hidden_threads);
            if (NULL == module) {
                ompi_output_verbose(10, mca_oob_base_output, "mca_oob_base_init: oob_init returned failure");
            } else {
              inited = OBJ_NEW(mca_oob_base_info_t);
              inited->oob_component = component;
              inited->oob_module = module;
              ompi_list_append(&mca_oob_base_modules, &inited->super);
            }
        }
    }
    /* set the global variable to point to the first initialize module */
    if (0 < ompi_list_get_size(&mca_oob_base_modules)) {
      first = (mca_oob_base_info_t *) ompi_list_get_first(&mca_oob_base_modules);
      mca_oob = *first->oob_module; 
      return OMPI_SUCCESS;
    } else {
      printf("No OOB modules available!\n");
      fflush(stdout);
      return OMPI_ERROR;
    }
}


                                                                                  
/**
*  Obtains the contact info (oob implementation specific) URI strings through
*  which this process can be contacted on an OOB channel.
*
*  @return  A null terminated string.
*
*  The caller is responsible for freeing the returned string.
*/
                                                                                                             
char* mca_oob_get_contact_info()
{
    return strdup("tcp:localhost:5000");
}