Allow for mutexes and condvars to be shared among different processes.

[frescor/fosa.git] / src_aquosa / fosa_mutexes_and_condvars.c

diff --git a/src_aquosa/fosa_mutexes_and_condvars.c b/src_aquosa/fosa_mutexes_and_condvars.c
index 8b03c8d488cf8b41f1dd3a08fb7e266d43aa587e..889edc031cf000a21a10a87c131a2f0936f8883c 100644 (file)
--- a/src_aquosa/fosa_mutexes_and_condvars.c
+++ b/src_aquosa/fosa_mutexes_and_condvars.c
@@ -59,6 +59,7 @@
 //================================================
 
 #include "fosa_time.h"
+#include "fosa_configuration_parameters.h"
 #include "fosa_mutexes_and_condvars.h"
 
 #ifdef OMK_FOR_USER            /* If compiled by OMK, use the config */
@@ -86,16 +87,20 @@
  **/
 int fosa_mutex_init(fosa_mutex_t *mutex, int prioceiling)
 {
-       int error;
+       int ret;
        pthread_mutexattr_t attr;
 
-       if ((error = pthread_mutexattr_init(&attr)) != 0)
-               return error;
+       ret = pthread_mutexattr_init(&attr);
+       if (ret) return errno;
 
 #ifndef CONFIG_NO_PRIO_INHERIT /* Valgrind doesn't support this attribute */
-       if ((error = pthread_mutexattr_setprotocol(&attr, PTHREAD_PRIO_INHERIT)) != 0)
-               return error;
+       ret = pthread_mutexattr_setprotocol(&attr, PTHREAD_PRIO_INHERIT);
+       if (ret) return errno;
 #endif
+
+       ret = pthread_mutexattr_setpshared(&attr, PTHREAD_PROCESS_SHARED);
+       if (ret) return errno;
+
        return pthread_mutex_init(mutex, &attr);
 }
 
@@ -128,7 +133,7 @@ int fosa_mutex_set_prioceiling(fosa_mutex_t *mutex,
                               int new_ceiling,
                               int *old_ceiling)
 {
-       return -EINVAL;
+       return FOSA_EINVAL;
 }
 
 /**
@@ -142,7 +147,7 @@ int fosa_mutex_set_prioceiling(fosa_mutex_t *mutex,
  **/
 int fosa_mutex_get_prioceiling(const fosa_mutex_t *mutex, int *ceiling)
 {
-       return -EINVAL;
+       return FOSA_EINVAL;
 }
 
 /**
@@ -224,7 +229,19 @@ int fosa_mutex_unlock(fosa_mutex_t *mutex)
  **/
 int fosa_cond_init(fosa_cond_t *cond)
 {
-       return pthread_cond_init(cond, NULL);
+       int ret;
+       pthread_condattr_t attr;
+
+       ret = pthread_condattr_init(&attr);
+       if (ret) return errno;
+
+       ret = pthread_condattr_setclock(&attr, FOSA_CLOCK_REALTIME);
+       if (ret) return errno;
+
+       ret = pthread_condattr_setpshared(&attr, PTHREAD_PROCESS_SHARED);
+       if (ret) return errno;
+
+       return pthread_cond_init(cond, &attr);
 }
 
 /**
@@ -321,6 +338,6 @@ int fosa_cond_timedwait(fosa_cond_t *cond,
        struct timespec abstime_tspec;
 
        abstime_tspec = fosa_abs_time_to_timespec(*abstime);
-
        return pthread_cond_timedwait(cond, mutex, &abstime_tspec);
 }
+