Skip to content
Snippets Groups Projects

Consolidation with CDI-PIO (develop)

Merged Sergey Kosukhin requested to merge m300488/develop-rebase into develop
1 file
+ 17
1
Compare changes
  • Side-by-side
  • Inline
+ 17
1
@@ -13,6 +13,22 @@
#include "pio_interface.h"
#include "pio_rpc.h"
/* replace once size_t-based version of vlistInqVarSize is merged */
static size_t
cdiPioVlistInqVarSize(int vlistID, int varID)
{
int zaxisID, gridID, tsteptype;
vlistInqVar(vlistID, varID, &gridID, &zaxisID, &tsteptype);
int nlevs = zaxisInqSize(zaxisID);
int gridsize = gridInqSize(gridID);
size_t size = (size_t) gridsize * (size_t) nlevs;
return size;
}
struct clientBufSize
computeClientStreamBufSize(int streamID, const struct collSpec *collector)
{
@@ -24,7 +40,7 @@ computeClientStreamBufSize(int streamID, const struct collSpec *collector)
{
size_t chunkSize;
{
int varSize = vlistInqVarSize(vlistID, (int) varID);
size_t varSize = cdiPioVlistInqVarSize(vlistID, (int) varID);
chunkSize = (size_t) (ceilf(cdiPIOpartInflate_ * (float) varSize / (float) collector->numClients));
}
rmaSizeSpec.numDataRecords += 2;
Loading