1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
/* DO NOT REMOVE the config.h include file under any circumstances,
* it's very much needed on some platforms */
#if defined(HAVE_CONFIG_H)
#include "config.h"
#endif
/* DO NOT REMOVE the above config.h include file under any
* circumstances as long as it's the autoconf configuration header
* used to build this package. When it's missing on some platforms,
* some poor person has to do long, tedious debugging sessions, where
* struct offsets almost imperceptibly change from one file to the
* next to find out what happened */
#include "dmemory.h"
#include "stream_scan.h"
void
streamScanResizeRecords1(stream_t *streamptr)
{
int nrecords = streamptr->tsteps[0].nallrecs;
if (nrecords < streamptr->tsteps[0].recordSize)
{
streamptr->tsteps[0].recordSize = nrecords;
streamptr->tsteps[0].recinfo = (recinfo_t *) Realloc(streamptr->tsteps[0].recinfo, (size_t) nrecords * sizeof(recinfo_t));
streamptr->tsteps[0].records = (record_t *) Realloc(streamptr->tsteps[0].records, (size_t) nrecords * sizeof(record_t));
}
streamptr->tsteps[0].recIDs = (int *) Malloc((size_t) nrecords * sizeof(int));
streamptr->tsteps[0].nrecs = nrecords;
for (int recID = 0; recID < nrecords; ++recID) streamptr->tsteps[0].recIDs[recID] = recID;
}
int
streamScanInitRecords2(stream_t *streamptr)
{
int nrecords = streamptr->tsteps[1].nallrecs;
streamptr->tsteps[1].recIDs = (int *) Malloc((size_t) nrecords * sizeof(int));
streamptr->tsteps[1].nrecs = 0;
for (int recID = 0; recID < nrecords; ++recID)
{
streamptr->tsteps[1].recIDs[recID] = -1;
streamptr->tsteps[1].records[recID].position = streamptr->tsteps[0].records[recID].position;
streamptr->tsteps[1].records[recID].size = streamptr->tsteps[0].records[recID].size;
}
return nrecords;
}
int
streamScanInitRecords(stream_t *streamptr, int tsID)
{
int nrecs = streamptr->tsteps[1].nrecs;
streamptr->tsteps[tsID].nrecs = nrecs;
streamptr->tsteps[tsID].recIDs = (int *) Malloc((size_t) nrecs * sizeof(int));
for (int recID = 0; recID < nrecs; ++recID) streamptr->tsteps[tsID].recIDs[recID] = streamptr->tsteps[1].recIDs[recID];
return nrecs;
}
void
streamScanTimeConstAdjust(stream_t *streamptr, const taxis_t *taxis)
{
int vlistID = streamptr->vlistID;
if (streamptr->ntsteps == 1 && cdiDateTime_isNull(taxis->vDateTime))
{
streamptr->ntsteps = 0;
for (int varID = 0; varID < streamptr->nvars; ++varID) vlistDefVarTimetype(vlistID, varID, TIME_CONSTANT);
}
}
void
streamScanTsFixNtsteps(stream_t *streamptr, off_t recpos)
{
if (streamptr->ntsteps == -1)
{
int tsID = tstepsNewEntry(streamptr);
if (tsID != streamptr->rtsteps) Error("Internal error. tsID = %d", tsID);
streamptr->tsteps[tsID - 1].next = true;
streamptr->tsteps[tsID].position = recpos;
}
}
|
