src_partikle/fosa_mutexes_and_condvars.c

   1 // -----------------------------------------------------------------------
   2 //  Copyright (C) 2006 - 2007 FRESCOR consortium partners:
   3 //
   4 //    Universidad de Cantabria,              SPAIN
   5 //    University of York,                    UK
   6 //    Scuola Superiore Sant'Anna,            ITALY
   7 //    Kaiserslautern University,             GERMANY
   8 //    Univ. Politecnica  Valencia,           SPAIN
   9 //    Czech Technical University in Prague,  CZECH REPUBLIC
  10 //    ENEA                                   SWEDEN
  11 //    Thales Communication S.A.              FRANCE
  12 //    Visual Tools S.A.                      SPAIN
  13 //    Rapita Systems Ltd                     UK
  14 //    Evidence                               ITALY
  15 //
  16 //    See http://www.frescor.org for a link to partners' websites
  17 //
  18 //           FRESCOR project (FP6/2005/IST/5-034026) is funded
  19 //        in part by the European Union Sixth Framework Programme
  20 //        The European Union is not liable of any use that may be
  21 //        made of this code.
  22 //
  23 //  This file is part of the FRSH implementation
  24 //
  25 //  FRSH is free software; you can  redistribute it and/or  modify
  26 //  it under the terms of  the GNU General Public License as published by
  27 //  the Free Software Foundation;  either  version 2, or (at  your option)
  28 //  any later version.
  29 //
  30 //  FRSH  is distributed  in  the hope  that  it  will  be useful,  but
  31 //  WITHOUT  ANY  WARRANTY;     without  even the   implied   warranty  of
  32 //  MERCHANTABILITY  or  FITNESS FOR  A  PARTICULAR PURPOSE. See  the  GNU
  33 //  General Public License for more details.
  34 //
  35 //  You should have  received a  copy of  the  GNU  General Public License
  36 //  distributed  with  FRSH;  see file COPYING.   If not,  write to the
  37 //  Free Software  Foundation,  59 Temple Place  -  Suite 330,  Boston, MA
  38 //  02111-1307, USA.
  39 //
  40 //  As a special exception, if you include this header file into source
  41 //  files to be compiled, this header file does not by itself cause
  42 //  the resulting executable to be covered by the GNU General Public
  43 //  License.  This exception does not however invalidate any other
  44 //  reasons why the executable file might be covered by the GNU General
  45 //  Public License.
  46 // -----------------------------------------------------------------------
  47 //==============================================
  48 //  ********  ******    ********  **********
  49 //  **///// /**    **  **//////  /**     /**
  50 //  **      /**    ** /**        /**     /**
  51 //  ******* /**    ** /********* /**********
  52 //  **////  /**    ** ////////** /**//////**
  53 //  **      /**    **        /** /**     /**
  54 //  **      /**    **  ********  /**     /**
  55 //  //       /******/  ////////   //      //
  56 //
  57 // FOSA(Frescor Operating System Adaptation layer)
  58 //================================================
  59
  60 #include <fosa_mutexes_and_condvars.h>
  61 #include <fosa_time.h>
  62
  63 /*******************************************************
  64  * Mutexes with priority ceiling
  65  ******************************************************/
  66 int fosa_mutex_init(fosa_mutex_t *mutex, int prioceiling)
  67 {
  68         pthread_mutexattr_t attr;
  69         int err;
  70
  71         err = pthread_mutexattr_init (&attr);
  72         if (err)
  73                 return err;
  74
  75         pthread_mutexattr_settype (&attr, PTHREAD_MUTEX_ERRORCHECK);
  76         pthread_mutexattr_setprotocol (&attr, PTHREAD_PRIO_PROTECT);
  77         err = pthread_mutexattr_setprioceiling (&attr, prioceiling);
  78         if (err)
  79                 return err;
  80
  81         return pthread_mutex_init (mutex, &attr);
  82 }
  83
  84 int fosa_mutex_destroy(fosa_mutex_t *mutex)
  85 {
  86         return pthread_mutex_destroy (mutex);
  87 }
  88
  89 int fosa_mutex_set_prioceiling
  90                 (fosa_mutex_t *mutex, int new_ceiling, int *old_ceiling)
  91 {
  92         return pthread_mutex_setprioceiling (mutex, new_ceiling, old_ceiling);
  93 }
  94
  95 int fosa_mutex_get_prioceiling(const fosa_mutex_t *mutex, int *ceiling)
  96 {
  97         return pthread_mutex_getprioceiling (mutex, ceiling);
  98 }
  99
 100 int fosa_mutex_lock(fosa_mutex_t *mutex)
 101 {
 102         return pthread_mutex_lock (mutex);
 103 }
 104
 105 int fosa_mutex_trylock(fosa_mutex_t *mutex)
 106 {
 107         return pthread_mutex_trylock (mutex);
 108 }
 109
 110 int fosa_mutex_unlock(fosa_mutex_t *mutex)
 111 {
 112         return pthread_mutex_unlock (mutex);
 113 }
 114
 115
 116 /**********************
 117  * Condition variables
 118  *********************/
 119 int fosa_cond_init(fosa_cond_t *cond)
 120 {
 121         pthread_condattr_t attr;
 122         int err;
 123
 124         err = pthread_condattr_init (&attr);
 125         if (err)
 126                 return err;
 127
 128         return pthread_cond_init (cond, NULL);
 129 }
 130
 131 int fosa_cond_destroy(fosa_cond_t *cond)
 132 {
 133         return pthread_cond_destroy (cond);
 134 }
 135
 136 int fosa_cond_signal(fosa_cond_t *cond)
 137 {
 138         return pthread_cond_signal (cond);
 139 }
 140
 141 int fosa_cond_broadcast(fosa_cond_t *cond)
 142 {
 143         return pthread_cond_broadcast (cond);
 144 }
 145
 146 int fosa_cond_wait(fosa_cond_t *cond, fosa_mutex_t *mutex)
 147 {
 148         return pthread_cond_wait (cond, mutex);
 149 }
 150
 151 int fosa_cond_timedwait (fosa_cond_t *cond, fosa_mutex_t *mutex,
 152                         const fosa_abs_time_t *abstime)
 153 {
 154         int err;
 155         struct timespec tout = fosa_abs_time_to_timespec (*abstime);
 156
 157         err = pthread_cond_timedwait (cond, mutex, &tout);
 158         if (err == ETIMEDOUT)
 159                 return FOSA_ETIMEDOUT;
 160
 161         if (err)
 162                 return FOSA_EINVAL;
 163
 164         return 0;
 165 }