cdi_int.h 9.26 KB
Newer Older
1
2
#ifndef _CDI_INT_H
#define _CDI_INT_H
Uwe Schulzweida's avatar
Uwe Schulzweida committed
3
4
5
6
7

#if defined (HAVE_CONFIG_H)
#  include "config.h"
#endif

Uwe Schulzweida's avatar
Uwe Schulzweida committed
8
#include <assert.h>
Uwe Schulzweida's avatar
Uwe Schulzweida committed
9
#include <stdio.h>
Uwe Schulzweida's avatar
Uwe Schulzweida committed
10
#include <stdbool.h>
Uwe Schulzweida's avatar
Uwe Schulzweida committed
11
#include <string.h>
Uwe Schulzweida's avatar
Uwe Schulzweida committed
12
#include <errno.h>
Uwe Schulzweida's avatar
Uwe Schulzweida committed
13
14
15
#include <math.h>
#include <sys/types.h>

16
17
18
/* dummy use of unused parameters to silence compiler warnings */
#define  UNUSED(x) (void)x

Uwe Schulzweida's avatar
Uwe Schulzweida committed
19
#ifndef strdupx
Uwe Schulzweida's avatar
Uwe Schulzweida committed
20
21
22
23
24
#ifndef strdup
char *strdup(const char *s);
#endif
#define strdupx  strdup
/*
Uwe Schulzweida's avatar
Uwe Schulzweida committed
25
26
27
28
29
30
31
#define strdupx(s)			          \
({					      	  \
   const char *__old = (s);			  \
   size_t __len = strlen(__old) + 1;		  \
   char *__new = (char *) malloc(__len);	  \
   (char *) memcpy(__new, __old, __len);	  \
})
Uwe Schulzweida's avatar
Uwe Schulzweida committed
32
*/
Uwe Schulzweida's avatar
Uwe Schulzweida committed
33
34
#endif

35
36
#ifndef  M_PI
#define  M_PI        3.14159265358979323846  /* pi */
Uwe Schulzweida's avatar
Uwe Schulzweida committed
37
38
39
40
41
42
43
44
45
#endif


#ifndef  _ERROR_H
#  include "error.h"
#endif
#ifndef _BASETIME_H
#  include "basetime.h"
#endif
46
47
48
#ifndef _TIMEBASE_H
#  include "timebase.h"
#endif
Uwe Schulzweida's avatar
Uwe Schulzweida committed
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
#ifndef  _TAXIS_H
#  include "taxis.h"
#endif
#ifndef  _CDI_LIMITS_H
#  include "cdi_limits.h"
#endif
#ifndef  _SERVICE_H
#  include "service.h"
#endif
#ifndef  _EXTRA_H
#  include "extra.h"
#endif
#ifndef  _IEG_H
#  include "ieg.h"
#endif
64
65
66
#ifndef RESOURCE_HANDLE_H
#  include "resource_handle.h"
#endif
Uwe Schulzweida's avatar
Uwe Schulzweida committed
67

68

Deike Kleberg's avatar
Deike Kleberg committed
69
70
#define check_parg(arg)  if ( arg == 0 ) Warning("Argument '" #arg "' not allocated!")

Uwe Schulzweida's avatar
Uwe Schulzweida committed
71
#if defined (__xlC__) /* performance problems on IBM */
Uwe Schulzweida's avatar
cleanup    
Uwe Schulzweida committed
72
73
74
75
#ifndef DBL_IS_NAN
#  define DBL_IS_NAN(x)     ((x) != (x))
#endif
#else
76
#ifndef DBL_IS_NAN
77
#if  defined  (HAVE_DECL_ISNAN)
78
#  define DBL_IS_NAN(x)     (isnan(x))
79
#elif  defined  (FP_NAN)
80
#  define DBL_IS_NAN(x)     (fpclassify(x) == FP_NAN)
81
#else
82
#  define DBL_IS_NAN(x)     ((x) != (x))
83
#endif
Uwe Schulzweida's avatar
Uwe Schulzweida committed
84
#endif
Uwe Schulzweida's avatar
Uwe Schulzweida committed
85
#endif
Uwe Schulzweida's avatar
Uwe Schulzweida committed
86

87
88
89
90
91
#ifndef DBL_IS_EQUAL
/*#define DBL_IS_EQUAL(x,y) (!(x < y || y < x)) */
#  define DBL_IS_EQUAL(x,y) (DBL_IS_NAN(x)||DBL_IS_NAN(y)?(DBL_IS_NAN(x)&&DBL_IS_NAN(y)?1:0):!(x < y || y < x))
#endif

92
93
94
95
96
97
#ifndef IS_EQUAL
#  define IS_NOT_EQUAL(x,y) (x < y || y < x)
#  define IS_EQUAL(x,y)     (!IS_NOT_EQUAL(x,y))
#endif


Uwe Schulzweida's avatar
Uwe Schulzweida committed
98
99
100
101
102
103
#define  FALSE  0
#define  TRUE   1

#define  TYPE_REC  0
#define  TYPE_VAR  1

104
105
106
#define  MEMTYPE_DOUBLE  1
#define  MEMTYPE_FLOAT   2

