3daf8b341b
1. if the user has specified sched_yield, we simply do what we are told 2. if they didn't specify anything, try to get the number of processors on this node. Note that we already now get the number of local procs in our job that are sharing this node - that now comes in through the proc callback and is stored in the ompi_proc_t structures. 3. if we can get the number of processors, compare that to the number of local procs from my job that are sharing my node. If the number of local procs exceeds the number of processors, then set sched_yield to true. If not, then be a hog and set sched_yield to false 4. if we can't get the number of processors, default to conservative behavior and set sched_yield to true. Note that I have not yet dealt with the need to dynamically adjust this setting as more processes are added via comm_spawn. So far, we are *only* looking within our own job. Given that we have now moved this logic to mpi_init (and away from the orteds), it isn't yet clear to me how a process will be informed about the number of procs in *other* jobs that are also sharing this node. Something to continue to ponder. This commit was SVN r13430.
88 строки
2.1 KiB
C
88 строки
2.1 KiB
C
/*
|
|
* Copyright (c) 2004-2005 The Trustees of Indiana University and Indiana
|
|
* University Research and Technology
|
|
* Corporation. All rights reserved.
|
|
* Copyright (c) 2004-2005 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$
|
|
*
|
|
* Additional copyrights may follow
|
|
*
|
|
* $HEADER$
|
|
*/
|
|
|
|
#ifndef ORTED_H
|
|
#define ORTED_H
|
|
|
|
#include "orte_config.h"
|
|
#include "orte/orte_types.h"
|
|
|
|
#include "opal/threads/mutex.h"
|
|
#include "opal/threads/condition.h"
|
|
#
|
|
#if defined(c_plusplus) || defined(__cplusplus)
|
|
extern "C" {
|
|
#endif
|
|
|
|
typedef struct {
|
|
bool help;
|
|
bool no_daemonize;
|
|
bool debug;
|
|
bool debug_daemons;
|
|
bool debug_daemons_file;
|
|
bool set_sid;
|
|
char* ns_nds;
|
|
char* name;
|
|
char* vpid_start;
|
|
char* num_procs;
|
|
char* universe;
|
|
char **saved_environ;
|
|
int bootproxy;
|
|
int uri_pipe;
|
|
opal_mutex_t mutex;
|
|
opal_condition_t condition;
|
|
bool exit_condition;
|
|
bool spin;
|
|
int reap;
|
|
} orted_globals_t;
|
|
|
|
|
|
/*
|
|
* Version-related strings and functions
|
|
*/
|
|
|
|
/* extern const char *ver_full; */
|
|
/* extern const char *ver_major; */
|
|
/* extern const char *ver_minor; */
|
|
/* extern const char *ver_release; */
|
|
/* extern const char *ver_alpha; */
|
|
/* extern const char *ver_beta; */
|
|
/* extern const char *ver_svn; */
|
|
|
|
/* void do_version(bool want_all, opal_cmd_line_t *cmd_line); */
|
|
/* void show_ompi_version(const char *scope); */
|
|
|
|
/*
|
|
* Parameter/configuration-related functions
|
|
*/
|
|
|
|
/* extern char *param_all; */
|
|
|
|
/* extern char *path_prefix; */
|
|
/* extern char *path_bindir; */
|
|
/* extern char *path_libdir; */
|
|
/* extern char *path_incdir; */
|
|
/* extern char *path_pkglibdir; */
|
|
/* extern char *path_sysconfdir; */
|
|
|
|
#if defined(c_plusplus) || defined(__cplusplus)
|
|
}
|
|
#endif
|
|
|
|
#endif /* ORTED_H */
|