X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ba9a4cfeba4eb00e84cd17603fc9654e81445655..0eead244337fde8f0508629f8f8473f946c19f88:/src/msg/msg_synchro.cpp diff --git a/src/msg/msg_synchro.cpp b/src/msg/msg_synchro.cpp index d88e01f655..4090fb3911 100644 --- a/src/msg/msg_synchro.cpp +++ b/src/msg/msg_synchro.cpp @@ -4,10 +4,12 @@ /* 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. */ +#include + #include "msg_private.h" -#include "xbt/sysdep.h" -#include "xbt/synchro_core.h" #include "xbt/log.h" +#include "xbt/synchro.h" +#include "xbt/sysdep.h" XBT_LOG_NEW_DEFAULT_SUBCATEGORY(msg_synchro, msg, "Logging specific to MSG (synchro)"); @@ -28,17 +30,13 @@ void MSG_sem_acquire(msg_sem_t sem) { /** @brief locks on a semaphore object up until the provided timeout expires */ msg_error_t MSG_sem_acquire_timeout(msg_sem_t sem, double timeout) { - xbt_ex_t e; msg_error_t res = MSG_OK; - TRY { + try { simcall_sem_acquire_timeout(sem,timeout); - } CATCH(e) { - if (e.category == timeout_error) { - res = MSG_TIMEOUT; - xbt_ex_free(e); - } else { - RETHROW; - } + } catch(xbt_ex& e) { + if (e.category == timeout_error) + return MSG_TIMEOUT; + throw; } return res; } @@ -48,8 +46,8 @@ void MSG_sem_release(msg_sem_t sem) { simcall_sem_release(sem); } -void MSG_sem_get_capacity(msg_sem_t sem) { - simcall_sem_get_capacity(sem); +int MSG_sem_get_capacity(msg_sem_t sem) { + return simcall_sem_get_capacity(sem); } void MSG_sem_destroy(msg_sem_t sem) { @@ -65,21 +63,44 @@ int MSG_sem_would_block(msg_sem_t sem) { return simcall_sem_would_block(sem); } +/*-**** barrier related functions ****-*/ +typedef struct s_msg_bar { + xbt_mutex_t mutex; + xbt_cond_t cond; + unsigned int arrived_processes; + unsigned int expected_processes; +} s_msg_bar_t; + /** @brief Initializes a barrier, with count elements */ msg_bar_t MSG_barrier_init(unsigned int count) { - return (msg_bar_t)xbt_barrier_init(count); + msg_bar_t bar = xbt_new0(s_msg_bar, 1); + bar->expected_processes = count; + bar->arrived_processes = 0; + bar->mutex = xbt_mutex_init(); + bar->cond = xbt_cond_init(); + return bar; } /** @brief Initializes a barrier, with count elements */ void MSG_barrier_destroy(msg_bar_t bar) { - xbt_barrier_destroy((xbt_bar_t)bar); + xbt_mutex_destroy(bar->mutex); + xbt_cond_destroy(bar->cond); + xbt_free(bar); } /** @brief Performs a barrier already initialized */ int MSG_barrier_wait(msg_bar_t bar) { - if(xbt_barrier_wait((xbt_bar_t)bar) == XBT_BARRIER_SERIAL_PROCESS) + xbt_mutex_acquire(bar->mutex); + bar->arrived_processes++; + if (bar->arrived_processes == bar->expected_processes) { + xbt_cond_broadcast(bar->cond); + xbt_mutex_release(bar->mutex); + bar->arrived_processes = 0; return MSG_BARRIER_SERIAL_PROCESS; - else - return 0; + } + + xbt_cond_wait(bar->cond, bar->mutex); + xbt_mutex_release(bar->mutex); + return 0; } /**@}*/