Home
last modified time | relevance | path

Searched refs:streamptr (Results 1 – 25 of 57) sorted by relevance

123

/dports/science/cdo/cdo-2.0.0/libcdi/src/
H A Dstream.c388 status = (streamptr->fdbRetrieve) ? fdbInqContents(streamptr) : grbInqContents(streamptr); in cdiInqContents()
1005 streamptr->self = reshPut(streamptr, &streamOps); in stream_new_entry()
1012 return streamptr; in stream_new_entry()
1018 if (streamptr->fdbStore || streamptr->fdbRetrieve) in cdiStreamCloseDefaultDelegate()
1080 if (streamptr->ntsteps == 0 && streamptr->tsteps != NULL) in cdiStreamCloseDefaultDelegate()
1140 if (streamptr->filetype != -1) streamCloseDelegate(streamptr, 1); in streamClose()
1151 if ( streamptr->filename ) Free(streamptr->filename); in streamClose()
1175 if (streamptr->tsteps) Free(streamptr->tsteps); in streamClose()
1185 if (streamptr->jobs) free(streamptr->jobs); in streamClose()
1197 Free(streamptr); in stream_delete_entry()
[all …]
H A Dstream_srv.c250 streamptr->nrecs++; in srv_add_record()
263 streamptr->curTsID = 0; in srvScanTimestep1()
277 streamptr->ntsteps = 1; in srvScanTimestep1()
322 streamptr->rtsteps = 1; in srvScanTimestep1()
349 streamptr->curTsID = 1; in srvScanTimestep2()
371 streamptr->ntsteps = 2; in srvScanTimestep2()
446 streamptr->rtsteps = 2; in srvScanTimestep2()
456 streamptr->curTsID = 0; in srvInqContents()
494 streamptr->ntsteps = streamptr->rtsteps + 1; in srvScanTimestep()
535 if ( streamptr->ntsteps != streamptr->rtsteps ) in srvScanTimestep()
[all …]
H A Dstream_ext.c240 streamptr->nrecs++; in extAddRecord()
254 streamptr->curTsID = 0; in extScanTimestep1()
268 streamptr->ntsteps = 1; in extScanTimestep1()
310 streamptr->rtsteps = 1; in extScanTimestep1()
337 streamptr->curTsID = 1; in extScanTimestep2()
359 streamptr->ntsteps = 2; in extScanTimestep2()
434 streamptr->rtsteps = 2; in extScanTimestep2()
444 streamptr->curTsID = 0; in extInqContents()
482 streamptr->ntsteps = streamptr->rtsteps + 1; in extScanTimestep()
523 if ( streamptr->ntsteps != streamptr->rtsteps ) in extScanTimestep()
[all …]
H A Dstream_scan.c11 streamptr->tsteps[0].records = in streamScanResizeRecords1()
16 streamptr->tsteps[0].nrecs = nrecords; in streamScanResizeRecords1()
26 streamptr->tsteps[1].nrecs = 0; in streamScanInitRecords2()
33 streamptr->tsteps[1].records[recID].position = streamptr->tsteps[0].records[recID].position; in streamScanInitRecords2()
34 streamptr->tsteps[1].records[recID].size = streamptr->tsteps[0].records[recID].size; in streamScanInitRecords2()
45 streamptr->tsteps[tsID].nrecs = nrecs; in streamScanInitRecords()
49 streamptr->tsteps[tsID].recIDs[recID] = streamptr->tsteps[1].recIDs[recID]; in streamScanInitRecords()
58 if (streamptr->ntsteps == 1) in streamScanTimeConstAdjust()
62 streamptr->ntsteps = 0; in streamScanTimeConstAdjust()
72 if (streamptr->ntsteps == -1) in streamScanTsFixNtsteps()
[all …]
H A Dstream_var.c19 streamptr->vars[varID].defmiss = false; in streamvar_init_entry()
21 streamptr->vars[varID].subtypeSize = 0; in streamvar_init_entry()
22 streamptr->vars[varID].recordTable = NULL; in streamvar_init_entry()
31 int streamvar_new_entry(stream_t *streamptr) in streamvar_new_entry() argument
35 svarinfo_t *streamvar = streamptr->vars; in streamvar_new_entry()
80 streamptr->varsAllocated = streamvarSize; in streamvar_new_entry()
81 streamptr->vars = streamvar; in streamvar_new_entry()
83 streamvar_init_entry(streamptr, varID); in streamvar_new_entry()
85 streamptr->vars[varID].isUsed = true; in streamvar_new_entry()
117 streamptr->nvars++; in stream_new_var()
[all …]
H A Dgrb_read.c129 const int vlistID = streamptr->vlistID; in grb_read_raw_data()
138 void *cgribexp = (gribbuffer && streamptr->record->cgribexp) ? streamptr->record->cgribexp : NULL; in grb_read_raw_data()
142 if (streamptr->fdbRetrieve) in grb_read_raw_data()
148 …recsize = fdb_read_record(streamptr->fdbHandle, fdbItem, &(streamptr->record->buffersize), &gribbu… in grb_read_raw_data()
176 .filetype = streamptr->filetype, in grb_read_raw_data()
183 .unreduced = streamptr->unreduced, in grb_read_raw_data()
222 if (workerCount > streamptr->tsteps[0].nrecs) workerCount = streamptr->tsteps[0].nrecs; in grb_read_next_record()
228 tsteps_t *timestep = &streamptr->tsteps[streamptr->curTsID]; in grb_read_next_record()
233 streamptr->jobs = jobs; in grb_read_next_record()
242 if (streamptr->cachedTsID == streamptr->curTsID) in grb_read_next_record()
[all …]
H A Dstream_ieg.c66 streamptr->numvals += size; in ieg_read_recordSP()
93 streamptr->numvals += size; in ieg_read_recordDP()
653 streamptr->nrecs++; in iegAddRecord()
710 streamptr->curTsID = 0; in iegScanTimestep1()
769 streamptr->rtsteps = 1; in iegScanTimestep1()
795 streamptr->curTsID = 1; in iegScanTimestep2()
897 streamptr->rtsteps = 2; in iegScanTimestep2()
907 streamptr->curTsID = 0; in iegInqContents()
946 streamptr->ntsteps = streamptr->rtsteps + 1; in iegScanTimestep()
990 if ( streamptr->ntsteps != streamptr->rtsteps ) in iegScanTimestep()
[all …]
H A Dstream_grb.c255 void grbDefRecord(stream_t * streamptr) in grbDefRecord() argument
257 UNUSED(streamptr); in grbDefRecord()
327 streamptr->curTsID = 0; in grbInqContents()
330 if (status == 0 && streamptr->ntsteps == -1) status = grbScanTimestep2(streamptr); in grbInqContents()
340 streamptr->curTsID = 0; in fdbInqContents()
357 if (tsID >= streamptr->ntsteps && streamptr->ntsteps != CDI_UNDEFID) in fdbInqTimestep()
363 streamptr->curTsID = tsID; in fdbInqTimestep()
383 streamptr->ntsteps = streamptr->rtsteps; in grbInqTimestep()
389 if (tsID >= streamptr->ntsteps && streamptr->ntsteps != CDI_UNDEFID) in grbInqTimestep()
395 streamptr->curTsID = tsID; in grbInqTimestep()
[all …]
H A Dstream_record.c93 streamptr->record = record; in cdiInitRecord()
117 if ( ! streamptr->record ) cdiInitRecord(streamptr); in streamInqRecord()
139 streamptr->curTsID = tsID; in streamInqRecord()
161 int tsID = streamptr->curTsID; in streamDefRecord()
169 if ( ! streamptr->record ) cdiInitRecord(streamptr); 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()
[all …]
H A Dcdf_write.c350 cdfDefSourceGlobal(streamptr); in cdfDefGlobalAtts()
362 streamptr->globalatts = 1; in cdfDefGlobalAtts()
416 cdfDefVarDeflate(streamptr->fileID, ncvarID, streamptr->complevel); in cdfDefVarCompression()
924 cdfDefGlobalAtts(streamptr); in cdfEndDef()
933 cdfDefVar(streamptr, varID); in cdfEndDef()
1253 if ( streamptr->accessmode == 0 ) cdfEndDef(streamptr); in cdf_write_var()
1272 if ( streamptr->ncmode == 1 ) in cdf_write_var()
1275 streamptr->ncmode = 2; in cdf_write_var()
1348 if ( streamptr->accessmode == 0 ) cdfEndDef(streamptr); in cdf_write_var_chunk()
1373 streamptr->ncmode = 2; in cdf_write_var_chunk()
[all …]
H A Dtsteps.c23 int tstepsNewEntry(stream_t *streamptr) in tstepsNewEntry() argument
25 const int tsID = streamptr->tstepsNextID++; in tstepsNewEntry()
27 tsteps_t *tstepsTable = streamptr->tsteps; in tstepsNewEntry()
43 streamptr->tstepsTableSize = tstepsTableSize; in tstepsNewEntry()
44 streamptr->tsteps = tstepsTable; in tstepsNewEntry()
46 tsteps_t *curTstep = &streamptr->tsteps[tsID]; in tstepsNewEntry()
55 void cdiCreateTimesteps(stream_t *streamptr) in cdiCreateTimesteps() argument
57 if (streamptr->ntsteps < 0 || streamptr->tstepsTableSize > 0) return; in cdiCreateTimesteps()
59 const int ntsteps = (streamptr->ntsteps == 0) ? 1 : (int)streamptr->ntsteps; in cdiCreateTimesteps()
63 streamptr->tstepsTableSize = ntsteps; in cdiCreateTimesteps()
[all …]
H A Dstream_cdf_o.c43 (void)streamptr; in cdfDefRecord()
58 streamptr->ncmode = 2; in cdfDefTimeValue()
124 streamptr->ncmode = 2; in cdfDefComplex()
198 streamptr->ncmode = 2; in cdfDefSPorFC()
768 streamptr->ncmode = 2; in cdfDefIrregularGridCommon()
1178 streamptr->ncmode = 2; in cdf_def_zaxis_hybrid_echam()
1186 ? streamptr->vct.mlevID : streamptr->vct.ilevID; in cdf_def_zaxis_hybrid_echam()
1321 streamptr->ncmode = 2; in cdf_def_zaxis_hybrid_cf()
1342 ? streamptr->vct.mlevID : streamptr->vct.ilevID; in cdf_def_zaxis_hybrid_cf()
1436 streamptr->ncmode = 2; in cdfDefZaxisChar()
[all …]
H A Dstream_write.c27 stream_t *streamptr = stream_to_pointer(streamID); in cdiStreamWriteVar_() local
34 const int filetype = streamptr->filetype; in cdiStreamWriteVar_()
50 srvWriteVarDP(streamptr, varID, (double *)data); in cdiStreamWriteVar_()
159 stream_t *streamptr = stream_to_pointer(streamID); in cdiStreamWriteVarSlice() local
166 const int filetype = streamptr->filetype; in cdiStreamWriteVarSlice()
290 const int filetype = streamptr->filetype; in cdiStreamWriteVarChunk_()
334 switch (cdiBaseFiletype(streamptr->filetype)) in stream_write_record()
344 srv_write_record(streamptr, memtype, data); in stream_write_record()
349 ext_write_record(streamptr, memtype, data); in stream_write_record()
354 ieg_write_record(streamptr, memtype, data); in stream_write_record()
[all …]
H A Dcdf_read.c23 const int vlistID = streamptr->vlistID; in cdfReadGridTraj()
24 const int fileID = streamptr->fileID; in cdfReadGridTraj()
30 const int tsID = streamptr->curTsID; in cdfReadGridTraj()
44 const int vlistID = streamptr->vlistID; in cdfGetSlapDescription()
45 const int tsID = streamptr->curTsID; in cdfGetSlapDescription()
56 cdfReadGridTraj(streamptr, gridID); in cdfGetSlapDescription()
451 const int tsID = streamptr->curTsID; in cdfGetSliceSlapDescription()
454 const int fileId = streamptr->fileID; in cdfGetSliceSlapDescription()
462 streamptr->numvals += gridsize; in cdfGetSliceSlapDescription()
594 const int fileID = streamptr->fileID; in cdfReadDataDP()
[all …]
H A Dstream_cdf.h11 void cdfDefCoordinateVars(stream_t *streamptr);
12 void cdfDefTimestep(stream_t *streamptr, int tsID);
13 int cdfInqTimestep(stream_t *streamptr, int tsID);
14 int cdfInqContents(stream_t *streamptr);
16 void cdfEndDef(stream_t * streamptr);
17 void cdfDefRecord(stream_t * streamptr);
23 void cdf_read_record(stream_t *streamptr, int memtype, void *data, size_t *nmiss);
24 void cdf_write_record(stream_t *streamptr, int memtype, const void *data, size_t nmiss);
32 void cdf_write_var_chunk(stream_t *streamptr, int varID, int memtype,
36 void cdfDefTime(stream_t* streamptr);
[all …]
H A Dstream_read.c28 stream_t *streamptr = stream_to_pointer(streamID); in cdiStreamReadVar() local
29 int filetype = streamptr->filetype; in cdiStreamReadVar()
155 stream_t *streamptr = stream_to_pointer(streamID); in cdiStreamReadVarSlice() local
156 int filetype = streamptr->filetype; in cdiStreamReadVarSlice()
282 stream_t *streamptr = stream_to_pointer(streamID); in stream_read_record() local
286 switch (cdiBaseFiletype(streamptr->filetype)) in stream_read_record()
291 grb_read_record(streamptr, memtype, data, nmiss); in stream_read_record()
296 srv_read_record(streamptr, memtype, data, nmiss); in stream_read_record()
301 ext_read_record(streamptr, memtype, data, nmiss); in stream_read_record()
306 ieg_read_record(streamptr, memtype, data, nmiss); in stream_read_record()
[all …]
H A Dstream_ieg.h8 int iegInqContents(stream_t *streamptr);
9 int iegInqTimestep(stream_t *streamptr, int tsID);
11 int iegInqRecord(stream_t *streamptr, int *varID, int *levelID);
12 void iegDefRecord(stream_t *streamptr);
14 void ieg_read_record(stream_t *streamptr, int memtype, void *data, size_t *nmiss);
15 void ieg_write_record(stream_t *streamptr, int memtype, const void *data);
17 void iegReadVarDP (stream_t *streamptr, int varID, double *data, size_t *nmiss);
18 void iegWriteVarDP(stream_t *streamptr, int varID, const double *data);
20 void iegReadVarSliceDP (stream_t *streamptr, int varID, int levelID, double *data, size_t *…
21 void iegWriteVarSliceDP(stream_t *streamptr, int varID, int levelID, const double *data);
H A Dstream_ext.h8 int extInqContents(stream_t *streamptr);
9 int extInqTimestep(stream_t *streamptr, int tsID);
11 int extInqRecord(stream_t *streamptr, int *varID, int *levelID);
12 void extDefRecord(stream_t *streamptr);
14 void ext_read_record(stream_t *streamptr, int memtype, void *data, size_t *nmiss);
15 void ext_write_record(stream_t *streamptr, int memtype, const void *data);
17 void extReadVarDP (stream_t *streamptr, int varID, double *data, size_t *nmiss);
18 void extWriteVarDP(stream_t *streamptr, int varID, const double *data);
20 void extReadVarSliceDP (stream_t *streamptr, int varID, int levelID, double *data, size_t *…
21 void extWriteVarSliceDP(stream_t *streamptr, int varID, int levelID, const double *data);
H A Dstream_srv.h8 int srvInqContents(stream_t *streamptr);
9 int srvInqTimestep(stream_t *streamptr, int tsID);
11 int srvInqRecord(stream_t *streamptr, int *varID, int *levelID);
12 void srvDefRecord(stream_t *streamptr);
14 void srv_read_record(stream_t *streamptr, int memtype, void *data, size_t *nmiss);
15 void srv_write_record(stream_t *streamptr, int memtype, const void *data);
17 void srvReadVarDP (stream_t *streamptr, int varID, double *data, size_t *nmiss);
18 void srvWriteVarDP(stream_t *streamptr, int varID, const double *data);
20 void srvReadVarSliceDP (stream_t *streamptr, int varID, int levelID, double *data, size_t *…
21 void srvWriteVarSliceDP(stream_t *streamptr, int varID, int levelID, const double *data);
H A Dstream_grb.h17 int fdbInqContents(stream_t *streamptr);
18 int grbInqContents(stream_t *streamptr);
19 int fdbInqTimestep(stream_t *streamptr, int tsID);
20 int grbInqTimestep(stream_t *streamptr, int tsID);
22 int grbInqRecord(stream_t *streamptr, int *varID, int *levelID);
23 void grbDefRecord(stream_t *streamptr);
24 void grb_read_record(stream_t *streamptr, int memtype, void *data, size_t *nmiss);
25 void grb_write_record(stream_t *streamptr, int memtype, const void *data, size_t nmiss);
28 void grb_read_var(stream_t *streamptr, int varID, int memtype, void *data, size_t *nmiss);
29 void grb_write_var(stream_t *streamptr, int varID, int memtype, const void *data, size_t nmiss);
[all …]
H A Dgribapi.c96 void gribContainersNew(stream_t * streamptr) in gribContainersNew() argument
98 const int editionNumber = (streamptr->filetype == CDI_FILETYPE_GRB) ? 1 : 2; in gribContainersNew()
107 const int nvars = streamptr->nvars; in gribContainersNew()
115 const int nlevs = streamptr->vars[varID].nlevs; in gribContainersNew()
125 streamptr->gribContainers = (void *) gribContainers; in gribContainersNew()
136 streamptr->gribContainers = (void *) gribContainers; in gribContainersNew()
142 void gribContainersDelete(stream_t * streamptr) in gribContainersDelete() argument
144 if ( streamptr->gribContainers ) in gribContainersDelete()
146 const int nvars = streamptr->nvars; in gribContainersDelete()
153 const int nlevs = streamptr->vars[varID].nlevs; in gribContainersDelete()
[all …]
H A Dstream_cdf_time.c140 void cdfDefTime(stream_t* streamptr) in cdfDefTime() argument
146 const int fileID = streamptr->fileID; in cdfDefTime()
148 if ( streamptr->ncmode == 0 ) streamptr->ncmode = 1; in cdfDefTime()
149 if ( streamptr->ncmode == 2 ) cdf_redef(fileID); in cdfDefTime()
151 taxis_t *taxis = &streamptr->tsteps[0].taxis; in cdfDefTime()
156 streamptr->basetime.ncdimid = time_dimid; in cdfDefTime()
163 streamptr->basetime.ncvarid = time_varid; in cdfDefTime()
166 if ( streamptr->filetype == CDI_FILETYPE_NC4 || streamptr->filetype == CDI_FILETYPE_NC4C ) in cdfDefTime()
182 streamptr->basetime.ncvarboundsid = time_bndsid; in cdfDefTime()
199 streamptr->basetime.leadtimeid = leadtimeid; in cdfDefTime()
[all …]
H A Dpio_client.c26 int filetype, stream_t *streamptr, in cdiPioClientStreamOpen() argument
29 (void)streamptr; (void)recordBufIsToBeCreated; in cdiPioClientStreamOpen()
38 int streamID = streamptr->self; in cdiPioClientStreamOpen()
77 streamptr->filetype = filetype; in cdiPioClientStreamOpen()
193 (void)streamptr; (void)tsID; in cdiPioCdfDefTimestepNOP()
198 cdiPioClientStreamNOP(stream_t *streamptr) in cdiPioClientStreamNOP() argument
200 (void)streamptr; in cdiPioClientStreamNOP()
208 int streamID = streamptr->self; in cdiPioClientStreamClose()
229 xmpi(MPI_Pack(&streamptr->self, 1, MPI_INT, in cdiPioClientStreamClose()
254 pioBufferFuncCall(streamptr->self, header, in cdiPioClientStreamDefTimestep_()
[all …]
H A Dstream_cgribex.c660 streamptr->nrecs++; in cgribexAddRecord()
781 streamptr->curTsID = 0; in cgribexScanTimestep1()
803 streamptr->ntsteps = 1; in cgribexScanTimestep1()
901 streamptr->rtsteps = 1; in cgribexScanTimestep1()
935 streamptr->curTsID = 1; in cgribexScanTimestep2()
969 streamptr->ntsteps = 2; in cgribexScanTimestep2()
1107 streamptr->rtsteps = 2; in cgribexScanTimestep2()
1159 streamptr->ntsteps = streamptr->rtsteps + 1; in cgribexScanTimestep()
1299 streamptr->rtsteps++; in cgribexScanTimestep()
1301 if ( streamptr->ntsteps != streamptr->rtsteps ) in cgribexScanTimestep()
[all …]
/dports/devel/glademm/glademm-2.6.0/src/SourceWriter/
H A DSystemFile.cc35 else if (streamptr.of) streamptr.of->close(); in close()
86 { if (streamptr.of && level) streamptr.of->write(" ",level); in Indent()
88 else if (streamptr.os && level) streamptr.os->write(" ",level); in Indent()
95 streamptr.of=0; in open()
99 if (streamptr.of) streamptr.of->open(name.c_str(),mode/*,prot*/); in open()
101 { streamptr.of=new std::ofstream(name.c_str(),mode/*,prot*/); in open()
109 { streamptr.of=new std::ofstream(name.c_str(),mode/*,prot*/); in SystemFile()
115 { if (deallocate) delete streamptr.os; in free()
116 streamptr.os=0; in free()
119 { if (deallocate) delete streamptr.of; in free()
[all …]

123