netcdf-c/dap4_test/test_common.h
Dennis Heimbigner 97ce621091 Improve operation of the DAP4 code and fix bugs
re: esupport 31942

* Add a new set of remote tests based on using the opendap hyrax server
* Re-enable --enable-dap-remote-tests as default on
* Make it possible to query the DMR separate from the DAP
  so that it is possible to delay reading data until it is actually
  requested. This make things like ncdump -h much more efficient.
* Fix handling of <Map>s in DMRs.
* Fix some memory leaks
2021-01-14 21:39:08 -07:00

185 lines
4.3 KiB
C

/*********************************************************************
* Copyright 2016, UCAR/Unidata
* See netcdf/COPYRIGHT file for copying and redistribution conditions.
*********************************************************************/
/* Define various things common to all the t_dmr*.c testers */
#undef DEBUG
#undef DUMP
#include "d4includes.h"
#ifdef DEBUG
#include "ezxml.h"
#endif
typedef int TDMR;
#define TDMR_PARSE 1
#define TDMR_META 2
#define TDMR_DATA 4
static NCbytes* input = NULL;
static NCbytes* output = NULL;
static NCD4meta* metadata = NULL;
static char* infile = NULL;
static char* outfile = NULL;
static int ncid = 0;
static int translatenc4 = 0;
static int
readfile(const char* filename, NCbytes* content)
{
FILE* stream;
char part[1024];
stream = fopen(filename,"r");
if(stream == NULL) return errno;
for(;;) {
size_t count = fread(part, 1, sizeof(part), stream);
if(count <= 0) break;
ncbytesappendn(content,part,count);
if(ferror(stream)) {fclose(stream); return NC_EIO;}
if(feof(stream)) break;
}
ncbytesnull(content);
fclose(stream);
return NC_NOERR;
}
static void
fail(int code)
{
if(code != NC_NOERR)
fprintf(stderr,"***Fail: %s\n",nc_strerror(code));
exit((code==NC_NOERR?EXIT_SUCCESS:EXIT_FAILURE));
}
static void
setup(int tdmr, int argc, char** argv)
{
int ret = NC_NOERR;
argc--; argv++;
int expected = 0;
NCD4mode mode = 0;
NCD4INFO* controller = NULL;
switch(tdmr) {
case TDMR_PARSE:
expected = 1;
mode = NCD4_DMR;
break;
case TDMR_META:
expected = 2;
mode = NCD4_DMR;
break;
case TDMR_DATA:
fprintf(stderr,"setup is not used for t_dmrdata\n");
mode = NCD4_DAP;
exit(1);
}
if(argc < expected) {
fprintf(stderr, "too few arguments\n");
exit(1);
}
infile = argv[0];
outfile = NULL;
input = ncbytesnew();
output = ncbytesnew();
if((ret = readfile(infile,input))) fail(ret);
{
const char* trans = getenv("translatenc4");
if(trans != NULL)
translatenc4 = 1;
}
#ifdef DUMP
NCD4_dumpbytes(ncbyteslength(input),ncbytescontents(input),0);
#endif
/* Create a fake NCD4INFO */
controller = (NCD4INFO*)calloc(1,sizeof(NCD4INFO));
if(controller == NULL)
fail(NC_ENOMEM);
controller->controls.translation = NCD4_TRANSNC4;
if(translatenc4)
controller->controls.translation = NCD4_TRANSNC4;
NCD4_applyclientparamcontrols(controller);
if((metadata=NCD4_newmeta(controller, ncbyteslength(input),ncbytescontents(input)))==NULL)
fail(NC_ENOMEM);
metadata->mode = mode;
if((ret=NCD4_dechunk(metadata))) /* ok for mode == DMR or mode == DAP */
fail(ret);
#ifdef DEBUG
{
int swap = (metadata->serial.hostbigendian != metadata->serial.remotebigendian);
void* d = metadata->serial.dap;
size_t sz = metadata->serial.dapsize;
fprintf(stderr,"====================\n");
fprintf(stderr,"%s\n",metadata->serial.dmr);
fprintf(stderr,"----------\n");
NCD4_dumpbytes(sz,d,swap);
fprintf(stderr,"====================\n");
fflush(stderr);
}
#endif
if(expected > 1) {
outfile = argv[1];
if((ret = nc_create(outfile,NC_CLOBBER|NC_NETCDF4,&ncid))) fail(ret);
}
#ifdef DEBUG
{
char* tree;
ezxml_t dom = ezxml_parse_str(ncbytescontents(input),ncbyteslength(input));
if(dom == NULL) exit(1);
tree = ezxml_toxml(dom);
fprintf(stderr,"////////////////////\n");
fprintf(stderr,"%s\n",tree);
fprintf(stderr,"////////////////////\n");
}
#endif
{
const char* slevel = getenv("d4loglevel");
int level;
if(slevel != NULL && sscanf(slevel,"%d",&level) == 1) {
nc_set_log_level(level);
}
}
}
int
cleanup(int ret)
{
if(outfile != NULL) {
if(ret != NC_NOERR)
ret = nc_abort(ncid);
else
ret = nc_close(ncid);
}
if(metadata->controller != NULL)
free(metadata->controller);
NCD4_reclaimMeta(metadata);
ncbytesfree(output);
if(ret)
fail(ret);
else
exit(EXIT_SUCCESS);
return 0;
}
#if 0
static void
printxml(const char* input)
{
char* tree;
ezxml_t dom = ezxml_parse_str(input,strlen(input));
if(dom == NULL) exit(1);
tree = ezxml_toxml(dom);
fprintf(stderr,"////////////////////\n");
fprintf(stderr,"%s\n",tree);
fprintf(stderr,"////////////////////\n");
}
#endif