1
1
addition error checking

This commit was SVN r5742.
Этот коммит содержится в:
Tim Woodall 2005-05-18 15:31:23 +00:00
родитель 75a43e84ba
Коммит 3528471f22
2 изменённых файлов: 8 добавлений и 2 удалений

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

@ -471,7 +471,8 @@ static void mca_oob_tcp_recv_handler(int sd, short flags, void* user)
mca_oob_tcp_recv_connect(sd, &hdr);
break;
default:
ompi_output(0, "[%lu,%lu,%lu] mca_oob_tcp_recv_handler: invalid message type: %d\n", hdr.msg_type);
ompi_output(0, "[%lu,%lu,%lu] mca_oob_tcp_recv_handler: invalid message type: %d\n",
ORTE_NAME_ARGS(orte_process_info.my_name), hdr.msg_type);
close(sd);
break;
}

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

@ -131,8 +131,8 @@ int mca_oob_tcp_ping(
}
hdr.msg_dst = *name;
hdr.msg_type = MCA_OOB_TCP_PROBE;
MCA_OOB_TCP_HDR_HTON(&hdr);
MCA_OOB_TCP_HDR_HTON(&hdr);
if((rc = write(sd, &hdr, sizeof(hdr))) != sizeof(hdr)) {
close(sd);
return OMPI_ERR_UNREACH;
@ -150,6 +150,11 @@ int mca_oob_tcp_ping(
close(sd);
return OMPI_ERR_UNREACH;
}
MCA_OOB_TCP_HDR_NTOH(&hdr);
if(hdhr.msg_type != MCA_OOB_TCP_PROBE) {
close(sd);
return OMPI_ERR_UNREACH;
}
close(sd);
return OMPI_SUCCESS;
}