Merge pull request #1590 from hjelmn/thread_multiple
osc/pt2pt: do not drop/reacquire the ompi_request_lock
Этот коммит содержится в:
Коммит
f0f3383006
@ -1622,8 +1622,6 @@ static int ompi_osc_pt2pt_callback (ompi_request_t *request)
|
|||||||
size_t incoming_length = request->req_status._ucount;
|
size_t incoming_length = request->req_status._ucount;
|
||||||
int source = request->req_status.MPI_SOURCE;
|
int source = request->req_status.MPI_SOURCE;
|
||||||
|
|
||||||
OPAL_THREAD_UNLOCK(&ompi_request_lock);
|
|
||||||
|
|
||||||
assert(incoming_length >= sizeof(ompi_osc_pt2pt_header_base_t));
|
assert(incoming_length >= sizeof(ompi_osc_pt2pt_header_base_t));
|
||||||
(void)incoming_length; // silence compiler warning
|
(void)incoming_length; // silence compiler warning
|
||||||
|
|
||||||
@ -1667,8 +1665,6 @@ static int ompi_osc_pt2pt_callback (ompi_request_t *request)
|
|||||||
osc_pt2pt_gc_add_request (module, request);
|
osc_pt2pt_gc_add_request (module, request);
|
||||||
ompi_osc_pt2pt_frag_start_receive (module);
|
ompi_osc_pt2pt_frag_start_receive (module);
|
||||||
|
|
||||||
OPAL_THREAD_LOCK(&ompi_request_lock);
|
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((50, ompi_osc_base_framework.framework_output,
|
OPAL_OUTPUT_VERBOSE((50, ompi_osc_base_framework.framework_output,
|
||||||
"finished posting receive request"));
|
"finished posting receive request"));
|
||||||
|
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user