304 |
|
void DumpWriter::writeFrame(std::ostream& os) { |
305 |
|
|
306 |
|
#ifdef IS_MPI |
307 |
< |
MPI_Status* istatus; |
307 |
> |
MPI_Status istatus; |
308 |
|
#endif |
309 |
|
|
310 |
|
Molecule* mol; |
397 |
|
// prepared by processor i: |
398 |
|
int recvLength; |
399 |
|
MPI_Recv(&recvLength, 1, MPI_INT, i, MPI_ANY_TAG, MPI_COMM_WORLD, |
400 |
< |
istatus); |
400 |
> |
&istatus); |
401 |
|
|
402 |
|
// create a buffer to receive the data |
403 |
|
char* recvBuffer = new char[recvLength]; |
405 |
|
} else { |
406 |
|
// receive the data: |
407 |
|
MPI_Recv(recvBuffer, recvLength, MPI_CHAR, i, |
408 |
< |
MPI_ANY_TAG, MPI_COMM_WORLD, istatus); |
408 |
> |
MPI_ANY_TAG, MPI_COMM_WORLD, &istatus); |
409 |
|
// send it to the file: |
410 |
|
os << recvBuffer; |
411 |
|
// get rid of the receive buffer: |
474 |
|
// prepared by processor i: |
475 |
|
int recvLength; |
476 |
|
MPI_Recv(&recvLength, 1, MPI_INT, i, MPI_ANY_TAG, MPI_COMM_WORLD, |
477 |
< |
istatus); |
477 |
> |
&istatus); |
478 |
|
|
479 |
|
// create a buffer to receive the data |
480 |
|
char* recvBuffer = new char[recvLength]; |
482 |
|
} else { |
483 |
|
// receive the data: |
484 |
|
MPI_Recv(recvBuffer, recvLength, MPI_CHAR, i, |
485 |
< |
MPI_ANY_TAG, MPI_COMM_WORLD, istatus); |
485 |
> |
MPI_ANY_TAG, MPI_COMM_WORLD, &istatus); |
486 |
|
// send it to the file: |
487 |
|
os << recvBuffer; |
488 |
|
// get rid of the receive buffer: |
737 |
|
} |
738 |
|
|
739 |
|
void DumpWriter::writeEor() { |
740 |
< |
std::ostream* eorStream; |
741 |
< |
|
740 |
> |
|
741 |
> |
std::ostream* eorStream = NULL; |
742 |
> |
|
743 |
|
#ifdef IS_MPI |
744 |
|
if (worldRank == 0) { |
745 |
|
#endif // is_mpi |