X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dd2fbfede2575bd9d7069a152b97983108a57c0a..54f07f038966ffe0b3e8ef526e9192f7eb49ad09:/src/kernel/activity/ExecImpl.cpp diff --git a/src/kernel/activity/ExecImpl.cpp b/src/kernel/activity/ExecImpl.cpp index 097947c319..e7b79f0528 100644 --- a/src/kernel/activity/ExecImpl.cpp +++ b/src/kernel/activity/ExecImpl.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2018. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -34,14 +34,14 @@ simgrid::kernel::activity::ExecImpl::~ExecImpl() void simgrid::kernel::activity::ExecImpl::suspend() { - XBT_VERB("This exec is suspended (remain: %f)", surfAction_->getRemains()); + XBT_VERB("This exec is suspended (remain: %f)", surfAction_->get_remains()); if (surfAction_) surfAction_->suspend(); } void simgrid::kernel::activity::ExecImpl::resume() { - XBT_VERB("This exec is resumed (remain: %f)", surfAction_->getRemains()); + XBT_VERB("This exec is resumed (remain: %f)", surfAction_->get_remains()); if (surfAction_) surfAction_->resume(); } @@ -52,21 +52,21 @@ double simgrid::kernel::activity::ExecImpl::remains() "We would need to return a vector instead of a scalar. " "Did you mean remainingRatio() instead?"); - return surfAction_ ? surfAction_->getRemains() : 0; + return surfAction_ ? surfAction_->get_remains() : 0; } double simgrid::kernel::activity::ExecImpl::remainingRatio() { if (host_ == nullptr) // parallel task: their remain is already between 0 and 1 (see comment in ExecImpl::remains()) - return surfAction_->getRemains(); + return surfAction_->get_remains(); else // Actually compute the ratio for sequential tasks - return surfAction_->getRemains() / surfAction_->getCost(); + return surfAction_->get_remains() / surfAction_->get_cost(); } void simgrid::kernel::activity::ExecImpl::setBound(double bound) { if (surfAction_) - surfAction_->setBound(bound); + surfAction_->set_bound(bound); } void simgrid::kernel::activity::ExecImpl::post() @@ -75,10 +75,10 @@ void simgrid::kernel::activity::ExecImpl::post() /* If the host running the synchro failed, notice it. This way, the asking * process can be killed if it runs on that host itself */ state = SIMIX_FAILED; - } else if (surfAction_->getState() == simgrid::surf::Action::State::failed) { + } else if (surfAction_ && surfAction_->get_state() == simgrid::kernel::resource::Action::State::failed) { /* If the host running the synchro didn't fail, then the synchro was canceled */ state = SIMIX_CANCELED; - } else if (timeoutDetector && timeoutDetector->getState() == simgrid::surf::Action::State::done) { + } else if (timeoutDetector && timeoutDetector->get_state() == simgrid::kernel::resource::Action::State::done) { state = SIMIX_TIMEOUT; } else { state = SIMIX_DONE; @@ -104,16 +104,16 @@ simgrid::kernel::activity::ExecImpl::migrate(simgrid::s4u::Host* to) { if (not MC_is_active() && not MC_record_replay_is_active()) { - surf_action_t oldAction = this->surfAction_; - surf_action_t newAction = to->pimpl_cpu->execution_start(oldAction->getCost()); - newAction->setRemains(oldAction->getRemains()); - newAction->setData(this); - newAction->setSharingWeight(oldAction->getPriority()); + simgrid::kernel::resource::Action* oldAction = this->surfAction_; + simgrid::kernel::resource::Action* newAction = to->pimpl_cpu->execution_start(oldAction->get_cost()); + newAction->set_remains(oldAction->get_remains()); + newAction->set_data(this); + newAction->set_priority(oldAction->get_priority()); // FIXME: the user-defined bound seem to not be kept by LMM, that seem to overwrite it for the multi-core modeling. // I hope that the user did not provide any. - oldAction->setData(nullptr); + oldAction->set_data(nullptr); oldAction->cancel(); oldAction->unref(); this->surfAction_ = newAction;