Skip to content

GitLab

Commit 15645451 authored by Uwe Schulzweida's avatar Uwe Schulzweida
Browse files

No commit message 

No commit message
parent fd6de689
Hide whitespace changes
Inline Side-by-side
ChangeLog
View file @ 15645451
......@@ -4,6 +4,7 @@
* add support for NaN in DBL_IS_EQUAL
* add support for GRID type LCC2 (LCC PROJ.4 version)
* add support for TUNIT_QUARTER (15 minutes)
* use env GRIB_INVENTORY_MODE=timestep to skip double entries
* grbDefTime: define tunit also for absolute time [report: Pruek Pongprueksa]
* change default calendar to CALENDAR_PROLEPTIC
* gridInqXinc: bug fix
......
src/stream_grb.c
View file @ 15645451
......@@ -22,6 +22,7 @@
#undef UNDEFID
#define UNDEFID CDI_UNDEFID
extern int cdiInventoryMode;
int _readline_(FILE *fp, char *line, int len);
......@@ -456,6 +457,7 @@ int grbScanTimestep(int streamID)
int status;
int fileID;
int rcode = 0, level1 = 0, level2 = 0, vdate = 0, vtime = 0;
DateTime datetime, datetime0;
int tsID;
int vrecID, recID;
int warn_numavg = TRUE;
......@@ -509,8 +511,11 @@ int grbScanTimestep(int streamID)
fileSetPos(fileID, streamptr->tsteps[tsID].position, SEEK_SET);
for ( rindex = 0; rindex <= nrecs; rindex++ )
rindex = 0;
while ( TRUE )
{
if ( rindex > nrecs ) break;
recsize = gribGetSize(fileID);
recpos = fileGetPos(fileID);
if ( recsize == 0 )
......@@ -572,6 +577,9 @@ int grbScanTimestep(int streamID)
}
taxis->vdate = vdate;
taxis->vtime = vtime;
datetime0.date = vdate;
datetime0.time = vtime;
}
if ( ISEC1_AvgNum )
......@@ -591,6 +599,8 @@ int grbScanTimestep(int streamID)
}
}
datetime.date = vdate;
datetime.time = vtime;
compVar.code = rcode;
compVar.table = ISEC1_CodeTable;
compVar.level1 = level1;
......@@ -604,18 +614,42 @@ int grbScanTimestep(int streamID)
compVar0.level1 = streamptr->tsteps[tsID].records[recID].ilevel;
compVar0.level2 = streamptr->tsteps[tsID].records[recID].ilevel2;
compVar0.ltype = streamptr->tsteps[tsID].records[recID].ltype;
if ( memcmp(&compVar0, &compVar, sizeof(COMPVAR)) == 0 )
{
streamptr->tsteps[tsID].records[recID].used = TRUE;
streamptr->tsteps[tsID].recIDs[rindex] = recID;
break;
}
if ( memcmp(&compVar0, &compVar, sizeof(COMPVAR)) == 0 ) break;
}
if ( vrecID == nrecs )
{
Warning(func, "1 code %d level %d not found at timestep %d",
Warning(func, "Code %d level %d not available at timestep %d!",
rcode, level1, tsID+1);
return (CDI_EUFSTRUCT);
if ( cdiInventoryMode == 1 )
return (CDI_EUFSTRUCT);
else
continue;
}
if ( cdiInventoryMode == 1 )
{
streamptr->tsteps[tsID].records[recID].used = TRUE;
streamptr->tsteps[tsID].recIDs[rindex] = recID;
}
else
{
if ( streamptr->tsteps[tsID].records[recID].used )
{
if ( memcmp(&datetime, &datetime0, sizeof(DateTime)) != 0 ) break;
if ( CDI_Debug )
Warning(func, "Code %d level %d already exist, skipped!", rcode, level1);
continue;
}
else
{
streamptr->tsteps[tsID].records[recID].used = TRUE;
streamptr->tsteps[tsID].recIDs[rindex] = recID;
}
}
if ( CDI_Debug )
......@@ -641,6 +675,8 @@ int grbScanTimestep(int streamID)
if ( CDI_Debug )
Message(func, "%4d %8d %4d %8d %8d %6d", rindex, (int)recpos, rcode, level1, vdate, vtime);
rindex++;
}
for ( vrecID = 0; vrecID < nrecs; vrecID++ )
......@@ -651,7 +687,7 @@ int grbScanTimestep(int streamID)
if ( vrecID < nrecs )
{
Warning(func, "2 code %d level %d not found at timestep %d",
Warning(func, "Code %d level %d not found at timestep %d!",
streamptr->tsteps[tsID].records[recID].code,
streamptr->tsteps[tsID].records[recID].ilevel,
tsID+1);
......@@ -1165,13 +1201,27 @@ void grbScanTimestep1(int streamID)
if ( memcmp(&compVar0, &compVar, sizeof(COMPVAR)) == 0 ) break;
}
if ( recID < nrecs ) break;
if ( warn_time )
if ( memcmp(&datetime, &datetime0, sizeof(DateTime)) )
{
Warning(func, "Inconsistent verification time (code %d level %d)", rcode, level1);
warn_time = FALSE;
}
if ( cdiInventoryMode == 1 )
{
if ( recID < nrecs ) break;
if ( warn_time )
if ( memcmp(&datetime, &datetime0, sizeof(DateTime)) != 0 )
{
Warning(func, "Inconsistent verification time (code %d level %d)", rcode, level1);
warn_time = FALSE;
}
}
else
{
if ( memcmp(&datetime, &datetime0, sizeof(DateTime)) != 0 ) break;
if ( recID < nrecs )
{
Warning(func, "Code %d level %d already exist, skipped!", rcode, level1);
continue;
}
}
}
if ( ISEC1_AvgNum )
......@@ -1273,6 +1323,7 @@ int grbScanTimestep2(int streamID)
int status;
int fileID;
int rcode = 0, level1 = 0, level2 = 0, vdate = 0, vtime = 0;
DateTime datetime, datetime0;
int tsID;
int varID, gridID;
size_t readsize;
......@@ -1280,7 +1331,6 @@ int grbScanTimestep2(int streamID)
long recsize = 0;
int warn_numavg = TRUE;
int taxisID = -1;
int nextstep;
TAXIS *taxis;
int vlistID;
long unzipsize;
......@@ -1331,8 +1381,11 @@ int grbScanTimestep2(int streamID)
streamptr->tsteps[0].records[recID].size;
}
for ( rindex = 0; rindex <= nrecords; rindex++ )
rindex = 0;
while ( TRUE )
{
if ( rindex > nrecords ) break;
recsize = gribGetSize(fileID);
recpos = fileGetPos(fileID);
if ( recsize == 0 )
......@@ -1386,6 +1439,9 @@ int grbScanTimestep2(int streamID)
}
taxis->vdate = vdate;
taxis->vtime = vtime;
datetime0.date = vdate;
datetime0.time = vtime;
}
if ( ISEC1_AvgNum )
......@@ -1405,12 +1461,13 @@ int grbScanTimestep2(int streamID)
}
}
datetime.date = vdate;
datetime.time = vtime;
compVar.code = rcode;
compVar.table = ISEC1_CodeTable;
compVar.level1 = level1;
compVar.level2 = level2;
compVar.ltype = ISEC1_LevelType;
nextstep = FALSE;
for ( recID = 0; recID < nrecords; recID++ )
{
compVar0.code = streamptr->tsteps[tsID].records[recID].code;
......@@ -1418,27 +1475,43 @@ int grbScanTimestep2(int streamID)
compVar0.level1 = streamptr->tsteps[tsID].records[recID].ilevel;
compVar0.level2 = streamptr->tsteps[tsID].records[recID].ilevel2;
compVar0.ltype = streamptr->tsteps[tsID].records[recID].ltype;
if ( memcmp(&compVar0, &compVar, sizeof(COMPVAR)) == 0 )
{
if ( streamptr->tsteps[tsID].records[recID].used )
{
nextstep = TRUE;
}
else
{
streamptr->tsteps[tsID].records[recID].used = TRUE;
streamptr->tsteps[tsID].recIDs[rindex] = recID;
}
break;
}
if ( memcmp(&compVar0, &compVar, sizeof(COMPVAR)) == 0 ) break;
}
if ( recID == nrecords )
{
Warning(func, "code %d level %d not found at timestep %d", rcode, level1, tsID+1);
Warning(func, "Code %d level %d not found at timestep %d!", rcode, level1, tsID+1);
return (CDI_EUFSTRUCT);
}
if ( nextstep ) break;
if ( cdiInventoryMode == 1 )
{
if ( streamptr->tsteps[tsID].records[recID].used )
{
break;
}
else
{
streamptr->tsteps[tsID].records[recID].used = TRUE;
streamptr->tsteps[tsID].recIDs[rindex] = recID;
}
}
else
{
if ( streamptr->tsteps[tsID].records[recID].used )
{
if ( memcmp(&datetime, &datetime0, sizeof(DateTime)) != 0 ) break;
Warning(func, "Code %d level %d already exist, skipped!", rcode, level1);
continue;
}
else
{
streamptr->tsteps[tsID].records[recID].used = TRUE;
streamptr->tsteps[tsID].recIDs[rindex] = recID;
}
}
if ( CDI_Debug )
Message(func, "%4d %8d %4d %8d %8d %6d", rindex+1, (int)recpos, rcode, level1, vdate, vtime);
......@@ -1469,6 +1542,8 @@ int grbScanTimestep2(int streamID)
IS_NOT_EQUAL(gridInqYval(gridID, 0),ISEC2_FirstLat*0.001) )
gridChangeType(gridID, GRID_TRAJECTORY);
}
rindex++;
}
nrecs = 0;
......
src/stream_int.c
View file @ 15645451
......@@ -22,6 +22,7 @@ int cdiNcMissingValue = CDI_UNDEFID;
int cdiSplitLtype105 = CDI_UNDEFID;
int cdiIgnoreAttCoordinates = FALSE;
int cdiInventoryMode = 1;
char *cdiPartabPath = NULL;
int cdiPartabIntern = 1;
......@@ -123,6 +124,17 @@ void cdiInitialize(void)
envString = getenv("IGNORE_ATT_COORDINATES");
if ( envString ) cdiIgnoreAttCoordinates = atoi(envString);
envString = getenv("GRIB_INVENTORY_MODE");
if ( envString )
{
if ( strncmp(envString, "time", 4) == 0 )
{
cdiInventoryMode = 2;
if ( CDI_Debug )
Message(func, "Inventory mode was set to timestep!");
}
}
envString = getenv("PARTAB_INTERN");
if ( envString ) cdiPartabIntern = atoi(envString);
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment