X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/8ab69237cb52b48a85bb047341892642cbebc20b..e1a5484101efbff9c8d982a0c4650f7953ee7e2f:/src/surf/network_interface.cpp diff --git a/src/surf/network_interface.cpp b/src/surf/network_interface.cpp index 68c455cea1..6b13a681ab 100644 --- a/src/surf/network_interface.cpp +++ b/src/surf/network_interface.cpp @@ -19,8 +19,6 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(res_network, ker_resource, "Network resources, t * Model * *********/ -simgrid::kernel::resource::NetworkModel* surf_network_model = nullptr; - namespace simgrid { namespace kernel { namespace resource { @@ -73,9 +71,8 @@ double NetworkModel::next_occurring_event_full(double now) * Resource * ************/ -LinkImpl::LinkImpl(const std::string& name, lmm::Constraint* constraint) : Resource(name), piface_(this) +LinkImpl::LinkImpl(const std::string& name) : Resource_T(name), piface_(this) { - this->set_constraint(constraint); if (name != "__loopback__") xbt_assert(not s4u::Link::by_name_or_null(name), "Link '%s' declared several times in the platform.", name.c_str()); @@ -111,12 +108,17 @@ double LinkImpl::get_bandwidth() const return bandwidth_.peak * bandwidth_.scale; } +LinkImpl* LinkImpl::set_sharing_policy(s4u::Link::SharingPolicy policy) +{ + get_constraint()->set_sharing_policy(policy); + return this; +} s4u::Link::SharingPolicy LinkImpl::get_sharing_policy() const { return get_constraint()->get_sharing_policy(); } -void LinkImpl::latency_check(double latency) +void LinkImpl::latency_check(double latency) const { static double last_warned_latency = sg_surf_precision; if (latency != 0.0 && latency < last_warned_latency) { @@ -141,10 +143,9 @@ void LinkImpl::turn_off() Resource::turn_off(); s4u::Link::on_state_change(this->piface_); - const kernel::lmm::Variable* var; const kernel::lmm::Element* elem = nullptr; double now = surf_get_clock(); - while ((var = get_constraint()->get_variable(&elem))) { + while (const auto* var = get_constraint()->get_variable(&elem)) { Action* action = var->get_id(); if (action->get_state() == Action::State::INITED || action->get_state() == Action::State::STARTED) { action->set_finish_time(now); @@ -153,27 +154,35 @@ void LinkImpl::turn_off() } } } + void LinkImpl::seal() { - this->set_model(surf_network_model); - - simgrid::s4u::Link::on_creation(*get_iface()); + xbt_assert(this->get_model(), "Cannot seal Link(%s) without setting the Network model first", this->get_cname()); + Resource::seal(); + s4u::Link::on_creation(*get_iface()); } + void LinkImpl::on_bandwidth_change() const { s4u::Link::on_bandwidth_change(this->piface_); } -void LinkImpl::set_bandwidth_profile(profile::Profile* profile) +LinkImpl* LinkImpl::set_bandwidth_profile(profile::Profile* profile) { - xbt_assert(bandwidth_.event == nullptr, "Cannot set a second bandwidth profile to Link %s", get_cname()); - bandwidth_.event = profile->schedule(&profile::future_evt_set, this); + if (profile) { + xbt_assert(bandwidth_.event == nullptr, "Cannot set a second bandwidth profile to Link %s", get_cname()); + bandwidth_.event = profile->schedule(&profile::future_evt_set, this); + } + return this; } -void LinkImpl::set_latency_profile(profile::Profile* profile) +LinkImpl* LinkImpl::set_latency_profile(profile::Profile* profile) { - xbt_assert(latency_.event == nullptr, "Cannot set a second latency profile to Link %s", get_cname()); - latency_.event = profile->schedule(&profile::future_evt_set, this); + if (profile) { + xbt_assert(latency_.event == nullptr, "Cannot set a second latency profile to Link %s", get_cname()); + latency_.event = profile->schedule(&profile::future_evt_set, this); + } + return this; } /**********