|
8 | 8 |
|
9 | 9 | #include "mpir_process.h" |
10 | 10 |
|
| 11 | +/* |
| 12 | +=== BEGIN_MPI_T_CVAR_INFO_BLOCK === |
| 13 | +
|
| 14 | +cvars: |
| 15 | + - name : MPIR_CVAR_PROGRESS_TIMEOUT |
| 16 | + category : CH4 |
| 17 | + type : int |
| 18 | + default : 0 |
| 19 | + class : none |
| 20 | + verbosity : MPI_T_VERBOSITY_USER_BASIC |
| 21 | + scope : MPI_T_SCOPE_LOCAL |
| 22 | + description : >- |
| 23 | + Sets the timeout in seconds to dump outstanding requests when progress wait is not making progress for some time. |
| 24 | +
|
| 25 | +
|
| 26 | +=== END_MPI_T_CVAR_INFO_BLOCK === |
| 27 | +*/ |
| 28 | + |
11 | 29 | /* NOTE-R1: MPIR_REQUEST_KIND__MPROBE signifies that this is a request created by |
12 | 30 | * MPI_Mprobe or MPI_Improbe. Since we use MPI_Request objects as our |
13 | 31 | * MPI_Message objects, we use this separate kind in order to provide stronger |
@@ -329,23 +347,23 @@ extern MPIR_Request MPIR_Request_direct[MPIR_REQUEST_PREALLOC]; |
329 | 347 | int iter = 0; \ |
330 | 348 | bool progress_timed_out = false; \ |
331 | 349 | MPL_time_t time_start; \ |
332 | | - if (MPIR_CVAR_DEBUG_PROGRESS_TIMEOUT > 0) { \ |
| 350 | + if (MPIR_CVAR_PROGRESS_TIMEOUT > 0) { \ |
333 | 351 | MPL_wtime(&time_start); \ |
334 | 352 | } |
335 | 353 |
|
336 | 354 | #define DEBUG_PROGRESS_CHECK \ |
337 | | - if (MPIR_CVAR_DEBUG_PROGRESS_TIMEOUT > 0) { \ |
| 355 | + if (MPIR_CVAR_PROGRESS_TIMEOUT > 0) { \ |
338 | 356 | iter++; \ |
339 | 357 | if (iter == 0xffff) {\ |
340 | 358 | double time_diff = 0.0; \ |
341 | 359 | MPL_time_t time_cur; \ |
342 | 360 | MPL_wtime(&time_cur); \ |
343 | 361 | MPL_wtime_diff(&time_start, &time_cur, &time_diff); \ |
344 | | - if (time_diff > MPIR_CVAR_DEBUG_PROGRESS_TIMEOUT && !progress_timed_out) { \ |
| 362 | + if (time_diff > MPIR_CVAR_PROGRESS_TIMEOUT && !progress_timed_out) { \ |
345 | 363 | MPIR_Request_debug(); \ |
346 | 364 | MPL_backtrace_show(stdout); \ |
347 | 365 | progress_timed_out = true; \ |
348 | | - } else if (time_diff > MPIR_CVAR_DEBUG_PROGRESS_TIMEOUT * 2) { \ |
| 366 | + } else if (time_diff > MPIR_CVAR_PROGRESS_TIMEOUT * 2) { \ |
349 | 367 | MPIR_ERR_SETANDJUMP(mpi_errno, MPI_ERR_OTHER, "**timeout"); \ |
350 | 368 | } \ |
351 | 369 | iter = 0; \ |
|
0 commit comments