X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f06041cf2c450457a0b47a49b66b19cb9133c18e..a34d8237b8267686bbd259670f27da273ff5236e:/src/surf/network_constant.cpp diff --git a/src/surf/network_constant.cpp b/src/surf/network_constant.cpp index 06001baa61..3421c67663 100644 --- a/src/surf/network_constant.cpp +++ b/src/surf/network_constant.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2013-2014. The SimGrid Team. +/* Copyright (c) 2013-2015. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -13,6 +13,10 @@ static int host_number_int = 0; static void netcste_count_hosts(sg_platf_host_cbarg_t /*h*/) { host_number_int++; } +static void netcste_parse_nolink(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')"); +} /********* * Model * @@ -22,21 +26,24 @@ void surf_network_model_init_Constant() xbt_assert(surf_network_model == NULL); surf_network_model = new NetworkConstantModel(); + routing_model_create(NULL); + sg_platf_host_add_cb(netcste_count_hosts); + sg_platf_link_add_cb(netcste_parse_nolink); - ModelPtr model = surf_network_model; + Model *model = surf_network_model; xbt_dynar_push(model_list, &model); } double NetworkConstantModel::shareResources(double /*now*/) { - NetworkConstantActionPtr action = NULL; + NetworkConstantAction *action = NULL; double min = -1.0; - ActionListPtr actionSet = getRunningActionSet(); + ActionList *actionSet = getRunningActionSet(); for(ActionList::iterator it(actionSet->begin()), itend(actionSet->end()) ; it != itend ; ++it) { - action = static_cast(&*it); + action = static_cast(&*it); if (action->m_latency > 0 && (min < 0 || action->m_latency < min)) min = action->m_latency; } @@ -46,12 +53,12 @@ double NetworkConstantModel::shareResources(double /*now*/) void NetworkConstantModel::updateActionsState(double /*now*/, double delta) { - NetworkConstantActionPtr action = NULL; - ActionListPtr actionSet = getRunningActionSet(); + NetworkConstantAction *action = NULL; + ActionList *actionSet = getRunningActionSet(); for(ActionList::iterator it(actionSet->begin()), itNext=it, itend(actionSet->end()) ; 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); @@ -74,52 +81,20 @@ void NetworkConstantModel::updateActionsState(double /*now*/, double delta) } } -ActionPtr NetworkConstantModel::communicate(RoutingEdgePtr src, RoutingEdgePtr dst, +Action *NetworkConstantModel::communicate(RoutingEdge *src, RoutingEdge *dst, double size, double rate) { char *src_name = src->getName(); char *dst_name = dst->getName(); XBT_IN("(%s,%s,%g,%g)", src_name, dst_name, size, rate); - NetworkConstantActionPtr action = new NetworkConstantAction(this, size, sg_latency_factor); + NetworkConstantAction *action = new NetworkConstantAction(this, size, sg_latency_factor); XBT_OUT(); surf_callback_emit(networkCommunicateCallbacks, action, src, dst, size, rate); return action; } -/************ - * Resource * - ************/ -bool NetworkConstantLink::isUsed() -{ - return 0; -} - -void NetworkConstantLink::updateState(tmgr_trace_event_t /*event_type*/, - double /*value*/, double /*time*/) -{ - DIE_IMPOSSIBLE; -} - -double NetworkConstantLink::getBandwidth() -{ - DIE_IMPOSSIBLE; - return -1.0; /* useless since DIE actually abort(), but eclipse prefer to have a useless and harmless return */ -} - -double NetworkConstantLink::getLatency() -{ - DIE_IMPOSSIBLE; - return -1.0; /* useless since DIE actually abort(), but eclipse prefer to have a useless and harmless return */ -} - -bool NetworkConstantLink::isShared() -{ - DIE_IMPOSSIBLE; - return -1; /* useless since DIE actually abort(), but eclipse prefer to have a useless and harmless return */ -} - /********** * Action * **********/ @@ -128,7 +103,7 @@ int NetworkConstantAction::unref() { m_refcount--; if (!m_refcount) { - if (actionHook::is_linked()) + if (action_hook.is_linked()) p_stateSet->erase(p_stateSet->iterator_to(*this)); delete this; return 1; @@ -141,7 +116,7 @@ void NetworkConstantAction::cancel() return; } -void NetworkConstantAction::setCategory(const char */*category*/) +void NetworkConstantAction::setCategory(const char * /*category*/) { //ignore completely the categories in constant model, they are not traced } @@ -157,11 +132,6 @@ void NetworkConstantAction::resume() m_suspended = false; } -void NetworkConstantAction::recycle() -{ - return; -} - bool NetworkConstantAction::isSuspended() { return m_suspended;