possible race condition - set endpoint state before sending connect ack
This commit was SVN r7448.
Этот коммит содержится в:
родитель
84e0d89497
Коммит
1b73d3856e
@ -406,7 +406,6 @@ static int mca_btl_mvapi_endpoint_reply_start_connect(mca_btl_mvapi_endpoint_t *
|
|||||||
mca_btl_mvapi_endpoint_set_remote_info(endpoint, rem_info);
|
mca_btl_mvapi_endpoint_set_remote_info(endpoint, rem_info);
|
||||||
|
|
||||||
/* Connect to endpoint */
|
/* Connect to endpoint */
|
||||||
|
|
||||||
rc = mca_btl_mvapi_endpoint_connect(endpoint);
|
rc = mca_btl_mvapi_endpoint_connect(endpoint);
|
||||||
if(rc != OMPI_SUCCESS) {
|
if(rc != OMPI_SUCCESS) {
|
||||||
BTL_ERROR(("error in endpoint connect error code is %d", rc));
|
BTL_ERROR(("error in endpoint connect error code is %d", rc));
|
||||||
@ -414,6 +413,7 @@ static int mca_btl_mvapi_endpoint_reply_start_connect(mca_btl_mvapi_endpoint_t *
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Send connection info over to remote endpoint */
|
/* Send connection info over to remote endpoint */
|
||||||
|
endpoint->endpoint_state = MCA_BTL_IB_CONNECT_ACK;
|
||||||
if(OMPI_SUCCESS != (rc = mca_btl_mvapi_endpoint_send_connect_data(endpoint))) {
|
if(OMPI_SUCCESS != (rc = mca_btl_mvapi_endpoint_send_connect_data(endpoint))) {
|
||||||
BTL_ERROR(("error in endpoint send connect request error code is %d", rc));
|
BTL_ERROR(("error in endpoint send connect request error code is %d", rc));
|
||||||
return rc;
|
return rc;
|
||||||
@ -602,9 +602,6 @@ static void mca_btl_mvapi_endpoint_recv(
|
|||||||
BTL_ERROR(("error in endpoint reply start connect"));
|
BTL_ERROR(("error in endpoint reply start connect"));
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Setup state as connected */
|
|
||||||
ib_endpoint->endpoint_state = MCA_BTL_IB_CONNECT_ACK;
|
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case MCA_BTL_IB_CONNECTING :
|
case MCA_BTL_IB_CONNECTING :
|
||||||
@ -628,8 +625,8 @@ static void mca_btl_mvapi_endpoint_recv(
|
|||||||
|
|
||||||
case MCA_BTL_IB_CONNECT_ACK:
|
case MCA_BTL_IB_CONNECT_ACK:
|
||||||
|
|
||||||
mca_btl_mvapi_endpoint_connected(ib_endpoint);
|
|
||||||
mca_btl_mvapi_endpoint_send_connect_data(ib_endpoint);
|
mca_btl_mvapi_endpoint_send_connect_data(ib_endpoint);
|
||||||
|
mca_btl_mvapi_endpoint_connected(ib_endpoint);
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case MCA_BTL_IB_CONNECTED :
|
case MCA_BTL_IB_CONNECTED :
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user