Uwe Schulzweida's avatar
Uwe Schulzweida committed
107
108
109
110
111
112
113
114
typedef struct
{
  void     *buffer;
  size_t    buffersize;
  off_t     position;
  int       recsize;
  int       size;
  int       dataread;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
115
  int       param;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
  int       level;
  int       date;
  int       time;
  int       gridID;
  int       zaxisID;
  int       used;
  int       nrec;
  int       varID;
  int       levelID;
  int       recid;
  int       prec;
  int       sec0[2];
  int       sec1[1024];
  int       sec2[4096];
  int       sec3[2];
  int       sec4[512];
132
  void     *exsep;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
133
134
135
136
137
138
139
140
}
Record;


typedef struct
{
  off_t     position;
  size_t    size;
141
  int       zip;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
142
  int       param;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
143
144
145
146
147
148
  int       ilevel;
  int       ilevel2;
  int       ltype;
  short     used;
  short     varID;
  short     levelID;
149
  char      varname[32]; /* needed for grib decoding with GRIB_API */
Uwe Schulzweida's avatar
Uwe Schulzweida committed
150
}
Uwe Schulzweida's avatar
Uwe Schulzweida committed
151
record_t;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
152
153
154


typedef struct {
Uwe Schulzweida's avatar
Uwe Schulzweida committed
155
  record_t *records;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
156
157
158
159
160
161
162
163
164
  int       recordSize;  /* number of allocated records           */
  int      *recIDs;      /* IDs of non constant records           */
  int       nrecs;       /* number of used records                */
                         /* tsID=0 nallrecs                       */
                         /* tsID>0 number of non constant records */
  int       nallrecs;    /* number of all records                 */
  int       curRecID;    /* current record ID                     */
  long      next;
  off_t     position;    /* timestep file position                */
165
  taxis_t   taxis;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
166
}
167
tsteps_t;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
168
169
170
171
172
173
174
175
176
177
178
179


typedef struct {
  int       ncvarid;
  int       nlevs;
  int      *level;       /* record IDs */
  int      *lindex;      /* level index */
  int       defmiss;     /* TRUE if missval is defined in file */

  int       isUsed;
  int       gridID;
  int       zaxisID;
180
  int       tsteptype;   /* TSTEP_* */
Uwe Schulzweida's avatar
Uwe Schulzweida committed
181
}
182
svarinfo_t;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
183
184
185
186
187
188
189
190
191
192
193
194


typedef struct {
  int       ilev;
  int       mlev;
  int       ilevID;
  int       mlevID;
}
VCT;


typedef struct {
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
  int         self;
  int         accesstype;   /* TYPE_REC or TYPE_VAR */
  int         accessmode;
  int         filetype;
  int         byteorder;
  int         fileID;
  int         dimgroupID;
  int         filemode;
  off_t       numvals;
  char       *filename;
  Record     *record;
  int        nrecs;        /* number of records                  */
  int         nvars;        /* number of variables                */
  int         varlocked;    /* variables locked                   */
  svarinfo_t *vars;
  int         varsAllocated;
  int         varinit;
  int         curTsID;      /* current timestep ID */
  int         rtsteps;      /* number of tsteps accessed       */
  long        ntsteps;      /* number of tsteps : only set if all records accessed */
  int         numTimestep;  /* number of tsteps : only set if all records accessed */
  tsteps_t   *tsteps;
  int         tstepsTableSize;
  int         tstepsNextID;
219
  basetime_t  basetime;
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
  int         ncmode;
  int         vlistID;
  int         xdimID[MAX_GRIDS_PS];
  int         ydimID[MAX_GRIDS_PS];
  int         zaxisID[MAX_ZAXES_PS];
  int         ncxvarID[MAX_GRIDS_PS];
  int         ncyvarID[MAX_GRIDS_PS];
  int         ncavarID[MAX_GRIDS_PS];
  int         historyID;
  int         globalatts;
  int         localatts;
  VCT         vct;
  int         unreduced;
  int         sortname;
  int         have_missval;
  int         comptype;      // compression type
  int         complevel;     // compression level
  int         curfile;
  int         nfiles;
  char      **fnames;
#if defined (GRIBCONTAINER2D)
  void      **gribContainers;
#else
  void       *gribContainers;
#endif
  int         vlistIDorig;
246
  /* only used by MPI-parallelized version of library */
247
  int       ownerRank;    // MPI rank of owner process
248
249
250
251
252
  /* ---------------------------------- */
  /* Local change: 2013-02-18, FP (DWD) */
  /* ---------------------------------- */

  void *gh; // grib handle
Uwe Schulzweida's avatar
Uwe Schulzweida committed
253
}
Uwe Schulzweida's avatar
Uwe Schulzweida committed
254
stream_t;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
255
256
257


extern int CDI_Debug;      /* If set to 1, debuggig (default 0)            */
258
extern int cdiGribApiDebug;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
259
260
261
262
263
extern double cdiDefaultMissval;
extern int cdiDefaultInstID;
extern int cdiDefaultModelID;
extern int cdiDefaultTableID;
extern int cdiDefaultLeveltype;
264
//extern int cdiNcMissingValue;
265
extern int cdiNcChunksizehint;
266
extern int cdiChunkType;
267
extern int cdiSplitLtype105;
Uwe Schulzweida's avatar
Uwe Schulzweida committed
268

Uwe Schulzweida's avatar
Uwe Schulzweida committed
269
270
271
extern char *cdiPartabPath;
extern int   cdiPartabIntern;

Uwe Schulzweida's avatar
Uwe Schulzweida committed
272
273
274
stream_t *stream_to_pointer(int idx);
stream_t *stream_new_entry(void);
void stream_delete_entry(stream_t *streamptr);
275
void stream_check_ptr(const char *caller, stream_t *streamptr);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
276

Uwe Schulzweida's avatar
Uwe Schulzweida committed
277
278
int     streamInqFileID(int streamID);

279
280
void    gridDefHasDims(int gridID, int hasdims);
int     gridInqHasDims(int gridID);
281
const char *gridNamePtr(int gridtype);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
282
char   *zaxisNamePtr(int leveltype);
283
int     zaxisInqLevelID(int zaxisID, double level);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
284

285
void    streamCheckID(const char *caller, int streamID);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
286
287
288
289
290

void    streamDefineTaxis(int streamID);

int     streamsNewEntry(int filetype);
void    streamsInitEntry(int streamID);
291
void    cdiStreamSetupVlist(stream_t *streamptr, int vlistID, int vlistIDorig);
292
int     stream_new_var(stream_t *streamptr, int gridID, int zaxisID);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
293

294
int     tstepsNewEntry(stream_t *streamptr);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
295

296
const char *strfiletype(int filetype);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
297

298
void    cdi_generate_vars(stream_t *streamptr);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
299

300
void    vlist_check_contents(int vlistID);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
301

302
void    cdi_create_records(stream_t *streamptr, int tsID);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
303

304
int     recordNewEntry(stream_t *streamptr, int tsID);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
305

306
void    cdiCreateTimesteps(stream_t *streamptr);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
307

Uwe Schulzweida's avatar
Uwe Schulzweida committed
308
void    recordInitEntry(record_t *record);
Uwe Schulzweida's avatar
Uwe Schulzweida committed
309
310
311
312
313
314
315
316
317
318
319

void    cdiCheckZaxis(int zaxisID);

void    cdiPrintDatatypes(void);

void    cdiDefAccesstype(int streamID, int type);
int     cdiInqAccesstype(int streamID);

void    streamDefDimgroupID(int streamID, int dimgroupID);
int     streamInqDimgroupID(int streamID);

Deike Kleberg's avatar
Deike Kleberg committed
320
321
322
int     getByteswap(int byteorder);

int     streamSize ();
323
void    streamGetIndexList ( int, int * );
Deike Kleberg's avatar
Deike Kleberg committed
324

Uwe Schulzweida's avatar
Uwe Schulzweida committed
325

326
327
328
329
void  cdiInitialize(void);

void stream_write_record(int streamID, int memtype, const void *data, int nmiss);

330
331
332
void uuid2str(const char *uuid, char *uuidstr);
void str2uuid(const char *uuidstr, char *uuid);

333
334
335
336
337
338
#define CDI_UNIT_PA   1
#define CDI_UNIT_HPA  2
#define CDI_UNIT_MM   3
#define CDI_UNIT_CM   4
#define CDI_UNIT_DM   5
#define CDI_UNIT_M    6
339

340
341
342
343
344
345
346
struct streamAssoc
{
  int streamID, vlistID, vlistIDorig;
};

struct streamAssoc
streamUnpack(char * unpackBuffer, int unpackBufferSize,
347
             int * unpackBufferPos, int originNamespace, void *context);
348

349
350
int
cdiStreamOpenDefaultDelegate(const char *filename, const char *filemode,
351
352
                             int filetype, stream_t *streamptr,
                             int recordBufIsToBeCreated);
353
354
355
356
357
358
359
360
361
362

void
cdiStreamDefVlist_(int streamID, int vlistID);
void
cdiStreamWriteVar_(int streamID, int varID, int memtype, const void *data,
                   int nmiss);
void
cdiStreamwriteVarChunk_(int streamID, int varID, int memtype,
                        const int rect[][2], const void *data, int nmiss);
void
363
364
cdiStreamCloseDefaultDelegate(stream_t *streamptr,
                              int recordBufIsToBeDeleted);
365

Thomas Jahns's avatar
Thomas Jahns committed
366
367
int cdiStreamDefTimestep_(stream_t *streamptr, int tsID);

Thomas Jahns's avatar
Thomas Jahns committed
368
369
void cdiStreamSync_(stream_t *streamptr);

370
371
char *cdiUnitNamePtr(int cdi_unit);

372
extern const resOps streamOps;
373
374

#endif  /* _CDI_INT_H */
375
376
377
378
379
380
381
382
383
/*
 * Local Variables:
 * c-file-style: "Java"
 * c-basic-offset: 2
 * indent-tabs-mode: nil
 * show-trailing-whitespace: t
 * require-trailing-newline: t
 * End:
 */