[bd84570] | 1 | /* |
---|
| 2 | * Copyright (C) 2015, UChicago Argonne, LLC |
---|
| 3 | * All Rights Reserved |
---|
| 4 | * |
---|
| 5 | * Generic IO (ANL-15-066) |
---|
| 6 | * Hal Finkel, Argonne National Laboratory |
---|
| 7 | * |
---|
| 8 | * OPEN SOURCE LICENSE |
---|
| 9 | * |
---|
| 10 | * Under the terms of Contract No. DE-AC02-06CH11357 with UChicago Argonne, |
---|
| 11 | * LLC, the U.S. Government retains certain rights in this software. |
---|
| 12 | * |
---|
| 13 | * Redistribution and use in source and binary forms, with or without |
---|
| 14 | * modification, are permitted provided that the following conditions are met: |
---|
| 15 | * |
---|
| 16 | * 1. Redistributions of source code must retain the above copyright notice, |
---|
| 17 | * this list of conditions and the following disclaimer. |
---|
| 18 | * |
---|
| 19 | * 2. Redistributions in binary form must reproduce the above copyright |
---|
| 20 | * notice, this list of conditions and the following disclaimer in the |
---|
| 21 | * documentation and/or other materials provided with the distribution. |
---|
| 22 | * |
---|
| 23 | * 3. Neither the names of UChicago Argonne, LLC or the Department of Energy |
---|
| 24 | * nor the names of its contributors may be used to endorse or promote |
---|
| 25 | * products derived from this software without specific prior written |
---|
| 26 | * permission. |
---|
| 27 | * |
---|
| 28 | * ***************************************************************************** |
---|
| 29 | * |
---|
| 30 | * DISCLAIMER |
---|
| 31 | * THE SOFTWARE IS SUPPLIED “AS IS” WITHOUT WARRANTY OF ANY KIND. NEITHER THE |
---|
| 32 | * UNTED STATES GOVERNMENT, NOR THE UNITED STATES DEPARTMENT OF ENERGY, NOR |
---|
| 33 | * UCHICAGO ARGONNE, LLC, NOR ANY OF THEIR EMPLOYEES, MAKES ANY WARRANTY, |
---|
| 34 | * EXPRESS OR IMPLIED, OR ASSUMES ANY LEGAL LIABILITY OR RESPONSIBILITY FOR THE |
---|
| 35 | * ACCURACY, COMPLETENESS, OR USEFULNESS OF ANY INFORMATION, DATA, APPARATUS, |
---|
| 36 | * PRODUCT, OR PROCESS DISCLOSED, OR REPRESENTS THAT ITS USE WOULD NOT INFRINGE |
---|
| 37 | * PRIVATELY OWNED RIGHTS. |
---|
| 38 | * |
---|
| 39 | * ***************************************************************************** |
---|
| 40 | */ |
---|
| 41 | |
---|
| 42 | #include <GenericIO.h> |
---|
| 43 | |
---|
| 44 | #include <stdint.h> |
---|
| 45 | #include <sstream> |
---|
| 46 | |
---|
| 47 | template <class T> |
---|
[d409b8c] | 48 | #ifndef GENERICIO_NO_MPI |
---|
| 49 | void read_gio(const MPI_Comm &C, char* file_name, std::string var_name, T*& data, int field_count){ |
---|
| 50 | gio::GenericIO reader(C, file_name); |
---|
| 51 | #else |
---|
[9796d0a] | 52 | void read_gio(char* file_name, std::string var_name, T*& data, int field_count){ |
---|
[bd84570] | 53 | gio::GenericIO reader(file_name); |
---|
[d409b8c] | 54 | #endif |
---|
[bd84570] | 55 | reader.openAndReadHeader(gio::GenericIO::MismatchAllowed); |
---|
| 56 | int num_ranks = reader.readNRanks(); |
---|
| 57 | uint64_t max_size = 0; |
---|
| 58 | uint64_t rank_size[num_ranks]; |
---|
| 59 | for(int i =0;i<num_ranks;++i){ |
---|
| 60 | rank_size[i] = reader.readNumElems(i); |
---|
| 61 | if(max_size < rank_size[i]) |
---|
| 62 | max_size = rank_size[i]; |
---|
| 63 | } |
---|
[9796d0a] | 64 | T* rank_data = new T[max_size*field_count+reader.requestedExtraSpace()/sizeof(T)]; |
---|
[bd84570] | 65 | int64_t offset =0; |
---|
[9796d0a] | 66 | reader.addScalarizedVariable(var_name,rank_data,field_count, |
---|
| 67 | gio::GenericIO::VarHasExtraSpace); |
---|
[bd84570] | 68 | for(int i=0;i<num_ranks;++i){ |
---|
| 69 | reader.readData(i,false); |
---|
[9796d0a] | 70 | std::copy(rank_data,rank_data+rank_size[i]*field_count,data+offset); |
---|
| 71 | offset +=rank_size[i]*field_count; |
---|
[bd84570] | 72 | } |
---|
| 73 | delete [] rank_data; |
---|
| 74 | reader.close(); |
---|
| 75 | } |
---|
[7889dc4] | 76 | extern "C" int64_t get_elem_num(const MPI_Comm &c, char* file_name); |
---|
[bd84570] | 77 | |
---|
[d409b8c] | 78 | extern "C" void read_gio_float (const MPI_Comm &C, char* file_name, char* var_name, float* data, int field_count); |
---|
| 79 | extern "C" void read_gio_double(const MPI_Comm &C, char* file_name, char* var_name, double* data, int field_count); |
---|
| 80 | extern "C" void read_gio_uint16 (const MPI_Comm &C, char* file_name, char* var_name, uint16_t* data, int field_count); |
---|
| 81 | extern "C" void read_gio_int32 (const MPI_Comm &C, char* file_name, char* var_name, int* data, int field_count); |
---|
| 82 | extern "C" void read_gio_int64 (const MPI_Comm &C, char* file_name, char* var_name, int64_t* data, int field_count); |
---|
[bd84570] | 83 | enum var_type{ |
---|
| 84 | float_type=0, |
---|
| 85 | double_type=1, |
---|
| 86 | int32_type=2, |
---|
| 87 | int64_type=3, |
---|
[dd56945] | 88 | uint16_type=4, |
---|
[bd84570] | 89 | type_not_found=9, |
---|
| 90 | var_not_found=10 |
---|
| 91 | }; |
---|
[7889dc4] | 92 | extern "C" var_type get_variable_type(const MPI_Comm &C, char* file_name,char* var_name); |
---|
| 93 | extern "C" int get_variable_field_count(const MPI_Comm &C, char* file_name,char* var_name); |
---|
[d409b8c] | 94 | extern "C" void inspect_gio(const MPI_Comm &C, char* file_name); |
---|