@@ -200,20 +200,20 @@ typedef struct async_instance_t {
200200 int nfopen;
201201 int mpi_size;
202202 int mpi_rank;
203- bool ex_delay; /* Delay background thread execution */
204- bool ex_fclose; /* Delay background thread execution until file close */
205- bool ex_gclose; /* Delay background thread execution until group close */
206- bool ex_dclose; /* Delay background thread execution until dset close */
207- bool start_abt_push; /* Start pushing tasks to Argobots pool */
208- bool prev_push_state; /* Previous state of start_abt_push before a change*/
209- bool pause; /* Pause background thread execution */
210- bool disable_implicit_file; /* Disable implicit async execution globally */
211- bool disable_implicit; /* Disable implicit async execution for dxpl */
212- bool disable_implicit_nondrw; /* Disable non-dataset read/write implicit async execution globally */
213- bool delay_time_env; /* Flag that indicates the delay time is set by env variable */
214- bool disable_async_dset_get; /* Disable async execution for dataset get */
215- uint64_t delay_time; /* Sleep time before background thread trying to acquire global mutex */
216- int sleep_time; /* Sleep time between checking the global mutex attemp count */
203+ bool ex_delay; /* Delay background thread execution */
204+ bool ex_fclose; /* Delay background thread execution until file close */
205+ bool ex_gclose; /* Delay background thread execution until group close */
206+ bool ex_dclose; /* Delay background thread execution until dset close */
207+ bool start_abt_push; /* Start pushing tasks to Argobots pool */
208+ bool prev_push_state; /* Previous state of start_abt_push before a change*/
209+ bool pause; /* Pause background thread execution */
210+ bool disable_implicit_file; /* Disable implicit async execution globally */
211+ bool disable_implicit; /* Disable implicit async execution for dxpl */
212+ bool disable_implicit_nondrw; /* Disable non-dataset read/write implicit async execution globally */
213+ bool delay_time_env; /* Flag that indicates the delay time is set by env variable */
214+ bool disable_async_dset_get; /* Disable async execution for dataset get */
215+ uint64_t delay_time; /* Sleep time before background thread trying to acquire global mutex */
216+ int sleep_time; /* Sleep time between checking the global mutex attemp count */
217217#ifdef ENABLE_WRITE_MEMCPY
218218 hsize_t max_mem;
219219 hsize_t used_mem;
@@ -1322,22 +1322,22 @@ async_instance_init(int backing_thread_count)
13221322 } // end for
13231323 } // end else
13241324
1325- aid->pool = pool;
1326- aid->xstreams = progress_xstreams;
1327- aid->num_xstreams = backing_thread_count;
1328- aid->progress_scheds = progress_scheds;
1329- aid->nfopen = 0;
1330- aid->ex_delay = false;
1331- aid->ex_fclose = false;
1332- aid->ex_gclose = false;
1333- aid->ex_dclose = false;
1334- aid->pause = false;
1335- aid->start_abt_push = false;
1336- aid->disable_implicit = false;
1337- aid->disable_implicit_file = false;
1338- aid->delay_time_env = false;
1339- aid->disable_async_dset_get = true;
1340- aid->disable_implicit_nondrw = false;
1325+ aid->pool = pool;
1326+ aid->xstreams = progress_xstreams;
1327+ aid->num_xstreams = backing_thread_count;
1328+ aid->progress_scheds = progress_scheds;
1329+ aid->nfopen = 0;
1330+ aid->ex_delay = false;
1331+ aid->ex_fclose = false;
1332+ aid->ex_gclose = false;
1333+ aid->ex_dclose = false;
1334+ aid->pause = false;
1335+ aid->start_abt_push = false;
1336+ aid->disable_implicit = false;
1337+ aid->disable_implicit_file = false;
1338+ aid->delay_time_env = false;
1339+ aid->disable_async_dset_get = true;
1340+ aid->disable_implicit_nondrw = false;
13411341
13421342 // Check for delaying operations to file / group / dataset close operations
13431343 env_var = getenv("HDF5_ASYNC_EXE_FCLOSE");
@@ -1366,7 +1366,7 @@ async_instance_init(int backing_thread_count)
13661366
13671367 env_var = getenv("HDF5_ASYNC_DISABLE_IMPLICIT_NON_DSET_RW");
13681368 if (env_var && *env_var && atoi(env_var) > 0)
1369- aid->disable_implicit_nondrw = true;
1369+ aid->disable_implicit_nondrw = true;
13701370
13711371#ifdef ENABLE_WRITE_MEMCPY
13721372 // Get max memory allowed for async memcpy
@@ -21819,7 +21819,7 @@ H5VL_async_is_implicit_disabled(int op_type, const char *func_name)
2181921819 ret_value = 1;
2182021820 }
2182121821 // Need file ops to be implicit to init requried internal data structures
21822- if (op_type != FILE_OP && op_type != DSET_RW_OP && async_instance_g->disable_implicit_nondrw ) {
21822+ if (op_type != FILE_OP && op_type != DSET_RW_OP && async_instance_g->disable_implicit_nondrw) {
2182321823 func_log(func_name, "implicit async disabled with disable_implicit_nondrw ");
2182421824 ret_value = 1;
2182521825 }
0 commit comments