Commit 324bd359 authored by Pedro Gonnet's avatar Pedro Gonnet
Browse files

add debug output for each part sent/received.


Former-commit-id: 78052f0629ab80163631a248a0af9f596d27c4a2
parent b23474cd
...@@ -926,14 +926,14 @@ int engine_exchange_strays ( struct engine *e , int offset , int *ind , int N ) ...@@ -926,14 +926,14 @@ int engine_exchange_strays ( struct engine *e , int offset , int *ind , int N )
// message( "request from proxy %i has arrived." , pid ); // message( "request from proxy %i has arrived." , pid );
if ( reqs_in[pid & ~1] == MPI_REQUEST_NULL && if ( reqs_in[pid & ~1] == MPI_REQUEST_NULL &&
reqs_in[pid | 1 ] == MPI_REQUEST_NULL ) { reqs_in[pid | 1 ] == MPI_REQUEST_NULL ) {
p = &e->proxies[pid/2]; p = &e->proxies[pid >> 1];
memcpy( &s->parts[offset + count] , p->parts_in , sizeof(struct part) * p->nr_parts_in ); memcpy( &s->parts[offset + count] , p->parts_in , sizeof(struct part) * p->nr_parts_in );
memcpy( &s->xparts[offset + count] , p->xparts_in , sizeof(struct xpart) * p->nr_parts_in ); memcpy( &s->xparts[offset + count] , p->xparts_in , sizeof(struct xpart) * p->nr_parts_in );
count += p->nr_parts_in; for ( int k = offset ; k < offset + count; k++ )
/* for ( int k = 0 ; k < p->nr_parts_in ; k++ )
message( "received particle %lli, x=[%.3e %.3e %.3e], h=%.3e, from node %i." , message( "received particle %lli, x=[%.3e %.3e %.3e], h=%.3e, from node %i." ,
p->parts_in[k].id , p->parts_in[k].x[0] , p->parts_in[k].x[1] , p->parts_in[k].x[2] , s->parts[k].id , s->parts[k].x[0] , s->parts[k].x[1] , s->parts[k].x[2] ,
p->parts_in[k].h , p->nodeID ); */ s->parts[k].h , p->nodeID );
count += p->nr_parts_in;
} }
} }
......
...@@ -215,10 +215,10 @@ void proxy_parts_exch1 ( struct proxy *p ) { ...@@ -215,10 +215,10 @@ void proxy_parts_exch1 ( struct proxy *p ) {
MPI_Isend( p->xparts_out , sizeof(struct xpart)*p->nr_parts_out , MPI_BYTE , p->nodeID , p->mynodeID*proxy_tag_shift + proxy_tag_xparts , MPI_COMM_WORLD , &p->req_xparts_out ) != MPI_SUCCESS ) MPI_Isend( p->xparts_out , sizeof(struct xpart)*p->nr_parts_out , MPI_BYTE , p->nodeID , p->mynodeID*proxy_tag_shift + proxy_tag_xparts , MPI_COMM_WORLD , &p->req_xparts_out ) != MPI_SUCCESS )
error( "Failed to isend part data." ); error( "Failed to isend part data." );
// message( "isent particle data (%i) to node %i." , p->nr_parts_out , p->nodeID ); fflush(stdout); // message( "isent particle data (%i) to node %i." , p->nr_parts_out , p->nodeID ); fflush(stdout);
/* for ( int k = 0 ; k < p->nr_parts_out ; k++ ) for ( int k = 0 ; k < p->nr_parts_out ; k++ )
message( "sending particle %lli, x=[%.3e %.3e %.3e], h=%.3e, to node %i." , message( "sending particle %lli, x=[%.3e %.3e %.3e], h=%.3e, to node %i." ,
p->parts_out[k].id , p->parts_out[k].x[0] , p->parts_out[k].x[1] , p->parts_out[k].x[2] , p->parts_out[k].id , p->parts_out[k].x[0] , p->parts_out[k].x[1] , p->parts_out[k].x[2] ,
p->parts_out[k].h , p->nodeID ); */ p->parts_out[k].h , p->nodeID );
} }
/* Receive the number of particles. */ /* Receive the number of particles. */
......
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