X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6c1fdfa949304917158331410c2e91b0ca1b2e90..6c56800bdad43cabb6c870c9163bbeea694d6692:/src/surf/network_cm02.hpp diff --git a/src/surf/network_cm02.hpp b/src/surf/network_cm02.hpp index 82d1480246..c962616e35 100644 --- a/src/surf/network_cm02.hpp +++ b/src/surf/network_cm02.hpp @@ -9,6 +9,7 @@ #include #include "network_interface.hpp" +#include "simgrid/kernel/resource/NetworkModelIntf.hpp" #include "xbt/graph.h" #include "xbt/string.hpp" @@ -29,13 +30,42 @@ class XBT_PRIVATE NetworkSmpiModel; *********/ class NetworkCm02Model : public NetworkModel { + /** @brief Get route information (2-way) */ + bool comm_get_route_info(const s4u::Host* src, const s4u::Host* dst, /* OUT */ double& latency, + std::vector& route, std::vector& back_route, + std::unordered_set& netzones) const; + /** @brief Create network action for this communication */ + NetworkCm02Action* comm_action_create(s4u::Host* src, s4u::Host* dst, double size, + const std::vector& route, bool failed); + /** @brief Expand link contraint considering this new communication action */ + void comm_action_expand_constraints(const s4u::Host* src, const s4u::Host* dst, const NetworkCm02Action* action, + const std::vector& route, + const std::vector& back_route) const; + /** @brief Set communication bounds for latency and bandwidth */ + void comm_action_set_bounds(const s4u::Host* src, const s4u::Host* dst, double size, NetworkCm02Action* action, + const std::vector& route, + const std::unordered_set& netzones, double rate); + /** @brief Create maxmin variable in communication action */ + void comm_action_set_variable(NetworkCm02Action* action, const std::vector& route, + const std::vector& back_route); + public: - explicit NetworkCm02Model(std::string name); - LinkImpl* create_link(const std::string& name, const std::vector& bandwidths, - s4u::Link::SharingPolicy policy) override; + explicit NetworkCm02Model(const std::string& name); + LinkImpl* create_link(const std::string& name, const std::vector& bandwidths) final; + LinkImpl* create_wifi_link(const std::string& name, const std::vector& bandwidths) override; void update_actions_state_lazy(double now, double delta) override; void update_actions_state_full(double now, double delta) override; Action* communicate(s4u::Host* src, s4u::Host* dst, double size, double rate) override; + void set_lat_factor_cb(const std::function& cb) override; + void set_bw_factor_cb(const std::function& cb) override; + +protected: + virtual void check_lat_factor_cb(); + virtual void check_bw_factor_cb(); + +private: + std::function lat_factor_cb_; + std::function bw_factor_cb_; }; /************ @@ -44,10 +74,10 @@ public: class NetworkCm02Link : public LinkImpl { public: - NetworkCm02Link(const std::string& name, double bandwidth, s4u::Link::SharingPolicy policy, lmm::System* system); + NetworkCm02Link(const std::string& name, double bandwidth, lmm::System* system); void apply_event(kernel::profile::Event* event, double value) override; void set_bandwidth(double value) override; - LinkImpl* set_latency(double value) override; + void set_latency(double value) override; }; /********** @@ -60,7 +90,7 @@ public: using NetworkAction::NetworkAction; void update_remains_lazy(double now) override; }; -} -} +} // namespace resource +} // namespace kernel } // namespace simgrid #endif /* SURF_NETWORK_CM02_HPP_ */