examples/s4u/io-async/s4u-io-async.cpp

   1 /* Copyright (c) 2007-2019. The SimGrid Team. All rights reserved.          */
   2
   3 /* This program is free software; you can redistribute it and/or modify it
   4  * under the terms of the license (GNU LGPL) which comes with this package. */
   5
   6 #include "simgrid/s4u.hpp"
   7
   8 XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_test, "Messages specific for this s4u example");
   9
  10 static void test(sg_size_t size)
  11 {
  12   simgrid::s4u::Disk* disk = simgrid::s4u::Disk::by_name("Disk1");
  13   XBT_INFO("Hello! read %llu bytes from %s", size, disk->get_cname());
  14
  15   simgrid::s4u::IoPtr activity = disk->io_init(size, simgrid::s4u::Io::OpType::READ);
  16   activity->start();
  17   activity->wait();
  18
  19   XBT_INFO("Goodbye now!");
  20 }
  21
  22 static void test_cancel(sg_size_t size)
  23 {
  24   simgrid::s4u::Disk* disk = simgrid::s4u::Disk::by_name("Disk2");
  25   XBT_INFO("Hello! write %llu bytes from %s", size, disk->get_cname());
  26
  27   simgrid::s4u::IoPtr activity = disk->write_async(size);
  28   simgrid::s4u::this_actor::sleep_for(0.5);
  29   XBT_INFO("I changed my mind, cancel!");
  30   activity->cancel();
  31
  32   XBT_INFO("Goodbye now!");
  33 }
  34
  35 int main(int argc, char* argv[])
  36 {
  37   simgrid::s4u::Engine e(&argc, argv);
  38   e.load_platform(argv[1]);
  39   simgrid::s4u::Actor::create("test", simgrid::s4u::Host::by_name("bob"), test, 2e7);
  40   simgrid::s4u::Actor::create("test_cancel", simgrid::s4u::Host::by_name("alice"), test_cancel, 5e7);
  41
  42   e.run();
  43
  44   XBT_INFO("Simulation time %g", e.get_clock());
  45
  46   return 0;
  47 }