Match the latest changes on the TEG PML (increase ompi_request_completed when a request is
finished). This commit was SVN r8259.
Этот коммит содержится в:
родитель
bf0892bb32
Коммит
011e46017f
@ -75,6 +75,7 @@ static int mca_pml_uniq_recv_request_cancel(struct ompi_request_t* request, int
|
|||||||
* broadcast the condition on the request in order to allow the other threads
|
* broadcast the condition on the request in order to allow the other threads
|
||||||
* to complete their test/wait functions.
|
* to complete their test/wait functions.
|
||||||
*/
|
*/
|
||||||
|
ompi_request_completed++;
|
||||||
if(ompi_request_waiting) {
|
if(ompi_request_waiting) {
|
||||||
opal_condition_broadcast(&ompi_request_cond);
|
opal_condition_broadcast(&ompi_request_cond);
|
||||||
}
|
}
|
||||||
@ -119,6 +120,7 @@ void mca_pml_uniq_recv_request_progress(
|
|||||||
req->req_recv.req_base.req_ompi.req_status._count = req->req_bytes_delivered;
|
req->req_recv.req_base.req_ompi.req_status._count = req->req_bytes_delivered;
|
||||||
req->req_recv.req_base.req_pml_complete = true;
|
req->req_recv.req_base.req_pml_complete = true;
|
||||||
req->req_recv.req_base.req_ompi.req_complete = true;
|
req->req_recv.req_base.req_ompi.req_complete = true;
|
||||||
|
ompi_request_completed++;
|
||||||
if(ompi_request_waiting) {
|
if(ompi_request_waiting) {
|
||||||
opal_condition_broadcast(&ompi_request_cond);
|
opal_condition_broadcast(&ompi_request_cond);
|
||||||
}
|
}
|
||||||
|
@ -160,6 +160,7 @@ void mca_pml_uniq_send_request_progress(
|
|||||||
req->req_send.req_base.req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS;
|
req->req_send.req_base.req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS;
|
||||||
req->req_send.req_base.req_ompi.req_status._count = req->req_bytes_sent;
|
req->req_send.req_base.req_ompi.req_status._count = req->req_bytes_sent;
|
||||||
req->req_send.req_base.req_ompi.req_complete = true;
|
req->req_send.req_base.req_ompi.req_complete = true;
|
||||||
|
ompi_request_completed++;
|
||||||
if(ompi_request_waiting) {
|
if(ompi_request_waiting) {
|
||||||
opal_condition_broadcast(&ompi_request_cond);
|
opal_condition_broadcast(&ompi_request_cond);
|
||||||
}
|
}
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user