diff options
Diffstat (limited to 'hl/test/test_packet.c')
| -rw-r--r-- | hl/test/test_packet.c | 776 |
1 files changed, 396 insertions, 380 deletions
diff --git a/hl/test/test_packet.c b/hl/test/test_packet.c index eb28e3d..1224f0f 100644 --- a/hl/test/test_packet.c +++ b/hl/test/test_packet.c @@ -21,41 +21,34 @@ *------------------------------------------------------------------------- */ -#define NRECORDS 8 -#define BIG_TABLE_SIZE 8000 -#define NFIELDS 5 -#define TEST_FILE_NAME "test_packet_table.h5" +#define NRECORDS 8 +#define BIG_TABLE_SIZE 8000 +#define NFIELDS 5 +#define TEST_FILE_NAME "test_packet_table.h5" #define TEST_COMPRESS_FILE "test_packet_compress.h5" -#define PT_NAME "Test Packet Table" -#define H5TB_TABLE_NAME "Table1" +#define PT_NAME "Test Packet Table" +#define H5TB_TABLE_NAME "Table1" /*------------------------------------------------------------------------- * structure used for some tests, a particle *------------------------------------------------------------------------- */ -typedef struct particle_t -{ - char name[16]; - int lati; - int longi; - float pressure; - double temperature; +typedef struct particle_t { + char name[16]; + int lati; + int longi; + float pressure; + double temperature; } particle_t; /*------------------------------------------------------------------------- * a static array of particles for writing and checking reads *------------------------------------------------------------------------- */ -static particle_t testPart[NRECORDS] = { - {"zero", 0,0, 0.0f, 0.0f}, - {"one", 10,10, 1.0f, 10.0f}, - {"two", 20,20, 2.0f, 20.0f}, - {"three",30,30, 3.0f, 30.0f}, - {"four", 40,40, 4.0f, 40.0f}, - {"five", 50,50, 5.0f, 50.0f}, - {"six", 60,60, 6.0f, 60.0f}, - {"seven",70,70, 7.0f, 70.0f} - }; +static particle_t testPart[NRECORDS] = {{"zero", 0, 0, 0.0f, 0.0f}, {"one", 10, 10, 1.0f, 10.0f}, + {"two", 20, 20, 2.0f, 20.0f}, {"three", 30, 30, 3.0f, 30.0f}, + {"four", 40, 40, 4.0f, 40.0f}, {"five", 50, 50, 5.0f, 50.0f}, + {"six", 60, 60, 6.0f, 60.0f}, {"seven", 70, 70, 7.0f, 70.0f}}; /*------------------------------------------------------------------------- * function that compares one particle @@ -63,16 +56,15 @@ static particle_t testPart[NRECORDS] = { * fields verbatim and not lose any bits. -JML *------------------------------------------------------------------------- */ -static int cmp_par(size_t i, size_t j, particle_t *rbuf, particle_t *wbuf ) +static int +cmp_par(size_t i, size_t j, particle_t *rbuf, particle_t *wbuf) { - if ( ( HDstrcmp( rbuf[i].name, wbuf[j].name ) != 0 ) || - rbuf[i].lati != wbuf[j].lati || - rbuf[i].longi != wbuf[j].longi || - !H5_FLT_ABS_EQUAL(rbuf[i].pressure,wbuf[j].pressure) || - !H5_DBL_ABS_EQUAL(rbuf[i].temperature,wbuf[j].temperature) ) { - return FAIL; - } - return SUCCEED; + if ((HDstrcmp(rbuf[i].name, wbuf[j].name) != 0) || rbuf[i].lati != wbuf[j].lati || + rbuf[i].longi != wbuf[j].longi || !H5_FLT_ABS_EQUAL(rbuf[i].pressure, wbuf[j].pressure) || + !H5_DBL_ABS_EQUAL(rbuf[i].temperature, wbuf[j].temperature)) { + return FAIL; + } + return SUCCEED; } /*------------------------------------------------------------------------- @@ -82,53 +74,51 @@ static int cmp_par(size_t i, size_t j, particle_t *rbuf, particle_t *wbuf ) static hid_t make_particle_type(void) { - hid_t type_id; - hid_t string_type; - size_t type_size = sizeof(particle_t); - - /* Create the memory data type. */ - if ((type_id = H5Tcreate (H5T_COMPOUND, type_size )) < 0 ) - return FAIL; - - /* Insert fields. */ - if ((string_type = H5Tcopy(H5T_C_S1)) < 0) - return FAIL; - if (H5Tset_size(string_type, (size_t)16) < 0) - return FAIL; - - if ( H5Tinsert(type_id, "Name", HOFFSET(particle_t, name) , string_type ) < 0 ) - return FAIL; - if ( H5Tinsert(type_id, "Lat", HOFFSET(particle_t, lati) , H5T_NATIVE_INT ) < 0 ) - return FAIL; - if ( H5Tinsert(type_id, "Long", HOFFSET(particle_t, longi) , H5T_NATIVE_INT ) < 0 ) - return FAIL; - if ( H5Tinsert(type_id, "Pressure", HOFFSET(particle_t, pressure) , H5T_NATIVE_FLOAT ) < 0 ) - return FAIL; - if ( H5Tinsert(type_id, "Temperature", HOFFSET(particle_t, temperature) , H5T_NATIVE_DOUBLE ) < 0 ) - return FAIL; - - return type_id; + hid_t type_id; + hid_t string_type; + size_t type_size = sizeof(particle_t); + + /* Create the memory data type. */ + if ((type_id = H5Tcreate(H5T_COMPOUND, type_size)) < 0) + return FAIL; + + /* Insert fields. */ + if ((string_type = H5Tcopy(H5T_C_S1)) < 0) + return FAIL; + if (H5Tset_size(string_type, (size_t)16) < 0) + return FAIL; + + if (H5Tinsert(type_id, "Name", HOFFSET(particle_t, name), string_type) < 0) + return FAIL; + if (H5Tinsert(type_id, "Lat", HOFFSET(particle_t, lati), H5T_NATIVE_INT) < 0) + return FAIL; + if (H5Tinsert(type_id, "Long", HOFFSET(particle_t, longi), H5T_NATIVE_INT) < 0) + return FAIL; + if (H5Tinsert(type_id, "Pressure", HOFFSET(particle_t, pressure), H5T_NATIVE_FLOAT) < 0) + return FAIL; + if (H5Tinsert(type_id, "Temperature", HOFFSET(particle_t, temperature), H5T_NATIVE_DOUBLE) < 0) + return FAIL; + + return type_id; } - /* Create a normal HL table just like the HL examples do */ -static int create_hl_table(hid_t fid) +/* Create a normal HL table just like the HL examples do */ +static int +create_hl_table(hid_t fid) { - /* Calculate the offsets of the particle struct members in memory */ - size_t part_offset[NFIELDS] = { HOFFSET( particle_t, name ), - HOFFSET( particle_t, lati ), - HOFFSET( particle_t, longi ), - HOFFSET( particle_t, pressure ), - HOFFSET( particle_t, temperature )}; + /* Calculate the offsets of the particle struct members in memory */ + size_t part_offset[NFIELDS] = {HOFFSET(particle_t, name), HOFFSET(particle_t, lati), + HOFFSET(particle_t, longi), HOFFSET(particle_t, pressure), + HOFFSET(particle_t, temperature)}; /* Define field information */ - const char *field_names[NFIELDS] = - { "Name","Latitude", "Longitude", "Pressure", "Temperature" }; - hid_t field_type[NFIELDS]; - hid_t string_type; - hsize_t chunk_size = 10; - int *fill_data = NULL; - int compress = 0; - herr_t status; + const char *field_names[NFIELDS] = {"Name", "Latitude", "Longitude", "Pressure", "Temperature"}; + hid_t field_type[NFIELDS]; + hid_t string_type; + hsize_t chunk_size = 10; + int * fill_data = NULL; + int compress = 0; + herr_t status; /* Initialize the field field_type */ if ((string_type = H5Tcopy(H5T_C_S1)) < 0) @@ -141,27 +131,24 @@ static int create_hl_table(hid_t fid) field_type[3] = H5T_NATIVE_FLOAT; field_type[4] = H5T_NATIVE_DOUBLE; + /*------------------------------------------------------------------------ + * H5TBmake_table + *------------------------------------------------------------------------- + */ - /*------------------------------------------------------------------------ - * H5TBmake_table - *------------------------------------------------------------------------- - */ - - status=H5TBmake_table( "Table Title", fid, H5TB_TABLE_NAME, (hsize_t)NFIELDS, - (hsize_t)NRECORDS, sizeof(particle_t), - field_names, part_offset, field_type, - chunk_size, fill_data, compress, testPart ); + status = H5TBmake_table("Table Title", fid, H5TB_TABLE_NAME, (hsize_t)NFIELDS, (hsize_t)NRECORDS, + sizeof(particle_t), field_names, part_offset, field_type, chunk_size, fill_data, + compress, testPart); - if (H5Tclose(string_type) < 0) - return FAIL; + if (H5Tclose(string_type) < 0) + return FAIL; - if(status<0) - return FAIL; - else - return SUCCEED; + if (status < 0) + return FAIL; + else + return SUCCEED; } - /*------------------------------------------------------------------------- * test_create_close * @@ -170,11 +157,12 @@ static int create_hl_table(hid_t fid) *------------------------------------------------------------------------- */ -static int test_create_close(hid_t fid) +static int +test_create_close(hid_t fid) { herr_t err; - hid_t table; - hid_t part_t; + hid_t table; + hid_t part_t; HL_TESTING2("H5PTcreate_fl and H5PTclose"); @@ -186,23 +174,23 @@ static int test_create_close(hid_t fid) /* Create the table */ table = H5PTcreate_fl(fid, PT_NAME, part_t, (hsize_t)100, -1); if (H5Tclose(part_t) < 0) - goto error; - if( H5PTis_valid(table) < 0) - goto error; - if( H5PTis_varlen(table) != 0) - goto error; + goto error; + if (H5PTis_valid(table) < 0) + goto error; + if (H5PTis_varlen(table) != 0) + goto error; /* Close the table */ err = H5PTclose(table); - if( err < 0) + if (err < 0) goto error; PASSED(); return SUCCEED; error: - H5_FAILED(); - return FAIL; + H5_FAILED(); + return FAIL; } /*------------------------------------------------------------------------- @@ -212,32 +200,34 @@ error: * *------------------------------------------------------------------------- */ -static int test_open(hid_t fid) +static int +test_open(hid_t fid) { herr_t err; - hid_t table; + hid_t table; HL_TESTING2("H5PTopen"); /* Open the table */ table = H5PTopen(fid, PT_NAME); - if( H5PTis_valid(table) < 0) + if (H5PTis_valid(table) < 0) goto error; - if( H5PTis_varlen(table) != 0) + if (H5PTis_varlen(table) != 0) goto error; /* Close the table */ err = H5PTclose(table); - if( err < 0) + if (err < 0) goto error; PASSED(); return SUCCEED; error: - if (table > 0) H5PTclose(table); - H5_FAILED(); - return FAIL; + if (table > 0) + H5PTclose(table); + H5_FAILED(); + return FAIL; } /*------------------------------------------------------------------------- @@ -247,63 +237,64 @@ error: * *------------------------------------------------------------------------- */ -static int test_append(hid_t fid) +static int +test_append(hid_t fid) { - herr_t err; - hid_t table; + herr_t err; + hid_t table; hsize_t count = 0; HL_TESTING2("H5PTappend"); /* Open the table */ table = H5PTopen(fid, PT_NAME); - if( H5PTis_valid(table) < 0) + if (H5PTis_valid(table) < 0) goto error; /* Count the number of packets in the table */ err = H5PTget_num_packets(table, &count); - if( err < 0) + if (err < 0) goto error; /* There should be 0 records in the table */ - if( count != 0 ) + if (count != 0) goto error; /* Append one particle */ err = H5PTappend(table, (size_t)1, &(testPart[0])); - if( err < 0) + if (err < 0) goto error; /* Append several particles */ err = H5PTappend(table, (size_t)6, &(testPart[1])); - if( err < 0) + if (err < 0) goto error; /* Append one more particle */ err = H5PTappend(table, (size_t)1, &(testPart[7])); - if( err < 0) + if (err < 0) goto error; /* Count the number of packets in the table */ err = H5PTget_num_packets(table, &count); - if( err < 0) + if (err < 0) goto error; /* There should be 8 records in the table now */ - if( count != 8 ) + if (count != 8) goto error; /* Close the table */ err = H5PTclose(table); - if( err < 0) + if (err < 0) goto error; PASSED(); return SUCCEED; error: - H5_FAILED(); - if( H5PTis_valid(table) > 0) - H5PTclose(table); - return FAIL; + H5_FAILED(); + if (H5PTis_valid(table) > 0) + H5PTclose(table); + return FAIL; } /*------------------------------------------------------------------------- @@ -313,45 +304,45 @@ error: * *------------------------------------------------------------------------- */ -static int test_read(hid_t fid) +static int +test_read(hid_t fid) { - herr_t err; - hid_t table; + herr_t err; + hid_t table; particle_t readBuf[NRECORDS]; - size_t c; + size_t c; HL_TESTING2("H5PTread_packets"); /* Open the table */ table = H5PTopen(fid, PT_NAME); - if( H5PTis_valid(table) < 0) + if (H5PTis_valid(table) < 0) goto error; /* Read several particles */ err = H5PTread_packets(table, (hsize_t)0, 3, &(readBuf[0])); - if( err < 0) + if (err < 0) goto error; /* Read one particle */ err = H5PTread_packets(table, (hsize_t)3, 1, &(readBuf[3])); - if( err < 0) + if (err < 0) goto error; /* Read several particles */ - err = H5PTread_packets(table, (hsize_t)4, (NRECORDS - 4 ), &(readBuf[4])); - if( err < 0) + err = H5PTread_packets(table, (hsize_t)4, (NRECORDS - 4), &(readBuf[4])); + if (err < 0) goto error; /* Ensure that particles were read correctly */ - for(c=0; c<NRECORDS; c++) - { - if( cmp_par(c%8, c, testPart, readBuf) != 0) + for (c = 0; c < NRECORDS; c++) { + if (cmp_par(c % 8, c, testPart, readBuf) != 0) goto error; } /* Close the table */ err = H5PTclose(table); - if( err < 0) + if (err < 0) goto error; PASSED(); @@ -359,10 +350,10 @@ static int test_read(hid_t fid) return SUCCEED; error: - H5_FAILED(); - if( H5PTis_valid(table) > 0) - H5PTclose(table); - return FAIL; + H5_FAILED(); + if (H5PTis_valid(table) > 0) + H5PTclose(table); + return FAIL; } /*------------------------------------------------------------------------- @@ -373,66 +364,63 @@ error: * *------------------------------------------------------------------------- */ -static int test_get_next(hid_t fid) +static int +test_get_next(hid_t fid) { - herr_t err; - hid_t table; + herr_t err; + hid_t table; particle_t readBuf[NRECORDS]; particle_t readBuf2[NRECORDS]; - size_t c; + size_t c; HL_TESTING2("H5PTget_next"); /* Open the table */ table = H5PTopen(fid, PT_NAME); - if( H5PTis_valid(table) < 0) + if (H5PTis_valid(table) < 0) goto error; /* Read several particles consecutively */ - for(c=0; c < NRECORDS; c++) - { + for (c = 0; c < NRECORDS; c++) { err = H5PTget_next(table, (size_t)1, &readBuf[c]); - if(err < 0) + if (err < 0) goto error; } /* Ensure that particles were read correctly */ - for(c=0; c<NRECORDS; c++) - { - if( cmp_par(c, c, testPart, readBuf) != 0) + for (c = 0; c < NRECORDS; c++) { + if (cmp_par(c, c, testPart, readBuf) != 0) goto error; } H5PTcreate_index(table); /* Read particles two by two */ - for(c=0; c < NRECORDS / 2; c++) - { + for (c = 0; c < NRECORDS / 2; c++) { err = H5PTget_next(table, (size_t)2, &readBuf2[c * 2]); - if(err < 0) + if (err < 0) goto error; } /* Ensure that particles were read correctly */ - for(c=0; c<NRECORDS; c++) - { - if( cmp_par(c, c, testPart, readBuf2) != 0) + for (c = 0; c < NRECORDS; c++) { + if (cmp_par(c, c, testPart, readBuf2) != 0) goto error; } /* Close the table */ err = H5PTclose(table); - if( err < 0) + if (err < 0) goto error; PASSED(); return SUCCEED; error: - H5_FAILED(); - if( H5PTis_valid(table) > 0) - H5PTclose(table); - return FAIL; + H5_FAILED(); + if (H5PTis_valid(table) > 0) + H5PTclose(table); + return FAIL; } /*------------------------------------------------------------------------- @@ -443,14 +431,15 @@ error: * *------------------------------------------------------------------------- */ -static int test_big_table(hid_t fid) +static int +test_big_table(hid_t fid) { - herr_t err; - hid_t table; - hid_t part_t; - size_t c; + herr_t err; + hid_t table; + hid_t part_t; + size_t c; particle_t readPart; - hsize_t count; + hsize_t count; HL_TESTING2("large packet table"); @@ -463,52 +452,50 @@ static int test_big_table(hid_t fid) table = H5PTcreate_fl(fid, "Packet Test Dataset2", part_t, (hsize_t)33, -1); if (H5Tclose(part_t) < 0) goto error; - if( H5PTis_valid(table) < 0) + if (H5PTis_valid(table) < 0) goto error; - /* Add many particles */ - for(c = 0; c < BIG_TABLE_SIZE ; c+=8) - { + /* Add many particles */ + for (c = 0; c < BIG_TABLE_SIZE; c += 8) { /* Append eight particles at once*/ err = H5PTappend(table, (size_t)8, &(testPart[0])); - if( err < 0) + if (err < 0) goto error; } /* Count the number of packets in the table */ err = H5PTget_num_packets(table, &count); - if( err < 0) + if (err < 0) goto error; - if( count != BIG_TABLE_SIZE ) + if (count != BIG_TABLE_SIZE) goto error; /* Read particles to ensure that all of them were written correctly */ /* Also, ensure that H5PTcreate_fl set the current packet to */ /* the first packet in the table */ - for(c = 0; c < BIG_TABLE_SIZE; c++) - { + for (c = 0; c < BIG_TABLE_SIZE; c++) { err = H5PTget_next(table, (size_t)1, &readPart); - if(err < 0) + if (err < 0) goto error; /* Ensure that particles were read correctly */ - if( cmp_par(c % 8, 0, testPart, &readPart) != 0) + if (cmp_par(c % 8, 0, testPart, &readPart) != 0) goto error; } /* Close the table */ err = H5PTclose(table); - if( err < 0) + if (err < 0) goto error; PASSED(); return SUCCEED; error: - H5_FAILED(); - if( H5PTis_valid(table) > 0) - H5PTclose(table); - return FAIL; + H5_FAILED(); + if (H5PTis_valid(table) > 0) + H5PTclose(table); + return FAIL; } /*------------------------------------------------------------------------- @@ -518,63 +505,63 @@ error: * *------------------------------------------------------------------------- */ -static int test_opaque(hid_t fid) +static int +test_opaque(hid_t fid) { - herr_t err; - hid_t table; - hid_t part_t; - size_t c; + herr_t err; + hid_t table; + hid_t part_t; + size_t c; particle_t readBuf[NRECORDS]; HL_TESTING2("opaque data"); /* Create an opaque datatype for the particle struct */ - if ((part_t = H5Tcreate (H5T_OPAQUE, sizeof(particle_t) )) < 0 ) + if ((part_t = H5Tcreate(H5T_OPAQUE, sizeof(particle_t))) < 0) return FAIL; HDassert(part_t != -1); /* Tag the opaque datatype */ - if ( H5Tset_tag(part_t, "Opaque Particle" ) < 0) + if (H5Tset_tag(part_t, "Opaque Particle") < 0) return FAIL; /* Create a new table */ table = H5PTcreate_fl(fid, "Packet Test Dataset3", part_t, (hsize_t)100, -1); - if( H5Tclose(part_t) < 0) + if (H5Tclose(part_t) < 0) goto error; - if( H5PTis_valid(table) < 0) + if (H5PTis_valid(table) < 0) goto error; /* Append several particles, starting at particle 1 */ err = H5PTappend(table, (size_t)(NRECORDS - 1), &(testPart[1])); - if( err < 0) + if (err < 0) goto error; /* Read the particles back */ err = H5PTread_packets(table, (hsize_t)0, 7, &(readBuf[0])); - if( err < 0) + if (err < 0) goto error; /* Ensure that particles were read correctly */ - for(c=0; c<NRECORDS - 1; c++) - { - if( cmp_par(c+1, c, testPart, readBuf) != 0) + for (c = 0; c < NRECORDS - 1; c++) { + if (cmp_par(c + 1, c, testPart, readBuf) != 0) goto error; } /* Close the table */ err = H5PTclose(table); - if( err < 0) + if (err < 0) goto error; PASSED(); return SUCCEED; error: - H5_FAILED(); - if( H5PTis_valid(table) > 0) - H5PTclose(table); - return FAIL; + H5_FAILED(); + if (H5PTis_valid(table) > 0) + H5PTclose(table); + return FAIL; } /*------------------------------------------------------------------------- @@ -588,22 +575,23 @@ error: static int test_compress(void) { - hid_t fid1 = H5I_INVALID_HID; - herr_t err; - hid_t table = H5I_INVALID_HID; - hid_t part_t = H5I_INVALID_HID; - hid_t dset_id = H5I_INVALID_HID; - hid_t plist_id = H5I_INVALID_HID; - size_t c; - size_t num_elems = 1; - unsigned filter_vals[1]; + hid_t fid1 = H5I_INVALID_HID; + herr_t err; + hid_t table = H5I_INVALID_HID; + hid_t part_t = H5I_INVALID_HID; + hid_t dset_id = H5I_INVALID_HID; + hid_t plist_id = H5I_INVALID_HID; + size_t c; + size_t num_elems = 1; + unsigned filter_vals[1]; particle_t readPart[1]; - hsize_t count; + hsize_t count; HL_TESTING2("packet table compression"); /* Create a file. */ - if((fid1 = H5Fcreate(TEST_COMPRESS_FILE, H5F_ACC_TRUNC, H5P_DEFAULT, H5P_DEFAULT)) < 0) TEST_ERROR; + if ((fid1 = H5Fcreate(TEST_COMPRESS_FILE, H5F_ACC_TRUNC, H5P_DEFAULT, H5P_DEFAULT)) < 0) + TEST_ERROR; /* Create a datatype for the particle struct */ part_t = make_particle_type(); @@ -612,106 +600,129 @@ test_compress(void) /* Create a new table with compression level 8 */ table = H5PTcreate_fl(fid1, "Compressed Test Dataset", part_t, (hsize_t)80, 8); - if( H5PTis_valid(table) < 0) TEST_ERROR; + if (H5PTis_valid(table) < 0) + TEST_ERROR; /* We can now use this table exactly the same way we use a normal uncompressed * packet table, and it should pass the same tests. */ - /* Add many particles */ - for(c = 0; c < BIG_TABLE_SIZE ; c+=8) - { + /* Add many particles */ + for (c = 0; c < BIG_TABLE_SIZE; c += 8) { /* Append eight particles at once*/ err = H5PTappend(table, (size_t)8, &(testPart[0])); - if( err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; } /* Count the number of packets in the table */ err = H5PTget_num_packets(table, &count); - if( err < 0) TEST_ERROR; - if( count != BIG_TABLE_SIZE ) TEST_ERROR; + if (err < 0) + TEST_ERROR; + if (count != BIG_TABLE_SIZE) + TEST_ERROR; /* Read particles to ensure that all of them were written correctly */ HDmemset(readPart, 0, sizeof(readPart)); - for(c = 0; c < BIG_TABLE_SIZE; c++) - { + for (c = 0; c < BIG_TABLE_SIZE; c++) { err = H5PTget_next(table, (size_t)1, readPart); - if(err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; /* Ensure that particles were read correctly */ - if( cmp_par(c % 8, 0, testPart, readPart) != 0) TEST_ERROR; + if (cmp_par(c % 8, 0, testPart, readPart) != 0) + TEST_ERROR; } /* Close the table */ err = H5PTclose(table); - if( err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; /* Open the packet table as a regular dataset and make sure that the * compression filter is set. */ dset_id = H5Dopen2(fid1, "Compressed Test Dataset", H5P_DEFAULT); - if( dset_id < 0) TEST_ERROR; + if (dset_id < 0) + TEST_ERROR; plist_id = H5Dget_create_plist(dset_id); - if( plist_id < 0) TEST_ERROR; + if (plist_id < 0) + TEST_ERROR; - err = H5Pget_filter_by_id2(plist_id, H5Z_FILTER_DEFLATE, NULL, &num_elems, - filter_vals, 0, NULL, NULL); - if( err < 0) TEST_ERROR; + err = H5Pget_filter_by_id2(plist_id, H5Z_FILTER_DEFLATE, NULL, &num_elems, filter_vals, 0, NULL, NULL); + if (err < 0) + TEST_ERROR; /* The compression level should be 8, the value we passed in */ - if(filter_vals[0] != 8) TEST_ERROR; + if (filter_vals[0] != 8) + TEST_ERROR; /* Clean up */ err = H5Pclose(plist_id); - if( err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; err = H5Dclose(dset_id); - if( err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; /* Create a new table without compression. */ table = H5PTcreate_fl(fid1, "Uncompressed Dataset", part_t, (hsize_t)80, -1); - if(table < 0) TEST_ERROR; + if (table < 0) + TEST_ERROR; /* Close the packet table */ err = H5PTclose(table); - if( err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; /* Open the packet table as a regular dataset and make sure that the * compression filter is not set. */ dset_id = H5Dopen2(fid1, "Uncompressed Dataset", H5P_DEFAULT); - if( dset_id < 0) TEST_ERROR; + if (dset_id < 0) + TEST_ERROR; plist_id = H5Dget_create_plist(dset_id); - if( plist_id < 0) TEST_ERROR; + if (plist_id < 0) + TEST_ERROR; - H5E_BEGIN_TRY { - err = H5Pget_filter_by_id2(plist_id, H5Z_FILTER_DEFLATE, NULL, &num_elems, - filter_vals, 0, NULL, NULL); - if( err >= 0) TEST_ERROR; - } H5E_END_TRY + H5E_BEGIN_TRY + { + err = + H5Pget_filter_by_id2(plist_id, H5Z_FILTER_DEFLATE, NULL, &num_elems, filter_vals, 0, NULL, NULL); + if (err >= 0) + TEST_ERROR; + } + H5E_END_TRY /* Clean up */ err = H5Pclose(plist_id); - if( err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; err = H5Dclose(dset_id); - if( err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; /* Close the datatype and the file */ err = H5Tclose(part_t); - if( err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; err = H5Fclose(fid1); - if( err < 0) TEST_ERROR; + if (err < 0) + TEST_ERROR; PASSED(); return SUCCEED; error: - H5E_BEGIN_TRY { - H5Pclose(plist_id); - H5Dclose(dset_id); - H5Tclose(part_t); - H5PTclose(table); - H5Fclose(fid1); - } H5E_END_TRY + H5E_BEGIN_TRY + { + H5Pclose(plist_id); + H5Dclose(dset_id); + H5Tclose(part_t); + H5PTclose(table); + H5Fclose(fid1); + } + H5E_END_TRY H5_FAILED(); return FAIL; } @@ -724,83 +735,85 @@ error: * *------------------------------------------------------------------------- */ -static int test_rw_nonnative_dt(hid_t fid) +static int +test_rw_nonnative_dt(hid_t fid) { - hid_t ptable; /* Packet table identifier */ + hid_t ptable; /* Packet table identifier */ - herr_t err; /* Function return status */ - hsize_t count; /* Number of records in the table */ + herr_t err; /* Function return status */ + hsize_t count; /* Number of records in the table */ - int x; /* Loop variable */ + int x; /* Loop variable */ - /* Buffers to hold data */ - int writeBuffer[5]; - int readBuffer[5]; + /* Buffers to hold data */ + int writeBuffer[5]; + int readBuffer[5]; - HL_TESTING2("reading/writing non-native packet table"); + HL_TESTING2("reading/writing non-native packet table"); - /* Initialize buffers */ - for(x=0; x<5; x++) { - writeBuffer[x]=x; - readBuffer[x] = -1; - } + /* Initialize buffers */ + for (x = 0; x < 5; x++) { + writeBuffer[x] = x; + readBuffer[x] = -1; + } - /* Create a fixed-length packet table within the file */ - /* This table's "packets" will be simple integers and it will use no compression */ - if(H5Tget_order(H5T_NATIVE_INT) == H5T_ORDER_LE) { - ptable = H5PTcreate(fid, "Packet Test Dataset, Non-native", H5T_STD_I32BE, (hsize_t)100, H5P_DEFAULT); - } else { - ptable = H5PTcreate(fid, "Packet Test Dataset, Non-native", H5T_STD_I32LE, (hsize_t)100, H5P_DEFAULT); - } - if(ptable == H5I_INVALID_HID) + /* Create a fixed-length packet table within the file */ + /* This table's "packets" will be simple integers and it will use no compression */ + if (H5Tget_order(H5T_NATIVE_INT) == H5T_ORDER_LE) { + ptable = H5PTcreate(fid, "Packet Test Dataset, Non-native", H5T_STD_I32BE, (hsize_t)100, H5P_DEFAULT); + } + else { + ptable = H5PTcreate(fid, "Packet Test Dataset, Non-native", H5T_STD_I32LE, (hsize_t)100, H5P_DEFAULT); + } + if (ptable == H5I_INVALID_HID) goto error; - /* Write one packet to the packet table */ - if( (err = H5PTappend(ptable, (size_t)1, &(writeBuffer[0]))) < 0 ) + /* Write one packet to the packet table */ + if ((err = H5PTappend(ptable, (size_t)1, &(writeBuffer[0]))) < 0) goto error; - /* Write several packets to the packet table */ - if( (err = H5PTappend(ptable, (size_t)4, &(writeBuffer[1]))) < 0) + /* Write several packets to the packet table */ + if ((err = H5PTappend(ptable, (size_t)4, &(writeBuffer[1]))) < 0) goto error; - if( (err = H5PTclose(ptable)) < 0) + if ((err = H5PTclose(ptable)) < 0) goto error; - /* Open the Packet table */ - if( (ptable = H5PTopen(fid, "Packet Test Dataset, Non-native")) < 0) + /* Open the Packet table */ + if ((ptable = H5PTopen(fid, "Packet Test Dataset, Non-native")) < 0) goto error; - /* Get the number of packets in the packet table. This should be five. */ - if( (err = H5PTget_num_packets(ptable, &count)) < 0) + /* Get the number of packets in the packet table. This should be five. */ + if ((err = H5PTget_num_packets(ptable, &count)) < 0) goto error; - if( (int)count != 5 ) + if ((int)count != 5) goto error; - /* Initialize packet table's "current record" */ - if( (err = H5PTcreate_index(ptable)) < 0) + /* Initialize packet table's "current record" */ + if ((err = H5PTcreate_index(ptable)) < 0) goto error; - /* Iterate through packets, read each one back */ - for(x=0; x<5; x++) { - if( (err = H5PTget_next(ptable, (size_t)1, &(readBuffer[x]))) < 0) - goto error; - if( x != readBuffer[x]) - goto error; - } + /* Iterate through packets, read each one back */ + for (x = 0; x < 5; x++) { + if ((err = H5PTget_next(ptable, (size_t)1, &(readBuffer[x]))) < 0) + goto error; + if (x != readBuffer[x]) + goto error; + } - /* Close the packet table */ - if( (err = H5PTclose(ptable)) < 0) + /* Close the packet table */ + if ((err = H5PTclose(ptable)) < 0) goto error; - PASSED(); - return SUCCEED; + PASSED(); + return SUCCEED; error: - H5_FAILED(); - if( H5PTis_valid(ptable) > 0) - H5PTclose(ptable); - return FAIL; + H5_FAILED(); + if (H5PTis_valid(ptable) > 0) + H5PTclose(ptable); + return FAIL; } /*------------------------------------------------------------------------- @@ -811,109 +824,110 @@ error: * *------------------------------------------------------------------------- */ -static int test_error(hid_t fid) +static int +test_error(hid_t fid) { - hid_t id = H5I_INVALID_HID; - int id_open=0; - particle_t readBuf[1]; + hid_t id = H5I_INVALID_HID; + int id_open = 0; + particle_t readBuf[1]; - HL_TESTING2("error conditions"); + HL_TESTING2("error conditions"); - /* Create a HL table */ - if(create_hl_table(fid) < 0) + /* Create a HL table */ + if (create_hl_table(fid) < 0) goto error; - /* Try to open things that are not packet tables */ - H5E_BEGIN_TRY - if(H5PTopen(fid, "Bogus_name") >= 0) + /* Try to open things that are not packet tables */ + H5E_BEGIN_TRY + if (H5PTopen(fid, "Bogus_name") >= 0) goto error; - if(H5PTopen(fid, "group1") >= 0) + if (H5PTopen(fid, "group1") >= 0) goto error; - H5E_END_TRY + H5E_END_TRY - /* Try to execute packet table commands on an invalid ID */ - H5E_BEGIN_TRY - if(H5PTis_valid(id) >= 0) + /* Try to execute packet table commands on an invalid ID */ + H5E_BEGIN_TRY + if (H5PTis_valid(id) >= 0) goto error; - if(H5PTis_varlen(id) >= 0) + if (H5PTis_varlen(id) >= 0) goto error; - if(H5PTclose(id) >= 0) + if (H5PTclose(id) >= 0) goto error; - if(H5PTappend(id, (size_t)1, testPart) >= 0) + if (H5PTappend(id, (size_t)1, testPart) >= 0) goto error; - if(H5PTread_packets(id, (hsize_t)0, 1, readBuf) >= 0) + if (H5PTread_packets(id, (hsize_t)0, 1, readBuf) >= 0) goto error; - if(H5PTcreate_index(id) >= 0) + if (H5PTcreate_index(id) >= 0) goto error; - if(H5PTset_index(id, (hsize_t)1) >= 0) + if (H5PTset_index(id, (hsize_t)1) >= 0) goto error; - if(H5PTget_index(id, NULL) >= 0) + if (H5PTget_index(id, NULL) >= 0) goto error; - H5E_END_TRY + H5E_END_TRY - /* Open a high-level non-packet (H5TB) table and try to */ - /* execute commands on it. */ - if((id=H5Dopen2(fid, H5TB_TABLE_NAME, H5P_DEFAULT)) <0) + /* Open a high-level non-packet (H5TB) table and try to */ + /* execute commands on it. */ + if ((id = H5Dopen2(fid, H5TB_TABLE_NAME, H5P_DEFAULT)) < 0) goto error; - id_open = 1; + id_open = 1; - H5E_BEGIN_TRY - if(H5PTis_valid(id) >= 0) + H5E_BEGIN_TRY + if (H5PTis_valid(id) >= 0) goto error; - if(H5PTis_varlen(id) >= 0) + if (H5PTis_varlen(id) >= 0) goto error; - if(H5PTclose(id) >= 0) + if (H5PTclose(id) >= 0) goto error; - if(H5PTappend(id, (size_t)1, testPart) >= 0) + if (H5PTappend(id, (size_t)1, testPart) >= 0) goto error; - if(H5PTread_packets(id, (hsize_t)0, 1, readBuf) >= 0) + if (H5PTread_packets(id, (hsize_t)0, 1, readBuf) >= 0) goto error; - if(H5PTcreate_index(id) >= 0) + if (H5PTcreate_index(id) >= 0) goto error; - if(H5PTset_index(id, (hsize_t)1) >= 0) + if (H5PTset_index(id, (hsize_t)1) >= 0) goto error; - if(H5PTget_index(id, NULL) >= 0) + if (H5PTget_index(id, NULL) >= 0) goto error; - H5E_END_TRY + H5E_END_TRY - id_open=0; - if(H5Dclose(id) <0) + id_open = 0; + if (H5Dclose(id) < 0) goto error; - /* Open and close a packet table. Try to execute */ - /* commands on the closed ID. */ - if((id=H5PTopen(fid, PT_NAME))<0) + /* Open and close a packet table. Try to execute */ + /* commands on the closed ID. */ + if ((id = H5PTopen(fid, PT_NAME)) < 0) goto error; - if(H5PTclose(id) <0) + if (H5PTclose(id) < 0) goto error; - H5E_BEGIN_TRY - if(H5PTis_valid(id) >= 0) + H5E_BEGIN_TRY + if (H5PTis_valid(id) >= 0) goto error; - if(H5PTis_varlen(id) >= 0) + if (H5PTis_varlen(id) >= 0) goto error; - if(H5PTclose(id) >= 0) + if (H5PTclose(id) >= 0) goto error; - if(H5PTappend(id, (size_t)1, testPart) >= 0) + if (H5PTappend(id, (size_t)1, testPart) >= 0) goto error; - if(H5PTread_packets(id, (hsize_t)0, 1, readBuf) >= 0) + if (H5PTread_packets(id, (hsize_t)0, 1, readBuf) >= 0) goto error; - if(H5PTcreate_index(id) >= 0) + if (H5PTcreate_index(id) >= 0) goto error; - if(H5PTset_index(id, (hsize_t)1) >= 0) + if (H5PTset_index(id, (hsize_t)1) >= 0) goto error; - if(H5PTget_index(id, NULL) >= 0) + if (H5PTget_index(id, NULL) >= 0) goto error; - H5E_END_TRY + H5E_END_TRY - PASSED(); - return SUCCEED; + PASSED(); + return SUCCEED; error: - H5_FAILED(); - if(id_open) - H5Dclose(id); - return FAIL; + H5_FAILED(); + if (id_open) + H5Dclose(id); + return FAIL; } /*------------------------------------------------------------------------- @@ -923,18 +937,19 @@ error: * *------------------------------------------------------------------------- */ -static int test_packet_table(hid_t fid) +static int +test_packet_table(hid_t fid) { - if( test_create_close(fid) < 0 ) + if (test_create_close(fid) < 0) return FAIL; - if( test_open(fid) < 0 ) + if (test_open(fid) < 0) return FAIL; /* test_append must be run before test_count and test_read, as it */ /* creates the packet table they use. */ - if( test_append(fid) < 0 ) + if (test_append(fid) < 0) return FAIL; /* These tests will not necessarily cause failures in each other, @@ -952,22 +967,23 @@ static int test_packet_table(hid_t fid) /* * -*/ -int main(void) + */ +int +main(void) { /* identifier for the file that is used in FL PT tests */ - hid_t fid; - int status = 0; + hid_t fid; + int status = 0; -/*------------------------------------------------------------------------- - * Packet test: test each function of the packet table library - *------------------------------------------------------------------------- - */ + /*------------------------------------------------------------------------- + * Packet test: test each function of the packet table library + *------------------------------------------------------------------------- + */ - /* create a file using default properties */ - fid=H5Fcreate(TEST_FILE_NAME, H5F_ACC_TRUNC, H5P_DEFAULT, H5P_DEFAULT); + /* create a file using default properties */ + fid = H5Fcreate(TEST_FILE_NAME, H5F_ACC_TRUNC, H5P_DEFAULT, H5P_DEFAULT); - HDputs("Testing packet table"); + HDputs("Testing packet table"); /* Test packet table with fixed length */ if (test_packet_table(fid) < 0) @@ -979,7 +995,7 @@ int main(void) /* Close the file */ if (H5Fclose(fid) < 0) - status = 1; + status = 1; return status; } |