[svn-r23958] Adding some Native HDF5 tests on the EFF Stack.

8 files changed, 859 insertions, 10 deletions

diff --git a/test/compactor_write_tests/Makefile b/test/compactor_write_tests/Makefile
index 2286f6a..7c9ebf8 100644
--- a/test/compactor_write_tests/Makefile
+++ b/test/compactor_write_tests/Makefile
@@ -1,12 +1,27 @@
-all:
-	h5pcc -o multiple-writes-test1 multiple-writes-test1.c
-	h5pcc -o multiple-writes-test2 multiple-writes-test2.c
-	h5pcc -o multiple-writes-test3 multiple-writes-test3.c	
-	h5pcc -o multiple-writes-test4 multiple-writes-test4.c
-	h5pcc -o multiple-writes-test5 multiple-writes-test5.c
-	h5pcc -o parallel_write parallel_write.c
-	h5pcc -o server  test_server.c
+all:	multiple-writes parallel-writes native-writes server
 
+multiple-writes:
+		h5pcc -o multiple-writes-test1 multiple-writes-test1.c
+		h5pcc -o multiple-writes-test2 multiple-writes-test2.c
+		h5pcc -o multiple-writes-test3 multiple-writes-test3.c
+		h5pcc -o multiple-writes-test4 multiple-writes-test4.c
+		h5pcc -o multiple-writes-test5 multiple-writes-test5.c
+
+parallel-writes:
+		h5pcc -o parallel_write parallel_write.c
+
+server:		
+		h5pcc -o server  test_server.c
+
+native-writes:
+		h5pcc -o native-write-basic native_write_basic.c
+		h5pcc -o native-write-test1 native_write_test1.c
+		h5pcc -o native-write-test2 native_write_test2.c
+		h5pcc -o native-write-test3 native_write_test3.c	
+		h5pcc -o native-parallel-write native-parallel-write.c
 clean:
