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

Add function to delete stream RMA struct on server.

parent b7ac8949
No related branches found
No related tags found
No related merge requests found
......@@ -83,18 +83,20 @@ static int numPioPrimes;
/************************************************************************/
static void
deleteServerStreamWin(size_t streamIdx)
{
free(rxWin[streamIdx].clientBuf[0].mem);
free(rxWin[streamIdx].clientBuf);
xmpi(MPI_Win_free(&rxWin[streamIdx].getWin));
}
static
void serverWinCleanup ()
void serverWinCleanup(void)
{
for (size_t streamIdx = 0; streamIdx < openStreams.size; ++streamIdx)
{
Free(rxWin[streamIdx].clientBuf[0].mem);
Free(rxWin[streamIdx].clientBuf);
xmpi(MPI_Win_free(&rxWin[streamIdx].getWin));
}
Free(rxWin);
xdebug("%s", "cleaned up mpi_win");
deleteServerStreamWin(streamIdx);
free(rxWin);
}
......
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