X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ead116337e0f3636ea2bcb200cd5156e576689eb..b83ad9c88af4715987015ddc91ac93ad749df428:/src/surf/network_interface.cpp diff --git a/src/surf/network_interface.cpp b/src/surf/network_interface.cpp index 0414e74bb5..8b4f978be4 100644 --- a/src/surf/network_interface.cpp +++ b/src/surf/network_interface.cpp @@ -35,9 +35,10 @@ namespace simgrid { LinkImpl** LinkImpl::linksList() { LinkImpl** res = xbt_new(LinkImpl*, (int)links->size()); - int i=0; + int i = 0; for (auto kv : *links) { - res[i++] = kv.second; + res[i] = kv.second; + i++; } return res; } @@ -99,7 +100,7 @@ namespace simgrid { ************/ LinkImpl::LinkImpl(simgrid::surf::NetworkModel* model, const char* name, lmm_constraint_t constraint) - : Resource(model, name, constraint), piface_(Link(this)) + : Resource(model, name, constraint), piface_(this) { if (strcmp(name,"__loopback__")) @@ -168,17 +169,17 @@ namespace simgrid { void LinkImpl::setStateTrace(tmgr_trace_t trace) { xbt_assert(stateEvent_ == nullptr, "Cannot set a second state trace to Link %s", cname()); - stateEvent_ = future_evt_set->add_trace(trace, 0.0, this); + stateEvent_ = future_evt_set->add_trace(trace, this); } void LinkImpl::setBandwidthTrace(tmgr_trace_t trace) { xbt_assert(bandwidth_.event == nullptr, "Cannot set a second bandwidth trace to Link %s", cname()); - bandwidth_.event = future_evt_set->add_trace(trace, 0.0, this); + bandwidth_.event = future_evt_set->add_trace(trace, this); } void LinkImpl::setLatencyTrace(tmgr_trace_t trace) { xbt_assert(latency_.event == nullptr, "Cannot set a second latency trace to Link %s", cname()); - latency_.event = future_evt_set->add_trace(trace, 0.0, this); + latency_.event = future_evt_set->add_trace(trace, this); } @@ -186,11 +187,30 @@ namespace simgrid { * Action * **********/ - void NetworkAction::setState(Action::State state){ + void NetworkAction::setState(Action::State state) + { Action::setState(state); s4u::Link::onCommunicationStateChange(this); } + /** @brief returns a list of all Links that this action is using */ + std::list NetworkAction::links() + { + std::list retlist; + lmm_system_t sys = getModel()->getMaxminSystem(); + int llen = lmm_get_number_of_cnst_from_var(sys, getVariable()); + + for (int i = 0; i < llen; i++) { + /* Beware of composite actions: ptasks put links and cpus together */ + // extra pb: we cannot dynamic_cast from void*... + Resource* resource = static_cast(lmm_constraint_id(lmm_get_cnst_from_var(sys, getVariable(), i))); + LinkImpl* link = dynamic_cast(resource); + if (link != nullptr) + retlist.push_back(link); + } + + return retlist; + } } }