X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c46aba70aa4ccf22cc19fac31d451c7158e922dd..353856867665015bd39041aacba13ad22035287c:/src/surf/network_constant.cpp diff --git a/src/surf/network_constant.cpp b/src/surf/network_constant.cpp index ce90e8ad18..fe3356da4f 100644 --- a/src/surf/network_constant.cpp +++ b/src/surf/network_constant.cpp @@ -19,15 +19,19 @@ void surf_network_model_init_Constant() routing_model_create(NULL); - simgrid::surf::on_link.connect([](sg_platf_link_cbarg_t link){ - xbt_die("There is no link in the Constant network model. " - "Please remove any link from your platform (and switch to routing='None')"); - }); + simgrid::surf::on_link.connect(netlink_parse_init); } namespace simgrid { namespace surf { + Link* NetworkConstantModel::createLink(const char *name, double bw, double lat, e_surf_link_sharing_policy_t policy, + xbt_dict_t properties) { + + xbt_die("Refusing to create the link %s: there is no link in the Constant network model. " + "Please remove any link from your platform (and switch to routing='None')", name); + } + double NetworkConstantModel::next_occuring_event(double /*now*/) { NetworkConstantAction *action = NULL; @@ -37,8 +41,8 @@ namespace simgrid { for(ActionList::iterator it(actionSet->begin()), itend(actionSet->end()) ; it != itend ; ++it) { action = static_cast(&*it); - if (action->m_latency > 0 && (min < 0 || action->m_latency < min)) - min = action->m_latency; + if (action->latency_ > 0 && (min < 0 || action->latency_ < min)) + min = action->latency_; } return min; @@ -52,11 +56,11 @@ namespace simgrid { ; it != itend ; it=itNext) { ++itNext; action = static_cast(&*it); - if (action->m_latency > 0) { - if (action->m_latency > delta) { - double_update(&(action->m_latency), delta, sg_surf_precision); + if (action->latency_ > 0) { + if (action->latency_ > delta) { + double_update(&(action->latency_), delta, sg_surf_precision); } else { - action->m_latency = 0.0; + action->latency_ = 0.0; } } action->updateRemains(action->getCost() * delta / action->m_latInit); @@ -65,26 +69,20 @@ namespace simgrid { if (action->getRemainsNoUpdate() <= 0) { action->finish(); - action->setState(SURF_ACTION_DONE); + action->setState(Action::State::done); } else if ((action->getMaxDuration() != NO_MAX_DURATION) && (action->getMaxDuration() <= 0)) { action->finish(); - action->setState(SURF_ACTION_DONE); + action->setState(Action::State::done); } } } - Action *NetworkConstantModel::communicate(NetCard *src, NetCard *dst, - double size, double rate) + Action *NetworkConstantModel::communicate(NetCard *src, NetCard *dst, double size, double rate) { - char *src_name = src->name(); - char *dst_name = dst->name(); - - XBT_IN("(%s,%s,%g,%g)", src_name, dst_name, size, rate); NetworkConstantAction *action = new NetworkConstantAction(this, size, sg_latency_factor); - XBT_OUT(); - networkCommunicateCallbacks(action, src, dst, size, rate); + Link::onCommunicate(action, src, dst); return action; }