tasks. At SURF level, only computation_amount and communication_amount
should be used. Get rid off amount in *execute_parallel_task functions.
Use 1 when creating the surf action.
void **workstation_list,
double *computation_amount,
double *communication_amount,
void **workstation_list,
double *computation_amount,
double *communication_amount,
- double amount, double rate);
double (*get_link_bandwidth) (const void *link); /**< Return the current bandwidth of a network link */
double (*get_link_latency) (const void *link); /**< Return the current latency of a network link */
surf_action_t(*open) (void *workstation, const char* storage, const char* path, const char* mode);
double (*get_link_bandwidth) (const void *link); /**< Return the current bandwidth of a network link */
double (*get_link_latency) (const void *link); /**< Return the current latency of a network link */
surf_action_t(*open) (void *workstation, const char* storage, const char* path, const char* mode);
action->execution.surf_exec =
surf_workstation_model->extension.workstation.
execute_parallel_task(host_nb, workstation_list, computation_amount,
action->execution.surf_exec =
surf_workstation_model->extension.workstation.
execute_parallel_task(host_nb, workstation_list, computation_amount,
- communication_amount, amount, rate);
+ communication_amount, rate);
surf_workstation_model->action_data_set(action->execution.surf_exec, action);
}
surf_workstation_model->action_data_set(action->execution.surf_exec, action);
}
void **workstation_list,
double *computation_amount,
double *communication_amount,
void **workstation_list,
double *computation_amount,
double *communication_amount,
- double amount, double rate)
{
THROW_UNIMPLEMENTED; /* This model does not implement parallel tasks */
return NULL;
{
THROW_UNIMPLEMENTED; /* This model does not implement parallel tasks */
return NULL;
double
*computation_amount, double
*communication_amount,
double
*computation_amount, double
*communication_amount,
double rate)
{
surf_action_workstation_L07_t action = NULL;
double rate)
{
surf_action_workstation_L07_t action = NULL;
- surf_action_new(sizeof(s_surf_action_workstation_L07_t), amount,
+ surf_action_new(sizeof(s_surf_action_workstation_L07_t), 1,
surf_workstation_model, 0);
XBT_DEBUG("Creating a parallel task (%p) with %d cpus and %d links.",
action, workstation_nb, nb_link);
surf_workstation_model, 0);
XBT_DEBUG("Creating a parallel task (%p) with %d cpus and %d links.",
action, workstation_nb, nb_link);
return ptask_execute_parallel_task(1, workstation_list,
computation_amount,
return ptask_execute_parallel_task(1, workstation_list,
computation_amount,
- communication_amount, 1, -1);
+ communication_amount, -1);
}
static surf_action_t ptask_communicate(void *src, void *dst, double size,
}
static surf_action_t ptask_communicate(void *src, void *dst, double size,
res = ptask_execute_parallel_task(2, workstation_list,
computation_amount,
res = ptask_execute_parallel_task(2, workstation_list,
computation_amount,
- communication_amount, 1, rate);
+ communication_amount, rate);