Skip to content
Snippets Groups Projects
Commit cb3252e9 authored by Thomas Jahns's avatar Thomas Jahns :cartwheel:
Browse files

Move streamWriteVarPart to pio_interface.c.

parent afac9e41
No related branches found
No related tags found
No related merge requests found
......@@ -28,7 +28,6 @@
#include "cdi_int.h"
#include "vlist.h"
extern resOps streamOps;
......@@ -991,6 +990,37 @@ void pioWriteTimestep ( int tsID, int vdate, int vtime )
#endif
}
#if defined USE_MPI
void
streamWriteVarPart(int streamID, int varID, int memtype, const void *data,
int nmiss, Xt_idxlist partDesc)
{
if ( CDI_Debug ) Message("streamID = %d varID = %d", streamID, varID);
check_parg(data);
if (namespaceHasLocalFile(namespaceGetActive ()))
xabort("local part writing is unsupported!");
switch (namespaceInqResStatus())
{
case STAGE_DEFINITION:
xabort("DEFINITION STAGE: PARALLEL WRITING NOT POSSIBLE.");
break;
case STAGE_TIMELOOP:
pioBufferPartData(streamID, varID, data, nmiss, partDesc);
return;
case STAGE_CLEANUP:
xabort("CLEANUP STAGE: PARALLEL WRITING NOT POSSIBLE.");
break;
default:
xabort("INTERNAL ERROR");
}
}
#endif
/*
* Local Variables:
* c-file-style: "Java"
......
......@@ -31,13 +31,6 @@
#include <string.h>
#ifdef USE_MPI
#include <yaxt.h>
#else
typedef struct Xt_idxlist_ *Xt_idxlist;
#endif
#define MAX_FNAMES 3
extern resOps streamOps;
......@@ -1670,35 +1663,6 @@ cdiStreamWriteVar_(int streamID, int varID, int memtype, const void *data,
}
}
void
streamWriteVarPart(int streamID, int varID, int memtype, const void *data,
int nmiss, Xt_idxlist partDesc)
{
#if defined USE_MPI
if ( CDI_Debug ) Message("streamID = %d varID = %d", streamID, varID);
check_parg(data);
if (namespaceHasLocalFile(namespaceGetActive ()))
xabort("local part writing is unsupported!");
switch (namespaceInqResStatus())
{
case STAGE_DEFINITION:
xabort("DEFINITION STAGE: PARALLEL WRITING NOT POSSIBLE.");
break;
case STAGE_TIMELOOP:
pioBufferPartData(streamID, varID, data, nmiss, partDesc);
return;
case STAGE_CLEANUP:
xabort("CLEANUP STAGE: PARALLEL WRITING NOT POSSIBLE.");
break;
default:
xabort("INTERNAL ERROR");
}
#endif
}
/*
@Function streamWriteVarF
@Title Write a variable
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment