examples/c/synchro-semaphore/synchro-semaphore.c

   1 /* Copyright (c) 2013-2021. The SimGrid Team.
   2  * All rights reserved.                                                     */
   3
   4 /* This program is free software; you can redistribute it and/or modify it
   5  * under the terms of the license (GNU LGPL) which comes with this package. */
   6
   7 #include "simgrid/actor.h"
   8 #include "simgrid/engine.h"
   9 #include "simgrid/host.h"
  10 #include "simgrid/semaphore.h"
  11
  12 #include "xbt/log.h"
  13 #include "xbt/str.h"
  14
  15 XBT_LOG_NEW_DEFAULT_CATEGORY(semaphores, "Messages specific for this example");
  16
  17 sg_sem_t sem;
  18
  19 static void peer(int argc, char* argv[])
  20 {
  21   int i = 0;
  22   while (i < argc) {
  23     double wait_time = xbt_str_parse_double(argv[i], "Invalid wait time: %s");
  24     i++;
  25     sg_actor_sleep_for(wait_time);
  26     XBT_INFO("Trying to acquire %d", i);
  27     sg_sem_acquire(sem);
  28     XBT_INFO("Acquired %d", i);
  29
  30     wait_time = xbt_str_parse_double(argv[i], "Invalid wait time: %s");
  31     i++;
  32     sg_actor_sleep_for(wait_time);
  33     XBT_INFO("Releasing %d", i);
  34     sg_sem_release(sem);
  35     XBT_INFO("Released %d", i);
  36   }
  37   sg_actor_sleep_for(50);
  38   XBT_INFO("Done");
  39 }
  40
  41 int main(int argc, char* argv[])
  42 {
  43   simgrid_init(&argc, argv);
  44   simgrid_load_platform(argv[1]);
  45
  46   sg_host_t h = sg_host_by_name("Fafard");
  47
  48   sem                      = sg_sem_init(1);
  49   const char* aliceTimes[] = {"0", "1", "3", "5", "1", "2", "5", "0"};
  50   const char* bobTimes[]   = {"0.9", "1", "1", "2", "2", "0", "0", "5"};
  51
  52   sg_actor_create("Alice", h, peer, 8, aliceTimes);
  53   sg_actor_create("Bob", h, peer, 8, bobTimes);
  54
  55   simgrid_run();
  56   sg_sem_destroy(sem);
  57   XBT_INFO("Finished\n");
  58   return 0;
  59 }