Skip to content

Commit

Permalink
Add more debug info
Browse files Browse the repository at this point in the history
  • Loading branch information
houjun committed Apr 1, 2024
1 parent 68faecb commit c915020
Showing 1 changed file with 8 additions and 3 deletions.
11 changes: 8 additions & 3 deletions src/h5_async_vol.c
Original file line number Diff line number Diff line change
Expand Up @@ -23443,8 +23443,6 @@ H5VL_async_request_wait(void *obj, uint64_t timeout, H5VL_request_status_t *stat
}

if (timeout > 0 && task->is_done == 0) {
func_log(__func__, "release global lock");

func_log(__func__, "release global lock");
if (H5TSmutex_release(&mutex_count) < 0)
fprintf(fout_g, " [ASYNC VOL ERROR] %s with H5TSmutex_release\n", __func__);
Expand Down Expand Up @@ -23549,11 +23547,18 @@ H5VL_async_request_wait(void *obj, uint64_t timeout, H5VL_request_status_t *stat

done:

int tmp_cnt = 0;
while (false == acquired && mutex_count > 0) {
func_log_int1(__func__, "trying to acquire global lock, count", mutex_count);
if (H5TSmutex_acquire(mutex_count, &acquired) < 0)
fprintf(fout_g, " [ASYNC VOL ERROR] %s with H5TSmutex_acquire\n", __func__);
func_log_int1(__func__, "acquired global lock, count", mutex_count);
func_log_uint64_1(__func__, " timeout", timeout);
func_log_int1(__func__, " iter", tmp_cnt);
if (tmp_cnt > 0)
usleep(1000000);
tmp_cnt++;
}
func_log_int1(__func__, "acquired global lock, count", mutex_count);

#ifdef ENABLE_DBG_MSG
if (async_instance_g && (async_instance_g->mpi_rank == ASYNC_DBG_MSG_RANK || -1 == ASYNC_DBG_MSG_RANK))
Expand Down

0 comments on commit c915020

Please sign in to comment.