|
@@ -596,7 +596,10 @@ int starpu_mpi_insert_task(MPI_Comm comm, struct starpu_codelet *codelet, ...)
|
|
|
|
|
|
_STARPU_MPI_DEBUG(1, "Execution of the codelet %p (%s)\n", codelet, codelet->name);
|
|
_STARPU_MPI_DEBUG(1, "Execution of the codelet %p (%s)\n", codelet, codelet->name);
|
|
va_start(varg_list, codelet);
|
|
va_start(varg_list, codelet);
|
|
|
|
+
|
|
struct starpu_task *task = starpu_task_create();
|
|
struct starpu_task *task = starpu_task_create();
|
|
|
|
+ task->cl_arg_free = 1;
|
|
|
|
+
|
|
if (codelet->nbuffers > STARPU_NMAXBUFS)
|
|
if (codelet->nbuffers > STARPU_NMAXBUFS)
|
|
{
|
|
{
|
|
task->dyn_handles = malloc(codelet->nbuffers * sizeof(starpu_data_handle_t));
|
|
task->dyn_handles = malloc(codelet->nbuffers * sizeof(starpu_data_handle_t));
|