Commit 55b4ca32 authored by Huihuo Zheng's avatar Huihuo Zheng
Browse files

remove mutex

parent 0603c6f2
......@@ -1245,9 +1245,10 @@ void *H5Dwrite_pthread_func_vol(void *arg) {
task->buf = mmap(NULL, task->size, PROT_READ, MAP_SHARED, wmm->mmap.fd, task->offset);
H5VL_pass_through_ext_t *o = (H5VL_pass_through_ext_t *)task->dataset_obj;
hbool_t acquired=false;
while(!acquired)
H5TSmutex_acquire(&acquired);
//while(!acquired)
//H5TSmutex_acquire(&acquired);
if (wmm->mpi.rank== io_node() && debug_level()>1) printf("pthread: acquired global mutex\n");
sleep(1);
H5VLrestore_lib_state(task->h5_state);
void **req;
#ifdef THETA
......@@ -1273,7 +1274,7 @@ void *H5Dwrite_pthread_func_vol(void *arg) {
H5Tclose(task->mem_type_id);
H5VLreset_lib_state();
H5VLfree_lib_state(task->h5_state);
H5TSmutex_release();
//H5TSmutex_release();
if (wmm->mpi.rank==io_node() && debug_level()>1) printf("pthread: global mutex_released\n");
if (wmm->mpi.rank== io_node() && debug_level()>1) {
printf("===================================\n");
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment