File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -241,7 +241,7 @@ int ompi_continue_progress_request(ompi_request_t *req)
241241 if (in_progress ) return 0 ;
242242 ompi_cont_request_t * cont_req = (ompi_cont_request_t * )req ;
243243 if (NULL == cont_req -> cont_complete_list ) {
244- /* progress as many as possible */
244+ /* progress as many as allowed */
245245 return ompi_continue_progress_n (cont_req -> continue_max_poll );
246246 }
247247 if (opal_list_is_empty (cont_req -> cont_complete_list )) {
@@ -279,6 +279,11 @@ int ompi_continue_progress_request(ompi_request_t *req)
279279 * Register the provided continuation request to be included in the
280280 * global progress loop (used while a thread is waiting for the contnuation
281281 * request to complete).
282+ * We move all local continuations into the global continuation list
283+ * and mark the continuation request such that future continuations
284+ * are directly put into the global continuations list.
285+ * Once the wait completed (i.e., all continuations registered with the
286+ * continuation request) we unmark it (see ompi_continue_deregister_request_progress).
282287 */
283288int ompi_continue_register_request_progress (ompi_request_t * req )
284289{
You can’t perform that action at this time.
0 commit comments