-	rm -rf multiple-writes-test1 multiple-writes-test2 multiple-writes-test3 multiple-writes-test4 multiple-writes-test5 server *.o *~ 
-	rm -rf parallel_write *.cfg
+	rm -rf multiple-writes-test1 multiple-writes-test2 
+	rm -rf multiple-writes-test3 multiple-writes-test4 multiple-writes-test5
+	rm -rf server *.o *~ 
+	rm -rf parallel_write native-write-basic *.cfg
+	rm -rf native-write-test1 native-write-test2
diff --git a/test/compactor_write_tests/eff_file.h5 b/test/compactor_write_tests/eff_file.h5
new file mode 100644
index 0000000..d1b4e1a
--- /dev/null
+++ b/test/compactor_write_tests/eff_file.h5
diff --git a/test/compactor_write_tests/native-parallel-write.c b/test/compactor_write_tests/native-parallel-write.c
new file mode 100644
index 0000000..d0a9b55
--- /dev/null
+++ b/test/compactor_write_tests/native-parallel-write.c
@@ -0,0 +1,144 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <assert.h>
+#include "mpi.h"
+#include "hdf5.h"
+
+#define NX     8                      /* dataset dimensions */
+#define NY     8 
+#define RANK   2
+
+
+
+int main (int argc, char **argv){
+  
+  const char filename[] = "eff_file.h5";
+  hid_t file_id, file_id_new;
+  hid_t dataspaceID, dataspace2;
+  hid_t dset_id, dset_id_new;
+  hid_t fapl_id, dxpl_id, fapl_self_id;
+  
+  const unsigned int nelem = 60;
+  int *data = NULL;
+  unsigned int i = 0;
+  hsize_t dimsf[2];
+  hsize_t count[2], offset[2];
+
+  int my_rank, my_size, ret;
+  int provided;
+  hid_t event_q, int_id;
+  
+  int num_requests = 0;  
+  H5_status_t *status = NULL;
+
+  MPI_Init_thread(&argc, &argv, MPI_THREAD_MULTIPLE, &provided);
+  if(MPI_THREAD_MULTIPLE != provided) {
+    fprintf(stderr, "MPI does not have MPI_THREAD_MULTIPLE support\n");
+    exit(1);
+  }
+
+  EFF_init (MPI_COMM_WORLD, MPI_INFO_NULL);
+
+  MPI_Comm_rank (MPI_COMM_WORLD, &my_rank);
+  MPI_Comm_size (MPI_COMM_WORLD, &my_size);
+
+  if (my_size > 8){
+    fprintf (stderr, "Max only 8 processes in this code!\n");
+    EFF_finalize();
+    MPI_Finalize();
+  }
+  fprintf(stderr, "APP processes = %d, my rank is %d\n", my_size, my_rank);
+
+  fapl_id = H5Pcreate (H5P_FILE_ACCESS);
+  H5Pset_fapl_iod(fapl_id, MPI_COMM_WORLD, MPI_INFO_NULL);
+
+
+  event_q = H5EQcreate(fapl_id);
+  assert(event_q);
+  dimsf[0] = NX;
+  dimsf[1] = NY;
+  dataspaceID = H5Screate_simple(RANK, dimsf, NULL); 
+
+  if (!my_rank){
+
+    fapl_self_id = H5Pcreate (H5P_FILE_ACCESS);
+    H5Pset_fapl_iod(fapl_self_id, MPI_COMM_SELF, MPI_INFO_NULL);
+  
+    fprintf(stderr,"Rank %d creating a File\n", my_rank);
+    file_id = H5Fcreate(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_self_id);
+    fprintf(stderr,"Rank %d completed creating a file\n", my_rank);
+    fprintf(stderr,"Rank %d creating a dataset\n", my_rank);
+    dset_id = H5Dcreate(file_id, "D1" , H5T_NATIVE_INT, dataspaceID,
+		      H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
+    fprintf(stderr,"completed creating a dataset\n", my_rank);
+    H5Pclose(fapl_self_id);
+    H5Dclose(dset_id);
+    H5Fclose(file_id);
+  }
+  
+  MPI_Barrier(MPI_COMM_WORLD);
+  
+  file_id_new = H5Fopen(filename, H5F_ACC_RDWR, fapl_id );
+  dset_id_new = H5Dopen(file_id_new, "D1", H5P_DEFAULT);
+
+  fprintf (stderr, "%d : file_id : %d, dset_id: %d\n",
+	   my_rank,
+	   file_id_new, dset_id);
+  
+  count[0] = NY/my_size;
+  count[1] = 8;
+  offset[0] = my_rank * count[0];
+  offset[1] = 0;
+
+  dataspace2 = H5Screate_simple(RANK, count, NULL);
+
+  H5Sselect_hyperslab(dataspaceID, 
+		      H5S_SELECT_SET,
+		      offset,
+		      NULL,
+		      count,
+		      NULL);
+
+  
+  data = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data[i] = my_rank + 10;
+  }
+  
+ 
+  ret = H5Dwrite_ff(dset_id_new, 
+		    H5T_NATIVE_INT,
+		    dataspace2, 
+		    dataspaceID,
+		    H5P_DEFAULT,
+		    data,
+		    0,
+		    event_q);
+  assert(ret == 0);
+  
+
+
+
+
+  H5EQwait(event_q, &num_requests, &status);
+  free(status);
+
+  H5Sclose(dataspaceID);
+  H5Sclose(dataspace2);
+  H5Pclose(fapl_id);
+  H5Dclose(dset_id_new);
+
+  H5Fclose(file_id_new);
+
+  H5EQclose (event_q);
+
+  free(data);
+  fprintf(stderr, "\n*****************************************************************************************************************\n");
+  fprintf(stderr, "Finalize EFF stack\n");
+  fprintf(stderr, "*****************************************************************************************************************\n");
+  EFF_finalize();
+  MPI_Finalize();
+  
+  return 0;
+}
diff --git a/test/compactor_write_tests/native_write_basic.c b/test/compactor_write_tests/native_write_basic.c
new file mode 100644
index 0000000..6cc1710
--- /dev/null
+++ b/test/compactor_write_tests/native_write_basic.c
@@ -0,0 +1,127 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <assert.h>
+#include "mpi.h"
+#include "hdf5.h"
+
+#define NX     16                      /* dataset dimensions */
+#define NY     8
+#define RANK   2
+
+/*Entire write gets replaced
+write buffer values start with 10's and increases and writes increase*/
+
+
+int main (int argc, char **argv){
+  
+  const char filename[] = "eff_file.h5";
+  hid_t file_id;
+  hid_t dataspaceID, dataspace2;
+  hid_t dset_id;
+  hid_t fapl_id, dxpl_id;
+  
+  const unsigned int nelem = 60;
+  int *data = NULL, *data1 = NULL;
+  unsigned int i = 0;
+  hsize_t dimsf[2];
+  hsize_t count[2], offset[2];
+  hsize_t s[2], b[2];
+  int my_rank, my_size, ret;
+  int provided;
+  hid_t event_q, int_id;
+  int num_requests = 0;  
+  H5_status_t *status = NULL;
+
+  MPI_Init_thread(&argc, &argv, MPI_THREAD_MULTIPLE, &provided);
+  if(MPI_THREAD_MULTIPLE != provided) {
+    fprintf(stderr, "MPI does not have MPI_THREAD_MULTIPLE support\n");
+    exit(1);
+  }
+
+
+  EFF_init (MPI_COMM_WORLD, MPI_INFO_NULL);
+
+  MPI_Comm_rank (MPI_COMM_WORLD, &my_rank);
+  MPI_Comm_size (MPI_COMM_WORLD, &my_size);
+
+
+  if (my_size > 1){
+    fprintf(stderr, "APP processes = %d cannot be greater than 1 \n", my_size);
+    MPI_Finalize();
+  }
+
+
+  fapl_id = H5Pcreate (H5P_FILE_ACCESS);
+  H5Pset_fapl_iod(fapl_id, MPI_COMM_WORLD, MPI_INFO_NULL);
+
+  event_q = H5EQcreate(fapl_id);
+  assert(event_q);
+
+  file_id =  H5Fcreate(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id);
+
+  dimsf[0] = NX;
+  dimsf[1] = NY;
+
+
+  dataspaceID = H5Screate_simple(RANK, dimsf, NULL); 
+
+
+  
+  dset_id = H5Dcreate(file_id, "D1", H5T_NATIVE_INT,dataspaceID, 
+		      H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
+
+  count[0] = 8;
+  count[1] = 8;
+  offset[0] = 0;
+  offset[1] = 0;
+
+  fprintf (stderr, "%d: count[0]:%lli, count[1]:%lli, offset[0]: %lli, offset[1]: %lli\n",
+	   my_rank,
+	   count[0], count[1], offset[0], offset[1]);
+
+  dataspace2 = H5Screate_simple(RANK, count, NULL);
+
+  H5Sselect_hyperslab(dataspaceID, 
+		      H5S_SELECT_SET,
+		      offset,
+		      NULL,
+		      count,
+		      NULL);
+  
+  data = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data[i] = my_rank + 10;
+  }
+ 
+  ret = H5Dwrite_ff(dset_id, 
+		    H5T_NATIVE_INT,
+		    dataspace2, 
+		    dataspaceID,
+		    H5P_DEFAULT,
+		    data,
+		    0,
+		    event_q);
+  assert(ret == 0);
+  
+  H5Dclose(dset_id);
+  H5Sclose(dataspaceID);
+  H5Sclose(dataspace2);
+  H5Pclose(fapl_id);
+  H5Fclose(file_id);
+  H5EQwait(event_q, &num_requests, &status);
+  free(status);
+  H5EQclose (event_q);
+  free(data);
+  free(data1);
+
+  fprintf(stderr, "\n*****************************************************************************************************************\n");
+  fprintf(stderr, "Finalize EFF stack\n");
+  fprintf(stderr, "*****************************************************************************************************************\n");
+
+
+  EFF_finalize();
+  MPI_Finalize();
+  
+  return 0;
+}
diff --git a/test/compactor_write_tests/native_write_test1.c b/test/compactor_write_tests/native_write_test1.c
new file mode 100644
index 0000000..b9a54a7
--- /dev/null
+++ b/test/compactor_write_tests/native_write_test1.c
@@ -0,0 +1,143 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <assert.h>
+#include "mpi.h"
+#include "hdf5.h"
+
+#define NX     16                      /* dataset dimensions */
+#define NY     8
+#define RANK   2
+
+/*Entire write gets replaced
+write buffer values start with 10's and increases and writes increase*/
+
+
+int main (int argc, char **argv){
+  
+  const char filename[] = "eff_file.h5";
+  hid_t file_id;
+  hid_t dataspaceID, dataspace2;
+  hid_t dset_id;
+  hid_t fapl_id, dxpl_id;
+  
+  const unsigned int nelem = 60;
+  int *data = NULL, *data1 = NULL;
+  unsigned int i = 0;
+  hsize_t dimsf[2];
+  hsize_t count[2], offset[2];
+  hsize_t s[2], b[2];
+  int my_rank, my_size, ret;
+  int provided;
+  hid_t event_q, int_id;
+  int num_requests = 0;  
+  H5_status_t *status = NULL;
+
+  MPI_Init_thread(&argc, &argv, MPI_THREAD_MULTIPLE, &provided);
+  if(MPI_THREAD_MULTIPLE != provided) {
+    fprintf(stderr, "MPI does not have MPI_THREAD_MULTIPLE support\n");
+    exit(1);
+  }
+
+
+  EFF_init (MPI_COMM_WORLD, MPI_INFO_NULL);
+
+  MPI_Comm_rank (MPI_COMM_WORLD, &my_rank);
+  MPI_Comm_size (MPI_COMM_WORLD, &my_size);
+
+
+  if (my_size > 1){
+    fprintf(stderr, "APP processes = %d cannot be greater than 1 \n", my_size);
+    MPI_Finalize();
+  }
+
+
+  fapl_id = H5Pcreate (H5P_FILE_ACCESS);
+  H5Pset_fapl_iod(fapl_id, MPI_COMM_WORLD, MPI_INFO_NULL);
+
+  event_q = H5EQcreate(fapl_id);
+  assert(event_q);
+
+  file_id =  H5Fcreate(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id);
+
+  dimsf[0] = NX;
+  dimsf[1] = NY;
+
+
+  dataspaceID = H5Screate_simple(RANK, dimsf, NULL); 
+
+
+ 
+   dset_id = H5Dcreate(file_id, "D1", H5T_NATIVE_INT,dataspaceID, 
+		      H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
+
+  count[0] = 8;
+  count[1] = 8;
+  offset[0] = 0;
+  offset[1] = 0;
+
+  fprintf (stderr, "%d: count[0]:%lli, count[1]:%lli, offset[0]: %lli, offset[1]: %lli\n",
+	   my_rank,
+	   count[0], count[1], offset[0], offset[1]);
+
+  dataspace2 = H5Screate_simple(RANK, count, NULL);
+
+  H5Sselect_hyperslab(dataspaceID, 
+		      H5S_SELECT_SET,
+		      offset,
+		      NULL,
+		      count,
+		      NULL);
+  
+  data = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data[i] = my_rank + 10;
+  }
+ 
+  ret = H5Dwrite_ff(dset_id, 
+		    H5T_NATIVE_INT,
+		    dataspace2, 
+		    dataspaceID,
+		    H5P_DEFAULT,
+		    data,
+		    0,
+		    event_q);
+  assert(ret == 0);
+
+  data1 = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data1[i] = my_rank + 11;
+  }
+  ret = H5Dwrite_ff(dset_id, 
+		    H5T_NATIVE_INT,
+		    dataspace2, 
+		    dataspaceID,
+		    H5P_DEFAULT,
+		    data1,
+		    0,
+		    event_q);
+  assert(ret == 0);
+ 
+
+  
+  H5Dclose(dset_id);
+  H5Sclose(dataspaceID);
+  H5Sclose(dataspace2);
+  H5Pclose(fapl_id);
+  H5Fclose(file_id);
+  H5EQwait(event_q, &num_requests, &status);
+  free(status);
+  H5EQclose (event_q);
+  free(data);
+  free(data1);
+
+  fprintf(stderr, "\n*****************************************************************************************************************\n");
+  fprintf(stderr, "Finalize EFF stack\n");
+  fprintf(stderr, "*****************************************************************************************************************\n");
+
+
+  EFF_finalize();
+  MPI_Finalize();
+  
+  return 0;
+}
diff --git a/test/compactor_write_tests/native_write_test2.c b/test/compactor_write_tests/native_write_test2.c
new file mode 100644
index 0000000..df5a100
--- /dev/null
+++ b/test/compactor_write_tests/native_write_test2.c
@@ -0,0 +1,165 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <assert.h>
+#include "mpi.h"
+#include "hdf5.h"
+
+#define NX     16                      /* dataset dimensions */
+#define NY     8
+#define RANK   2
+
+/*Entire write gets replaced
+write buffer values start with 10's and increases and writes increase*/
+
+
+int main (int argc, char **argv){
+  
+  const char filename[] = "eff_file.h5";
+  hid_t file_id;
+  hid_t dataspaceID, dataspace2;
+  hid_t dataspace3, dataspace4;
+  hid_t dset_id;
+  hid_t fapl_id, dxpl_id;
+  
+  const unsigned int nelem = 60;
+  int *data = NULL, *data1 = NULL;
+  unsigned int i = 0;
+  hsize_t dimsf[2];
+  hsize_t count[2], offset[2];
+  hsize_t s[2], b[2];
+  int my_rank, my_size, ret;
+  int provided;
+  hid_t event_q, int_id;
+  int num_requests = 0;  
+  H5_status_t *status = NULL;
+
+  MPI_Init_thread(&argc, &argv, MPI_THREAD_MULTIPLE, &provided);
+  if(MPI_THREAD_MULTIPLE != provided) {
+    fprintf(stderr, "MPI does not have MPI_THREAD_MULTIPLE support\n");
+    exit(1);
+  }
+
+
+  EFF_init (MPI_COMM_WORLD, MPI_INFO_NULL);
+
+  MPI_Comm_rank (MPI_COMM_WORLD, &my_rank);
+  MPI_Comm_size (MPI_COMM_WORLD, &my_size);
+
+
+  if (my_size > 1){
+    fprintf(stderr, "APP processes = %d cannot be greater than 1 \n", my_size);
+    MPI_Finalize();
+  }
+
+
+  fapl_id = H5Pcreate (H5P_FILE_ACCESS);
+  H5Pset_fapl_iod(fapl_id, MPI_COMM_WORLD, MPI_INFO_NULL);
+
+  event_q = H5EQcreate(fapl_id);
+  assert(event_q);
+
+  file_id =  H5Fcreate(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id);
+
+  dimsf[0] = NX;
+  dimsf[1] = NY;
+
+
+  dataspaceID = H5Screate_simple(RANK, dimsf, NULL);
+  dataspace4 = H5Screate_simple(RANK, dimsf, NULL); 
+
+
+  
+  dset_id = H5Dcreate(file_id, "D1", H5T_NATIVE_INT,dataspaceID, 
+		      H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
+
+  count[0] = 8;
+  count[1] = 8;
+  offset[0] = 0;
+  offset[1] = 0;
+
+  fprintf (stderr, "%d: count[0]:%lli, count[1]:%lli, offset[0]: %lli, offset[1]: %lli\n",
+	   my_rank,
+	   count[0], count[1], offset[0], offset[1]);
+
+  dataspace2 = H5Screate_simple(RANK, count, NULL);
+
+  H5Sselect_hyperslab(dataspaceID, 
+		      H5S_SELECT_SET,
+		      offset,
+		      NULL,
+		      count,
+		      NULL);
+  
+  data = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data[i] = my_rank + 10;
+  }
+ 
+  ret = H5Dwrite_ff(dset_id, 
+		    H5T_NATIVE_INT,
+		    dataspace2, 
+		    dataspaceID,
+		    H5P_DEFAULT,
+		    data,
+		    0,
+		    event_q);
+  assert(ret == 0);
+
+  count[0] = 8;
+  count[1] = 8;
+  offset[0] = 4;
+  offset[1] = 0;
+
+  
+  fprintf (stderr, "%d: count[0]:%lli, count[1]:%lli, offset[0]: %lli, offset[1]: %lli\n",
+	   my_rank,
+	   count[0], count[1], offset[0], offset[1]);
+
+  dataspace3 = H5Screate_simple(RANK, count, NULL);
+  H5Sselect_hyperslab(dataspace4, 
+		      H5S_SELECT_SET,
+		      offset,
+		      NULL,
+		      count,
+		      NULL);
+
+  data1 = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data1[i] = my_rank + 11;
+  }
+ 
+
+  ret = H5Dwrite_ff(dset_id, 
+		    H5T_NATIVE_INT,
+		    dataspace3, 
+		    dataspace4,
+		    H5P_DEFAULT,
+		    data1,
+		    0,
+		    event_q);
+  assert(ret == 0);
+
+  
+
+  H5Dclose(dset_id);
+  H5Sclose(dataspaceID);
+  H5Sclose(dataspace2);
+  H5Pclose(fapl_id);
+  H5Fclose(file_id);
+  H5EQwait(event_q, &num_requests, &status);
+  free(status);
+  H5EQclose (event_q);
+  free(data);
+  free(data1);
+
+  fprintf(stderr, "\n*****************************************************************************************************************\n");
+  fprintf(stderr, "Finalize EFF stack\n");
+  fprintf(stderr, "*****************************************************************************************************************\n");
+
+
+  EFF_finalize();
+  MPI_Finalize();
+  
+  return 0;
+}
diff --git a/test/compactor_write_tests/native_write_test3.c b/test/compactor_write_tests/native_write_test3.c
new file mode 100644
index 0000000..c5f7d15
--- /dev/null
+++ b/test/compactor_write_tests/native_write_test3.c
@@ -0,0 +1,253 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <assert.h>
+#include "mpi.h"
+#include "hdf5.h"
+
+#define NX     16                      /* dataset dimensions */
+#define NY     8
+#define RANK   2
+
+
+
+int main (int argc, char **argv){
+  
+  const char filename[] = "eff_file.h5";
+  hid_t file_id;
+  hid_t dataspaceID, dataspace2;
+  hid_t dataspace3, dataspace4;
+  hid_t dataspace5, dataspace6;
+  hid_t dataspace7, dataspace8;
+  hid_t dset_id;
+  hid_t fapl_id, dxpl_id;
+  
+  const unsigned int nelem = 60;
+  int *data = NULL, *data1 = NULL;
+  int *data2 =  NULL, *data3 = NULL;
+  unsigned int i = 0;
+  hsize_t dimsf[2];
+  hsize_t count[2], offset[2];
+  hsize_t s[2], b[2];
+  int my_rank, my_size, ret;
+  int provided;
+  hid_t event_q, int_id;
+  int num_requests = 0;  
+  H5_status_t *status = NULL;
+
+  MPI_Init_thread(&argc, &argv, MPI_THREAD_MULTIPLE, &provided);
+  if(MPI_THREAD_MULTIPLE != provided) {
+    fprintf(stderr, "MPI does not have MPI_THREAD_MULTIPLE support\n");
+    exit(1);
+  }
+
+
+  EFF_init (MPI_COMM_WORLD, MPI_INFO_NULL);
+
+  MPI_Comm_rank (MPI_COMM_WORLD, &my_rank);
+  MPI_Comm_size (MPI_COMM_WORLD, &my_size);
+
+
+  if (my_size > 1){
+    fprintf(stderr, "APP processes = %d cannot be greater than 1 \n", my_size);
+    MPI_Finalize();
+  }
+
+
+  fapl_id = H5Pcreate (H5P_FILE_ACCESS);
+  H5Pset_fapl_iod(fapl_id, MPI_COMM_WORLD, MPI_INFO_NULL);
+
+  event_q = H5EQcreate(fapl_id);
+  assert(event_q);
+
+  file_id = H5Fcreate(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id);
+
+
+
+  dimsf[0] = NX;
+  dimsf[1] = NY;
+
+
+  dataspaceID = H5Screate_simple(RANK, dimsf, NULL); 
+  dataspace4 = H5Screate_simple(RANK, dimsf, NULL); 
+  dataspace5 = H5Screate_simple(RANK, dimsf, NULL); 
+  dataspace7 = H5Screate_simple(RANK, dimsf, NULL); 
+
+  dset_id = H5Dcreate(file_id, "D1", H5T_NATIVE_INT,dataspaceID, 
+		      H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
+  count[0] = 4;
+  count[1] = 4;
+  offset[0] = 0;
+  offset[1] = 0;
+
+  fprintf (stderr, "%d: count[0]:%lli, count[1]:%lli, offset[0]: %lli, offset[1]: %lli\n",
+	   my_rank,
+	   count[0], count[1], offset[0], offset[1]);
+
+  dataspace2 = H5Screate_simple(RANK, count, NULL);
+
+  H5Sselect_hyperslab(dataspaceID, 
+		      H5S_SELECT_SET,
+		      offset,
+		      NULL,
+		      count,
+		      NULL);
+  
+  data = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data[i] = my_rank + 10;
+  }
+ 
+  ret = H5Dwrite_ff(dset_id, 
+		    H5T_NATIVE_INT,
+		    dataspace2, 
+		    dataspaceID,
+		    H5P_DEFAULT,
+		    data,
+		    0,
+		    event_q);
+  assert(ret == 0);
+  
+  count[0] = 4;
+  count[1] = 4;
+  offset[0] = 6;
+  offset[1] = 0;
+
+
+  fprintf (stderr, "%d: count[0]:%lli, count[1]:%lli, offset[0]: %lli, offset[1]: %lli\n",
+	   my_rank,
+	   count[0], count[1], offset[0], offset[1]);
+
+  dataspace3 = H5Screate_simple(RANK, count, NULL);
+
+
+  H5Sselect_hyperslab(dataspace4, 
+		      H5S_SELECT_SET,
+		      offset,
+		      NULL,
+		      count,
+		      NULL);
+
+
+  data1 = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data1[i] = my_rank + 12;
+  }
+
+
+  ret = H5Dwrite_ff(dset_id, 
+		    H5T_NATIVE_INT,
+		    dataspace3, 
+		    dataspace4,
+		    H5P_DEFAULT,
+		    data1,
+		    0,
+		    event_q);
+  assert(ret == 0);
+
+
+  count[0] = 4;
+  count[1] = 4;
+  offset[0] = 3;
+  offset[1] = 0;
+
+
+  data2 = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data2[i] = my_rank + 13;
+  }
+
+
+  
+  fprintf (stderr, "%d: count[0]:%lli, count[1]:%lli, offset[0]: %lli, offset[1]: %lli\n",
+	   my_rank,
+	   count[0], count[1], offset[0], offset[1]);
+  
+  dataspace6 = H5Screate_simple(RANK, count, NULL);
+
+  H5Sselect_hyperslab(dataspace5, 
+		      H5S_SELECT_SET,
+		      offset,
+		      NULL,
+		      count,
+		      NULL);
+  
+  
+
+  ret = H5Dwrite_ff(dset_id, 
+		    H5T_NATIVE_INT,
+		    dataspace6, 
+		    dataspace5,
+		    H5P_DEFAULT,
+		    data2,
+		    0,
+		    event_q);
+  assert(ret == 0);
+
+
+  count[0] = 8;
+  count[1] = 5;
+  offset[0] = 0;
+  offset[1] = 3;
+
+
+  data3 = (int *) malloc(sizeof(int)*count[0]*count[1]);
+  for (i=0; i < count[0]*count[1]; i++) {
+    data3[i] = my_rank + 14;
+  }
+
+
+  
+  fprintf (stderr, "%d: count[0]:%lli, count[1]:%lli, offset[0]: %lli, offset[1]: %lli\n",
+	   my_rank,
+	   count[0], count[1], offset[0], offset[1]);
+  
+  dataspace8 = H5Screate_simple(RANK, count, NULL);
+
+  H5Sselect_hyperslab(dataspace7, 
+		      H5S_SELECT_SET,
+		      offset,
+		      NULL,
+		      count,
+		      NULL);
+  
+  
+
+  ret = H5Dwrite_ff(dset_id, 
+		    H5T_NATIVE_INT,
+		    dataspace8, 
+		    dataspace7,
+		    H5P_DEFAULT,
+		    data3,
+		    0,
+		    event_q);
+  assert(ret == 0);
+
+
+  
+  
+  H5Dclose(dset_id);
+  H5Sclose(dataspaceID);
+  H5Sclose(dataspace2);
+  H5Sclose(dataspace3);
+  H5Sclose(dataspace4);
+  H5Sclose(dataspace5);
+  H5Sclose(dataspace6);
+  H5Pclose(fapl_id);
+  H5Fclose(file_id);
+  H5EQwait(event_q, &num_requests, &status);
+  free(status);
+  H5EQclose (event_q);
+
+  free(data);
+  free(data1);
+  free(data2);
+  free(data3);
+  fprintf(stderr, "\n*****************************************************************************************************************\n");
+  fprintf(stderr, "Finalize EFF stack\n");
+  fprintf(stderr, "*****************************************************************************************************************\n");
+  EFF_finalize();
+  MPI_Finalize();
+  
+  return 0;
+}
diff --git a/test/compactor_write_tests/test_server.c b/test/compactor_write_tests/test_server.c
index 5d71e35..ee28de4 100644
--- a/test/compactor_write_tests/test_server.c
+++ b/test/compactor_write_tests/test_server.c
@@ -41,7 +41,9 @@ int main(int argc, char **argv) {
        is finalized the operation returns. */

     H5VLiod_start_handler(MPI_COMM_WORLD, MPI_INFO_NULL);

     H5close();

+    fflush(stderr);

     MPI_Finalize();

+    fflush(stderr);

 

     return 0;

 }