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

Strictly isolate collector server functionality in cdiPioServer.

* The function is correspondingly renamed to reflect the narrower
  functionality.
parent fe59ed09
No related branches found
No related tags found
No related merge requests found
......@@ -518,7 +518,9 @@ cdiPioInit(MPI_Comm commGlob, int IOMode, int clientServerRole,
namespaceSwitchSet(NSSWITCH_FILE_OPEN, NSSW_FUNC(pioFileOpen));
namespaceSwitchSet(NSSWITCH_FILE_CLOSE, NSSW_FUNC(pioFileClose));
postCommSetupActions();
cdiPioServer();
cdiPioFileWritingInit();
if (commInqRankColl() >= 0)
cdiPioCollectorMessageLoop();
namespaceNew();
cdiPioCommFinalize();
if (xtInitByCDI)
......
......@@ -987,15 +987,12 @@ cdiPioCdfDefTimestep(stream_t *streamptr, int tsID)
* @brief is encapsulated in CDI library and run on I/O PEs.
*/
void cdiPioServer(void)
void cdiPioCollectorMessageLoop(void)
{
MPI_Status status;
xdebug("%s", "START");
cdiPioFileWritingInit();
if (commInqRankPio() >= commInqSizeColl())
return;
MPI_Comm pioInterComm = cdiPioInqInterComm();
#ifdef HAVE_PARALLEL_NC4
cdiPioEnableNetCDFParAccess();
......
......@@ -7,7 +7,7 @@
#include <mpi.h>
void cdiPioServer(void);
void cdiPioCollectorMessageLoop(void);
#endif
/*
......
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