File tree Expand file tree Collapse file tree 1 file changed +5
-8
lines changed Expand file tree Collapse file tree 1 file changed +5
-8
lines changed Original file line number Diff line number Diff line change @@ -304,8 +304,7 @@ mca_part_persist_progress(void)
304
304
req -> flags [i ] = 0 ;
305
305
}
306
306
307
- if (0 == req -> flags [i ])
308
- {
307
+ if (0 == req -> flags [i ] && OMPI_REQUEST_ACTIVE == req -> persist_reqs [i ]-> req_state ) {
309
308
ompi_request_test (& (req -> persist_reqs [i ]), & (req -> flags [i ]), MPI_STATUS_IGNORE );
310
309
if (0 != req -> flags [i ]) req -> done_count ++ ;
311
310
}
@@ -323,16 +322,14 @@ mca_part_persist_progress(void)
323
322
to_delete = req ;
324
323
}
325
324
}
325
+ }
326
326
327
+ if (NULL != to_delete && OPAL_SUCCESS == err ) {
328
+ err = mca_part_persist_free_req (to_delete );
327
329
}
330
+
328
331
OPAL_THREAD_UNLOCK (& ompi_part_persist .lock );
329
332
block_entry = opal_atomic_add_fetch_32 (& (ompi_part_persist .block_entry ), -1 );
330
- if (to_delete ) {
331
- err = mca_part_persist_free_req (to_delete );
332
- if (OMPI_SUCCESS != err ) {
333
- return OMPI_ERROR ;
334
- }
335
- }
336
333
337
334
return OMPI_SUCCESS ;
338
335
}
You can’t perform that action at this time.
0 commit comments