Clean out the cruft leftover from the use_common_ports experiment
cmr:v1.7 This commit was SVN r28184.
Этот коммит содержится в:
родитель
8ce2041102
Коммит
147c6ff9e7
@ -319,13 +319,13 @@ int orte_ess_base_orted_setup(char **hosts)
|
||||
goto error;
|
||||
}
|
||||
#if ORTE_ENABLE_STATIC_PORTS
|
||||
/* if we are using static ports or a common port, then we need to setup
|
||||
/* if we are using static ports, then we need to setup
|
||||
* the daemon info so the RML can function properly
|
||||
* without requiring a wireup stage. This must be done
|
||||
* after we enable_comm as that function determines our
|
||||
* own port, which we need in order to construct the nidmap
|
||||
*/
|
||||
if (orte_static_ports || orte_use_common_port) {
|
||||
if (orte_static_ports) {
|
||||
/* define the routing tree so we know the pattern
|
||||
* if we are trying to setup common or static ports
|
||||
*/
|
||||
|
@ -647,16 +647,8 @@ mca_oob_tcp_create_listen(int *target_sd, unsigned short *target_port, uint16_t
|
||||
port in the range. Otherwise, tcp_port_min will be 0, which
|
||||
means "pick any port" */
|
||||
if (AF_INET == af_family) {
|
||||
if (ORTE_PROC_IS_DAEMON && orte_use_common_port) {
|
||||
/* use the same port as the HNP */
|
||||
char *ptr, *portptr;
|
||||
portptr = strdup(orte_process_info.my_hnp_uri);
|
||||
ptr = strrchr(portptr, ':');
|
||||
ptr++;
|
||||
opal_argv_append_nosize(&ports, ptr);
|
||||
free(portptr);
|
||||
} else if (ORTE_PROC_IS_HNP || ORTE_PROC_IS_DAEMON ||
|
||||
ORTE_PROC_IS_CM || ORTE_PROC_IS_CMSLAVE) {
|
||||
if (ORTE_PROC_IS_HNP || ORTE_PROC_IS_DAEMON ||
|
||||
ORTE_PROC_IS_CM || ORTE_PROC_IS_CMSLAVE) {
|
||||
if (NULL != mca_oob_tcp_component.tcp4_static_ports) {
|
||||
/* if static ports were provided, the daemon takes the
|
||||
* first entry in the list
|
||||
|
@ -1059,8 +1059,8 @@ int orte_plm_base_orted_append_basic_args(int *argc, char ***argv,
|
||||
opal_argv_append(argc, argv, param);
|
||||
free(param);
|
||||
|
||||
/* if given and we have static ports or are using a common port, pass the node list */
|
||||
if ((orte_static_ports || orte_use_common_port) && NULL != nodes) {
|
||||
/* if we have static ports, pass the node list */
|
||||
if (orte_static_ports && NULL != nodes) {
|
||||
/* convert the nodes to a regex */
|
||||
if (ORTE_SUCCESS != (rc = orte_regex_create(nodes, ¶m))) {
|
||||
ORTE_ERROR_LOG(rc);
|
||||
@ -1072,15 +1072,6 @@ int orte_plm_base_orted_append_basic_args(int *argc, char ***argv,
|
||||
free(param);
|
||||
}
|
||||
|
||||
if (orte_use_common_port) {
|
||||
/* tell the daemon to use the common port */
|
||||
opal_argv_append(argc, argv, "--use-common-port");
|
||||
} else {
|
||||
opal_argv_append(argc, argv, "-mca");
|
||||
opal_argv_append(argc, argv, "orte_use_common_port");
|
||||
opal_argv_append(argc, argv, "0");
|
||||
}
|
||||
|
||||
/* warn the daemons if we are using a tree spawn pattern so they
|
||||
* know they shouldn't do a rollup on their callback
|
||||
*/
|
||||
|
@ -793,11 +793,6 @@ static int remote_spawn(opal_buffer_t *launch)
|
||||
goto cleanup;
|
||||
}
|
||||
|
||||
/* ensure the system knows we are not using common ports since we are
|
||||
* doing a tree spawn
|
||||
*/
|
||||
orte_use_common_port = false;
|
||||
|
||||
/* setup the launch */
|
||||
if (ORTE_SUCCESS != (rc = setup_launch(&argc, &argv, orte_process_info.nodename, &node_name_index1,
|
||||
&proc_vpid_index, prefix))) {
|
||||
@ -1090,11 +1085,6 @@ static void launch_daemons(int fd, short args, void *cbdata)
|
||||
opal_byte_object_t bo, *boptr;
|
||||
orte_job_t *jdatorted;
|
||||
|
||||
/* ensure all systems know we are not using a common port since we
|
||||
* are doing a tree spawn
|
||||
*/
|
||||
orte_use_common_port = false;
|
||||
|
||||
/* get the tree spawn buffer */
|
||||
orte_tree_launch_cmd = OBJ_NEW(opal_buffer_t);
|
||||
/* insert the tree_spawn cmd */
|
||||
|
@ -148,9 +148,6 @@ static int plm_slurm_init(void)
|
||||
return rc;
|
||||
}
|
||||
|
||||
/* lock OFF the common port for now */
|
||||
orte_use_common_port = false;
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
|
@ -375,7 +375,7 @@ static orte_process_name_t get_route(orte_process_name_t *target)
|
||||
|
||||
/* THIS CAME FROM OUR OWN JOB FAMILY... */
|
||||
if (OPAL_EQUAL == orte_util_compare_name_fields(ORTE_NS_CMP_ALL, ORTE_PROC_MY_HNP, target)) {
|
||||
if (!hnp_direct || orte_static_ports || orte_use_common_port) {
|
||||
if (!hnp_direct || orte_static_ports) {
|
||||
OPAL_OUTPUT_VERBOSE((2, orte_routed_base_output,
|
||||
"%s routing to the HNP through my parent %s",
|
||||
ORTE_NAME_PRINT(ORTE_PROC_MY_NAME),
|
||||
|
@ -385,7 +385,7 @@ static orte_process_name_t get_route(orte_process_name_t *target)
|
||||
/* THIS CAME FROM OUR OWN JOB FAMILY... */
|
||||
|
||||
if (OPAL_EQUAL == orte_util_compare_name_fields(ORTE_NS_CMP_ALL, ORTE_PROC_MY_HNP, target)) {
|
||||
if (!hnp_direct || orte_static_ports || orte_use_common_port) {
|
||||
if (!hnp_direct || orte_static_ports) {
|
||||
OPAL_OUTPUT_VERBOSE((2, orte_routed_base_output,
|
||||
"%s routing to the HNP through my parent %s",
|
||||
ORTE_NAME_PRINT(ORTE_PROC_MY_NAME),
|
||||
@ -489,8 +489,8 @@ static int init_routes(orte_jobid_t job, opal_buffer_t *ndat)
|
||||
return rc;
|
||||
}
|
||||
|
||||
/* if we are using static ports or a common port, set my lifeline to point at my parent */
|
||||
if (orte_static_ports || orte_use_common_port) {
|
||||
/* if we are using static ports, set my lifeline to point at my parent */
|
||||
if (orte_static_ports) {
|
||||
lifeline = ORTE_PROC_MY_PARENT;
|
||||
} else {
|
||||
/* set our lifeline to the HNP - we will abort if that connection is lost */
|
||||
|
@ -379,7 +379,7 @@ static orte_process_name_t get_route(orte_process_name_t *target)
|
||||
* how to get there - otherwise, send it via the tree
|
||||
*/
|
||||
if (OPAL_EQUAL == orte_util_compare_name_fields(ORTE_NS_CMP_ALL, ORTE_PROC_MY_HNP, target)) {
|
||||
if (!hnp_direct || orte_static_ports || orte_use_common_port) {
|
||||
if (!hnp_direct || orte_static_ports) {
|
||||
OPAL_OUTPUT_VERBOSE((2, orte_routed_base_output,
|
||||
"%s routing to the HNP through my parent %s",
|
||||
ORTE_NAME_PRINT(ORTE_PROC_MY_NAME),
|
||||
|
@ -171,10 +171,6 @@ opal_cmd_line_init_t orte_cmd_line_opts[] = {
|
||||
NULL, OPAL_CMD_LINE_TYPE_STRING,
|
||||
"URI for the parent if tree launch is enabled."},
|
||||
|
||||
{ "orte_use_common_port", '\0', NULL, "use-common-port", 0,
|
||||
NULL, OPAL_CMD_LINE_TYPE_BOOL,
|
||||
"Use the same port as the HNP."},
|
||||
|
||||
{ NULL, '\0', NULL, "tree-spawn", 0,
|
||||
&orted_globals.tree_spawn, OPAL_CMD_LINE_TYPE_BOOL,
|
||||
"Tree spawn is underway"},
|
||||
@ -748,7 +744,7 @@ int orte_daemon(int argc, char *argv[])
|
||||
}
|
||||
#endif
|
||||
|
||||
if ((orte_static_ports || orte_use_common_port) && !orted_globals.tree_spawn) {
|
||||
if (orte_static_ports && !orted_globals.tree_spawn) {
|
||||
/* use the rollup collective to send our data to the HNP
|
||||
* so we minimize the HNP bottleneck
|
||||
*/
|
||||
|
@ -73,7 +73,6 @@ char *orte_basename = NULL;
|
||||
bool orte_static_ports = false;
|
||||
char *orte_oob_static_ports = NULL;
|
||||
bool orte_standalone_operation = false;
|
||||
bool orte_use_common_port = false;
|
||||
|
||||
bool orte_keep_fqdn_hostnames = false;
|
||||
bool orte_have_fqdn_allocation = false;
|
||||
|
@ -603,7 +603,6 @@ ORTE_DECLSPEC extern char *orte_basename;
|
||||
ORTE_DECLSPEC extern bool orte_static_ports;
|
||||
ORTE_DECLSPEC extern char *orte_oob_static_ports;
|
||||
ORTE_DECLSPEC extern bool orte_standalone_operation;
|
||||
ORTE_DECLSPEC extern bool orte_use_common_port;
|
||||
|
||||
/* nodename flags */
|
||||
ORTE_DECLSPEC extern bool orte_keep_fqdn_hostnames;
|
||||
|
@ -555,15 +555,6 @@ int orte_register_params(void)
|
||||
"Maximum size of virtual machine - used to subdivide allocation",
|
||||
false, false, -1, &orte_max_vm_size);
|
||||
|
||||
#if ORTE_ENABLE_STATIC_PORTS
|
||||
mca_base_param_reg_int_name("orte", "use_common_port",
|
||||
"Daemons use same port as HNP",
|
||||
false, false, (int)false, &value);
|
||||
orte_use_common_port = OPAL_INT_TO_BOOL(value);
|
||||
#else
|
||||
orte_use_common_port = false;
|
||||
#endif
|
||||
|
||||
mca_base_param_reg_string_name("orte", "set_default_slots",
|
||||
"Set the number of slots on nodes that lack such info to the number of specified objects [a number, \"cores\", \"numas\", \"sockets\", or \"hwthreads\"]",
|
||||
false, false, NULL, &orte_set_slots);
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user