Commit 13e2e31d authored by Thomas Jahns's avatar Thomas Jahns 🤸
Browse files

Remove unused stage.

* Namespaces are either in-use or unused, no further state logic is
  required.
parent 62506efe
......@@ -8,7 +8,6 @@
typedef enum {
STAGE_DEFINITION = 0,
STAGE_TIMELOOP = 1,
STAGE_UNUSED = 3,
} statusCode;
......
......@@ -34,7 +34,6 @@ cdiPioClientStreamOpen(const char *filename, char filemode,
switch ( nspStatus )
{
case STAGE_DEFINITION:
case STAGE_TIMELOOP:
{
MPI_Comm comm = cdiPioInqInterComm();
int clientRank = commInqRankModel(),
......@@ -102,7 +101,6 @@ cdiPioClientStreamDefVlist_(int streamID, int vlistID)
switch ( nspStatus )
{
case STAGE_DEFINITION:
case STAGE_TIMELOOP:
{
int clientRank = commInqRankModel(),
numClients = cdiPioCommInqSizeClients(),
......@@ -187,9 +185,6 @@ cdiPioClientStreamWriteVarPart(int streamID, int varID, const void *data,
switch (namespaceInqResStatus())
{
case STAGE_DEFINITION:
xabort("DEFINITION STAGE: PARALLEL WRITING NOT POSSIBLE.");
break;
case STAGE_TIMELOOP:
pioBufferPartData(streamID, varID, data, nmiss, partDesc);
return;
default:
......@@ -207,9 +202,6 @@ cdiPioClientStreamWriteScatteredVarPart(int streamID, int varID,
switch (namespaceInqResStatus())
{
case STAGE_DEFINITION:
xabort("DEFINITION STAGE: PARALLEL WRITING NOT POSSIBLE.");
break;
case STAGE_TIMELOOP:
cdiPioBufferPartDataGather(streamID, varID, data, numBlocks,
blocklengths, displacements, nmiss, partDesc);
return;
......@@ -242,7 +234,6 @@ cdiPioClientStreamClose(stream_t *streamptr, int recordBufIsToBeDeleted)
switch ( nspStatus )
{
case STAGE_DEFINITION:
case STAGE_TIMELOOP:
{
int clientRank = commInqRankModel(),
numClients = cdiPioCommInqSizeClients(),
......@@ -295,7 +286,6 @@ cdiPioClientStreamDefTimestep_(stream_t *streamptr, int tsID)
switch ( nspStatus )
{
case STAGE_DEFINITION:
case STAGE_TIMELOOP:
taxisID = vlistInqTaxis(streamptr->vlistID);
header = (struct winHeaderEntry){
.id = STREAMDEFTIMESTEP,
......
......@@ -580,23 +580,14 @@ void pioEndDef ( void )
numColl = commInqSizeColl(),
collRank = cdiPioCollRank(clientRank, numClients, numColl);
xdebug("%s", "START");
if (clientRank == cdiPioClientRangeStart(collRank, numClients, numColl))
{
MPI_Comm comm = cdiPioInqInterComm();
reshPackBufferCreate(&buffer, &bufferSize, &comm);
xmpi(MPI_Send(buffer, bufferSize, MPI_PACKED, collRank,
RESOURCES, comm));
xdebug("%s", "SENT MESSAGE WITH TAG \"RESOURCES\"");
reshPackBufferDestroy ( &buffer );
reshPackBufferDestroy(&buffer);
}
namespaceDefResStatus ( STAGE_TIMELOOP );
xdebug("%s", "RETURN");
}
/************************************************************************/
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment