summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVishwanath Venkatesan <vish@hdfgroup.org>2013-08-13 17:01:12 (GMT)
committerVishwanath Venkatesan <vish@hdfgroup.org>2013-08-13 17:01:12 (GMT)
commit8b0b6610386a0019b428645db3003ce03b277d4a (patch)
treefdbc8c7fded7f91140d5742d9453f44e9ba00cd5
parent2892c7d8e65d78ba21b9b2fbb83ceba38d36e489 (diff)
downloadhdf5-8b0b6610386a0019b428645db3003ce03b277d4a.zip
hdf5-8b0b6610386a0019b428645db3003ce03b277d4a.tar.gz
hdf5-8b0b6610386a0019b428645db3003ce03b277d4a.tar.bz2
[svn-r24001] removing compactor write_tests from test as we moved it to testff
-rw-r--r--test/compactor_write_tests/Makefile34
-rw-r--r--test/compactor_write_tests/multiple-writes-test1.c171
-rw-r--r--test/compactor_write_tests/multiple-writes-test2.c168
-rw-r--r--test/compactor_write_tests/multiple-writes-test3.c254
-rw-r--r--test/compactor_write_tests/multiple-writes-test4.c254
-rw-r--r--test/compactor_write_tests/multiple-writes-test5.c254
-rw-r--r--test/compactor_write_tests/native-parallel-write-large.c144
-rw-r--r--test/compactor_write_tests/native-parallel-write.c144
-rw-r--r--test/compactor_write_tests/native_read_1.c160
-rw-r--r--test/compactor_write_tests/native_read_2.c233
-rw-r--r--test/compactor_write_tests/native_write_basic.c127
-rw-r--r--test/compactor_write_tests/native_write_test1.c143
-rw-r--r--test/compactor_write_tests/native_write_test2.c165
-rw-r--r--test/compactor_write_tests/native_write_test3.c253
-rw-r--r--test/compactor_write_tests/parallel_write.c126
-rw-r--r--test/compactor_write_tests/read_test_1.c139
-rw-r--r--test/compactor_write_tests/read_test_2.c164
-rw-r--r--test/compactor_write_tests/read_test_3.c197
-rw-r--r--test/compactor_write_tests/test_server.c50
19 files changed, 0 insertions, 3180 deletions
diff --git a/test/compactor_write_tests/Makefile b/test/compactor_write_tests/Makefile
deleted file mode 100644
index 8c75a6d..0000000
--- a/test/compactor_write_tests/Makefile
+++ /dev/null
@@ -1,34 +0,0 @@
-all: writes natives reads server
-
-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
- h5pcc -o parallel_write parallel_write.c
-
-server:
- h5pcc -o server test_server.c
-
-natives:
- 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
-reads:
- h5pcc -o read_test_1 read_test_1.c
- h5pcc -o read_test_2 read_test_2.c
- h5pcc -o read_test_3 read_test_3.c
- h5pcc -o native_read_1 native_read_1.c
- h5pcc -o native_read_2 native_read_2.c
-
-clean:
- rm -rf multiple-writes-test1 multiple-writes-test2 read_test_1
- 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
- rm -rf native-write-basic native-write-test3 native-parallel-write
- rm -rf read_test_1 read_test_2 read_test_3 native_read_1 native_read_2
diff --git a/test/compactor_write_tests/multiple-writes-test1.c b/test/compactor_write_tests/multiple-writes-test1.c
deleted file mode 100644
index 754de5b..0000000
--- a/test/compactor_write_tests/multiple-writes-test1.c
+++ /dev/null
@@ -1,171 +0,0 @@
-#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 dataspace5, dataspace6;
- 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);
- EFF_finalize();
- 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_ff(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id, event_q);
- assert(file_id);
-
-
- dimsf[0] = NX;
- dimsf[1] = NY;
-
-
- dataspaceID = H5Screate_simple(RANK, dimsf, NULL);
- dataspace4 = H5Screate_simple(RANK, dimsf, NULL);
-
- dset_id = H5Dcreate_ff(file_id, "D1" , H5T_NATIVE_INT, dataspaceID,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT, 0, event_q);
- assert(dset_id);
-
- 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] = 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]);
-
- 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);
-
- /* assert(H5Tclose_ff(int_id, event_q) == 0);*/
- assert(H5Dclose_ff(dset_id, event_q) == 0);
- H5Sclose(dataspaceID);
- H5Sclose(dataspace2);
- H5Sclose(dataspace3);
- H5Sclose(dataspace4);
- H5Pclose(fapl_id);
- assert(H5Fclose_ff(file_id, event_q) == 0);
- 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/multiple-writes-test2.c b/test/compactor_write_tests/multiple-writes-test2.c
deleted file mode 100644
index d18795e..0000000
--- a/test/compactor_write_tests/multiple-writes-test2.c
+++ /dev/null
@@ -1,168 +0,0 @@
-#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
-
-/*Second write -- writes more than first write but overlaps*/
-
-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 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_ff(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id, event_q);
- assert(file_id);
-
-
- dimsf[0] = NX;
- dimsf[1] = NY;
-
-
- dataspaceID = H5Screate_simple(RANK, dimsf, NULL);
- dataspace4 = H5Screate_simple(RANK, dimsf, NULL);
-
- dset_id = H5Dcreate_ff(file_id, "D1" , H5T_NATIVE_INT, dataspaceID,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT, 0, event_q);
- assert(dset_id);
-
- count[0] = 4;
- 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] = 2;
- 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);
-
- /* assert(H5Tclose_ff(int_id, event_q) == 0);*/
- assert(H5Dclose_ff(dset_id, event_q) == 0);
- H5Sclose(dataspaceID);
- H5Sclose(dataspace2);
- H5Sclose(dataspace3);
- H5Sclose(dataspace4);
- H5Pclose(fapl_id);
- assert(H5Fclose_ff(file_id, event_q) == 0);
- 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/multiple-writes-test3.c b/test/compactor_write_tests/multiple-writes-test3.c
deleted file mode 100644
index 9fa7170..0000000
--- a/test/compactor_write_tests/multiple-writes-test3.c
+++ /dev/null
@@ -1,254 +0,0 @@
-#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_ff(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id, event_q);
- assert(file_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_ff(file_id, "D1" , H5T_NATIVE_INT, dataspaceID,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT, 0, event_q);
- assert(dset_id);
-
- count[0] = 4;
- 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] = 2;
- count[1] = 8;
- offset[0] = 2;
- 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] = 2;
- count[1] = 8;
- offset[0] = 6;
- 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] = 4;
- count[1] = 8;
- offset[0] = 3;
- offset[1] = 0;
-
-
- 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);
-
-
-
-
-
- assert(H5Dclose_ff(dset_id, event_q) == 0);
- H5Sclose(dataspaceID);
- H5Sclose(dataspace2);
- H5Sclose(dataspace3);
- H5Sclose(dataspace4);
- H5Sclose(dataspace5);
- H5Sclose(dataspace6);
- H5Pclose(fapl_id);
- assert(H5Fclose_ff(file_id, event_q) == 0);
- 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/multiple-writes-test4.c b/test/compactor_write_tests/multiple-writes-test4.c
deleted file mode 100644
index 0f32697..0000000
--- a/test/compactor_write_tests/multiple-writes-test4.c
+++ /dev/null
@@ -1,254 +0,0 @@
-#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_ff(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id, event_q);
- assert(file_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_ff(file_id, "D1" , H5T_NATIVE_INT, dataspaceID,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT, 0, event_q);
- assert(dset_id);
-
- count[0] = 4;
- 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] = 2;
- count[1] = 8;
- offset[0] = 2;
- 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] = 2;
- count[1] = 8;
- offset[0] = 6;
- 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] = 8;
- offset[0] = 2;
- offset[1] = 0;
-
-
- 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);
-
-
-
-
-
- assert(H5Dclose_ff(dset_id, event_q) == 0);
- H5Sclose(dataspaceID);
- H5Sclose(dataspace2);
- H5Sclose(dataspace3);
- H5Sclose(dataspace4);
- H5Sclose(dataspace5);
- H5Sclose(dataspace6);
- H5Pclose(fapl_id);
- assert(H5Fclose_ff(file_id, event_q) == 0);
- 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/multiple-writes-test5.c b/test/compactor_write_tests/multiple-writes-test5.c
deleted file mode 100644
index 2cea44b..0000000
--- a/test/compactor_write_tests/multiple-writes-test5.c
+++ /dev/null
@@ -1,254 +0,0 @@
-#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_ff(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id, event_q);
- assert(file_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_ff(file_id, "D1" , H5T_NATIVE_INT, dataspaceID,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT, 0, event_q);
- assert(dset_id);
-
- 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);
-
-
-
-
-
- assert(H5Dclose_ff(dset_id, event_q) == 0);
- H5Sclose(dataspaceID);
- H5Sclose(dataspace2);
- H5Sclose(dataspace3);
- H5Sclose(dataspace4);
- H5Sclose(dataspace5);
- H5Sclose(dataspace6);
- H5Pclose(fapl_id);
- assert(H5Fclose_ff(file_id, event_q) == 0);
- 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-parallel-write-large.c b/test/compactor_write_tests/native-parallel-write-large.c
deleted file mode 100644
index d0a9b55..0000000
--- a/test/compactor_write_tests/native-parallel-write-large.c
+++ /dev/null
@@ -1,144 +0,0 @@
-#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-parallel-write.c b/test/compactor_write_tests/native-parallel-write.c
deleted file mode 100644
index 66d7cc2..0000000
--- a/test/compactor_write_tests/native-parallel-write.c
+++ /dev/null
@@ -1,144 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <assert.h>
-#include "mpi.h"
-#include "hdf5.h"
-
-#define NX 1024 /* dataset dimensions */
-#define NY 1024
-#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] = NY;
- 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_read_1.c b/test/compactor_write_tests/native_read_1.c
deleted file mode 100644
index cf4ed0b..0000000
--- a/test/compactor_write_tests/native_read_1.c
+++ /dev/null
@@ -1,160 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <assert.h>
-#include "mpi.h"
-#include "hdf5.h"
-
-#define NX 16
-#define NY 8
-#define RANK 2
-
-
-
-int main (int argc, char **argv){
-
- const char filename[] = "eff_file.h5";
- hid_t file_id;
- hid_t dataspace3, dataspace4;
- hid_t dataspace7, dataspace8;
-
- hid_t dset_id;
- hid_t fapl_id, dxpl_id;
-
- const unsigned int nelem = 60;
- int *data2 = NULL, *data3 = 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_Comm comm;
- MPI_Info info;
-
-
- 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);
- }
-
- comm = MPI_COMM_WORLD;
- info = MPI_INFO_NULL;
-
- EFF_init (comm, info);
- MPI_Comm_rank (comm, &my_rank);
- MPI_Comm_size (comm, &my_size);
-
- if (my_size > 1){
- fprintf(stderr, "APP processes = %d cannot be greater than 1 \n", my_size);
- EFF_finalize();
- MPI_Finalize();
- }
-
- fapl_id = H5Pcreate (H5P_FILE_ACCESS);
- H5Pset_fapl_iod(fapl_id, comm, info);
-
- 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;
-
-
- dataspace3 = H5Screate_simple(RANK, dimsf, NULL);
- dataspace7 = H5Screate_simple(RANK, dimsf, NULL);
-
- dset_id = H5Dcreate (file_id, "D1", H5T_NATIVE_INT, dataspace3,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
- assert(dset_id);
-
-
-
- count[0] = 8;
- count[1] = 8;
- offset[0] = 0;
- offset[1] = 0;
- H5Sselect_hyperslab(dataspace7,
- H5S_SELECT_SET,
- offset,
- NULL,
- count,
- NULL);
-
- data3 = (int *) malloc (sizeof(int)*count[0]*count[1]);
- for (i = 0; i < count[0]*count[1]; i++){
- data3[i] = 1024;
- }
-
- dataspace8 = H5Screate_simple(RANK, count, NULL);
-
-
- ret = H5Dwrite_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace8,
- dataspace7,
- H5P_DEFAULT,
- data3,
- 0,
- event_q);
- assert(ret == 0);
-
- count[0] = 8;
- count[1] = 1;
- offset[0] = 0;
- offset[1] = 0;
-
-
- dataspace4 = H5Screate_simple(RANK, count, NULL);
-
- H5Sselect_hyperslab(dataspace3,
- H5S_SELECT_SET,
- offset,
- NULL,
- count,
- NULL);
-
-
-
- data2 = (int *) malloc(sizeof(int)*count[0]*count[1]);
-
- ret = H5Dread_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace4,
- dataspace3,
- H5P_DEFAULT,
- data2,
- 0,
- event_q);
- assert(ret == 0);
-
- H5Dclose(dset_id);
- H5Sclose(dataspace3); H5Sclose(dataspace4);
- H5Sclose(dataspace7); H5Sclose(dataspace8);
- H5Pclose(fapl_id);
- H5Fclose(file_id);
- H5EQwait(event_q, &num_requests, &status);
- free(status);
- H5EQclose (event_q);
-
- for (i = 0; i < 8; i++){
- fprintf (stderr,"data2[%d]: %d\n",
- i, data2[i]);
- }
-
- 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/native_read_2.c b/test/compactor_write_tests/native_read_2.c
deleted file mode 100644
index fa4ae6e..0000000
--- a/test/compactor_write_tests/native_read_2.c
+++ /dev/null
@@ -1,233 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <assert.h>
-#include "mpi.h"
-#include "hdf5.h"
-
-#define NX 16
-#define NY 8
-#define RANK 2
-
-
-
-int main (int argc, char **argv){
-
- const char filename[] = "eff_file.h5";
- hid_t file_id;
- hid_t dataspace1, 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];
- int my_rank, my_size, ret;
- int provided;
- hid_t event_q, int_id;
- int num_requests = 0;
- H5_status_t *status = NULL;
- MPI_Comm comm;
- MPI_Info info;
-
-
- 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);
- }
-
- comm = MPI_COMM_WORLD;
- info = MPI_INFO_NULL;
-
- EFF_init (comm, info);
- MPI_Comm_rank (comm, &my_rank);
- MPI_Comm_size (comm, &my_size);
-
- if (my_size > 1){
- fprintf(stderr, "APP processes = %d cannot be greater than 1 \n", my_size);
- EFF_finalize();
- MPI_Finalize();
- }
-
- fapl_id = H5Pcreate (H5P_FILE_ACCESS);
- H5Pset_fapl_iod(fapl_id, comm, info);
-
- 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;
-
- dataspace1 = H5Screate_simple(RANK, dimsf, NULL);
- dataspace3 = 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, dataspace1,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
- assert(dset_id);
-
-
-
- count[0] = 8;
- count[1] = 8;
- offset[0] = 0;
- offset[1] = 0;
- H5Sselect_hyperslab(dataspace7,
- H5S_SELECT_SET,
- offset,
- NULL,
- count,
- NULL);
-
- data3 = (int *) malloc (sizeof(int)*count[0]*count[1]);
- for (i = 0; i < count[0]*count[1]; i++){
- data3[i] = 1024;
- }
-
- dataspace8 = H5Screate_simple(RANK, count, NULL);
-
-
- ret = H5Dwrite_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace8,
- dataspace7,
- H5P_DEFAULT,
- data3,
- 0,
- event_q);
- assert(ret == 0);
-
- /*Make sure the above write completes for testing
- partial read!*/
- H5EQwait(event_q, &num_requests, &status);
-
- count[0] = 1;
- count[1] = 8;
- offset[0] = 0;
- offset[1] = 0;
-
- dataspace2 = H5Screate_simple(RANK, count, NULL);
-
- H5Sselect_hyperslab(dataspace1,
- 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] = 10;
- }
-
- ret = H5Dwrite_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace2,
- dataspace1,
- H5P_DEFAULT,
- data,
- 0,
- event_q);
- assert(ret == 0);
-
- count[0] = 8;
- count[1] = 1;
- offset[0] = 0;
- offset[1] = 0;
-
-
- dataspace4 = H5Screate_simple(RANK, count, NULL);
-
- H5Sselect_hyperslab(dataspace3,
- H5S_SELECT_SET,
- offset,
- NULL,
- count,
- NULL);
-
-
-
- data2 = (int *) malloc(sizeof(int)*count[0]*count[1]);
-
- ret = H5Dread_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace4,
- dataspace3,
- H5P_DEFAULT,
- data2,
- 0,
- event_q);
- assert(ret == 0);
-
- count[0] = 4;
- count[1] = 4;
- offset[0] = 2;
- offset[1] = 0;
-
-
- H5Sselect_hyperslab(dataspace5,
- H5S_SELECT_SET,
- offset,
- NULL,
- count,
- NULL);
-
- dataspace6 = H5Screate_simple(RANK, count, NULL);
-
- data3 = (int *) malloc(sizeof(int)*count[0]*count[1]);
- for (i = 0; i < count[0]*count[1]; i++){
- data3[i] = 11;
- }
-
- ret = H5Dwrite_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace6,
- dataspace5,
- H5P_DEFAULT,
- data3,
- 0,
- event_q);
- assert(ret == 0);
-
-
-
- H5Dclose(dset_id);
- H5Sclose(dataspace1); H5Sclose(dataspace2);
- H5Sclose(dataspace3); H5Sclose(dataspace4);
- H5Sclose(dataspace5); H5Sclose(dataspace6);
- H5Sclose(dataspace7); H5Sclose(dataspace8);
- H5Pclose(fapl_id);
- H5Fclose(file_id);
- H5EQwait(event_q, &num_requests, &status);
- free(status);
- H5EQclose (event_q);
-
- for (i = 0; i < 8; i++){
- fprintf (stderr,"data2[%d]: %d\n",
- i, data2[i]);
- }
-
- 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/native_write_basic.c b/test/compactor_write_tests/native_write_basic.c
deleted file mode 100644
index 6cc1710..0000000
--- a/test/compactor_write_tests/native_write_basic.c
+++ /dev/null
@@ -1,127 +0,0 @@
-#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
deleted file mode 100644
index 02c8554..0000000
--- a/test/compactor_write_tests/native_write_test1.c
+++ /dev/null
@@ -1,143 +0,0 @@
-#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 16
-#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] = NX;
- count[1] = NY;
- 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
deleted file mode 100644
index df5a100..0000000
--- a/test/compactor_write_tests/native_write_test2.c
+++ /dev/null
@@ -1,165 +0,0 @@
-#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
deleted file mode 100644
index 2dafe73..0000000
--- a/test/compactor_write_tests/native_write_test3.c
+++ /dev/null
@@ -1,253 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <assert.h>
-#include "mpi.h"
-#include "hdf5.h"
-
-#define NX 256 /* dataset dimensions */
-#define NY 256
-#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] = 256;
- count[1] = 256;
- 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] = 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] = 8;
- count[1] = 8;
- 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/parallel_write.c b/test/compactor_write_tests/parallel_write.c
deleted file mode 100644
index e996388..0000000
--- a/test/compactor_write_tests/parallel_write.c
+++ /dev/null
@@ -1,126 +0,0 @@
-#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;
- hid_t dataspaceID, dataspace2;
- hid_t dset_id;
- hid_t fapl_id, dxpl_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);
-
- 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);
-
- file_id = H5Fcreate_ff(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id, event_q);
- assert(file_id);
-
-
- dimsf[0] = NX;
- dimsf[1] = NY;
-
- /* int_id = H5Tcopy(H5T_STD_I32LE);
- ret = H5Tcommit_ff(file_id, "int", int_id, H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT,
- 0, event_q);
-
- assert(ret == 0);*/
-
- dataspaceID = H5Screate_simple(RANK, dimsf, NULL);
-
- dset_id = H5Dcreate_ff(file_id, "D1" , H5T_NATIVE_INT, dataspaceID,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT, 0, event_q);
- assert(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,
- H5T_NATIVE_INT,
- dataspace2,
- dataspaceID,
- H5P_DEFAULT,
- data,
- 0,
- event_q);
- assert(ret == 0);
-
-
-
- assert(H5Dclose_ff(dset_id, event_q) == 0);
- H5Sclose(dataspaceID);
- H5Sclose(dataspace2);
- H5Pclose(fapl_id);
- assert(H5Fclose_ff(file_id, event_q) == 0);
- H5EQwait(event_q, &num_requests, &status);
- free(status);
- 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/read_test_1.c b/test/compactor_write_tests/read_test_1.c
deleted file mode 100644
index 0ef3edc..0000000
--- a/test/compactor_write_tests/read_test_1.c
+++ /dev/null
@@ -1,139 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <assert.h>
-#include "mpi.h"
-#include "hdf5.h"
-
-#define NX 16
-#define NY 8
-#define RANK 2
-
-
-
-int main (int argc, char **argv){
-
- const char filename[] = "eff_file.h5";
- hid_t file_id;
- hid_t dataspace1, 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];
- int my_rank, my_size, ret;
- int provided;
- hid_t event_q, int_id;
- int num_requests = 0;
- H5_status_t *status = NULL;
- MPI_Comm comm;
- MPI_Info info;
-
-
- 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);
- }
-
- comm = MPI_COMM_WORLD;
- info = MPI_INFO_NULL;
-
- EFF_init (comm, info);
- MPI_Comm_rank (comm, &my_rank);
- MPI_Comm_size (comm, &my_size);
-
- if (my_size > 1){
- fprintf(stderr, "APP processes = %d cannot be greater than 1 \n", my_size);
- EFF_finalize();
- MPI_Finalize();
- }
-
- fapl_id = H5Pcreate (H5P_FILE_ACCESS);
- H5Pset_fapl_iod(fapl_id, comm, info);
-
- event_q = H5EQcreate(fapl_id);
- assert(event_q);
-
- file_id = H5Fcreate_ff(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id, event_q);
- assert(file_id);
-
- dimsf[0] = NX;
- dimsf[1] = NY;
-
- dataspace1 = H5Screate_simple(RANK, dimsf, NULL);
-
-
- dset_id = H5Dcreate_ff (file_id, "D1", H5T_NATIVE_INT, dataspace1,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT, 0, event_q);
- assert(dset_id);
-
- count[0] = 8;
- count[1] = 8;
- offset[0] = 0;
- offset[1] = 0;
-
- dataspace2 = H5Screate_simple(RANK, count, NULL);
-
- H5Sselect_hyperslab(dataspace1,
- 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] = 10;
- }
- ret = H5Dwrite_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace2,
- dataspace1,
- H5P_DEFAULT,
- data,
- 0,
- event_q);
- assert(ret == 0);
-
- data1 = (int *) malloc(sizeof(int)*count[0]*count[1]);
- ret = H5Dread_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace2,
- dataspace1,
- H5P_DEFAULT,
- data1,
- 0,
- event_q);
- assert(ret == 0);
-
-
-
- assert(H5Dclose_ff(dset_id, event_q) == 0);
- H5Sclose(dataspace1);
- H5Sclose(dataspace2);
- H5Pclose(fapl_id);
- assert(H5Fclose_ff(file_id, event_q)== 0);
- H5EQwait(event_q, &num_requests, &status);
- free(status);
- H5EQclose (event_q);
-
- for (i = 0; i < (count[0] * count[1]); i++){
- fprintf (stderr,"data1[%d]: %d\n",
- i, data1[i]);
- }
-
- 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/read_test_2.c b/test/compactor_write_tests/read_test_2.c
deleted file mode 100644
index 4c0f75c..0000000
--- a/test/compactor_write_tests/read_test_2.c
+++ /dev/null
@@ -1,164 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <assert.h>
-#include "mpi.h"
-#include "hdf5.h"
-
-#define NX 16
-#define NY 8
-#define RANK 2
-
-
-
-int main (int argc, char **argv){
-
- const char filename[] = "eff_file.h5";
- hid_t file_id;
- hid_t dataspace1, 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;
- int *data2 = NULL, *data3 = 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_Comm comm;
- MPI_Info info;
-
-
- 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);
- }
-
- comm = MPI_COMM_WORLD;
- info = MPI_INFO_NULL;
-
- EFF_init (comm, info);
- MPI_Comm_rank (comm, &my_rank);
- MPI_Comm_size (comm, &my_size);
-
- if (my_size > 1){
- fprintf(stderr, "APP processes = %d cannot be greater than 1 \n", my_size);
- EFF_finalize();
- MPI_Finalize();
- }
-
- fapl_id = H5Pcreate (H5P_FILE_ACCESS);
- H5Pset_fapl_iod(fapl_id, comm, info);
-
- event_q = H5EQcreate(fapl_id);
- assert(event_q);
-
- file_id = H5Fcreate_ff(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id, event_q);
- assert(file_id);
-
- dimsf[0] = NX;
- dimsf[1] = NY;
-
- dataspace1 = H5Screate_simple(RANK, dimsf, NULL);
- dataspace3 = H5Screate_simple(RANK, dimsf, NULL);
-
- dset_id = H5Dcreate_ff (file_id, "D1", H5T_NATIVE_INT, dataspace1,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT, 0, event_q);
- assert(dset_id);
-
- count[0] = 4;
- count[1] = 8;
- offset[0] = 0;
- offset[1] = 0;
-
- dataspace2 = H5Screate_simple(RANK, count, NULL);
-
- H5Sselect_hyperslab(dataspace1,
- 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] = 10;
- }
-
- ret = H5Dwrite_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace2,
- dataspace1,
- H5P_DEFAULT,
- data,
- 0,
- event_q);
- assert(ret == 0);
-
- count[0] = 8;
- count[1] = 1;
- offset[0] = 0;
- offset[1] = 0;
-
-
- dataspace4 = H5Screate_simple(RANK, count, NULL);
-
- H5Sselect_hyperslab(dataspace3,
- H5S_SELECT_SET,
- offset,
- NULL,
- count,
- NULL);
-
-
-
- data2 = (int *) malloc(sizeof(int)*count[0]*count[1]);
-
- ret = H5Dread_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace4,
- dataspace3,
- H5P_DEFAULT,
- data2,
- 0,
- event_q);
- assert(ret == 0);
-
-
-
-
- assert(H5Dclose_ff(dset_id, event_q) == 0);
- H5Sclose(dataspace1); H5Sclose(dataspace2);
- H5Sclose(dataspace3); H5Sclose(dataspace4);
- H5Pclose(fapl_id);
- assert(H5Fclose_ff(file_id, event_q)== 0);
- H5EQwait(event_q, &num_requests, &status);
- free(status);
- H5EQclose (event_q);
-
- for (i = 0; i < (count[0] * count[1]); i++){
- fprintf (stderr,"data2[%d]: %d\n",
- i, data2[i]);
- }
-
- 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/read_test_3.c b/test/compactor_write_tests/read_test_3.c
deleted file mode 100644
index 220bff6..0000000
--- a/test/compactor_write_tests/read_test_3.c
+++ /dev/null
@@ -1,197 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <assert.h>
-#include "mpi.h"
-#include "hdf5.h"
-
-#define NX 16
-#define NY 8
-#define RANK 2
-
-
-
-int main (int argc, char **argv){
-
- const char filename[] = "eff_file.h5";
- hid_t file_id;
- hid_t dataspace1, dataspace2;
- hid_t dataspace3, dataspace4;
- hid_t dataspace5, dataspace6;
-
- 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];
- int my_rank, my_size, ret;
- int provided;
- hid_t event_q, int_id;
- int num_requests = 0;
- H5_status_t *status = NULL;
- MPI_Comm comm;
- MPI_Info info;
-
-
- 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);
- }
-
- comm = MPI_COMM_WORLD;
- info = MPI_INFO_NULL;
-
- EFF_init (comm, info);
- MPI_Comm_rank (comm, &my_rank);
- MPI_Comm_size (comm, &my_size);
-
- if (my_size > 1){
- fprintf(stderr, "APP processes = %d cannot be greater than 1 \n", my_size);
- EFF_finalize();
- MPI_Finalize();
- }
-
- fapl_id = H5Pcreate (H5P_FILE_ACCESS);
- H5Pset_fapl_iod(fapl_id, comm, info);
-
- event_q = H5EQcreate(fapl_id);
- assert(event_q);
-
- file_id = H5Fcreate_ff(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id, event_q);
- assert(file_id);
-
- dimsf[0] = NX;
- dimsf[1] = NY;
-
- dataspace1 = H5Screate_simple(RANK, dimsf, NULL);
- dataspace3 = H5Screate_simple(RANK, dimsf, NULL);
- dataspace5 = H5Screate_simple(RANK, dimsf, NULL);
-
- dset_id = H5Dcreate_ff (file_id, "D1", H5T_NATIVE_INT, dataspace1,
- H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT, 0, event_q);
- assert(dset_id);
-
- count[0] = 1;
- count[1] = 8;
- offset[0] = 0;
- offset[1] = 0;
-
- dataspace2 = H5Screate_simple(RANK, count, NULL);
-
- H5Sselect_hyperslab(dataspace1,
- 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] = 10;
- }
-
- ret = H5Dwrite_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace2,
- dataspace1,
- H5P_DEFAULT,
- data,
- 0,
- event_q);
- assert(ret == 0);
-
- count[0] = 8;
- count[1] = 1;
- offset[0] = 0;
- offset[1] = 0;
-
-
- dataspace4 = H5Screate_simple(RANK, count, NULL);
-
- H5Sselect_hyperslab(dataspace3,
- H5S_SELECT_SET,
- offset,
- NULL,
- count,
- NULL);
-
-
-
- data2 = (int *) malloc(sizeof(int)*count[0]*count[1]);
-
- ret = H5Dread_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace4,
- dataspace3,
- H5P_DEFAULT,
- data2,
- 0,
- event_q);
- assert(ret == 0);
-
- count[0] = 4;
- count[1] = 4;
- offset[0] = 2;
- offset[1] = 0;
-
-
- H5Sselect_hyperslab(dataspace5,
- H5S_SELECT_SET,
- offset,
- NULL,
- count,
- NULL);
-
- dataspace6 = H5Screate_simple(RANK, count, NULL);
-
- data3 = (int *) malloc(sizeof(int)*count[0]*count[1]);
- for (i = 0; i < count[0]*count[1]; i++){
- data3[i] = 11;
- }
-
- ret = H5Dwrite_ff(dset_id,
- H5T_NATIVE_INT,
- dataspace6,
- dataspace5,
- H5P_DEFAULT,
- data3,
- 0,
- event_q);
- assert(ret == 0);
-
-
-
- assert(H5Dclose_ff(dset_id, event_q) == 0);
- H5Sclose(dataspace1); H5Sclose(dataspace2);
- H5Sclose(dataspace3); H5Sclose(dataspace4);
- H5Sclose(dataspace5); H5Sclose(dataspace6);
- H5Pclose(fapl_id);
- assert(H5Fclose_ff(file_id, event_q)== 0);
- H5EQwait(event_q, &num_requests, &status);
- free(status);
- H5EQclose (event_q);
-
- for (i = 0; i < 8; i++){
- fprintf (stderr,"data2[%d]: %d\n",
- i, data2[i]);
- }
-
- 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
deleted file mode 100644
index ee28de4..0000000
--- a/test/compactor_write_tests/test_server.c
+++ /dev/null
@@ -1,50 +0,0 @@
-/*
- * test_server.c: Server side of Milestone 3.3 Asynchronous I/O and initial
- * IOD VOL plugin demonstration.
- */
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <assert.h>
-#include <string.h>
-#include "mpi.h"
-#include "hdf5.h"
-
-int main(int argc, char **argv) {
- int my_size, my_rank;
- int provided;
-
- MPI_Init_thread(&argc, &argv, MPI_THREAD_MULTIPLE, &provided);
- if(MPI_THREAD_MULTIPLE != provided) {
- printf("MPI does not have MPI_THREAD_MULTIPLE support\n");
- exit(1);
- }
-
- MPI_Comm_rank(MPI_COMM_WORLD, &my_rank);
- MPI_Comm_size(MPI_COMM_WORLD, &my_size);
- printf("Number of server processes = %d, my rank is %d\n", my_size, my_rank);
-
- H5open();
- /* This call initiliazes the FS for the server processes (create metadata and
- bulk data handles). It also registers with the Function shipper the
- HDF5 VOL server routines that will be executed when the clients ship the VOL
- routines. Then it executes a loop to receive requests from clients that map
- to one of the registered callbacks.
-
- Whenever a request is received, the corresponding callback is called which
- inserts the operation into the AXE (the Asynchronous eXecution Engine) and
- returns to receive another request. The AXE schedules that operation to
- execute by assigning a thread to it. After the operation is complete, the
- result is returned to the client through the function shipper complete call.
-
- Finally, when all clients send a terminate call, the function shipper interface
- is finalized the operation returns. */
- H5VLiod_start_handler(MPI_COMM_WORLD, MPI_INFO_NULL);
- H5close();
- fflush(stderr);
- MPI_Finalize();
- fflush(stderr);
-
- return 0;
-}
-