1
1

Remove the diagnostic messages from the xcast. Move one step closer on comm_spawn....

This commit was SVN r3759.
Этот коммит содержится в:
Ralph Castain 2004-12-09 06:32:44 +00:00
родитель 017d39a633
Коммит 95510d3684
3 изменённых файлов: 5 добавлений и 6 удалений

Просмотреть файл

@ -393,7 +393,8 @@ int ompi_comm_start_processes (char *command, char **argv, int maxprocs,
NULL,
maxprocs,
ompi_rte_all_procs_registered, NULL);
free(segment);
/*
* spawn procs
*/

Просмотреть файл

@ -55,10 +55,7 @@ int mca_oob_xcast(
for (ptr = (ompi_name_server_namelist_t*)ompi_list_get_first(peers);
ptr != (ompi_name_server_namelist_t*)ompi_list_get_end(peers);
ptr = (ompi_name_server_namelist_t*)ompi_list_get_next(ptr)) {
ompi_output(0, "[%d,%d,%d] xcasting message of size %d to [%d,%d,%d]",
OMPI_NAME_ARGS(*root), (int)buf_size, OMPI_NAME_ARGS(*(ptr->name)));
rc = mca_oob_send_packed(ptr->name, buffer, tag, 0);
ompi_output(0, "\tsend complete with return code %d", (int)rc);
if(rc < 0) {
return rc;
}
@ -66,7 +63,6 @@ int mca_oob_xcast(
} else {
ompi_buffer_t rbuf;
int rc = mca_oob_recv_packed(MCA_OOB_NAME_ANY, &rbuf, &tag);
ompi_output(0, "[%d,%d,%d] received xcast", OMPI_NAME_ARGS(*ompi_rte_get_self()));
if(rc < 0) {
return rc;
}

Просмотреть файл

@ -121,7 +121,8 @@ static mca_oob_t mca_oob_tcp = {
mca_oob_tcp_init,
mca_oob_tcp_fini,
mca_oob_tcp_addr_pack,
mca_oob_tcp_registry_callback
mca_oob_tcp_registry_callback,
mca_oob_xcast
};
@ -562,6 +563,7 @@ int mca_oob_tcp_resolve(mca_oob_tcp_peer_t* peer)
OMPI_REGISTRY_OR,
OMPI_REGISTRY_NOTIFY_ADD_ENTRY|OMPI_REGISTRY_NOTIFY_DELETE_ENTRY|
OMPI_REGISTRY_NOTIFY_MODIFICATION|
OMPI_REGISTRY_NOTIFY_PRE_EXISTING |
OMPI_REGISTRY_NOTIFY_ON_STARTUP|OMPI_REGISTRY_NOTIFY_INCLUDE_STARTUP_DATA|
OMPI_REGISTRY_NOTIFY_ON_SHUTDOWN|OMPI_REGISTRY_NOTIFY_INCLUDE_SHUTDOWN_DATA,
segment,