Mentions légales du service

Skip to content
Snippets Groups Projects
Commit d0f1510f authored by Mathieu Faverge's avatar Mathieu Faverge
Browse files

Revert commit fef23203 to fix #109 (Pruning must be done at application level)

parent f2bc5add
No related branches found
No related tags found
No related merge requests found
...@@ -416,23 +416,11 @@ void RUNTIME_data_migrate( const RUNTIME_sequence_t *sequence, ...@@ -416,23 +416,11 @@ void RUNTIME_data_migrate( const RUNTIME_sequence_t *sequence,
lhandle = *handle; lhandle = *handle;
if ( lhandle == NULL ) { if ( lhandle == NULL ) {
int involved;
old_rank = A->get_rankof( A, Am, An );
involved = (A->myrank == old_rank) || (A->myrank == new_rank);
/* Quick return */
if ( !involved ) {
return;
}
/* Register the data */ /* Register the data */
lhandle = RUNTIME_data_getaddr( A, Am, An ); lhandle = RUNTIME_data_getaddr( A, Am, An );
} }
/* Update the rank if has been moved already (cf qr for example) */
old_rank = starpu_mpi_data_get_rank( lhandle ); old_rank = starpu_mpi_data_get_rank( lhandle );
assert( old_rank == A->get_rankof( A, Am, An ) );
if ( old_rank != new_rank ) { if ( old_rank != new_rank ) {
starpu_mpi_data_migrate( MPI_COMM_WORLD, lhandle, new_rank ); starpu_mpi_data_migrate( MPI_COMM_WORLD, lhandle, new_rank );
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment