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 #include "../simix/smx_private.h" /* FIXME */
  17
  18 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(xbt_sync, xbt,
  19                                 "Synchronization mechanism");
  20
  21 /****** mutex related functions ******/
  22 struct s_xbt_mutex_ {
  23   s_smx_mutex_t mutex;
  24 };
  25
  26 xbt_mutex_t xbt_mutex_init(void)
  27 {
  28   return (xbt_mutex_t) simcall_mutex_init();
  29 }
  30
  31 void xbt_mutex_acquire(xbt_mutex_t mutex)
  32 {
  33   simcall_mutex_lock((smx_mutex_t) mutex);
  34 }
  35
  36 int xbt_mutex_try_acquire(xbt_mutex_t mutex)
  37 {
  38   return simcall_mutex_trylock((smx_mutex_t) mutex);
  39 }
  40
  41 void xbt_mutex_release(xbt_mutex_t mutex)
  42 {
  43   simcall_mutex_unlock((smx_mutex_t) mutex);
  44 }
  45
  46 void xbt_mutex_destroy(xbt_mutex_t mutex)
  47 {
  48   SIMIX_mutex_destroy((smx_mutex_t) mutex);
  49 }
  50
  51 /***** condition related functions *****/
  52 struct s_xbt_cond_ {
  53   s_smx_cond_t cond;
  54 };
  55
  56 xbt_cond_t xbt_cond_init(void)
  57 {
  58   return (xbt_cond_t) simcall_cond_init();
  59 }
  60
  61 void xbt_cond_wait(xbt_cond_t cond, xbt_mutex_t mutex)
  62 {
  63   simcall_cond_wait((smx_cond_t) cond, (smx_mutex_t) mutex);
  64 }
  65
  66 void xbt_cond_timedwait(xbt_cond_t cond, xbt_mutex_t mutex, double delay)
  67 {
  68   simcall_cond_wait_timeout((smx_cond_t) cond, (smx_mutex_t) mutex, delay);
  69 }
  70
  71 void xbt_cond_signal(xbt_cond_t cond)
  72 {
  73   simcall_cond_signal((smx_cond_t) cond);
  74 }
  75
  76 void xbt_cond_broadcast(xbt_cond_t cond)
  77 {
  78   simcall_cond_broadcast((smx_cond_t) cond);
  79 }
  80
  81 void xbt_cond_destroy(xbt_cond_t cond)
  82 {
  83   SIMIX_cond_destroy((smx_cond_t) cond);
  84 }
  85
  86 /***** barrier related functions *****/
  87 typedef struct s_xbt_bar_ {
  88   xbt_mutex_t mutex;
  89   xbt_cond_t cond;
  90   unsigned int arrived_processes;
  91   unsigned int expected_processes;
  92 } s_xbt_bar_;
  93
  94 xbt_bar_t xbt_barrier_init(unsigned int count)
  95 {
  96   xbt_bar_t bar = xbt_new0(s_xbt_bar_, 1);
  97   bar->expected_processes = count;
  98   bar->arrived_processes = 0;
  99   bar->mutex = xbt_mutex_init();
 100   bar->cond = xbt_cond_init();
 101   return bar;
 102 }
 103
 104
 105 int xbt_barrier_wait(xbt_bar_t bar)
 106 {
 107    int ret=0;
 108    xbt_mutex_acquire(bar->mutex);
 109    if (++bar->arrived_processes == bar->expected_processes) {
 110      xbt_cond_broadcast(bar->cond);
 111      xbt_mutex_release(bar->mutex);
 112      ret=XBT_BARRIER_SERIAL_PROCESS;
 113      bar->arrived_processes = 0;
 114    } else {
 115      xbt_cond_wait(bar->cond, bar->mutex);
 116      xbt_mutex_release(bar->mutex);
 117    }
 118
 119    return ret;
 120 }
 121
 122 void xbt_barrier_destroy(xbt_bar_t bar)
 123 {
 124    xbt_mutex_destroy(bar->mutex);
 125    xbt_cond_destroy(bar->cond);
 126    xbt_free(bar);
 127 }
 128