Skip to content

Commit 77c3a19

Browse files
committed
The matching lock should be acquired only once.
The lock will then be released in mca_pml_ob1_recv_frag_match_proc and reaquired in the while loop. Signed-off-by: George Bosilca <bosilca@icl.utk.edu>
1 parent fa08eac commit 77c3a19

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ompi/mca/pml/ob1/pml_ob1_recvfrag.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -647,12 +647,12 @@ int mca_pml_ob1_merge_cant_match( ompi_communicator_t * ompi_comm )
647647
mca_pml_ob1_comm_proc_t* proc;
648648
int cnt = 0;
649649

650+
OB1_MATCHING_LOCK(&pml_comm->matching_lock);
650651
for (uint32_t i = 0; i < pml_comm->num_procs; i++) {
651652
if ((NULL == (proc = pml_comm->procs[i])) || (NULL != proc->frags_cant_match)) {
652653
continue;
653654
}
654655

655-
OB1_MATCHING_LOCK(&pml_comm->matching_lock);
656656
/* Acquire all cant_match frags from the peer */
657657
frags_cant_match = proc->frags_cant_match;
658658
proc->frags_cant_match = NULL;

0 commit comments

Comments
 (0)