@@ -1048,10 +1048,6 @@ int mca_pml_ob1_recv_request_schedule_once( mca_pml_ob1_recv_request_t* recvreq,
1048
1048
static inline void append_recv_req_to_queue (opal_list_t * queue ,
1049
1049
mca_pml_ob1_recv_request_t * req )
1050
1050
{
1051
- if (OPAL_UNLIKELY (req -> req_recv .req_base .req_type == MCA_PML_REQUEST_IPROBE ||
1052
- req -> req_recv .req_base .req_type == MCA_PML_REQUEST_IMPROBE ))
1053
- return ;
1054
-
1055
1051
opal_list_append (queue , (opal_list_item_t * )req );
1056
1052
1057
1053
#if OMPI_WANT_PERUSE
@@ -1202,7 +1198,7 @@ void mca_pml_ob1_recv_req_start(mca_pml_ob1_recv_request_t *req)
1202
1198
req -> req_recv .req_base .req_proc = proc -> ompi_proc ;
1203
1199
frag = recv_req_match_specific_proc (req , proc );
1204
1200
queue = & proc -> specific_receives ;
1205
- /* wild cardrecv will be prepared on match */
1201
+ /* wildcard recv will be prepared on match */
1206
1202
prepare_recv_req_converter (req );
1207
1203
}
1208
1204
@@ -1211,7 +1207,9 @@ void mca_pml_ob1_recv_req_start(mca_pml_ob1_recv_request_t *req)
1211
1207
& (req -> req_recv .req_base ), PERUSE_RECV );
1212
1208
/* We didn't find any matches. Record this irecv so we can match
1213
1209
it when the message comes in. */
1214
- append_recv_req_to_queue (queue , req );
1210
+ if (OPAL_LIKELY (req -> req_recv .req_base .req_type != MCA_PML_REQUEST_IPROBE &&
1211
+ req -> req_recv .req_base .req_type != MCA_PML_REQUEST_IMPROBE ))
1212
+ append_recv_req_to_queue (queue , req );
1215
1213
req -> req_match_received = false;
1216
1214
OB1_MATCHING_UNLOCK (& ob1_comm -> matching_lock );
1217
1215
} else {
0 commit comments