@@ -153,7 +153,7 @@ static opal_mutex_t request_cont_lock;
153153static bool progress_callback_registered = false;
154154
155155static inline
156- void ompi_continue_cont_destroy (ompi_continuation_t * cont , ompi_request_t * cont_req )
156+ void ompi_continue_cont_release (ompi_continuation_t * cont )
157157{
158158 ompi_cont_request_t * cont_req = cont -> cont_req ;
159159 assert (OMPI_REQUEST_CONT == cont_req -> super .req_type );
@@ -197,7 +197,7 @@ void ompi_continue_cont_invoke(ompi_continuation_t *cont)
197197 void * cont_data = cont -> cont_data ;
198198 MPI_Status * statuses = cont -> cont_status ;
199199 fn (statuses , cont_data );
200- ompi_continue_cont_destroy (cont , cont_req );
200+ ompi_continue_cont_release (cont );
201201}
202202
203203/**
@@ -207,7 +207,7 @@ void ompi_continue_cont_invoke(ompi_continuation_t *cont)
207207static opal_thread_local int in_progress = 0 ;
208208
209209static
210- int ompi_continue_progress_some (const uint32_t max )
210+ int ompi_continue_progress_n (const uint32_t max )
211211{
212212
213213 if (in_progress || opal_list_is_empty (& continuation_list )) return 0 ;
@@ -231,7 +231,7 @@ int ompi_continue_progress_some(const uint32_t max)
231231
232232static int ompi_continue_progress_callback ()
233233{
234- return ompi_continue_progress_some (1 );
234+ return ompi_continue_progress_n (1 );
235235}
236236
237237int ompi_continue_progress_request (ompi_request_t * req )
@@ -240,7 +240,7 @@ int ompi_continue_progress_request(ompi_request_t *req)
240240 ompi_cont_request_t * cont_req = (ompi_cont_request_t * )req ;
241241 if (NULL == cont_req -> cont_complete_list ) {
242242 /* progress as many as possible */
243- return ompi_continue_progress_some ( req_cont_data -> continue_max_poll );
243+ return ompi_continue_progress_n ( cont_req -> continue_max_poll );
244244 }
245245 if (opal_list_is_empty (cont_req -> cont_complete_list )) {
246246 return 0 ;
0 commit comments