X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/43793104b1630504dfaa7486958884a214896049..d9c1e4df4ecfc39d84e55527fa05e9bd19f70c6c:/src/s4u/s4u_Task.cpp diff --git a/src/s4u/s4u_Task.cpp b/src/s4u/s4u_Task.cpp index 9419363f1d..ee75342eae 100644 --- a/src/s4u/s4u_Task.cpp +++ b/src/s4u/s4u_Task.cpp @@ -1,9 +1,9 @@ #include #include -#include #include #include #include +#include #include #include "src/simgrid/module.hpp" @@ -50,7 +50,7 @@ void Task::receive(Task* source) if (tokens_received_.size() <= queued_firings_ + source_count) tokens_received_.emplace_back(); tokens_received_[queued_firings_ + source_count][source] = source->token_; - bool enough_tokens = true; + bool enough_tokens = true; for (auto const& [key, val] : predecessors_) if (val < 1) { enough_tokens = false; @@ -126,10 +126,11 @@ std::shared_ptr Task::get_next_token_from(TaskPtr t) return tokens_received_.front()[t]; } -void Task::fire() { +void Task::fire() +{ on_this_start(this); on_start(this); - working_ = true; + working_ = true; queued_firings_ = std::max(queued_firings_ - 1, 0); if (not tokens_received_.empty()) tokens_received_.pop_front();