Lines Matching refs:streamptr

40 int recordNewEntry(stream_t *streamptr, int tsID)  in recordNewEntry()  argument
43 size_t recordSize = (size_t)streamptr->tsteps[tsID].recordSize; in recordNewEntry()
44 record_t *records = streamptr->tsteps[tsID].records; in recordNewEntry()
83 streamptr->tsteps[tsID].recordSize = (int)recordSize; in recordNewEntry()
84 streamptr->tsteps[tsID].records = records; in recordNewEntry()
90 void cdiInitRecord(stream_t *streamptr) in cdiInitRecord() argument
93 streamptr->record = record; in cdiInitRecord()
113 stream_t *streamptr = stream_to_pointer(streamID); in streamInqRecord() local
117 if ( ! streamptr->record ) cdiInitRecord(streamptr); in streamInqRecord()
119 int tsID = streamptr->curTsID; in streamInqRecord()
120 int rindex = streamptr->tsteps[tsID].curRecID + 1; in streamInqRecord()
122 if ( rindex >= streamptr->tsteps[tsID].nrecs ) in streamInqRecord()
125 int recID = streamptr->tsteps[tsID].recIDs[rindex]; in streamInqRecord()
127 if ( recID == -1 || recID >= streamptr->tsteps[tsID].nallrecs ) in streamInqRecord()
130 *varID = streamptr->tsteps[tsID].records[recID].varID; in streamInqRecord()
131 int lindex = streamptr->tsteps[tsID].records[recID].levelID; in streamInqRecord()
133 int isub = subtypeInqActiveIndex(streamptr->vars[*varID].subtypeID); in streamInqRecord()
134 *levelID = streamptr->vars[*varID].recordTable[isub].lindex[lindex]; in streamInqRecord()
139 streamptr->curTsID = tsID; in streamInqRecord()
140 streamptr->tsteps[tsID].curRecID = rindex; in streamInqRecord()
159 stream_t *streamptr = stream_to_pointer(streamID); in streamDefRecord() local
161 int tsID = streamptr->curTsID; in streamDefRecord()
169 if ( ! streamptr->record ) cdiInitRecord(streamptr); in streamDefRecord()
171 int vlistID = streamptr->vlistID; in streamDefRecord()
177 Record *record = streamptr->record; in streamDefRecord()
182 record->date = streamptr->tsteps[tsID].taxis.vdate; in streamDefRecord()
183 record->time = streamptr->tsteps[tsID].taxis.vtime; in streamDefRecord()
187 switch (cdiBaseFiletype(streamptr->filetype)) in streamDefRecord()
192 grbDefRecord(streamptr); in streamDefRecord()
197 srvDefRecord(streamptr); in streamDefRecord()
202 extDefRecord(streamptr); in streamDefRecord()
207 iegDefRecord(streamptr); in streamDefRecord()
212 if ( streamptr->accessmode == 0 ) cdfEndDef(streamptr); in streamDefRecord()
213 cdfDefRecord(streamptr); in streamDefRecord()
217 Error("%s support not compiled in!", strfiletype(streamptr->filetype)); in streamDefRecord()
273 void cdi_create_records(stream_t *streamptr, int tsID) in cdi_create_records() argument
277 tsteps_t *sourceTstep = streamptr->tsteps; in cdi_create_records()
282 int vlistID = streamptr->vlistID; in cdi_create_records()
287 int nvars = streamptr->nvars; in cdi_create_records()
289 for (int isub=0; isub<streamptr->vars[varID].subtypeSize; isub++) in cdi_create_records()
290 maxrecords += (unsigned)streamptr->vars[varID].recordTable[isub].nlevs; in cdi_create_records()
315 nrecords = (unsigned)streamptr->tsteps[1].nallrecs; in cdi_create_records()