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

Only flush file actually writing to.

* This hopefully fixes a problem introduced with support for
  differential timesteps.
parent dbefa21d
No related branches found
No related tags found
No related merge requests found
......@@ -147,9 +147,8 @@ defTimestep(remoteFileBuf *afd, int tsID)
}
static void
flushOp(void *b, void *tsID)
flushOp(remoteFileBuf *fb, int tsID)
{
remoteFileBuf *fb = b;
sendP(fb, fb->fileID);
defTimestep(fb, (int)(intptr_t)tsID);
}
......@@ -165,14 +164,13 @@ pioSendWrite(int id, int tsID, const void *buffer, size_t len)
afd = listSetGet(bibRemoteFileBuf, fileIDTest, (void *)(intptr_t)id);
flush = ( tsID != afd->tsID ) ? 1 : 0;
flush = tsID != afd->tsID;
if ( flush == 1 )
if ( flush )
{
xdebug ( "tsID = %d, flush buffer", tsID );
listSetForeach(bibRemoteFileBuf, flushOp, (void *)(intptr_t)tsID);
xdebug("tsID = %d, flush buffer for fileID=%d", tsID, afd->fileID);
flushOp(afd, tsID);
{
double startTime;
MPI_Status status;
......
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