# | Line 368 | Line 368 | void DumpReader :: readSet( int whichFrame ){ | |
---|---|---|
368 | MPI_Recv(&nCurObj, 1, MPI_INT, which_node, | |
369 | TAKE_THIS_TAG_INT, MPI_COMM_WORLD, &istatus); | |
370 | ||
371 | < | for(j=0; j < integrableObjects.size(); j++){ |
371 | > | for(j=0; j < nCurObj; j++){ |
372 | ||
373 | eof_test = fgets(read_buffer, sizeof(read_buffer), inFile); | |
374 | if(eof_test == NULL){ | |
# | Line 744 | Line 744 | void DumpReader::nodeZeroError( void ){ | |
744 | int j, myStatus; | |
745 | ||
746 | myStatus = 0; | |
747 | < | for (j = 0; j < mpiSim->getNumberProcessors(); j++) { |
747 | > | for (j = 0; j < mpiSim->getNprocessors(); j++) { |
748 | MPI_Send( &myStatus, 1, MPI_INT, j, | |
749 | TAKE_THIS_TAG_INT, MPI_COMM_WORLD); | |
750 | } | |
# | Line 760 | Line 760 | void DumpReader::anonymousNodeDie( void ){ | |
760 | MPI_Finalize(); | |
761 | exit (0); | |
762 | } | |
763 | < | #endif |
763 | > | #endif |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |