X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/237fd22b56db7d1c67360c37559ce3aab16a002d..cc320f970d3f91bf9483f44340078c0250a4a44b:/src/s4u/s4u_Activity.cpp diff --git a/src/s4u/s4u_Activity.cpp b/src/s4u/s4u_Activity.cpp index ae3846b588..8c22f5871e 100644 --- a/src/s4u/s4u_Activity.cpp +++ b/src/s4u/s4u_Activity.cpp @@ -3,13 +3,13 @@ /* 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. */ -#include "xbt/log.h" +#include +#include +#include +#include +#include +#include -#include "simgrid/Exception.hpp" -#include "simgrid/s4u/Activity.hpp" -#include "simgrid/s4u/Engine.hpp" -#include "simgrid/s4u/Exec.hpp" -#include "simgrid/s4u/Io.hpp" #include "src/kernel/activity/ActivityImpl.hpp" #include "src/kernel/actor/ActorImpl.hpp" #include "src/kernel/actor/SimcallObserver.hpp" @@ -20,6 +20,11 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(s4u_activity, s4u, "S4U activities"); namespace simgrid { namespace s4u { +xbt::signal Activity::on_veto; +xbt::signal Activity::on_completion; + +std::set* Activity::vetoed_activities_ = nullptr; + void Activity::wait_until(double time_limit) { double now = Engine::get_clock(); @@ -112,10 +117,19 @@ double Activity::get_remaining() const else return pimpl_->get_remaining(); } +double Activity::get_start_time() const +{ + return pimpl_->get_start_time(); +} +double Activity::get_finish_time() const +{ + return pimpl_->get_finish_time(); +} Activity* Activity::set_remaining(double remains) { - xbt_assert(state_ == State::INITED, "Cannot change the remaining amount of work once the Activity is started"); + xbt_assert(state_ == State::INITED || state_ == State::STARTING, + "Cannot change the remaining amount of work once the Activity is started"); remains_ = remains; return this; }