/* update remains before return it */
if(cpu_update_mechanism == UM_LAZY)
cpu_update_remains(ACTION_GET_CPU(action), surf_get_clock());
- return action->remains;
XBT_OUT();
+ return action->remains;
}
static e_surf_resource_state_t cpu_get_state(void *cpu)
cpu_ti_update_remaining_amount((cpu_ti_t)
((surf_action_cpu_ti_t) action)->cpu,
surf_get_clock());
- return action->remains;
XBT_OUT();
+ return action->remains;
}
static e_surf_resource_state_t cpu_ti_get_state(void *cpu)
static int selective_update = 0;
static int net_action_is_suspended(surf_action_t action);
-static void net_update_actions_state(double now, double delta);
static void update_action_remaining(double now);
static xbt_swag_t net_modified_set = NULL;
static xbt_heap_t net_action_heap = NULL;
xbt_swag_t keep_track = NULL;
-extern int sg_maxmin_selective_update;
#ifdef HAVE_SMPI
static void gap_append(double size, const link_CM02_t link, surf_action_network_CM02_t action);
static double netcste_get_link_bandwidth(const void *link)
{
DIE_IMPOSSIBLE;
+ return -1.0;
}
static double netcste_get_link_latency(const void *link)
{
DIE_IMPOSSIBLE;
+ return -1.0;
}
static int link_shared(const void *link)
{
DIE_IMPOSSIBLE;
+ return -1;
}
static void netcste_action_suspend(surf_action_t action)
static int int_die_impossible_paction(surf_action_t action)
{
DIE_IMPOSSIBLE;
+ return -1;
}
/** @brief initialize common datastructures to all models */
#include "surf_routing_private.h"
/* Global vars */
-extern routing_global_t global_routing;
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_route_cluster, surf, "Routing part of surf");
xbt_dynar_t generic_get_onelink_routes(AS_t rc) { // FIXME: kill that stub
xbt_die("\"generic_get_onelink_routes\" not implemented yet");
+ return NULL;
}
route_t generic_get_bypassroute(AS_t rc, const char *src, const char *dst)
/* Global vars */
extern routing_global_t global_routing;
-extern xbt_dynar_t parsed_link_list;
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_route_rulebased, surf, "Routing part of surf");
break;
default:
surf_parse_error(bprintf("invalid state for link %s",link.id));
+ break;
}
link.state_trace = tmgr_trace_new(A_surfxml_link_state_file);
break;
default:
surf_parse_error(bprintf("Invalid sharing policy in link %s",link.id));
+ break;
}
sg_platf_new_link(&link);
static int ws_resource_used(void *resource_id)
{
THROW_IMPOSSIBLE; /* This model does not implement parallel tasks */
+ return -1;
}
static void ws_parallel_action_cancel(surf_action_t action)
static int ws_parallel_action_free(surf_action_t action)
{
THROW_UNIMPLEMENTED; /* This model does not implement parallel tasks */
+ return -1;
}
static int ws_action_unref(surf_action_t action)
if (action->model_type == surf_cpu_model)
return surf_cpu_model->is_suspended(action);
DIE_IMPOSSIBLE;
+ return -1;
}
static void ws_action_set_max_duration(surf_action_t action,
if (action->model_type == surf_cpu_model)
return surf_cpu_model->get_remains(action);
DIE_IMPOSSIBLE;
+ return -1.0;
}
static surf_action_t ws_communicate(void *workstation_src,
double amount, double rate)
{
THROW_UNIMPLEMENTED; /* This model does not implement parallel tasks */
+ return NULL;
}
static double ptask_action_get_remains(surf_action_t action)
{
XBT_IN("(%p)", action);
- return action->remains;
XBT_OUT();
+ return action->remains;
}
/**************************************/