|
@@ -142,29 +142,22 @@ int main(int argc, char **argv)
|
|
|
starpu_task_wait_for_all();
|
|
|
starpu_mpi_barrier(MPI_COMM_WORLD);
|
|
|
|
|
|
-
|
|
|
FPRINTF(stderr, "** Burst warmup **\n");
|
|
|
burst_all(mpi_rank);
|
|
|
|
|
|
-
|
|
|
starpu_sleep(0.3); // sleep to easily distinguish different bursts in traces
|
|
|
|
|
|
-
|
|
|
FPRINTF(stderr, "** Burst while there is no task available, but workers are polling **\n");
|
|
|
burst_all(mpi_rank);
|
|
|
|
|
|
-
|
|
|
starpu_sleep(0.3); // sleep to easily distinguish different bursts in traces
|
|
|
|
|
|
-
|
|
|
FPRINTF(stderr, "** Burst while there is no task available, workers are paused **\n");
|
|
|
starpu_pause();
|
|
|
burst_all(mpi_rank);
|
|
|
|
|
|
-
|
|
|
starpu_sleep(0.3); // sleep to easily distinguish different bursts in traces
|
|
|
|
|
|
-
|
|
|
FPRINTF(stderr, "** Burst while workers are really working **\n");
|
|
|
if(gemm_submit_tasks() == -ENODEV)
|
|
|
goto enodev;
|
|
@@ -178,10 +171,8 @@ int main(int argc, char **argv)
|
|
|
starpu_task_wait_for_all();
|
|
|
starpu_mpi_barrier(MPI_COMM_WORLD);
|
|
|
|
|
|
-
|
|
|
starpu_sleep(0.3); // sleep to easily distinguish different parts in traces
|
|
|
|
|
|
-
|
|
|
FPRINTF(stderr, "** Workers are computing, without communications **\n");
|
|
|
starpu_pause();
|
|
|
if(gemm_submit_tasks() == -ENODEV)
|
|
@@ -192,10 +183,8 @@ int main(int argc, char **argv)
|
|
|
starpu_task_wait_for_all();
|
|
|
starpu_mpi_barrier(MPI_COMM_WORLD);
|
|
|
|
|
|
-
|
|
|
starpu_sleep(0.3); // sleep to easily distinguish different parts in traces
|
|
|
|
|
|
-
|
|
|
FPRINTF(stderr, "** Burst while workers are computing, but polling a moment between each task **\n");
|
|
|
starpu_pause();
|
|
|
gemm_add_polling_dependencies();
|