X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ea74f5d95928a521a588737e81f1de94eef25d19..9a6b1a23ce86f475df4c3dd63310c3484cebd956:/src/kernel/activity/ExecImpl.hpp diff --git a/src/kernel/activity/ExecImpl.hpp b/src/kernel/activity/ExecImpl.hpp index 0aefc02526..a6c691b423 100644 --- a/src/kernel/activity/ExecImpl.hpp +++ b/src/kernel/activity/ExecImpl.hpp @@ -11,18 +11,16 @@ #include "src/kernel/activity/ActivityImpl.hpp" #include "src/kernel/context/Context.hpp" -namespace simgrid { -namespace kernel { -namespace activity { +namespace simgrid::kernel::activity { class XBT_PUBLIC ExecImpl : public ActivityImpl_T { std::unique_ptr> timeout_detector_{ nullptr, [](resource::Action* a) { a->unref(); }}; double sharing_penalty_ = 1.0; double bound_ = 0.0; - std::vector hosts_; std::vector flops_amounts_; std::vector bytes_amounts_; + int thread_count_ = 1; int cb_id_ = -1; // callback id from Host::on_state_change.connect() public: @@ -42,9 +40,10 @@ public: ExecImpl& set_flops_amounts(const std::vector& flops_amounts); ExecImpl& set_bytes_amounts(const std::vector& bytes_amounts); + ExecImpl& set_thread_count(int thread_count); ExecImpl& set_hosts(const std::vector& hosts); - unsigned int get_host_number() const { return hosts_.size(); } + unsigned int get_host_number() const { return static_cast(hosts_.size()); } double get_seq_remaining_ratio(); double get_par_remaining_ratio(); double get_remaining() const override; @@ -56,11 +55,8 @@ public: void finish() override; void reset(); - static void wait_any_for(actor::ActorImpl* issuer, const std::vector& execs, double timeout); static xbt::signal on_migration; }; -} // namespace activity -} // namespace kernel -} // namespace simgrid +} // namespace simgrid::kernel::activity #endif