mirror of
https://github.com/Unidata/netcdf-c.git
synced 2024-12-21 08:39:46 +08:00
d953899559
re: https://github.com/zarr-developers/zarr-specs/issues/41 After discussions with the Zarr community, it was decided to convert to a new representation of the NCZarr meta-data extensions: version 2. These extensions store information necessary to mapping the Zarr data model to the netcdf-4 data model. The basic change is to remove the NCZarr specific objects: .nczarr, .nczgroup, .nczarray, and .nczattr. The contents of these objects is moved into the corresponding existing Zarr objects as special keys. The mapping is as follows: * ''.nczarr'' => ''/.zgroup/_NCZARR_SUPERBLOCK_'' * ''.nczgroup => ''.zgroup/_NCZARR_GROUP_'' * ''.nczarray => ''.zarray/_NCZARR_ARRAY_'' * ''.nczattr => ''.zattr/_NCZARR_ATTR_'' Backward compatibility is maintained by looking for the object ''/.nczarr'' and if found, then assuming that the dataset is in the older version 1 format. This compatibility only supports reading of such version 1 datasets. Documentation and test cases are also added. Misc. Other Changes: 1. The json parsing code was added to the general library instead of nczarr only (ncjson.c, ncjson.h). 2. Improved support for different platform paths by allowing conversion to a single common path representation. 3. Add some new error codes. 4. Modify nccopy usage to mention the new chunking specification.
284 lines
7.2 KiB
C
284 lines
7.2 KiB
C
/*
|
|
* Copyright 2018, University Corporation for Atmospheric Research
|
|
* See netcdf/COPYRIGHT file for copying and redistribution conditions.
|
|
*/
|
|
|
|
#include "ut_includes.h"
|
|
|
|
#define DEBUG
|
|
|
|
typedef enum Cmds {
|
|
cmd_none = 0,
|
|
cmd_build = 1,
|
|
cmd_parse = 2,
|
|
} Cmds;
|
|
|
|
/* Forward */
|
|
static int testbuild(void);
|
|
static int testparse(void);
|
|
|
|
static void dump(NCjson* json);
|
|
static void dumpR(NCjson* json, int depth);
|
|
static char* sortname(int sort);
|
|
|
|
struct Test tests[] = {
|
|
{"build", testbuild},
|
|
{"parse", testparse},
|
|
{NULL, NULL}
|
|
};
|
|
|
|
typedef struct NCJ {
|
|
NCjson* ncj_string;
|
|
NCjson* ncj_int;
|
|
NCjson* ncj_double;
|
|
NCjson* ncj_boolean;
|
|
NCjson* ncj_null;
|
|
NCjson* ncj_array1;
|
|
NCjson* ncj_array2;
|
|
NCjson* ncj_dict1;
|
|
NCjson* ncj_dict2;
|
|
} NCJ;
|
|
|
|
int
|
|
main(int argc, char** argv)
|
|
{
|
|
int stat = NC_NOERR;
|
|
|
|
if((stat = ut_init(argc, argv, &utoptions))) goto done;
|
|
if((stat = runtests((const char**)utoptions.cmds,tests))) goto done;
|
|
|
|
done:
|
|
if(stat) usage(stat);
|
|
return 0;
|
|
}
|
|
|
|
/* Build a reasonably complex json structure */
|
|
static int
|
|
build(NCJ* ncj)
|
|
{
|
|
int stat = NC_NOERR;
|
|
NCjson* clone;
|
|
|
|
memset(ncj,0,sizeof(NCJ));
|
|
|
|
/* Build instances of primitives */
|
|
if((stat = NCJnew(NCJ_STRING,&ncj->ncj_string))) goto done;
|
|
ncj->ncj_string->string = strdup("string");
|
|
if((stat = NCJnew(NCJ_INT,&ncj->ncj_int))) goto done;
|
|
ncj->ncj_int->string = strdup("117");
|
|
if((stat = NCJnew(NCJ_DOUBLE,&ncj->ncj_double))) goto done;
|
|
ncj->ncj_double->string = strdup("3.1415926");
|
|
if((stat = NCJnew(NCJ_BOOLEAN,&ncj->ncj_boolean))) goto done;
|
|
ncj->ncj_boolean->string = strdup("true");
|
|
if((stat = NCJnew(NCJ_NULL,&ncj->ncj_null))) goto done;
|
|
|
|
/* Create an empty array */
|
|
if((stat = NCJnew(NCJ_ARRAY,&ncj->ncj_array1))) goto done;
|
|
|
|
/* Create a filled array */
|
|
if((stat = NCJnew(NCJ_ARRAY,&ncj->ncj_array2))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_string,&clone))) goto done;
|
|
if((stat = NCJappend(ncj->ncj_array2,clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_int,&clone))) goto done;
|
|
if((stat = NCJappend(ncj->ncj_array2,clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_double,&clone))) goto done;
|
|
if((stat = NCJappend(ncj->ncj_array2,clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_boolean,&clone))) goto done;
|
|
if((stat = NCJappend(ncj->ncj_array2,clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_null,&clone))) goto done;
|
|
if((stat = NCJappend(ncj->ncj_array2,clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_array1,&clone))) goto done;
|
|
if((stat = NCJappend(ncj->ncj_array2,clone))) goto done;
|
|
|
|
/* Create an empty dict */
|
|
if((stat = NCJnew(NCJ_DICT,&ncj->ncj_dict1))) goto done;
|
|
|
|
/* Create a filled dict */
|
|
if((stat = NCJnew(NCJ_DICT,&ncj->ncj_dict2))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_string,&clone))) goto done;
|
|
if((stat = NCJinsert(ncj->ncj_dict2,"string",clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_int,&clone))) goto done;
|
|
if((stat = NCJinsert(ncj->ncj_dict2,"int",clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_double,&clone))) goto done;
|
|
if((stat = NCJinsert(ncj->ncj_dict2,"double",clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_boolean,&clone))) goto done;
|
|
if((stat = NCJinsert(ncj->ncj_dict2,"boolean",clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_null,&clone))) goto done;
|
|
if((stat = NCJinsert(ncj->ncj_dict2,"null",clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_array1,&clone))) goto done;
|
|
if((stat = NCJinsert(ncj->ncj_dict2,"array1",clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_array2,&clone))) goto done;
|
|
if((stat = NCJinsert(ncj->ncj_dict2,"array2",clone))) goto done;
|
|
if((stat = NCJclone(ncj->ncj_dict1,&clone))) goto done;
|
|
if((stat = NCJinsert(ncj->ncj_dict2,"dict1",clone))) goto done;
|
|
|
|
done:
|
|
return THROW(stat);
|
|
}
|
|
|
|
static void
|
|
clear(NCJ* ncj)
|
|
{
|
|
NCJreclaim(ncj->ncj_array1);
|
|
NCJreclaim(ncj->ncj_array2);
|
|
NCJreclaim(ncj->ncj_dict1);
|
|
NCJreclaim(ncj->ncj_dict2);
|
|
NCJreclaim(ncj->ncj_string);
|
|
NCJreclaim(ncj->ncj_int);
|
|
NCJreclaim(ncj->ncj_double);
|
|
NCJreclaim(ncj->ncj_boolean);
|
|
NCJreclaim(ncj->ncj_null);
|
|
}
|
|
|
|
/* Create test netcdf4 file via netcdf.h API*/
|
|
static int
|
|
testbuild(void)
|
|
{
|
|
int stat = NC_NOERR;
|
|
NCJ ncj;
|
|
|
|
/* Build */
|
|
if((stat = build(&ncj))) goto done;
|
|
|
|
/* Primitives */
|
|
dump(ncj.ncj_string);
|
|
dump(ncj.ncj_int);
|
|
dump(ncj.ncj_double);
|
|
dump(ncj.ncj_boolean);
|
|
dump(ncj.ncj_null);
|
|
|
|
/* Empty array */
|
|
dump(ncj.ncj_array1);
|
|
|
|
/* Filled array */
|
|
dump(ncj.ncj_array2);
|
|
|
|
/* Empty dict */
|
|
dump(ncj.ncj_dict1);
|
|
|
|
/* Filled dict */
|
|
dump(ncj.ncj_dict2);
|
|
|
|
done:
|
|
clear(&ncj);
|
|
return THROW(stat);
|
|
}
|
|
|
|
/* Test the parser */
|
|
static int
|
|
testparse(void)
|
|
{
|
|
NCJ ncj;
|
|
int stat = NC_NOERR;
|
|
char* text = NULL;
|
|
char* result = NULL;
|
|
NCjson* json = NULL;
|
|
|
|
/* Build */
|
|
if((stat = build(&ncj))) goto done;
|
|
|
|
if((stat = NCJunparse(ncj.ncj_dict2,0,&text))) goto done;
|
|
|
|
if((stat = NCJparse(text,0,&json))) goto done;
|
|
|
|
if((stat = NCJunparse(json,0,&result))) goto done;
|
|
|
|
printf("text : |%s|\nresult: |%s|\n",text,result);
|
|
|
|
done:
|
|
nullfree(text);
|
|
nullfree(result);
|
|
NCJreclaim(json);
|
|
clear(&ncj);
|
|
return stat;
|
|
}
|
|
|
|
static void
|
|
dump(NCjson* json)
|
|
{
|
|
dumpR(json,0);
|
|
fflush(stdout);
|
|
fflush(stderr);
|
|
}
|
|
|
|
static void
|
|
dumpR(NCjson* json, int depth)
|
|
{
|
|
int ok, count, i;
|
|
long long int64v;
|
|
double float64v;
|
|
|
|
printf("/%s/ ",sortname(json->sort));
|
|
switch(json->sort) {
|
|
case NCJ_STRING: printf("\"%s\"",json->string); break;
|
|
case NCJ_INT:
|
|
ok = sscanf(json->string,"%lld%n",&int64v,&count);
|
|
if(ok != 1 || count != strlen(json->string)) goto fail;
|
|
printf("%lld",int64v);
|
|
break;
|
|
case NCJ_DOUBLE:
|
|
ok = sscanf(json->string,"%lg%n",&float64v,&count);
|
|
if(ok != 1 || count != strlen(json->string)) goto fail;
|
|
printf("%lg",float64v);
|
|
break;
|
|
case NCJ_BOOLEAN:
|
|
if(strcasecmp(json->string,"true") != 0
|
|
&& strcasecmp(json->string,"false") != 0) goto fail;
|
|
printf("%s",json->string);
|
|
break;
|
|
case NCJ_NULL:
|
|
printf("null");
|
|
break;
|
|
case NCJ_DICT:
|
|
if(NCJlength(json) == 0) {
|
|
printf("{}");
|
|
} else {
|
|
printf("\n");
|
|
for(i=0;i<NCJlength(json);i+=2) {
|
|
NCjson* j = NULL;
|
|
j = (NCjson*)NCJith(json,i);
|
|
assert(j->sort == NCJ_STRING);
|
|
printf("{%d} ",depth+1);
|
|
printf("\"%s\" => ",j->string);
|
|
if(i+1 >= NCJlength(json)) {/* malformed */
|
|
printf("<malformed>");
|
|
} else
|
|
dumpR((NCjson*)NCJith(json,i+1),depth+1);
|
|
}
|
|
}
|
|
break;
|
|
case NCJ_ARRAY:
|
|
if(NCJlength(json) == 0) {
|
|
printf("[]");
|
|
} else {
|
|
printf("\n");
|
|
for(i=0;i<NCJlength(json);i++) {
|
|
printf("[%d] ",depth+1);
|
|
dumpR((NCjson*)NCJith(json,i),depth+1);
|
|
}
|
|
}
|
|
break;
|
|
default: printf("unknown"); break;
|
|
}
|
|
printf("\n");
|
|
return;
|
|
fail:
|
|
printf("????\n");
|
|
}
|
|
|
|
static char*
|
|
sortname(int sort)
|
|
{
|
|
switch (sort) {
|
|
case NCJ_STRING: return "String";
|
|
case NCJ_INT: return "Int";
|
|
case NCJ_DOUBLE: return "Double";
|
|
case NCJ_BOOLEAN: return "Boolean";
|
|
case NCJ_NULL: return "Null";
|
|
case NCJ_DICT: return "Dict";
|
|
case NCJ_ARRAY: return "Array";
|
|
default: break;
|
|
}
|
|
return "Unknown";
|
|
}
|