Commit 6431137a authored by iker_martin's avatar iker_martin
Browse files

Minor bug fixed for RED Pthread strat

parent a589976d
...@@ -1001,7 +1001,6 @@ int thread_check(int wait_completed) { ...@@ -1001,7 +1001,6 @@ int thread_check(int wait_completed) {
// Comprueba que todos los hilos han terminado la distribucion (Mismo valor en commAsync) // Comprueba que todos los hilos han terminado la distribucion (Mismo valor en commAsync)
MPI_Allreduce(&comm_state, &all_completed, 1, MPI_INT, MPI_MAX, mall->comm); MPI_Allreduce(&comm_state, &all_completed, 1, MPI_INT, MPI_MAX, mall->comm);
if(all_completed != MALL_DIST_COMPLETED) return MALL_DIST_PENDING; // Continue only if asynchronous send has ended if(all_completed != MALL_DIST_COMPLETED) return MALL_DIST_PENDING; // Continue only if asynchronous send has ended
//FIXME No se tiene en cuenta el estado MALL_APP_ENDED
if(pthread_join(mall->async_thread, NULL)) { if(pthread_join(mall->async_thread, NULL)) {
printf("Error al esperar al hilo\n"); printf("Error al esperar al hilo\n");
...@@ -1013,7 +1012,7 @@ int thread_check(int wait_completed) { ...@@ -1013,7 +1012,7 @@ int thread_check(int wait_completed) {
MPI_Barrier(mall->intercomm); MPI_Barrier(mall->intercomm);
#endif #endif
if(mall_conf->spawn_method == MALL_SPAWN_MERGE) mall_conf->times->async_end = MPI_Wtime(); // Merge method only if(mall_conf->spawn_method == MALL_SPAWN_MERGE) mall_conf->times->async_end = MPI_Wtime(); // Merge method only
return end_redistribution(); return MALL_USER_PENDING;
} }
......
...@@ -47,8 +47,7 @@ void free_malleability_times() { ...@@ -47,8 +47,7 @@ void free_malleability_times() {
} }
void malleability_times_broadcast(int root) { void malleability_times_broadcast(int root) {
malleability_times_t *times = mall_conf->times; MPI_Bcast(mall_conf->times, 1, mall_conf->times->times_type, root, mall->intercomm);
MPI_Bcast(mall_conf->times, 1, times->times_type, root, mall->intercomm);
} }
void MAM_I_retrieve_times(double *sp_time, double *sy_time, double *asy_time, double *mall_time) { void MAM_I_retrieve_times(double *sp_time, double *sy_time, double *asy_time, double *mall_time) {
......
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