123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390 |
- #include <stdlib.h>
- #include <string.h>
- #include <assert.h>
- #include <netcdf.h>
- #include "ncaux.h"
- struct NCAUX_FIELD {
- char* name;
- nc_type fieldtype;
- int ndims;
- int dimsizes[NC_MAX_VAR_DIMS];
- size_t size;
- size_t offset;
- size_t alignment;
- };
- struct NCAUX_CMPD {
- int ncid;
- int mode;
- char* name;
- int nfields;
- struct NCAUX_FIELD* fields;
- size_t size;
- size_t offset;
- size_t alignment;
- };
- static int ncaux_initialized = 0;
- static void compute_alignments(void);
- static int computefieldinfo(struct NCAUX_CMPD* cmpd);
- int
- ncaux_begin_compound(int ncid, const char *name, int alignmode, void** tagp)
- {
- int status = NC_NOERR;
- struct NCAUX_CMPD* cmpd = NULL;
- if(!ncaux_initialized) {
- compute_alignments();
- ncaux_initialized = 1;
- }
- if(tagp) *tagp = NULL;
-
- cmpd = (struct NCAUX_CMPD*)calloc(1,sizeof(struct NCAUX_CMPD));
- if(cmpd == NULL) {status = NC_ENOMEM; goto fail;}
- cmpd->ncid = ncid;
- cmpd->mode = alignmode;
- cmpd->nfields = 0;
- cmpd->name = strdup(name);
- if(cmpd->name == NULL) {status = NC_ENOMEM; goto fail;}
- if(tagp) *tagp = (void*)cmpd;
- return status;
- fail:
- ncaux_abort_compound((void*)cmpd);
- return status;
- }
- int
- ncaux_abort_compound(void* tag)
- {
- int i;
- struct NCAUX_CMPD* cmpd = (struct NCAUX_CMPD*)tag;
- if(cmpd == NULL) goto done;
- if(cmpd->name) free(cmpd->name);
- for(i=0;i<cmpd->nfields;i++) {
- struct NCAUX_FIELD* field = &cmpd->fields[i];
- if(field->name) free(field->name);
- }
- if(cmpd->fields) free(cmpd->fields);
- free(cmpd);
- done:
- return NC_NOERR;
- }
- int
- ncaux_add_field(void* tag, const char *name, nc_type field_type,
- int ndims, const int* dimsizes)
- {
- int i;
- int status = NC_NOERR;
- struct NCAUX_CMPD* cmpd = (struct NCAUX_CMPD*)tag;
- struct NCAUX_FIELD* newfields = NULL;
- struct NCAUX_FIELD* field = NULL;
- if(cmpd == NULL) goto done;
- if(ndims < 0) {status = NC_EINVAL; goto done;}
- for(i=0;i<ndims;i++) {
- if(dimsizes[i] <= 0) {status = NC_EINVAL; goto done;}
- }
- if(cmpd->fields == NULL) {
- newfields = (struct NCAUX_FIELD*)calloc(1,sizeof(struct NCAUX_FIELD));
- } else {
- newfields = (struct NCAUX_FIELD*)realloc(cmpd->fields,cmpd->nfields+1*sizeof(struct NCAUX_FIELD));
- }
- if(cmpd->fields == NULL) {status = NC_ENOMEM; goto done;}
- cmpd->fields = newfields;
- field = &cmpd->fields[cmpd->nfields+1];
- field->name = strdup(name);
- field->fieldtype = field_type;
- if(field->name == NULL) {status = NC_ENOMEM; goto done;}
- field->ndims = ndims;
- memcpy(field->dimsizes,dimsizes,sizeof(int)*ndims);
- cmpd->nfields++;
- done:
- return status;
- }
- static size_t
- dimproduct(int ndims, int* dimsizes)
- {
- int i;
- size_t product = 1;
- for(i=0;i<ndims;i++) product *= dimsizes[i];
- return product;
- }
- int
- ncaux_end_compound(void* tag, nc_type* idp)
- {
- int i;
- int status = NC_NOERR;
- struct NCAUX_CMPD* cmpd = (struct NCAUX_CMPD*)tag;
- if(cmpd == NULL) {status = NC_EINVAL; goto done;}
-
- status = computefieldinfo(cmpd);
- if(status != NC_NOERR) goto done;
- status = nc_def_compound(cmpd->ncid, cmpd->size, cmpd->name, idp);
- if(status != NC_NOERR) goto done;
- for(i=0;i<cmpd->nfields;i++) {
- struct NCAUX_FIELD* field = &cmpd->fields[i];
- if(field->ndims > 0) {
- status = nc_insert_compound(cmpd->ncid, *idp, field->name,
- field->offset, field->fieldtype);
- } else {
- status = nc_insert_array_compound(cmpd->ncid, *idp, field->name,
- field->offset, field->fieldtype,
- field->ndims,field->dimsizes);
- }
- if(status != NC_NOERR) goto done;
- }
- done:
- return status;
- }
- #define COMP_ALIGNMENT(DST,TYPE) {\
- struct {char f1; TYPE x;} tmp; \
- DST.typename = #TYPE ; \
- DST.alignment = (size_t)((char*)(&(tmp.x)) - (char*)(&tmp));}
- #define NATINDEX 0
- #define CHARINDEX 1
- #define UCHARINDEX 2
- #define SHORTINDEX 3
- #define USHORTINDEX 4
- #define INTINDEX 5
- #define UINTINDEX 6
- #define LONGINDEX 7
- #define ULONGINDEX 8
- #define LONGLONGINDEX 9
- #define ULONGLONGINDEX 10
- #define FLOATINDEX 11
- #define DOUBLEINDEX 12
- #define PTRINDEX 13
- #define NCVLENINDEX 14
- #define NCTYPES 15
- typedef struct Alignment {
- char* typename;
- int alignment;
- } Alignment;
- typedef Alignment Typealignvec;
- typedef struct Typealignset {
- Alignment charalign;
- Alignment ucharalign;
- Alignment shortalign;
- Alignment ushortalign;
- Alignment intalign;
- Alignment uintalign;
- Alignment longalign;
- Alignment ulongalign;
- Alignment longlongalign;
- Alignment ulonglongalign;
- Alignment floatalign;
- Alignment doublealign;
- Alignment ptralign;
- Alignment ncvlenalign;
- } Typealignset;
- static Typealignvec vec[NCTYPES];
- static Typealignset set;
- static void
- compute_alignments(void)
- {
-
-
-
- memset((void*)&set,0,sizeof(set));
- memset((void*)vec,0,sizeof(vec));
- COMP_ALIGNMENT(set.charalign,char);
- COMP_ALIGNMENT(set.ucharalign,unsigned char);
- COMP_ALIGNMENT(set.shortalign,short);
- COMP_ALIGNMENT(set.ushortalign,unsigned short);
- COMP_ALIGNMENT(set.intalign,int);
- COMP_ALIGNMENT(set.uintalign,unsigned int);
- COMP_ALIGNMENT(set.longalign,long);
- COMP_ALIGNMENT(set.ulongalign,unsigned long);
- COMP_ALIGNMENT(set.longlongalign,long long);
- COMP_ALIGNMENT(set.ulonglongalign,unsigned long long);
- COMP_ALIGNMENT(set.floatalign,float);
- COMP_ALIGNMENT(set.doublealign,double);
- COMP_ALIGNMENT(set.ptralign,void*);
- COMP_ALIGNMENT(set.ncvlenalign,nc_vlen_t);
-
- COMP_ALIGNMENT(vec[CHARINDEX],char);
- COMP_ALIGNMENT(vec[UCHARINDEX],unsigned char);
- COMP_ALIGNMENT(vec[SHORTINDEX],short);
- COMP_ALIGNMENT(vec[USHORTINDEX],unsigned short);
- COMP_ALIGNMENT(vec[INTINDEX],int);
- COMP_ALIGNMENT(vec[UINTINDEX],unsigned int);
- COMP_ALIGNMENT(vec[LONGINDEX],long);
- COMP_ALIGNMENT(vec[ULONGINDEX],unsigned long);
- COMP_ALIGNMENT(vec[LONGLONGINDEX],long long);
- COMP_ALIGNMENT(vec[ULONGLONGINDEX],unsigned long long);
- COMP_ALIGNMENT(vec[FLOATINDEX],float);
- COMP_ALIGNMENT(vec[DOUBLEINDEX],double);
- COMP_ALIGNMENT(vec[PTRINDEX],void*);
- COMP_ALIGNMENT(vec[NCVLENINDEX],nc_vlen_t);
- }
- static size_t
- nctypealignment(nc_type nctype)
- {
- Alignment* align = NULL;
- int index = 0;
- switch (nctype) {
- case NC_BYTE: index = UCHARINDEX; break;
- case NC_CHAR: index = CHARINDEX; break;
- case NC_SHORT: index = SHORTINDEX; break;
- case NC_INT: index = INTINDEX; break;
- case NC_FLOAT: index = FLOATINDEX; break;
- case NC_DOUBLE: index = DOUBLEINDEX; break;
- case NC_UBYTE: index = UCHARINDEX; break;
- case NC_USHORT: index = USHORTINDEX; break;
- case NC_UINT: index = UINTINDEX; break;
- case NC_INT64: index = LONGLONGINDEX; break;
- case NC_UINT64: index = ULONGLONGINDEX; break;
- case NC_STRING: index = PTRINDEX; break;
- case NC_VLEN: index = NCVLENINDEX; break;
- case NC_OPAQUE: index = UCHARINDEX; break;
- default: assert(0);
- }
- align = &vec[index];
- return align->alignment;
- }
- static int
- getpadding(int offset, int alignment)
- {
- int rem = (alignment==0?0:(offset % alignment));
- int pad = (rem==0?0:(alignment - rem));
- return pad;
- }
- static nc_type
- findfirstfield(int ncid, nc_type xtype)
- {
- int status = NC_NOERR;
- nc_type fieldtype = xtype;
- if(xtype <= NC_MAX_ATOMIC_TYPE) goto done;
-
- status = nc_inq_compound_fieldtype(ncid, xtype, 0, &fieldtype);
- if(status != NC_NOERR) goto done;
- fieldtype = findfirstfield(ncid,fieldtype);
- done:
- return (status == NC_NOERR?fieldtype:NC_NAT);
- }
- static int
- computefieldinfo(struct NCAUX_CMPD* cmpd)
- {
- int i;
- int status = NC_NOERR;
- size_t offset = 0;
- size_t totaldimsize;
-
- for(i=0;i<cmpd->nfields;i++) {
- struct NCAUX_FIELD* field = &cmpd->fields[i];
- status = nc_inq_type(cmpd->ncid,field->fieldtype,NULL,&field->size);
- if(status != NC_NOERR) goto done;
- totaldimsize = dimproduct(field->ndims,field->dimsizes);
- field->size *= totaldimsize;
- }
- for(offset=0,i=0;i<cmpd->nfields;i++) {
- struct NCAUX_FIELD* field = &cmpd->fields[i];
- int alignment = 0;
- nc_type firsttype = findfirstfield(cmpd->ncid,field->fieldtype);
-
- switch (field->fieldtype) {
- case NC_OPAQUE:
- field->alignment = 1;
- break;
- case NC_ENUM:
- field->alignment = nctypealignment(firsttype);
- break;
- case NC_VLEN:
- case NC_COMPOUND:
- field->alignment = nctypealignment(firsttype);
- break;
- default:
- field->alignment = nctypealignment(field->fieldtype);
- break;
- }
- offset += getpadding(offset,alignment);
- field->offset = offset;
- offset += field->size;
- }
- cmpd->size = offset;
- cmpd->alignment = cmpd->fields[0].alignment;
- done:
- return status;
- }
|