X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/bfd4a01db7f2f21e67c9ce03d32eb47a9601f759..e98ff738e16a6e5a18426c8686407511f4c0c8a4:/include/simgrid/s4u/Task.hpp diff --git a/include/simgrid/s4u/Task.hpp b/include/simgrid/s4u/Task.hpp index ea144e239d..1fe18138bd 100644 --- a/include/simgrid/s4u/Task.hpp +++ b/include/simgrid/s4u/Task.hpp @@ -48,7 +48,7 @@ class Task { void receive(Task* source); std::shared_ptr token_ = nullptr; - std::deque>> tokens_received_; + std::map>> tokens_received_; std::map> current_activities_ = { {"instance_0", {}}, {"dispatcher", {}}, {"collector", {}}}; @@ -83,7 +83,9 @@ public: void set_load_balancing_function(std::function func); void set_token(std::shared_ptr token); - std::shared_ptr get_next_token_from(TaskPtr t) const { return tokens_received_.front().at(t); } + std::shared_ptr get_token_from(TaskPtr t) const { return tokens_received_.at(t).front(); } + std::deque> get_tokens_from(TaskPtr t) const { return tokens_received_.at(t); } + void deque_token_from(TaskPtr t); void add_successor(TaskPtr t); void remove_successor(TaskPtr t);