Lines Matching refs:streamptr
81 void ext_read_recordSP(stream_t *streamptr, float *data, size_t *nmiss) in ext_read_recordSP() argument
83 int vlistID = streamptr->vlistID; in ext_read_recordSP()
84 int fileID = streamptr->fileID; in ext_read_recordSP()
85 int tsID = streamptr->curTsID; in ext_read_recordSP()
87 int vrecID = streamptr->tsteps[tsID].curRecID; in ext_read_recordSP()
88 int recID = streamptr->tsteps[tsID].recIDs[vrecID]; in ext_read_recordSP()
89 int varID = streamptr->tsteps[tsID].records[recID].varID; in ext_read_recordSP()
90 off_t recpos = streamptr->tsteps[tsID].records[recID].position; in ext_read_recordSP()
94 void *extp = streamptr->record->exsep; in ext_read_recordSP()
109 streamptr->numvals += size; in ext_read_recordSP()
113 void ext_read_recordDP(stream_t *streamptr, double *data, size_t *nmiss) in ext_read_recordDP() argument
115 int vlistID = streamptr->vlistID; in ext_read_recordDP()
116 int fileID = streamptr->fileID; in ext_read_recordDP()
117 int tsID = streamptr->curTsID; in ext_read_recordDP()
119 int vrecID = streamptr->tsteps[tsID].curRecID; in ext_read_recordDP()
120 int recID = streamptr->tsteps[tsID].recIDs[vrecID]; in ext_read_recordDP()
121 int varID = streamptr->tsteps[tsID].records[recID].varID; in ext_read_recordDP()
122 off_t recpos = streamptr->tsteps[tsID].records[recID].position; in ext_read_recordDP()
126 void *extp = streamptr->record->exsep; in ext_read_recordDP()
141 streamptr->numvals += size; in ext_read_recordDP()
145 void ext_read_record(stream_t *streamptr, int memtype, void *data, size_t *nmiss) in ext_read_record() argument
148 ext_read_recordDP(streamptr, (double*) data, nmiss); in ext_read_record()
150 ext_read_recordSP(streamptr, (float*) data, nmiss); in ext_read_record()
160 void extDefRecord(stream_t *streamptr) in extDefRecord() argument
162 Record *record = streamptr->record; in extDefRecord()
181 void ext_write_recordSP(stream_t *streamptr, const float *data) in ext_write_recordSP() argument
183 void *extp = streamptr->record->exsep; in ext_write_recordSP()
185 extWrite(streamptr->fileID, extp); in ext_write_recordSP()
189 void ext_write_recordDP(stream_t *streamptr, const double *data) in ext_write_recordDP() argument
191 void *extp = streamptr->record->exsep; in ext_write_recordDP()
193 extWrite(streamptr->fileID, extp); in ext_write_recordDP()
197 void ext_write_record(stream_t *streamptr, int memtype, const void *data) in ext_write_record() argument
200 ext_write_recordDP(streamptr, (const double *) data); in ext_write_record()
202 ext_write_recordSP(streamptr, (const float *) data); in ext_write_record()
206 void extAddRecord(stream_t *streamptr, int param, int level, size_t xysize, in extAddRecord() argument
209 const int vlistID = streamptr->vlistID; in extAddRecord()
210 const int tsID = streamptr->curTsID; in extAddRecord()
211 const int recID = recordNewEntry(streamptr, tsID); in extAddRecord()
212 record_t *record = &streamptr->tsteps[tsID].records[recID]; in extAddRecord()
239 streamptr->tsteps[tsID].nallrecs++; in extAddRecord()
240 streamptr->nrecs++; in extAddRecord()
247 void extScanTimestep1(stream_t *streamptr) in extScanTimestep1() argument
252 extrec_t *extp = (extrec_t*) streamptr->record->exsep; in extScanTimestep1()
254 streamptr->curTsID = 0; in extScanTimestep1()
256 int tsID = tstepsNewEntry(streamptr); in extScanTimestep1()
258 taxis_t *taxis = &streamptr->tsteps[tsID].taxis; in extScanTimestep1()
260 const int fileID = streamptr->fileID; in extScanTimestep1()
268 streamptr->ntsteps = 1; in extScanTimestep1()
292 record_t *records = streamptr->tsteps[tsID].records; in extScanTimestep1()
306 extAddRecord(streamptr, param, rlevel, rxysize, recsize, recpos, extp->prec, extp->number); in extScanTimestep1()
310 streamptr->rtsteps = 1; in extScanTimestep1()
312 cdi_generate_vars(streamptr); in extScanTimestep1()
319 const int vlistID = streamptr->vlistID; in extScanTimestep1()
324 streamScanResizeRecords1(streamptr); in extScanTimestep1()
326 streamScanTsFixNtsteps(streamptr, recpos); in extScanTimestep1()
327 streamScanTimeConstAdjust(streamptr, taxis); in extScanTimestep1()
331 int extScanTimestep2(stream_t *streamptr) in extScanTimestep2() argument
335 void *extp = streamptr->record->exsep; in extScanTimestep2()
337 streamptr->curTsID = 1; in extScanTimestep2()
339 const int fileID = streamptr->fileID; in extScanTimestep2()
340 const int vlistID = streamptr->vlistID; in extScanTimestep2()
342 int tsID = streamptr->rtsteps; in extScanTimestep2()
345 taxis_t *taxis = &streamptr->tsteps[tsID].taxis; in extScanTimestep2()
347 fileSetPos(fileID, streamptr->tsteps[tsID].position, SEEK_SET); in extScanTimestep2()
349 cdi_create_records(streamptr, tsID); in extScanTimestep2()
350 record_t *records = streamptr->tsteps[tsID].records; in extScanTimestep2()
352 const int nrecords = streamScanInitRecords2(streamptr); in extScanTimestep2()
359 streamptr->ntsteps = 2; in extScanTimestep2()
393 streamptr->tsteps[tsID].recIDs[rindex] = recID; in extScanTimestep2()
432 streamptr->tsteps[tsID].nrecs = nrecs; in extScanTimestep2()
434 streamptr->rtsteps = 2; in extScanTimestep2()
436 streamScanTsFixNtsteps(streamptr, recpos); in extScanTimestep2()
442 int extInqContents(stream_t *streamptr) in extInqContents() argument
444 streamptr->curTsID = 0; in extInqContents()
446 extScanTimestep1(streamptr); in extInqContents()
448 const int status = (streamptr->ntsteps == -1) ? extScanTimestep2(streamptr) : 0; in extInqContents()
450 fileSetPos(streamptr->fileID, 0, SEEK_SET); in extInqContents()
456 long extScanTimestep(stream_t *streamptr) in extScanTimestep() argument
461 void *extp = streamptr->record->exsep; in extScanTimestep()
463 int tsID = streamptr->rtsteps; in extScanTimestep()
464 taxis_t *taxis = &streamptr->tsteps[tsID].taxis; in extScanTimestep()
466 if ( streamptr->tsteps[tsID].recordSize == 0 ) in extScanTimestep()
468 cdi_create_records(streamptr, tsID); in extScanTimestep()
469 record_t *records = streamptr->tsteps[tsID].records; in extScanTimestep()
471 nrecs = streamScanInitRecords(streamptr, tsID); in extScanTimestep()
473 const int fileID = streamptr->fileID; in extScanTimestep()
475 fileSetPos(fileID, streamptr->tsteps[tsID].position, SEEK_SET); in extScanTimestep()
482 streamptr->ntsteps = streamptr->rtsteps + 1; in extScanTimestep()
498 const int recID = streamptr->tsteps[tsID].recIDs[rindex]; in extScanTimestep()
521 streamptr->rtsteps++; in extScanTimestep()
523 if ( streamptr->ntsteps != streamptr->rtsteps ) in extScanTimestep()
525 tsID = tstepsNewEntry(streamptr); in extScanTimestep()
526 if ( tsID != streamptr->rtsteps ) in extScanTimestep()
529 streamptr->tsteps[tsID-1].next = true; in extScanTimestep()
530 streamptr->tsteps[tsID].position = recpos; in extScanTimestep()
533 fileSetPos(fileID, streamptr->tsteps[tsID].position, SEEK_SET); in extScanTimestep()
534 streamptr->tsteps[tsID].position = recpos; in extScanTimestep()
537 if ( nrecs > 0 && nrecs < streamptr->tsteps[tsID].nrecs ) in extScanTimestep()
540 streamptr->ntsteps = tsID; in extScanTimestep()
543 return streamptr->ntsteps; in extScanTimestep()
547 int extInqTimestep(stream_t *streamptr, int tsID) in extInqTimestep() argument
549 if ( tsID == 0 && streamptr->rtsteps == 0 ) in extInqTimestep()
553 Message("tsID = %d rtsteps = %d", tsID, streamptr->rtsteps); in extInqTimestep()
556 while ( ( tsID + 1 ) > streamptr->rtsteps && ntsteps == CDI_UNDEFID ) in extInqTimestep()
557 ntsteps = extScanTimestep(streamptr); in extInqTimestep()
560 if ( !(tsID >= streamptr->ntsteps && streamptr->ntsteps != CDI_UNDEFID) ) in extInqTimestep()
562 streamptr->curTsID = tsID; in extInqTimestep()
563 nrecs = streamptr->tsteps[tsID].nrecs; in extInqTimestep()
570 void extReadVarSliceDP(stream_t *streamptr, int varID, int levID, double *data, size_t *nmiss) in extReadVarSliceDP() argument
572 if ( CDI_Debug ) Message("streamID = %d varID = %d levID = %d", streamptr->self, varID, levID); in extReadVarSliceDP()
574 void *extp = streamptr->record->exsep; in extReadVarSliceDP()
576 int vlistID = streamptr->vlistID; in extReadVarSliceDP()
577 int fileID = streamptr->fileID; in extReadVarSliceDP()
581 int tsid = streamptr->curTsID; in extReadVarSliceDP()
585 int recID = streamptr->vars[varID].recordTable[0].recordID[levID]; in extReadVarSliceDP()
586 off_t recpos = streamptr->tsteps[tsid].records[recID].position; in extReadVarSliceDP()
602 void extReadVarDP(stream_t *streamptr, int varID, double *data, size_t *nmiss) in extReadVarDP() argument
604 if ( CDI_Debug ) Message("streamID = %d varID = %d", streamptr->self, varID); in extReadVarDP()
606 int vlistID = streamptr->vlistID; in extReadVarDP()
608 size_t nlevs = (size_t) streamptr->vars[varID].recordTable[0].nlevs; in extReadVarDP()
611 extReadVarSliceDP(streamptr, varID, (int)levID, &data[levID*gridsize], nmiss); in extReadVarDP()
615 void extWriteVarSliceDP(stream_t *streamptr, int varID, int levID, const double *data) in extWriteVarSliceDP() argument
617 if ( CDI_Debug ) Message("streamID = %d varID = %d levID = %d", streamptr->self, varID, levID); in extWriteVarSliceDP()
619 int vlistID = streamptr->vlistID; in extWriteVarSliceDP()
620 int fileID = streamptr->fileID; in extWriteVarSliceDP()
621 int tsID = streamptr->curTsID; in extWriteVarSliceDP()
627 header[0] = streamptr->tsteps[tsID].taxis.vdate; in extWriteVarSliceDP()
634 extrec_t *extp = (extrec_t*) streamptr->record->exsep; in extWriteVarSliceDP()
643 void extWriteVarDP(stream_t *streamptr, int varID, const double *data) in extWriteVarDP() argument
645 if ( CDI_Debug ) Message("streamID = %d varID = %d", streamptr->self, varID); in extWriteVarDP()
647 int vlistID = streamptr->vlistID; in extWriteVarDP()
652 extWriteVarSliceDP(streamptr, varID, (int)levID, &data[levID*gridsize]); in extWriteVarDP()