mca_plm_rsh_component 72 orte/mca/plm/rsh/plm_rsh.h ORTE_MODULE_DECLSPEC extern orte_plm_rsh_component_t mca_plm_rsh_component; mca_plm_rsh_component 81 orte/mca/plm/rsh/plm_rsh_component.c orte_plm_rsh_component_t mca_plm_rsh_component = { mca_plm_rsh_component 109 orte/mca/plm/rsh/plm_rsh_component.c mca_base_component_t *c = &mca_plm_rsh_component.super.base_version; mca_plm_rsh_component 112 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.num_concurrent = 128; mca_plm_rsh_component 118 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.num_concurrent); mca_plm_rsh_component 120 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.force_rsh = false; mca_plm_rsh_component 125 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.force_rsh); mca_plm_rsh_component 126 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.disable_qrsh = false; mca_plm_rsh_component 132 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.disable_qrsh); mca_plm_rsh_component 134 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.daemonize_qrsh = false; mca_plm_rsh_component 140 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.daemonize_qrsh); mca_plm_rsh_component 142 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.disable_llspawn = false; mca_plm_rsh_component 148 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.disable_llspawn); mca_plm_rsh_component 150 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.daemonize_llspawn = false; mca_plm_rsh_component 156 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.daemonize_llspawn); mca_plm_rsh_component 158 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.priority = 10; mca_plm_rsh_component 163 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.priority); mca_plm_rsh_component 173 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.no_tree_spawn = false; mca_plm_rsh_component 179 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.no_tree_spawn); mca_plm_rsh_component 182 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.agent = "ssh : rsh"; mca_plm_rsh_component 188 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.agent); mca_plm_rsh_component 193 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.assume_same_shell = true; mca_plm_rsh_component 199 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.assume_same_shell); mca_plm_rsh_component 203 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.pass_environ_mca_params = true; mca_plm_rsh_component 209 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.pass_environ_mca_params); mca_plm_rsh_component 210 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.ssh_args = NULL; mca_plm_rsh_component 216 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.ssh_args); mca_plm_rsh_component 218 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.pass_libpath = NULL; mca_plm_rsh_component 224 orte/mca/plm/rsh/plm_rsh_component.c &mca_plm_rsh_component.pass_libpath); mca_plm_rsh_component 234 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.using_qrsh = false; mca_plm_rsh_component 235 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.using_llspawn = false; mca_plm_rsh_component 236 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.agent_argv = NULL; mca_plm_rsh_component 239 orte/mca/plm/rsh/plm_rsh_component.c if (mca_plm_rsh_component.num_concurrent <= 0) { mca_plm_rsh_component 241 orte/mca/plm/rsh/plm_rsh_component.c true, mca_plm_rsh_component.num_concurrent); mca_plm_rsh_component 242 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.num_concurrent = 1; mca_plm_rsh_component 246 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.delay.tv_sec = strtol(mca_plm_rsh_delay_string, &ctmp, 10); mca_plm_rsh_component 248 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.delay.tv_sec = 0; mca_plm_rsh_component 251 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.delay.tv_nsec = 1000 * strtol (ctmp + 1, NULL, 10); mca_plm_rsh_component 280 orte/mca/plm/rsh/plm_rsh_component.c if (!mca_plm_rsh_component.disable_qrsh && mca_plm_rsh_component 296 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.agent = tmp; mca_plm_rsh_component 297 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.using_qrsh = true; mca_plm_rsh_component 302 orte/mca/plm/rsh/plm_rsh_component.c if (!mca_plm_rsh_component.disable_llspawn && mca_plm_rsh_component 314 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.agent = strdup("llspawn"); mca_plm_rsh_component 315 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.using_llspawn = true; mca_plm_rsh_component 325 orte/mca/plm/rsh/plm_rsh_component.c if (NULL != mca_plm_rsh_component.agent) { mca_plm_rsh_component 327 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.agent); mca_plm_rsh_component 336 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.agent)); mca_plm_rsh_component 343 orte/mca/plm/rsh/plm_rsh_component.c *priority = mca_plm_rsh_component.priority; mca_plm_rsh_component 372 orte/mca/plm/rsh/plm_rsh_component.c lines = opal_argv_split(mca_plm_rsh_component.agent, ':'); mca_plm_rsh_component 419 orte/mca/plm/rsh/plm_rsh_component.c (NULL == agent_list) ? mca_plm_rsh_component.agent : agent_list, mca_plm_rsh_component 421 orte/mca/plm/rsh/plm_rsh_component.c if (NULL == (mca_plm_rsh_component.agent_argv = orte_plm_rsh_search(agent_list, path))) { mca_plm_rsh_component 427 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.agent_path = strdup(mca_plm_rsh_component.agent_argv[0]); mca_plm_rsh_component 428 orte/mca/plm/rsh/plm_rsh_component.c bname = opal_basename(mca_plm_rsh_component.agent_argv[0]); mca_plm_rsh_component 433 orte/mca/plm/rsh/plm_rsh_component.c free(mca_plm_rsh_component.agent_argv[0]); mca_plm_rsh_component 434 orte/mca/plm/rsh/plm_rsh_component.c mca_plm_rsh_component.agent_argv[0] = bname; mca_plm_rsh_component 439 orte/mca/plm/rsh/plm_rsh_component.c opal_argv_append_unique_nosize(&mca_plm_rsh_component.agent_argv, "-X", false); mca_plm_rsh_component 445 orte/mca/plm/rsh/plm_rsh_component.c for (i = 1; NULL != mca_plm_rsh_component.agent_argv[i]; ++i) { mca_plm_rsh_component 446 orte/mca/plm/rsh/plm_rsh_component.c if (0 == strcasecmp("-x", mca_plm_rsh_component.agent_argv[i])) { mca_plm_rsh_component 450 orte/mca/plm/rsh/plm_rsh_component.c if (NULL == mca_plm_rsh_component.agent_argv[i]) { mca_plm_rsh_component 451 orte/mca/plm/rsh/plm_rsh_component.c opal_argv_append_nosize(&mca_plm_rsh_component.agent_argv, "-x"); mca_plm_rsh_component 195 orte/mca/plm/rsh/plm_rsh_module.c if (mca_plm_rsh_component.using_qrsh) { mca_plm_rsh_component 218 orte/mca/plm/rsh/plm_rsh_module.c } else if(mca_plm_rsh_component.using_llspawn) { mca_plm_rsh_component 230 orte/mca/plm/rsh/plm_rsh_module.c if (ORTE_SUCCESS != (rc = launch_agent_setup(mca_plm_rsh_component.agent, NULL))) { mca_plm_rsh_component 321 orte/mca/plm/rsh/plm_rsh_module.c if (num_in_progress < mca_plm_rsh_component.num_concurrent) { mca_plm_rsh_component 382 orte/mca/plm/rsh/plm_rsh_module.c if (NULL != mca_plm_rsh_component.ssh_args) { mca_plm_rsh_component 384 orte/mca/plm/rsh/plm_rsh_module.c ssh_argv = opal_argv_split(mca_plm_rsh_component.ssh_args, ' '); mca_plm_rsh_component 452 orte/mca/plm/rsh/plm_rsh_module.c if (NULL != mca_plm_rsh_component.pass_libpath) { mca_plm_rsh_component 454 orte/mca/plm/rsh/plm_rsh_module.c opal_asprintf(&lib_base, "%s:%s/%s", mca_plm_rsh_component.pass_libpath, prefix_dir, param); mca_plm_rsh_component 456 orte/mca/plm/rsh/plm_rsh_module.c opal_asprintf(&lib_base, "%s:%s", mca_plm_rsh_component.pass_libpath, param); mca_plm_rsh_component 596 orte/mca/plm/rsh/plm_rsh_module.c if (mca_plm_rsh_component.no_tree_spawn && mca_plm_rsh_component 603 orte/mca/plm/rsh/plm_rsh_module.c ((!mca_plm_rsh_component.using_qrsh) || mca_plm_rsh_component 604 orte/mca/plm/rsh/plm_rsh_module.c (mca_plm_rsh_component.using_qrsh && mca_plm_rsh_component.daemonize_qrsh)) && mca_plm_rsh_component 605 orte/mca/plm/rsh/plm_rsh_module.c ((!mca_plm_rsh_component.using_llspawn) || mca_plm_rsh_component 606 orte/mca/plm/rsh/plm_rsh_module.c (mca_plm_rsh_component.using_llspawn && mca_plm_rsh_component.daemonize_llspawn))) { mca_plm_rsh_component 624 orte/mca/plm/rsh/plm_rsh_module.c if (!mca_plm_rsh_component.no_tree_spawn) { mca_plm_rsh_component 634 orte/mca/plm/rsh/plm_rsh_module.c if (mca_plm_rsh_component.pass_environ_mca_params) { mca_plm_rsh_component 888 orte/mca/plm/rsh/plm_rsh_module.c mca_plm_rsh_component.no_tree_spawn = true; mca_plm_rsh_component 944 orte/mca/plm/rsh/plm_rsh_module.c while (num_in_progress < mca_plm_rsh_component.num_concurrent) { mca_plm_rsh_component 1096 orte/mca/plm/rsh/plm_rsh_module.c mca_plm_rsh_component.num_concurrent < map->num_new_daemons) { mca_plm_rsh_component 1111 orte/mca/plm/rsh/plm_rsh_module.c true, mca_plm_rsh_component.num_concurrent, map->num_new_daemons); mca_plm_rsh_component 1169 orte/mca/plm/rsh/plm_rsh_module.c if (!mca_plm_rsh_component.no_tree_spawn) { mca_plm_rsh_component 1200 orte/mca/plm/rsh/plm_rsh_module.c if (!mca_plm_rsh_component.no_tree_spawn) { mca_plm_rsh_component 1282 orte/mca/plm/rsh/plm_rsh_module.c mca_plm_rsh_component.no_tree_spawn = true; mca_plm_rsh_component 1362 orte/mca/plm/rsh/plm_rsh_module.c free(mca_plm_rsh_component.agent_path); mca_plm_rsh_component 1364 orte/mca/plm/rsh/plm_rsh_module.c opal_argv_free(mca_plm_rsh_component.agent_argv); mca_plm_rsh_component 1418 orte/mca/plm/rsh/plm_rsh_module.c if (NULL == mca_plm_rsh_component.agent && NULL == agent) { mca_plm_rsh_component 1426 orte/mca/plm/rsh/plm_rsh_module.c (NULL == agent) ? mca_plm_rsh_component.agent : agent, mca_plm_rsh_component 1513 orte/mca/plm/rsh/plm_rsh_module.c argv = opal_argv_copy(mca_plm_rsh_component.agent_argv); mca_plm_rsh_component 1514 orte/mca/plm/rsh/plm_rsh_module.c argc = opal_argv_count(mca_plm_rsh_component.agent_argv); mca_plm_rsh_component 1622 orte/mca/plm/rsh/plm_rsh_module.c if (mca_plm_rsh_component.assume_same_shell) {