Initialize sink location when stdin is forwarded to all ranks
This commit was SVN r26107.
Этот коммит содержится в:
родитель
4e7e7d7c3f
Коммит
e71e871bae
@ -263,6 +263,8 @@ static int hnp_push(const orte_process_name_t* dst_name, orte_iof_tag_t src_tag,
|
|||||||
ORTE_IOF_SINK_DEFINE(&sink, dst_name, -1, ORTE_IOF_STDIN,
|
ORTE_IOF_SINK_DEFINE(&sink, dst_name, -1, ORTE_IOF_STDIN,
|
||||||
stdin_write_handler,
|
stdin_write_handler,
|
||||||
&mca_iof_hnp_component.sinks);
|
&mca_iof_hnp_component.sinks);
|
||||||
|
sink->daemon.jobid = ORTE_PROC_MY_NAME->jobid;
|
||||||
|
sink->daemon.vpid = ORTE_VPID_WILDCARD;
|
||||||
} else {
|
} else {
|
||||||
/* no - lookup the proc's daemon and set that into sink */
|
/* no - lookup the proc's daemon and set that into sink */
|
||||||
if (NULL == (jdata = orte_get_job_data_object(dst_name->jobid))) {
|
if (NULL == (jdata = orte_get_job_data_object(dst_name->jobid))) {
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user