src/xbt/xbt_os_synchro.c

   1 /* xbt_synchro -- Synchronization virtualized depending on whether we are   */
   2 /*                in simulation or real life (act on simulated processes)   */
   3
   4 /* This is the simulation implementation, using simix.                      */
   5
   6 /* Copyright (c) 2007-2016. The SimGrid Team.
   7  * All rights reserved.                                                     */
   8
   9 /* This program is free software; you can redistribute it and/or modify it
  10  * under the terms of the license (GNU LGPL) which comes with this package. */
  11
  12 #include "xbt/ex.h"
  13 #include "xbt/synchro_core.h"
  14
  15 #include "simgrid/simix.h"        /* used implementation */
  16
  17 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(xbt_sync, xbt, "Synchronization mechanism");
  18
  19 /****** mutex related functions ******/
  20 xbt_mutex_t xbt_mutex_init(void)
  21 {
  22   return (xbt_mutex_t) simcall_mutex_init();
  23 }
  24
  25 void xbt_mutex_acquire(xbt_mutex_t mutex)
  26 {
  27   simcall_mutex_lock((smx_mutex_t) mutex);
  28 }
  29
  30 int xbt_mutex_try_acquire(xbt_mutex_t mutex)
  31 {
  32   return simcall_mutex_trylock((smx_mutex_t) mutex);
  33 }
  34
  35 void xbt_mutex_release(xbt_mutex_t mutex)
  36 {
  37   simcall_mutex_unlock((smx_mutex_t) mutex);
  38 }
  39
  40 void xbt_mutex_destroy(xbt_mutex_t mutex)
  41 {
  42   SIMIX_mutex_unref((smx_mutex_t) mutex);
  43 }
  44
  45 /***** condition related functions *****/
  46 xbt_cond_t xbt_cond_init(void)
  47 {
  48   return (xbt_cond_t) simcall_cond_init();
  49 }
  50
  51 void xbt_cond_wait(xbt_cond_t cond, xbt_mutex_t mutex)
  52 {
  53   simcall_cond_wait((smx_cond_t) cond, (smx_mutex_t) mutex);
  54 }
  55
  56 void xbt_cond_timedwait(xbt_cond_t cond, xbt_mutex_t mutex, double delay)
  57 {
  58   simcall_cond_wait_timeout((smx_cond_t) cond, (smx_mutex_t) mutex, delay);
  59 }
  60
  61 void xbt_cond_signal(xbt_cond_t cond)
  62 {
  63   simcall_cond_signal((smx_cond_t) cond);
  64 }
  65
  66 void xbt_cond_broadcast(xbt_cond_t cond)
  67 {
  68   simcall_cond_broadcast((smx_cond_t) cond);
  69 }
  70
  71 void xbt_cond_destroy(xbt_cond_t cond)
  72 {
  73   SIMIX_cond_unref((smx_cond_t) cond);
  74 }
  75
  76 /***** barrier related functions *****/
  77 typedef struct s_xbt_bar_ {
  78   xbt_mutex_t mutex;
  79   xbt_cond_t cond;
  80   unsigned int arrived_processes;
  81   unsigned int expected_processes;
  82 } s_xbt_bar_;
  83
  84 xbt_bar_t xbt_barrier_init(unsigned int count)
  85 {
  86   xbt_bar_t bar = xbt_new0(s_xbt_bar_, 1);
  87   bar->expected_processes = count;
  88   bar->arrived_processes = 0;
  89   bar->mutex = xbt_mutex_init();
  90   bar->cond = xbt_cond_init();
  91   return bar;
  92 }
  93
  94 int xbt_barrier_wait(xbt_bar_t bar)
  95 {
  96    int ret=0;
  97    xbt_mutex_acquire(bar->mutex);
  98    if (++bar->arrived_processes == bar->expected_processes) {
  99      xbt_cond_broadcast(bar->cond);
 100      xbt_mutex_release(bar->mutex);
 101      ret=XBT_BARRIER_SERIAL_PROCESS;
 102      bar->arrived_processes = 0;
 103    } else {
 104      xbt_cond_wait(bar->cond, bar->mutex);
 105      xbt_mutex_release(bar->mutex);
 106    }
 107    return ret;
 108 }
 109
 110 void xbt_barrier_destroy(xbt_bar_t bar)
 111 {
 112    xbt_mutex_destroy(bar->mutex);
 113    xbt_cond_destroy(bar->cond);
 114    xbt_free(bar);
 115 }