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

Rename externally visible function.

parent 03988d32
No related branches found
No related tags found
2 merge requests!91Add alternative code path for huge buffers.,!89Miscellaneous fixes and CDI-PIO improvements
......@@ -189,7 +189,8 @@ cdiPioClientStreamWinCreate(int streamID, struct collSpec *cspec)
* platforms that block the servers in MPI_Win_complete
*/
collWaitAll();
struct clientBufSize bufSize = computeClientStreamBufSize(streamID, cspec);
struct clientBufSize bufSize
= cdiPioClientStreamBufSize(streamID, cspec);
MPI_Info no_locks_info;
xmpi(MPI_Info_create(&no_locks_info));
xmpi(MPI_Info_set(no_locks_info, "no_locks", "true"));
......
......@@ -33,7 +33,7 @@ cdiPioVlistInqVarSize(int vlistID, int varID)
}
struct clientBufSize
computeClientStreamBufSize(int streamID, const struct collSpec *collector)
cdiPioClientStreamBufSize(int streamID, const struct collSpec *collector)
{
/* 1 record is filled in last to indicate number of records in total */
struct clientBufSize rmaSizeSpec = { .bufSize = sizeof(struct winHeaderEntry), .numDataRecords = 1, .numRPCRecords = 0 };
......
......@@ -137,7 +137,8 @@ struct collSpec
bool sendRPCData;
};
struct clientBufSize computeClientStreamBufSize(int streamID, const struct collSpec *collector);
struct clientBufSize
cdiPioClientStreamBufSize(int streamID, const struct collSpec *collector);
struct partDescPreset
{
......
......@@ -2039,10 +2039,11 @@ cdiPioRecvStreamDefVlist(void *buffer, int size, int *pos, MPI_Comm pioInterComm
{
collectorData.partDesc = NULL;
collectorData.conversion = NULL;
bufSizes[0] = computeClientStreamBufSize(serverStreamID, &collectorData);
bufSizes[0] = cdiPioClientStreamBufSize(serverStreamID, &collectorData);
collectorData.sendRPCData = 0;
for (size_t clientIdx = 1; clientIdx < (size_t) numClients_; ++clientIdx)
bufSizes[clientIdx] = computeClientStreamBufSize(serverStreamID, &collectorData);
for (size_t clientIdx = 1; clientIdx < (size_t)numClients_; ++clientIdx)
bufSizes[clientIdx]
= cdiPioClientStreamBufSize(serverStreamID, &collectorData);
}
else /* tag == STREAM_DEF_DECOMPOSED_VLIST */
{
......@@ -2079,7 +2080,8 @@ cdiPioRecvStreamDefVlist(void *buffer, int size, int *pos, MPI_Comm pioInterComm
remainingSize -= clientPos;
*pos += clientPos;
collectorData.partDesc = clientPartDesc;
bufSizes[clientIdx] = computeClientStreamBufSize(serverStreamID, &collectorData);
bufSizes[clientIdx]
= cdiPioClientStreamBufSize(serverStreamID, &collectorData);
collectorData.sendRPCData = 0;
}
Free(clientPartDesc);
......
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