X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6d64076cb863913f0443de9e191934756abdae9c..d549f28334d919c9efe4cca11076418a3280bdec:/src/surf/surf_routing_vivaldi.c diff --git a/src/surf/surf_routing_vivaldi.c b/src/surf/surf_routing_vivaldi.c index 85b8fabd61..6ba2ebedb9 100644 --- a/src/surf/surf_routing_vivaldi.c +++ b/src/surf/surf_routing_vivaldi.c @@ -7,36 +7,27 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_route_vivaldi, surf, "Routing part of surf"); -/* Business methods */ -static route_extended_t vivaldi_get_route(routing_component_t rc, - const char *src, - const char *dst) -{ - xbt_assert(rc && src - && dst, - "Invalid params for \"get_route\" function at AS \"%s\"", - rc->name); +static XBT_INLINE double euclidean_dist_comp(int index, xbt_dynar_t src, xbt_dynar_t dst) { + double src_coord, dst_coord; + + src_coord = xbt_dynar_get_as(src, index, double); + dst_coord = xbt_dynar_get_as(dst, index, double); - route_extended_t new_e_route = xbt_new0(s_route_extended_t, 1); - new_e_route->src_gateway = ROUTER_PEER(src); - new_e_route->dst_gateway = ROUTER_PEER(dst); - new_e_route->generic_route.link_list = xbt_dynar_new(0, NULL); - return new_e_route; + return (src_coord-dst_coord)*(src_coord-dst_coord); } -static double euclidean_dist_comp(int index, xbt_dynar_t src, xbt_dynar_t dst) +static void vivaldi_get_route_and_latency( + AS_t rc, const char *src_p, const char *dst_p, + route_t route, double *lat) { - double src_coord, dst_coord; - - src_coord = atof(xbt_dynar_get_as(src, index, char *)); - dst_coord = atof(xbt_dynar_get_as(dst, index, char *)); + char *src = (char*)src_p; + char *dst = (char*)dst_p; - return (src_coord-dst_coord)*(src_coord-dst_coord); - -} + if(routing_get_network_element_type(src) == SURF_NETWORK_ELEMENT_AS) { + src = route->src_gateway = ROUTER_PEER(src); + dst = route->dst_gateway = ROUTER_PEER(dst); + } -static double base_vivaldi_get_latency (const char *src, const char *dst) -{ double euclidean_dist; xbt_dynar_t src_ctn, dst_ctn; src_ctn = xbt_lib_get_or_null(host_lib, src, COORD_HOST_LEVEL); @@ -44,37 +35,22 @@ static double base_vivaldi_get_latency (const char *src, const char *dst) dst_ctn = xbt_lib_get_or_null(host_lib, dst, COORD_HOST_LEVEL); if(!dst_ctn) dst_ctn = xbt_lib_get_or_null(as_router_lib, dst, COORD_ASR_LEVEL); - if(dst_ctn == NULL || src_ctn == NULL) - xbt_die("Coord src '%s' :%p dst '%s' :%p",src,src_ctn,dst,dst_ctn); + xbt_assert(src_ctn,"No coordinate found for element '%s'",src); + xbt_assert(dst_ctn,"No coordinate found for element '%s'",dst); euclidean_dist = sqrt (euclidean_dist_comp(0,src_ctn,dst_ctn)+euclidean_dist_comp(1,src_ctn,dst_ctn)) - + fabs(atof(xbt_dynar_get_as(src_ctn, 2, char *)))+fabs(atof(xbt_dynar_get_as(dst_ctn, 2, char *))); + + fabs(xbt_dynar_get_as(src_ctn, 2, double))+fabs(xbt_dynar_get_as(dst_ctn, 2, double)); - xbt_assert(euclidean_dist>=0, "Euclidean Dist is less than 0\"%s\" and \"%.2f\"", src, euclidean_dist); + if (lat) + *lat += euclidean_dist / 1000; //From .ms to .s - //From .ms to .s - return euclidean_dist / 1000; } -static double vivaldi_get_link_latency (routing_component_t rc,const char *src, const char *dst, route_extended_t e_route) -{ - if(get_network_element_type(src) == SURF_NETWORK_ELEMENT_AS) { - int need_to_clean = e_route?0:1; - double latency; - e_route = e_route?e_route:(*(rc->get_route)) (rc, src, dst); - latency = base_vivaldi_get_latency(e_route->src_gateway,e_route->dst_gateway); - if(need_to_clean) generic_free_extended_route(e_route); - return latency; - } else { - return base_vivaldi_get_latency(src,dst); - } -} /* Creation routing model functions */ -routing_component_t model_vivaldi_create(void) +AS_t model_vivaldi_create(void) { - routing_component_t new_component = model_none_create(); - new_component->get_route = vivaldi_get_route; - new_component->get_latency = vivaldi_get_link_latency; + AS_t new_component = model_rulebased_create(); + new_component->get_route_and_latency = vivaldi_get_route_and_latency; return new_component; }