X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/99c75b59f07f933766771d5e8a0a525cf83387dc..2c0aa88e3d941e79fc79d39e3e58224d282b76d3:/examples/smpi/replay_multiple_manual_deploy/replay_multiple_manual.cpp diff --git a/examples/smpi/replay_multiple_manual_deploy/replay_multiple_manual.cpp b/examples/smpi/replay_multiple_manual_deploy/replay_multiple_manual.cpp index 4ccbb8aa7a..2e769f6ca8 100644 --- a/examples/smpi/replay_multiple_manual_deploy/replay_multiple_manual.cpp +++ b/examples/smpi/replay_multiple_manual_deploy/replay_multiple_manual.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2009-2018. The SimGrid Team. +/* Copyright (c) 2009-2020. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -14,7 +14,7 @@ This is done to avoid SMPI actors to start at actor_id=0. 3. For each job: 1. Sleep until job's starting time is reached (if needed) - 2. Launch the replay of the corresponding time-indepent trace. + 2. Launch the replay of the corresponding time-independent trace. 3. Create inter-process noise, by spawning useless actors. 4. Wait for completion (via s4u::Engine's run method) */ @@ -65,7 +65,7 @@ static void smpi_replay_process(Job* job, simgrid::s4u::BarrierPtr barrier, int } // Sleeps for a given amount of time -static int sleeper_process(int* param) +static int sleeper_process(const int* param) { XBT_DEBUG("Sleeping for %d seconds", *param); simgrid::s4u::this_actor::sleep_for(*param); @@ -79,8 +79,7 @@ static int sleeper_process(int* param) static void pop_some_processes(int nb_processes, simgrid::s4u::Host* host) { for (int i = 0; i < nb_processes; ++i) { - int* param = new int; - *param = i + 1; + auto* param = new int(i + 1); simgrid::s4u::Actor::create("meh", host, sleeper_process, param); } } @@ -106,7 +105,7 @@ static int job_executor_process(Job* job) } // Executes a workload of SMPI processes -static int workload_executor_process(std::vector* workload) +static int workload_executor_process(const std::vector* workload) { for (Job* job : *workload) { // Let's wait until the job's waiting time if needed