/dports/science/cdo/cdo-2.0.0/libcdi/src/ |
H A D | stream.c | 388 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 D | stream_srv.c | 250 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 D | stream_ext.c | 240 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 D | stream_scan.c | 11 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 D | stream_var.c | 19 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 D | grb_read.c | 129 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 D | stream_ieg.c | 66 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 D | stream_grb.c | 255 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 D | stream_record.c | 93 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 D | cdf_write.c | 350 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 D | tsteps.c | 23 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 D | stream_cdf_o.c | 43 (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 D | stream_write.c | 27 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 D | cdf_read.c | 23 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 D | stream_cdf.h | 11 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 D | stream_read.c | 28 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 D | stream_ieg.h | 8 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 D | stream_ext.h | 8 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 D | stream_srv.h | 8 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 D | stream_grb.h | 17 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 D | gribapi.c | 96 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 D | stream_cdf_time.c | 140 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 D | pio_client.c | 26 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 D | stream_cgribex.c | 660 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 D | SystemFile.cc | 35 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 …]
|