16 |
|
#ifdef IS_MPI |
17 |
|
#include <mpi.h> |
18 |
|
#include "mpiSimulation.hpp" |
19 |
< |
#define TAKE_THIS_TAG_CHAR 0 |
20 |
< |
#define TAKE_THIS_TAG_INT 1 |
19 |
> |
#define TAKE_THIS_TAG_CHAR 3134 |
20 |
> |
#define TAKE_THIS_TAG_INT 3135 |
21 |
|
|
22 |
|
namespace initFile{ |
23 |
|
void nodeZeroError( void ); |
220 |
|
|
221 |
|
MPI_Bcast(read_buffer, BUFFERSIZE, MPI_CHAR, 0, MPI_COMM_WORLD); |
222 |
|
|
223 |
+ |
cerr << "node " << worldRank << " finished MPI_Bcast" << endl; |
224 |
+ |
|
225 |
|
parseErr = parseCommentLine( read_buffer, simnfo); |
226 |
|
|
227 |
|
if( parseErr != NULL ){ |
270 |
|
|
271 |
|
MPI_Recv(&nCurObj, 1, MPI_INT, which_node, |
272 |
|
TAKE_THIS_TAG_INT, MPI_COMM_WORLD, &istatus); |
273 |
< |
|
274 |
< |
for(j=0; j < integrableObjects.size(); j++){ |
273 |
> |
cerr << "node " << worldRank << " finished MPI_Send" << endl; |
274 |
> |
for(j=0; j < nCurObj; j++){ |
275 |
|
|
276 |
|
eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file); |
277 |
|
if(eof_test == NULL){ |
288 |
|
|
289 |
|
MPI_Send(read_buffer, BUFFERSIZE, MPI_CHAR, which_node, |
290 |
|
TAKE_THIS_TAG_CHAR, MPI_COMM_WORLD); |
291 |
< |
|
291 |
> |
cerr << "node " << worldRank << " finished MPI_Send" << endl; |
292 |
|
} |
293 |
|
|
294 |
|
} |
301 |
|
|
302 |
|
MPI_Bcast(read_buffer, BUFFERSIZE, MPI_CHAR, 0, MPI_COMM_WORLD); |
303 |
|
|
304 |
+ |
cerr << "node " << worldRank << " finished MPI_Bcast" << endl; |
305 |
|
parseErr = parseCommentLine( read_buffer, simnfo); |
306 |
|
|
307 |
|
if( parseErr != NULL ){ |
331 |
|
MPI_Send(&nCurObj, 1, MPI_INT, 0, |
332 |
|
TAKE_THIS_TAG_INT, MPI_COMM_WORLD); |
333 |
|
|
334 |
+ |
cerr << "node " << worldRank << " finished MPI_Send" << endl; |
335 |
|
for(j = 0; j < integrableObjects.size(); j++){ |
336 |
|
|
337 |
|
MPI_Recv(read_buffer, BUFFERSIZE, MPI_CHAR, 0, |
338 |
|
TAKE_THIS_TAG_CHAR, MPI_COMM_WORLD, &istatus); |
339 |
|
|
340 |
+ |
cerr << "node " << worldRank << " finished MPI_Recv" << endl; |
341 |
|
parseErr = parseDumpLine(read_buffer, integrableObjects[j]); |
342 |
|
|
343 |
|
if( parseErr != NULL ){ |