Commit e41d0a58 authored by Huihuo Zheng's avatar Huihuo Zheng
Browse files

debug

parent 7137617a
......@@ -1248,6 +1248,7 @@ void *H5Dwrite_pthread_func_vol(void *arg) {
data->file_space_id, data->xfer_plist_id,
data->buf, req);
#endif
if (o->H5DRMM->mpi.rank==0)printf("write dataset done.\n");
munmap(data->buf, data->size);
H5Sclose(data->mem_space_id);
H5Sclose(data->file_space_id);
......@@ -1732,12 +1733,7 @@ H5VL_pass_through_ext_file_create(const char *name, unsigned flags, hid_t fcpl_i
} /* end if */
else
file = NULL;
/* Close underlying FAPL */
H5Pclose(under_fapl_id);
/* Release copy of our VOL info */
H5VL_pass_through_ext_info_free(info);
printf("create|\n");
srand(time(NULL)); // Initialization, should only be called once.
file->H5DWMM = (H5Dwrite_cache_metadata*) malloc(sizeof(H5Dwrite_cache_metadata));
setH5SSD(&SSD);
......@@ -1775,6 +1771,13 @@ H5VL_pass_through_ext_file_create(const char *name, unsigned flags, hid_t fcpl_i
file->H5DWMM->mmap.fd = open(file->H5DWMM->mmap.fname, O_RDWR | O_CREAT | O_TRUNC, 0644);
file->write_cache = true;
int rc = pthread_create(&file->H5DWMM->io.pthread, NULL, H5Dwrite_pthread_func_vol, file->H5DWMM);
/* Close underlying FAPL */
H5Pclose(under_fapl_id);
/* Release copy of our VOL info */
H5VL_pass_through_ext_info_free(info);
printf("create done|\n");
return (void *)file;
} /* end H5VL_pass_through_ext_file_create() */
......
......@@ -8,7 +8,7 @@ LIBS=-L$(HDF5_DIR)/lib -lhdf5 -lz
CFLAGS=$(INCLUDES) $(LIBS)
TARGET=libh5passthrough_vol.dylib
TARGET=libh5passthrough_vol.so
CXX=mpicxx
all: makeso test_write_cache
......
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