X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a243b4c3535f516d05259cac06963c422d4aadc0..f70ee620c8df5cdf749f4dfbc9777359cd3cb12a:/examples/msg/cloud/multicore.c diff --git a/examples/msg/cloud/multicore.c b/examples/msg/cloud/multicore.c index 124769539d..28c409b9fa 100644 --- a/examples/msg/cloud/multicore.c +++ b/examples/msg/cloud/multicore.c @@ -1,10 +1,11 @@ -/* Copyright (c) 2007-2013. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2014. The SimGrid Team. + * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ #include -#include "msg/msg.h" +#include "simgrid/msg.h" #include "xbt/sysdep.h" /* calloc, printf */ /* Create a log channel to have nice outputs. */ @@ -36,14 +37,14 @@ struct task_data { static void task_data_init_clock(struct task_data *t) { - t->prev_computation_amount = MSG_task_get_remaining_computation(t->task); + t->prev_computation_amount = MSG_task_get_flops_amount(t->task); t->prev_clock = MSG_get_clock(); } static void task_data_get_clock(struct task_data *t) { - double now_computation_amount = MSG_task_get_remaining_computation(t->task); + double now_computation_amount = MSG_task_get_flops_amount(t->task); double now_clock = MSG_get_clock(); double done = t->prev_computation_amount - now_computation_amount; @@ -69,10 +70,10 @@ static void test_pm_pin(void) struct task_data t3; struct task_data t4; - t1.task = MSG_task_create("Task1", 10000000000000000UL, 0, NULL); - t2.task = MSG_task_create("Task2", 10000000000000000UL, 0, NULL); - t3.task = MSG_task_create("Task3", 10000000000000000UL, 0, NULL); - t4.task = MSG_task_create("Task4", 10000000000000000UL, 0, NULL); + t1.task = MSG_task_create("Task1", 1e16, 0, NULL); + t2.task = MSG_task_create("Task2", 1e16, 0, NULL); + t3.task = MSG_task_create("Task3", 1e16, 0, NULL); + t4.task = MSG_task_create("Task4", 1e16, 0, NULL); MSG_process_create("worker1", worker_main, t1.task, pm1); MSG_process_create("worker2", worker_main, t2.task, pm1); @@ -176,7 +177,7 @@ static void test_vm_pin(void) msg_vm_t vm2 = MSG_vm_create_core(pm2, "VM2"); msg_vm_t vm3 = MSG_vm_create_core(pm2, "VM3"); - s_ws_params_t params; + s_vm_params_t params; memset(¶ms, 0, sizeof(params)); params.ramsize = 1L * 1024 * 1024; params.skip_stage1 = 1; @@ -199,10 +200,10 @@ static void test_vm_pin(void) struct task_data t2; struct task_data t3; - t0.task = MSG_task_create("Task0", 10000000000000000UL, 0, NULL); - t1.task = MSG_task_create("Task1", 10000000000000000UL, 0, NULL); - t2.task = MSG_task_create("Task2", 10000000000000000UL, 0, NULL); - t3.task = MSG_task_create("Task3", 10000000000000000UL, 0, NULL); + t0.task = MSG_task_create("Task0", 1e16, 0, NULL); + t1.task = MSG_task_create("Task1", 1e16, 0, NULL); + t2.task = MSG_task_create("Task2", 1e16, 0, NULL); + t3.task = MSG_task_create("Task3", 1e16, 0, NULL); MSG_process_create("worker0", worker_main, t0.task, vm0); MSG_process_create("worker1", worker_main, t1.task, vm1);