simgrid::surf::HostModel *surf_host_model = NULL;
-void host_add_traces(){
- surf_host_model->addTraces();
-}
-
/*************
* Callbacks *
*************/
iter != VMModel::ws_vms.end(); ++iter) {
VirtualMachine *ws_vm = &*iter;
- CpuCas01 *cpu_cas01 = static_cast<CpuCas01*>(ws_vm->p_cpu);
- xbt_assert(cpu_cas01, "cpu-less host");
+ Cpu *cpu = ws_vm->p_cpu;
- int is_active = lmm_constraint_used(cpu_cas01->getModel()->getMaxminSystem(), cpu_cas01->getConstraint());
- // int is_active_old = constraint_is_active(cpu_cas01);
+ int is_active = lmm_constraint_used(cpu->getModel()->getMaxminSystem(), cpu->getConstraint());
if (is_active) {
/* some tasks exist on this VM */
}
}
+Action *HostModel::executeParallelTask(int host_nb,
+ sg_host_t *host_list,
+ double *flops_amount,
+ double *bytes_amount,
+ double rate){
+#define cost_or_zero(array,pos) ((array)?(array)[pos]:0.0)
+ Action *action =NULL;
+ if ((host_nb == 1)
+ && (cost_or_zero(bytes_amount, 0) == 0.0)){
+ action = host_list[0]->pimpl_cpu->execute(flops_amount[0]);
+ } else if ((host_nb == 1)
+ && (cost_or_zero(flops_amount, 0) == 0.0)) {
+ action = surf_network_model->communicate(host_list[0]->pimpl_netcard,
+ host_list[0]->pimpl_netcard,
+ bytes_amount[0], rate);
+ } else if ((host_nb == 2)
+ && (cost_or_zero(flops_amount, 0) == 0.0)
+ && (cost_or_zero(flops_amount, 1) == 0.0)) {
+ int i,nb = 0;
+ double value = 0.0;
+
+ for (i = 0; i < host_nb * host_nb; i++) {
+ if (cost_or_zero(bytes_amount, i) > 0.0) {
+ nb++;
+ value = cost_or_zero(bytes_amount, i);
+ }
+ }
+ if (nb == 1){
+ action = surf_network_model->communicate(host_list[0]->pimpl_netcard,
+ host_list[1]->pimpl_netcard,
+ value, rate);
+ }
+ } else
+ THROW_UNIMPLEMENTED; /* This model does not implement parallel tasks for more than 2 hosts */
+#undef cost_or_zero
+ xbt_free(host_list);
+ return action;
+}
+
/************
* Resource *
************/