Коммит
650a67b2a8
@ -879,7 +879,7 @@ int mca_oob_tcp_peer_recv_connect_ack(mca_oob_tcp_peer_t* pr,
|
|||||||
* process, I'll simply defer until I receive the request
|
* process, I'll simply defer until I receive the request
|
||||||
*/
|
*/
|
||||||
if (is_new &&
|
if (is_new &&
|
||||||
( MCA_OOB_TCP_CONNECTED == peer->state ||
|
( MCA_OOB_TCP_CONNECTED == peer->state ||
|
||||||
MCA_OOB_TCP_CONNECTING == peer->state ||
|
MCA_OOB_TCP_CONNECTING == peer->state ||
|
||||||
MCA_OOB_TCP_CONNECT_ACK == peer->state ) ) {
|
MCA_OOB_TCP_CONNECT_ACK == peer->state ) ) {
|
||||||
if (retry(peer, sd, false)) {
|
if (retry(peer, sd, false)) {
|
||||||
@ -888,7 +888,7 @@ int mca_oob_tcp_peer_recv_connect_ack(mca_oob_tcp_peer_t* pr,
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* check that this is from a matching version */
|
/* check that this is from a matching version */
|
||||||
version = (char*)((void*)msg + offset);
|
version = (char*)((char*)msg + offset);
|
||||||
offset += strlen(version) + 1;
|
offset += strlen(version) + 1;
|
||||||
if (0 != strcmp(version, orte_version_string)) {
|
if (0 != strcmp(version, orte_version_string)) {
|
||||||
opal_output(0, "%s tcp_peer_recv_connect_ack: "
|
opal_output(0, "%s tcp_peer_recv_connect_ack: "
|
||||||
@ -908,7 +908,7 @@ int mca_oob_tcp_peer_recv_connect_ack(mca_oob_tcp_peer_t* pr,
|
|||||||
ORTE_NAME_PRINT(&peer->name));
|
ORTE_NAME_PRINT(&peer->name));
|
||||||
|
|
||||||
/* check security token */
|
/* check security token */
|
||||||
cred = (char*)((void*)msg + offset);
|
cred = (char*)((char*)msg + offset);
|
||||||
credsize = hdr.nbytes - offset;
|
credsize = hdr.nbytes - offset;
|
||||||
if (OPAL_SUCCESS != (rc = opal_sec.authenticate(cred, credsize, &peer->auth_method))) {
|
if (OPAL_SUCCESS != (rc = opal_sec.authenticate(cred, credsize, &peer->auth_method))) {
|
||||||
char *hostname;
|
char *hostname;
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user