sal/osl/unx/mutex.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #if defined LINUX
  21 // to define __USE_UNIX98, via _XOPEN_SOURCE, enabling pthread_mutexattr_settype
  22 #ifndef _GNU_SOURCE
  23 #define _GNU_SOURCE 1
  24 #endif
  25 #endif
  26 #include "unixerrnostring.hxx"
  27
  28 #include <sal/log.hxx>
  29 #include <osl/mutex.h>
  30
  31 #include <pthread.h>
  32 #include <stdlib.h>
  33
  34
  35 typedef struct _oslMutexImpl
  36 {
  37     pthread_mutex_t mutex;
  38 } oslMutexImpl;
  39
  40 oslMutex SAL_CALL osl_createMutex()
  41 {
  42     oslMutexImpl* pMutex = static_cast<oslMutexImpl*>(malloc(sizeof(oslMutexImpl)));
  43     pthread_mutexattr_t aMutexAttr;
  44     int nRet=0;
  45
  46     SAL_WARN_IF(!pMutex, "sal.osl.mutex", "null pMutex");
  47
  48     if ( pMutex == nullptr )
  49     {
  50         return nullptr;
  51     }
  52
  53     pthread_mutexattr_init(&aMutexAttr);
  54
  55     nRet = pthread_mutexattr_settype(&aMutexAttr, PTHREAD_MUTEX_RECURSIVE);
  56     if( nRet == 0 )
  57         nRet = pthread_mutex_init(&(pMutex->mutex), &aMutexAttr);
  58     if ( nRet != 0 )
  59     {
  60         SAL_WARN("sal.osl.mutex", "pthread_muxex_init failed: " << UnixErrnoString(nRet));
  61
  62         free(pMutex);
  63         pMutex = nullptr;
  64     }
  65
  66     pthread_mutexattr_destroy(&aMutexAttr);
  67
  68     return pMutex;
  69 }
  70
  71 void SAL_CALL osl_destroyMutex(oslMutex pMutex)
  72 {
  73     SAL_WARN_IF(!pMutex, "sal.osl.mutex", "null pMutex");
  74
  75     if ( pMutex != nullptr )
  76     {
  77         int nRet = pthread_mutex_destroy(&(pMutex->mutex));
  78         if ( nRet != 0 )
  79         {
  80             SAL_WARN("sal.osl.mutex", "pthread_mutex_destroy failed: " << UnixErrnoString(nRet));
  81         }
  82
  83         free(pMutex);
  84     }
  85 }
  86
  87 #ifdef __COVERITY__
  88     extern void __coverity_recursive_lock_acquire__(void*);
  89     extern void __coverity_recursive_lock_release__(void*);
  90     extern void __coverity_assert_locked__(void*);
  91 #endif
  92
  93 sal_Bool SAL_CALL osl_acquireMutex(oslMutex pMutex)
  94 {
  95     SAL_WARN_IF(!pMutex, "sal.osl.mutex", "null pMutex");
  96
  97     if ( pMutex != nullptr )
  98     {
  99         int nRet = pthread_mutex_lock(&(pMutex->mutex));
 100         if ( nRet != 0 )
 101         {
 102             SAL_WARN("sal.osl.mutex", "pthread_mutex_lock failed: " << UnixErrnoString(nRet));
 103             return false;
 104         }
 105 #ifdef __COVERITY__
 106     __coverity_recursive_lock_acquire__(pMutex);
 107 #endif
 108         return true;
 109     }
 110
 111     /* not initialized */
 112     return false;
 113 }
 114
 115 sal_Bool SAL_CALL osl_tryToAcquireMutex(oslMutex pMutex)
 116 {
 117     bool result = false;
 118
 119     SAL_WARN_IF(!pMutex, "sal.osl.mutex", "null pMutex");
 120
 121     if ( pMutex )
 122     {
 123         int nRet = pthread_mutex_trylock(&(pMutex->mutex));
 124         if ( nRet == 0  )
 125         {
 126 #ifdef __COVERITY__
 127             __coverity_recursive_lock_acquire__(pMutex);
 128 #endif
 129             result = true;
 130         }
 131     }
 132
 133     return result;
 134 }
 135
 136 sal_Bool SAL_CALL osl_releaseMutex(oslMutex pMutex)
 137 {
 138 #ifdef __COVERITY__
 139     __coverity_assert_locked__(pMutex);
 140 #endif
 141     SAL_WARN_IF(!pMutex, "sal.osl.mutex", "null pMutex");
 142
 143     if ( pMutex )
 144     {
 145         int nRet = pthread_mutex_unlock(&(pMutex->mutex));
 146         if ( nRet != 0 )
 147         {
 148             SAL_WARN("sal.osl.mutex", "pthread_mutex_unlock failed: " << UnixErrnoString(nRet));
 149             return false;
 150         }
 151
 152 #ifdef __COVERITY__
 153             __coverity_recursive_lock_release__(pMutex);
 154 #endif
 155         return true;
 156     }
 157
 158     /* not initialized */
 159     return false;
 160 }
 161
 162 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */