X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4c753f8d4cabd4104f3f7109823f16be2ebdcce3..2ef958bf49890e4ac8fbe179f1d339b923fb67a8:/examples/cpp/energy-link/s4u-energy-link.cpp?ds=sidebyside diff --git a/examples/cpp/energy-link/s4u-energy-link.cpp b/examples/cpp/energy-link/s4u-energy-link.cpp index d8030250e3..b20ad0ad84 100644 --- a/examples/cpp/energy-link/s4u-energy-link.cpp +++ b/examples/cpp/energy-link/s4u-energy-link.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2017-2022. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2017-2023. 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. */ @@ -33,10 +33,10 @@ static void sender(std::vector args) mailbox->put(payload, comm_size); } else { // Start all comms in parallel, and wait for all completions in one shot - std::vector comms; + sg4::ActivitySet comms; for (int i = 0; i < flow_amount; i++) - comms.push_back(mailbox->put_async(bprintf("%d", i), comm_size)); - sg4::Comm::wait_all(comms); + comms.push(mailbox->put_async(bprintf("%d", i), comm_size)); + comms.wait_all(); } XBT_INFO("sender done."); } @@ -56,11 +56,11 @@ static void receiver(std::vector args) std::vector data(flow_amount); // Start all comms in parallel, and wait for their completion in one shot - std::vector comms; + sg4::ActivitySet comms; for (int i = 0; i < flow_amount; i++) - comms.push_back(mailbox->get_async(&data[i])); + comms.push(mailbox->get_async(&data[i])); - sg4::Comm::wait_all(comms); + comms.wait_all(); for (int i = 0; i < flow_amount; i++) xbt_free(data[i]); }