Commit 03f566b9 authored by iker_martin's avatar iker_martin
Browse files

WIP. Encontrada condicion de carrera entorno a Alltoallv cuando el tiempo por...

WIP. Encontrada condicion de carrera entorno a Alltoallv cuando el tiempo por iteracion es menor a 10ms
parent 178383ba
...@@ -175,7 +175,7 @@ void realloc_results_iters(results_data *results, int needed) { ...@@ -175,7 +175,7 @@ void realloc_results_iters(results_data *results, int needed) {
type_aux = (int *) realloc(results->iters_type, needed * sizeof(int)); type_aux = (int *) realloc(results->iters_type, needed * sizeof(int));
if(time_aux == NULL || type_aux == NULL) { if(time_aux == NULL || type_aux == NULL) {
fprintf(stderr, "No se ha podido realojar la memoria de resultados\n"); fprintf(stderr, "Fatal error - No se ha podido realojar la memoria de resultados\n");
MPI_Abort(MPI_COMM_WORLD, 1); MPI_Abort(MPI_COMM_WORLD, 1);
} }
......
...@@ -150,7 +150,13 @@ void send_sync_arrays(struct Dist_data dist_data, char *array, int rootBcast, in ...@@ -150,7 +150,13 @@ void send_sync_arrays(struct Dist_data dist_data, char *array, int rootBcast, in
} }
//print_counts(dist_data, counts.counts, counts.displs, numP_child, "Padres"); //print_counts(dist_data, counts.counts, counts.displs, numP_child, "Padres");
/* COMUNICACION DE DATOS */ /* COMUNICACION DE DATOS */
//int myId;
//MPI_Comm_rank(MPI_COMM_WORLD, &myId);
//if(myId == 0) { printf("TEST PREALL SEND\n"); fflush(stdout); }
//MPI_Barrier(dist_data.intercomm);
MPI_Alltoallv(array, counts.counts, counts.displs, MPI_CHAR, NULL, counts.zero_arr, counts.zero_arr, MPI_CHAR, dist_data.intercomm); MPI_Alltoallv(array, counts.counts, counts.displs, MPI_CHAR, NULL, counts.zero_arr, counts.zero_arr, MPI_CHAR, dist_data.intercomm);
//MPI_Barrier(dist_data.intercomm);
//if(myId == 0) { printf("TEST POSTALL SEND\n"); fflush(stdout); }
} }
...@@ -176,7 +182,13 @@ void recv_sync_arrays(struct Dist_data dist_data, char *array, int root, int num ...@@ -176,7 +182,13 @@ void recv_sync_arrays(struct Dist_data dist_data, char *array, int root, int num
//print_counts(dist_data, counts.counts, counts.displs, numP_parents, "Hijos"); //print_counts(dist_data, counts.counts, counts.displs, numP_parents, "Hijos");
/* COMUNICACION DE DATOS */ /* COMUNICACION DE DATOS */
//int myId;
//MPI_Comm_rank(MPI_COMM_WORLD, &myId);
//if(myId == 0) { printf("TEST PREALL RECV\n"); fflush(stdout); }
//MPI_Barrier(dist_data.intercomm);
MPI_Alltoallv(&aux, counts.zero_arr, counts.zero_arr, MPI_CHAR, array, counts.counts, counts.displs, MPI_CHAR, dist_data.intercomm); MPI_Alltoallv(&aux, counts.zero_arr, counts.zero_arr, MPI_CHAR, array, counts.counts, counts.displs, MPI_CHAR, dist_data.intercomm);
//MPI_Barrier(dist_data.intercomm);
//if(myId == 0) { printf("TEST POSTALL RECV\n"); fflush(stdout); }
} }
......
#!/bin/bash #!/bin/bash
#SBATCH --exclude=n[06-07],c01 #SBATCH --exclude=c01
dir="/home/martini/malleability_benchmark" dir="/home/martini/malleability_benchmark"
codeDir="/Codes" codeDir="/Codes"
...@@ -21,7 +21,7 @@ do ...@@ -21,7 +21,7 @@ do
for phy_dist in cpu node for phy_dist in cpu node
do do
for ibarrier_use in 0 #TODO Poner a 0 1 for ibarrier_use in 3 #TODO Poner a 0 1
do do
i=$(($i + 1)) i=$(($i + 1))
cd $name_dir/Run$i cd $name_dir/Run$i
......
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