X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7b04ac2704aebd762fb95fdf6694335595fee8dd..83f0364920918d0380a5d538216193bfe00ddc47:/examples/c/cloud-masterworker/cloud-masterworker.c?ds=sidebyside diff --git a/examples/c/cloud-masterworker/cloud-masterworker.c b/examples/c/cloud-masterworker/cloud-masterworker.c index 911fe8bbca..f3a4b032dd 100644 --- a/examples/c/cloud-masterworker/cloud-masterworker.c +++ b/examples/c/cloud-masterworker/cloud-masterworker.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2020. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2021. 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. */ @@ -11,9 +11,9 @@ #include "simgrid/plugins/live_migration.h" #include "simgrid/vm.h" -#include "xbt/asserts.h" #include "xbt/log.h" #include "xbt/str.h" +#include "xbt/sysdep.h" XBT_LOG_NEW_DEFAULT_CATEGORY(cloud_masterworker, "Messages specific for this example"); @@ -21,14 +21,14 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(cloud_masterworker, "Messages specific for this exa #define FINALIZE 221297 /* a magic number to tell people to stop working */ const double comp_size = 10000000; -const double comm_size = 10000000; +const long comm_size = 10000000; static void send_tasks(int nb_workers) { for (int i = 0; i < nb_workers; i++) { char mbox_name[MAXMBOXLEN]; snprintf(mbox_name, MAXMBOXLEN, "MBOX:WRK%02d", i); - double* payload = (double*)malloc(sizeof(double)); + double* payload = xbt_malloc(sizeof(double)); *payload = comp_size; sg_mailbox_t mbox = sg_mailbox_by_name(mbox_name); @@ -37,7 +37,7 @@ static void send_tasks(int nb_workers) } } -static void worker_fun(XBT_ATTRIB_UNUSED int argc, XBT_ATTRIB_UNUSED char* argv[]) +static void worker_fun(int argc, char* argv[]) { const char* pr_name = sg_actor_self_get_name(); char mbox_name[MAXMBOXLEN]; @@ -63,11 +63,11 @@ static void worker_fun(XBT_ATTRIB_UNUSED int argc, XBT_ATTRIB_UNUSED char* argv[ } } -static void master_fun(XBT_ATTRIB_UNUSED int argc, XBT_ATTRIB_UNUSED char* argv[]) +static void master_fun(int argc, char* argv[]) { - sg_host_t* worker_pms = sg_actor_self_data(); + sg_host_t* worker_pms = sg_actor_self_get_data(); - sg_vm_t* vms = (sg_vm_t*)malloc(2 * sizeof(sg_vm_t)); + sg_vm_t* vms = xbt_malloc(2 * sizeof(sg_vm_t)); /* Launch VMs and worker actors. One VM per PM, and one worker actor per VM. */ XBT_INFO("# Launch 2 VMs"); @@ -146,7 +146,7 @@ static void master_fun(XBT_ATTRIB_UNUSED int argc, XBT_ATTRIB_UNUSED char* argv[ char mbox_name[MAXMBOXLEN]; snprintf(mbox_name, MAXMBOXLEN, "MBOX:WRK%02d", i); sg_mailbox_t mbox = sg_mailbox_by_name(mbox_name); - double* payload = (double*)malloc(sizeof(double)); + double* payload = xbt_malloc(sizeof(double)); *payload = FINALIZE; sg_mailbox_put(mbox, payload, 0); } @@ -185,14 +185,14 @@ int main(int argc, char* argv[]) /* the first pm is the master, the others are workers */ sg_host_t master_pm = pms[0]; - sg_host_t* worker_pms = (sg_host_t*)malloc(2 * sizeof(sg_host_t)); + sg_host_t* worker_pms = xbt_malloc(2 * sizeof(sg_host_t)); for (int i = 0; i < 2; i++) worker_pms[i] = pms[i + 1]; free(pms); sg_actor_t actor = sg_actor_init("master", master_pm); - sg_actor_data_set(actor, worker_pms); + sg_actor_set_data(actor, worker_pms); sg_actor_start(actor, master_fun, 0, NULL); simgrid_run();