X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c5441f8d3e27c39b8ff6a42b835af7d7eeb5e136..104c3ca5da690c2296039f8e59dd47f1b496621e:/src/surf/network_constant.cpp diff --git a/src/surf/network_constant.cpp b/src/surf/network_constant.cpp index 8ad621d2bc..6114f6f4d1 100644 --- a/src/surf/network_constant.cpp +++ b/src/surf/network_constant.cpp @@ -5,7 +5,6 @@ * under the terms of the license (GNU LGPL) which comes with this package. */ #include "network_constant.hpp" -#include "surf/random_mgr.h" #include "host_interface.hpp" #include "src/surf/platform.hpp" @@ -32,17 +31,17 @@ void surf_network_model_init_Constant() namespace simgrid { namespace surf { -double NetworkConstantModel::shareResources(double /*now*/) +double NetworkConstantModel::next_occuring_event(double /*now*/) { NetworkConstantAction *action = NULL; double min = -1.0; ActionList *actionSet = getRunningActionSet(); 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; + ; it != itend ; ++it) { + action = static_cast(&*it); + if (action->m_latency > 0 && (min < 0 || action->m_latency < min)) + min = action->m_latency; } return min; @@ -53,9 +52,9 @@ void NetworkConstantModel::updateActionsState(double /*now*/, double delta) NetworkConstantAction *action = NULL; ActionList *actionSet = getRunningActionSet(); for(ActionList::iterator it(actionSet->begin()), itNext=it, itend(actionSet->end()) - ; it != itend ; it=itNext) { + ; it != itend ; it=itNext) { ++itNext; - action = static_cast(&*it); + action = static_cast(&*it); if (action->m_latency > 0) { if (action->m_latency > delta) { double_update(&(action->m_latency), delta, sg_surf_precision); @@ -71,7 +70,7 @@ void NetworkConstantModel::updateActionsState(double /*now*/, double delta) action->finish(); action->setState(SURF_ACTION_DONE); } else if ((action->getMaxDuration() != NO_MAX_DURATION) - && (action->getMaxDuration() <= 0)) { + && (action->getMaxDuration() <= 0)) { action->finish(); action->setState(SURF_ACTION_DONE); } @@ -79,10 +78,10 @@ void NetworkConstantModel::updateActionsState(double /*now*/, double delta) } Action *NetworkConstantModel::communicate(NetCard *src, NetCard *dst, - double size, double rate) + double size, double rate) { - char *src_name = src->getName(); - char *dst_name = dst->getName(); + 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); @@ -100,10 +99,10 @@ int NetworkConstantAction::unref() { m_refcount--; if (!m_refcount) { - if (action_hook.is_linked()) - p_stateSet->erase(p_stateSet->iterator_to(*this)); + if (action_hook.is_linked()) + p_stateSet->erase(p_stateSet->iterator_to(*this)); delete this; - return 1; + return 1; } return 0; }