X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/400da29670150f252dc2b3878c230f2e1b4a0cef..a61cf9dabf627125ada5e55686ce7f8d57097c71:/src/surf/network_interface.cpp diff --git a/src/surf/network_interface.cpp b/src/surf/network_interface.cpp index b4708a0d5e..0996ae36b8 100644 --- a/src/surf/network_interface.cpp +++ b/src/surf/network_interface.cpp @@ -43,8 +43,8 @@ void* sg_link_data(Link *link) { void sg_link_data_set(Link *link,void *data) { link->setData(data); } -int sg_link_amount(void) { - return Link::linksAmount(); +int sg_link_count(void) { + return Link::linksCount(); } Link** sg_link_list(void) { return Link::linksList(); @@ -72,7 +72,7 @@ Link *Link::byName(const char* name) { return res; } /** @brief Returns the amount of links in the platform */ -int Link::linksAmount() { +int Link::linksCount() { return links->size(); } /** @brief Returns a list of all existing links */ @@ -95,12 +95,12 @@ void Link::linksExit() { * Callbacks * *************/ -simgrid::surf::signal Link::onCreation; -simgrid::surf::signal Link::onDestruction; -simgrid::surf::signal Link::onStateChange; +simgrid::xbt::signal Link::onCreation; +simgrid::xbt::signal Link::onDestruction; +simgrid::xbt::signal Link::onStateChange; // signature: wasOn, currentlyOn -simgrid::surf::signal networkActionStateChangedCallbacks; -simgrid::surf::signal networkCommunicateCallbacks; +simgrid::xbt::signal networkActionStateChangedCallbacks; +simgrid::xbt::signal networkCommunicateCallbacks; } } @@ -114,7 +114,7 @@ void netlink_parse_init(sg_platf_link_cbarg_t link){ link->bandwidth_trace, link->latency, link->latency_trace, - link->state, + link->initiallyOn, link->state_trace, link->policy, link->properties); xbt_free(link_id); link_id = bprintf("%s_DOWN", link->id); @@ -123,7 +123,7 @@ void netlink_parse_init(sg_platf_link_cbarg_t link){ link->bandwidth_trace, link->latency, link->latency_trace, - link->state, + link->initiallyOn, link->state_trace, link->policy, link->properties); xbt_free(link_id); } else { @@ -132,15 +132,11 @@ void netlink_parse_init(sg_platf_link_cbarg_t link){ link->bandwidth_trace, link->latency, link->latency_trace, - link->state, + link->initiallyOn, link->state_trace, link->policy, link->properties); } } -void net_add_traces(){ - surf_network_model->addTraces(); -} - /********* * Model * *********/ @@ -205,13 +201,13 @@ Link::Link(simgrid::surf::NetworkModel *model, const char *name, xbt_dict_t prop Link::Link(simgrid::surf::NetworkModel *model, const char *name, xbt_dict_t props, lmm_constraint_t constraint, - tmgr_history_t history, + sg_future_evt_set_t fes, tmgr_trace_t state_trace) : Resource(model, name, constraint), PropertyHolder(props) { if (state_trace) - p_stateEvent = tmgr_history_add_trace(history, state_trace, 0.0, 0, this); + p_stateEvent = fes->add_trace(state_trace, 0.0, this); links->insert({name, this}); XBT_DEBUG("Create link '%s'",name); @@ -255,10 +251,17 @@ int Link::sharingPolicy() return lmm_constraint_sharing_policy(getConstraint()); } -void Link::setState(e_surf_resource_state_t state){ - e_surf_resource_state_t old = Resource::getState(); - Resource::setState(state); - onStateChange(this, old, state); +void Link::turnOn(){ + if (isOff()) { + Resource::turnOn(); + onStateChange(this, 0, 1); + } +} +void Link::turnOff(){ + if (isOn()) { + Resource::turnOff(); + onStateChange(this, 1, 0); + } } /**********