X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/e526ad06508e0193155f0591b43d7d9e9e92f6c7..a7ece9a7073ae69a657ba432b187a69ef7db23d9:/src/surf/ptask_L07.cpp diff --git a/src/surf/ptask_L07.cpp b/src/surf/ptask_L07.cpp index f11d8dff39..9e252ee753 100644 --- a/src/surf/ptask_L07.cpp +++ b/src/surf/ptask_L07.cpp @@ -182,7 +182,7 @@ L07Action::L07Action(Model *model, int host_nb, sg_host_t *host_list, double lat=0.0; std::vector route; - hostList_->at(i)->routeTo(hostList_->at(j), &route, &lat); + hostList_->at(i)->routeTo(hostList_->at(j), route, &lat); latency = MAX(latency, lat); for (auto const& link : route) @@ -195,24 +195,22 @@ L07Action::L07Action(Model *model, int host_nb, sg_host_t *host_list, } XBT_DEBUG("Creating a parallel task (%p) with %d hosts and %d unique links.", this, host_nb, nb_link); - this->latency_ = latency; + latency_ = latency; - this->variable_ = lmm_variable_new(model->getMaxminSystem(), this, 1.0, - (rate > 0 ? rate : -1.0), - host_nb + nb_link); + setVariable(lmm_variable_new(model->getMaxminSystem(), this, 1.0, (rate > 0 ? rate : -1.0), host_nb + nb_link)); - if (this->latency_ > 0) - lmm_update_variable_weight(model->getMaxminSystem(), this->getVariable(), 0.0); + if (latency_ > 0) + lmm_update_variable_weight(model->getMaxminSystem(), getVariable(), 0.0); for (int i = 0; i < host_nb; i++) - lmm_expand(model->getMaxminSystem(), host_list[i]->pimpl_cpu->constraint(), this->getVariable(), flops_amount[i]); + lmm_expand(model->getMaxminSystem(), host_list[i]->pimpl_cpu->constraint(), getVariable(), flops_amount[i]); if(bytes_amount != nullptr) { for (int i = 0; i < host_nb; i++) { for (int j = 0; j < host_nb; j++) { if (bytes_amount[i * host_nb + j] > 0.0) { std::vector route; - hostList_->at(i)->routeTo(hostList_->at(j), &route, nullptr); + hostList_->at(i)->routeTo(hostList_->at(j), route, nullptr); for (auto const& link : route) lmm_expand_add(model->getMaxminSystem(), link->constraint(), this->getVariable(), @@ -292,7 +290,7 @@ Action *CpuL07::execution_start(double size) Action *CpuL07::sleep(double duration) { L07Action *action = static_cast(execution_start(1.0)); - action->maxDuration_ = duration; + action->setMaxDuration(duration); action->suspended_ = 2; lmm_update_variable_weight(model()->getMaxminSystem(), action->getVariable(), 0.0); @@ -409,7 +407,7 @@ void L07Action::updateBound() if (communicationAmount_[i * hostNb + j] > 0) { double lat = 0.0; std::vector route; - hostList_->at(i)->routeTo(hostList_->at(j), &route, &lat); + hostList_->at(i)->routeTo(hostList_->at(j), route, &lat); lat_current = MAX(lat_current, lat * communicationAmount_[i * hostNb + j]); }