From 9c0926ef2a0fd6182f737999125b3106abaef94b Mon Sep 17 00:00:00 2001 From: Afrian Jackson Date: Thu, 7 Nov 2019 20:17:55 +0000 Subject: [PATCH] Moving fsync pmdk functionalty from persist to drain on the advice of the PMDK developers --- src/aiori-PMDK.c | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/src/aiori-PMDK.c b/src/aiori-PMDK.c index 5bb7add..4a3953b 100644 --- a/src/aiori-PMDK.c +++ b/src/aiori-PMDK.c @@ -98,13 +98,14 @@ static void *PMDK_Create(char * testFileName, IOR_param_t * param){ perror("pmem_map_file"); MPI_CHECK(MPI_Abort(MPI_COMM_WORLD, -1), "MPI_Abort() error"); } - + if(!is_pmem){ fprintf(stdout, "\n is_pmem is %d\n",is_pmem); fprintf(stdout, "\npmem_map_file thinks the hardware being used is not pmem\n"); MPI_CHECK(MPI_Abort(MPI_COMM_WORLD, -1), "MPI_Abort() error"); } + return((void *)pmemaddr); } /* PMDK_Create() */ @@ -137,12 +138,12 @@ static void *PMDK_Open(char * testFileName, IOR_param_t * param){ fprintf(stdout, "\n %ld %ld\n",open_length, mapped_len); MPI_CHECK(MPI_Abort(MPI_COMM_WORLD, -1), "MPI_Abort() error"); } - + if(!is_pmem){ fprintf(stdout, "pmem_map_file thinks the hardware being used is not pmem\n"); MPI_CHECK(MPI_Abort(MPI_COMM_WORLD, -1), "MPI_Abort() error"); } - + return((void *)pmemaddr); } /* PMDK_Open() */ @@ -184,9 +185,7 @@ static IOR_offset_t PMDK_Xfer(int access, void *file, IOR_size_t * buffer, static void PMDK_Fsync(void *fd, IOR_param_t * param) { - size_t open_length; - open_length = param->transferSize; - pmem_persist(&fd, open_length); + pmem_drain(); } /* PMDK_Fsync() */