* under the terms of the license (GNU LGPL) which comes with this package. */
#include "surf_private.h"
+#include "surf/maxmin.h"
#include "surf/ns3/ns3_interface.h"
#include "xbt/lib.h"
#include "surf/network_ns3_private.h"
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_network_ns3, surf,
"Logging specific to the SURF network NS3 module");
-#define MAX_LENGHT_IPV4 16 //255.255.255.255\0
-
extern routing_global_t global_routing;
extern xbt_dict_t dict_socket;
str = xbt_strdup(buffer);
}
-static void replace_bdw_ns3(char * bdw)
+static void replace_bdw_ns3(char ** bdw)
{
- char *temp = xbt_strdup(bdw);
- xbt_free(bdw);
- bdw = bprintf("%fBps",atof(temp));
+ char *temp = xbt_strdup(*bdw);
+ xbt_free(*bdw);
+ *bdw = bprintf("%fBps",atof(temp));
xbt_free(temp);
}
-static void replace_lat_ns3(char * lat)
+static void replace_lat_ns3(char ** lat)
{
- char *temp = xbt_strdup(lat);
- xbt_free(lat);
- lat = bprintf("%fs",atof(temp));
+ char *temp = xbt_strdup(*lat);
+ xbt_free(*lat);
+ *lat = bprintf("%fs",atof(temp));
xbt_free(temp);
}
{
XBT_DEBUG("NS3_ADD_LINK '%s'",A_surfxml_link_id);
- if(!IPV4addr) IPV4addr = xbt_dynar_new(MAX_LENGHT_IPV4*sizeof(char),ns3_free_dynar);
+ if(!IPV4addr) IPV4addr = xbt_dynar_new(sizeof(char*),ns3_free_dynar);
tmgr_trace_t bw_trace;
tmgr_trace_t state_trace;
int elmts;
char * lat = xbt_strdup(cluster_lat);
char * bw = xbt_strdup(cluster_bw);
- replace_lat_ns3(lat);
- replace_bdw_ns3(bw);
+ replace_lat_ns3(&lat);
+ replace_bdw_ns3(&bw);
xbt_dynar_foreach(tab_elements_num,cpt,elmts)
{
//Create link backbone
lat = xbt_strdup(cluster_bb_lat);
bw = xbt_strdup(cluster_bb_bw);
- replace_lat_ns3(lat);
- replace_bdw_ns3(bw);
+ replace_lat_ns3(&lat);
+ replace_bdw_ns3(&bw);
ns3_add_cluster(bw,lat,A_surfxml_cluster_id);
xbt_free(lat);
xbt_free(bw);
XBT_DEBUG("Route from '%s' to '%s' with link '%s'",src,dst,((surf_ns3_link_t)link)->data->id);
char * link_bdw = bprintf("%s",((surf_ns3_link_t)link)->data->bdw);
char * link_lat = bprintf("%s",(((surf_ns3_link_t)link)->data->lat));
- replace_lat_ns3(link_lat);
- replace_bdw_ns3(link_bdw);
+ replace_lat_ns3(&link_lat);
+ replace_bdw_ns3(&link_bdw);
((surf_ns3_link_t)link)->created = 0;
// XBT_DEBUG("src (%s), dst (%s), src_id = %d, dst_id = %d",src,dst, src_id, dst_id);
surf_network_model->states.running_action_set;
//get the first relevant value from the running_actions list
- if (!xbt_swag_size(running_actions))
- return -1.0;
-
- ns3_simulator(min);
- time_to_next_flow_completion = ns3_time() - surf_get_clock();
-
-// XBT_INFO("min : %f",min);
-// XBT_INFO("ns3 time : %f",ns3_time());
-// XBT_INFO("surf time : %f",surf_get_clock());
+ if (!xbt_swag_size(running_actions) || min == 0.0)
+ return -1.0;
+ else
+ do {
+ ns3_simulator(min);
+ time_to_next_flow_completion = ns3_time() - surf_get_clock();
+ } while(double_equals(time_to_next_flow_completion,0));
+
+ XBT_DEBUG("min : %f",min);
+ XBT_DEBUG("ns3 time : %f",ns3_time());
+ XBT_DEBUG("surf time : %f",surf_get_clock());
+ XBT_DEBUG("Next completion %f :",time_to_next_flow_completion);
- xbt_assert(time_to_next_flow_completion,
- "Time to next flow completion not initialized!\n");
-
- XBT_DEBUG("ns3_share_resources return %f",time_to_next_flow_completion);
return time_to_next_flow_completion;
}
surf_network_model->states.running_action_set;
/* If there are no running flows, just return */
- if (!xbt_swag_size(running_actions))
- return;
+ if (!xbt_swag_size(running_actions)) {
+ while(double_positive(now-ns3_time())) {
+ ns3_simulator(now-ns3_time());
+ }
+ return;
+ }
xbt_dict_foreach(dict_socket,cursor,key,data){
action = (surf_action_network_ns3_t)ns3_get_socket_action(data);