Commit 625abbda authored by Thomas Jahns's avatar Thomas Jahns 🤸
Browse files

Use MPI_UNSIGNED_CHAR for encoded byte buffers.

parent 53f59435
......@@ -332,7 +332,8 @@ void pioWriterAIO(void)
bfd->nextOpIndex = ( bfd->nextOpIndex + 1 ) % nPrefStreams;
xmpi(MPI_Recv((void *)bfd->ctrlBlks[bfd->currOpIndex].aio_buf,
messagesize, MPI_CHAR, source, tag, commNode, &status ));
messagesize, MPI_UNSIGNED_CHAR, source, tag, commNode,
&status));
writePA(bfd, (size_t)messagesize);
break;
......
......@@ -239,8 +239,8 @@ pioWriterStdIO(void)
xdebug("COMMAND %s, ID=%d, NAME=%s, AMOUNT=%zu",
command2charP[rtag.command], rtag.id, bfd->name, amount);
xmpi(MPI_Recv(bfd->fb->buffer, messagesize, MPI_CHAR, source, tag,
commNode, &status));
xmpi(MPI_Recv(bfd->fb->buffer, messagesize, MPI_UNSIGNED_CHAR,
source, tag, commNode, &status));
writeP ( bfd, amount );
......
......@@ -119,8 +119,9 @@ sendP(remoteFileBuf *afd, int id)
if ( ddebug ) accumWait += ( MPI_Wtime () - startTime );
/* FIXME: amount > INT_MAX unhandled */
xmpi(MPI_Issend(afd->db->buffer, (int)amount, MPI_CHAR, commInqSpecialRankNode(),
tag, commInqCommNode(), &( afd->request )));
xmpi(MPI_Issend(afd->db->buffer, (int)amount, MPI_UNSIGNED_CHAR,
commInqSpecialRankNode(), tag, commInqCommNode(),
&afd->request));
/* change outputBuffer */
dbuffer_reset ( afd->db );
......
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