X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d8eb62b207b566949a0d9ce649a7b21e226b9168..c18fbaf6d573a7fcdf499c5b9554778c28a71520:/src/simdag/sd_task.cpp diff --git a/src/simdag/sd_task.cpp b/src/simdag/sd_task.cpp index aa2fb4d337..86a8e15fe4 100644 --- a/src/simdag/sd_task.cpp +++ b/src/simdag/sd_task.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2018. The SimGrid Team. +/* Copyright (c) 2006-2019. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -593,7 +593,6 @@ int SD_task_dependency_exists(SD_task_t src, SD_task_t dst) } else { return dst->predecessors->size() + dst->inputs->size(); } - return 0; } /** @@ -794,26 +793,14 @@ void SD_task_run(SD_task_t task) XBT_VERB("Executing task '%s'", task->name); - /* Copy the elements of the task into the action */ - int host_nb = task->allocation->size(); - sg_host_t* hosts = new sg_host_t[host_nb]; - std::copy_n(task->allocation->begin(), host_nb, hosts); - - double* flops_amount = new double[host_nb](); - double* bytes_amount = new double[host_nb * host_nb](); - - if(task->flops_amount) - std::copy_n(task->flops_amount, host_nb, flops_amount); - if(task->bytes_amount) - std::copy_n(task->bytes_amount, host_nb * host_nb, bytes_amount); - - task->surf_action = surf_host_model->execute_parallel(host_nb, hosts, flops_amount, bytes_amount, task->rate); + /* Beware! The scheduling data are now used by the surf action directly! no copy was done */ + task->surf_action = surf_host_model->execute_parallel(task->allocation->size(), task->allocation->data(), + task->flops_amount, task->bytes_amount, task->rate); task->surf_action->set_data(task); XBT_DEBUG("surf_action = %p", task->surf_action); - __SD_task_destroy_scheduling_data(task); /* now the scheduling data are not useful anymore */ SD_task_set_state(task, SD_RUNNING); sd_global->return_set->insert(task); }