Source/Base/Threading/OSGSemaphore.cpp

   1 /*---------------------------------------------------------------------------*\
   2  *                                OpenSG                                     *
   3  *                                                                           *
   4  *                                                                           *
   5  *             Copyright (C) 2000-2003 by the OpenSG Forum                   *
   6  *                                                                           *
   7  *                            www.opensg.org                                 *
   8  *                                                                           *
   9  *   contact: dirk@opensg.org, gerrit.voss@vossg.org, jbehr@zgdv.de          *
  10  *                                                                           *
  11 \*---------------------------------------------------------------------------*/
  12 /*---------------------------------------------------------------------------*\
  13  *                                License                                    *
  14  *                                                                           *
  15  * This library is free software; you can redistribute it and/or modify it   *
  16  * under the terms of the GNU Library General Public License as published    *
  17  * by the Free Software Foundation, version 2.                               *
  18  *                                                                           *
  19  * This library is distributed in the hope that it will be useful, but       *
  20  * WITHOUT ANY WARRANTY; without even the implied warranty of                *
  21  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU         *
  22  * Library General Public License for more details.                          *
  23  *                                                                           *
  24  * You should have received a copy of the GNU Library General Public         *
  25  * License along with this library; if not, write to the Free Software       *
  26  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.                 *
  27  *                                                                           *
  28 \*---------------------------------------------------------------------------*/
  29 /*---------------------------------------------------------------------------*\
  30  *                                Changes                                    *
  31  *                                                                           *
  32  *                                                                           *
  33  *                                                                           *
  34  *                                                                           *
  35  *                                                                           *
  36  *                                                                           *
  37 \*---------------------------------------------------------------------------*/
  38
  39 #include <cstdlib>
  40 #include <cstdio>
  41
  42 #include "OSGConfig.h"
  43
  44 #include <iostream>
  45
  46 #include "OSGSemaphore.h"
  47
  48 #include "OSGBaseFunctions.h"
  49
  50 #include "OSGThreadManager.h"
  51
  52 #include "OSGLog.h"
  53
  54 OSG_BEGIN_NAMESPACE
  55
  56 //---------------------------------------------------------------------------
  57 //  Class
  58 //---------------------------------------------------------------------------
  59
  60 /*--------------------------- Constructors --------------------------------*/
  61
  62 SemaphoreCommonBase::SemaphoreCommonBase(void) :
  63      Inherited    (NULL, true),
  64     _uiSemaphoreId(0         )
  65 {
  66 }
  67
  68 SemaphoreCommonBase::SemaphoreCommonBase(const Char8  *szName,
  69                                                UInt32  uiId,
  70                                                bool    bGlobal) :
  71      Inherited    (szName,
  72                    bGlobal),
  73     _uiSemaphoreId(uiId   )
  74 {
  75 }
  76
  77 /*---------------------------- Destructor ---------------------------------*/
  78
  79 SemaphoreCommonBase::~SemaphoreCommonBase(void)
  80 {
  81 }
  82
  83
  84
  85 #if defined (OSG_USE_PTHREADS)
  86
  87 //---------------------------------------------------------------------------
  88 //  Class
  89 //---------------------------------------------------------------------------
  90
  91 /*--------------------------- Constructors --------------------------------*/
  92
  93 PThreadSemaphoreBase::PThreadSemaphoreBase(void):
  94      Inherited         (),
  95     _pLowLevelSemaphore()
  96 {
  97 }
  98
  99 PThreadSemaphoreBase::PThreadSemaphoreBase(const Char8  *szName,
 100                                                  UInt32  uiId,
 101                                                  bool    bGlobal) :
 102      Inherited         (szName, uiId, bGlobal),
 103     _pLowLevelSemaphore(                     )
 104 {
 105 }
 106
 107 /*---------------------------- Destructor ---------------------------------*/
 108
 109 PThreadSemaphoreBase::~PThreadSemaphoreBase(void)
 110 {
 111 }
 112
 113 /*--------------------------- Construction --------------------------------*/
 114
 115 bool PThreadSemaphoreBase::init(void)
 116 {
 117     sem_init(&(_pLowLevelSemaphore), 0, 0);
 118
 119     return true;
 120 }
 121
 122 /*--------------------------- Destruction ---------------------------------*/
 123
 124 void PThreadSemaphoreBase::shutdown(void)
 125 {
 126     sem_destroy(&(_pLowLevelSemaphore));
 127 }
 128
 129
 130 #endif /* OSG_USE_PTHREADS */
 131
 132
 133
 134
 135 #if defined (OSG_USE_SPROC)
 136
 137 //---------------------------------------------------------------------------
 138 //  Class
 139 //---------------------------------------------------------------------------
 140
 141 /*--------------------------- Constructors --------------------------------*/
 142
 143 SprocSemaphoreBase::SprocSemaphoreBase(void):
 144      Inherited    (    ),
 145     _pLowLevelSema(NULL)
 146 {
 147 }
 148
 149 SprocSemaphoreBase::SprocSemaphoreBase(const Char8  *szName,
 150                                              UInt32  uiId,
 151                                              bool    bGlobal) :
 152      Inherited    (szName, uiId, bGlobal),
 153     _pLowLevelSema(NULL                 )
 154 {
 155 }
 156
 157 /*---------------------------- Destructor ---------------------------------*/
 158
 159 SprocSemaphoreBase::~SprocSemaphoreBase(void)
 160 {
 161 }
 162
 163 /*--------------------------- Construction --------------------------------*/
 164
 165 bool SprocSemaphoreBase::init(void)
 166 {
 167     ThreadManager *pThreadManager = ThreadManager::the();
 168
 169     if(pThreadManager == NULL)
 170         return false;
 171
 172     if(pThreadManager->getArena() == NULL)
 173         return false;
 174
 175     _pLowLevelSema = usnewsema(pThreadManager->getArena(), 1);
 176
 177     if(_pLowLevelSema == NULL)
 178         return false;
 179
 180     usinitsema(_pLowLevelSema, 1);
 181     usctlsema (_pLowLevelSema, CS_RECURSIVEON, NULL);
 182
 183     return true;
 184 }
 185
 186 /*--------------------------- Destruction ---------------------------------*/
 187
 188 void SprocSemaphoreBase::shutdown(void)
 189 {
 190     ThreadManager *pThreadManager = ThreadManager::the();
 191
 192     if(pThreadManager == NULL)
 193         return;
 194
 195     if(pThreadManager->getArena() == NULL)
 196         return;
 197
 198     if(_pLowLevelSema != NULL)
 199     {
 200         usfreesema(_pLowLevelSema, pThreadManager->getArena());
 201
 202         _pLowLevelSema = NULL;
 203     }
 204 }
 205
 206 /*----------------------------- Semaphore ---------------------------------*/
 207
 208 #endif /* OSG_USE_SPROC */
 209
 210
 211
 212 #if defined (OSG_USE_WINTHREADS)
 213
 214 //---------------------------------------------------------------------------
 215 //  Class
 216 //---------------------------------------------------------------------------
 217
 218 /*--------------------------- Constructors --------------------------------*/
 219
 220 WinThreadSemaphoreBase::WinThreadSemaphoreBase(void) :
 221      Inherited (    ),
 222     _pSemaphore(NULL)
 223 {
 224 }
 225
 226 WinThreadSemaphoreBase::WinThreadSemaphoreBase(const Char8  *szName,
 227                                                      UInt32  uiId,
 228                                                      bool    bGlobal) :
 229      Inherited (szName, uiId, bGlobal),
 230     _pSemaphore(NULL                 )
 231 {
 232 }
 233
 234 /*---------------------------- Destructor ---------------------------------*/
 235
 236 WinThreadSemaphoreBase::~WinThreadSemaphoreBase(void)
 237 {
 238 }
 239
 240 /*-------------------------- Construction ---------------------------------*/
 241
 242 bool WinThreadSemaphoreBase::init(void)
 243 {
 244     _pSemaphore = CreateSemaphore( NULL,     // no security attributes
 245                                    0,    // initially not owned
 246                                    1024,
 247                                   _szName);  // name of mutex
 248
 249     if(_pSemaphore == NULL)
 250     {
 251         return false;
 252     }
 253
 254     return true;
 255 }
 256
 257 /*-------------------------- Destruction ----------------------------------*/
 258
 259 void WinThreadSemaphoreBase::shutdown(void)
 260 {
 261     if(_pSemaphore != NULL)
 262     {
 263         CloseHandle(_pSemaphore);
 264         _pSemaphore = NULL;
 265     }
 266 }
 267
 268 #endif /* OSG_USE_WINTHREADS */
 269
 270
 271
 272 //---------------------------------------------------------------------------
 273 //  Class
 274 //---------------------------------------------------------------------------
 275
 276 MPSemaphoreType Semaphore::_type( "OSGSemaphore",
 277                                   "OSGMPBase",
 278                                  &Semaphore::create);
 279
 280 /*------------------------------- Get -------------------------------------*/
 281
 282 Semaphore::ObjTransitPtr Semaphore::get(const Char8 *szName, bool bGlobal)
 283 {
 284     return ThreadManager::the()->getSemaphore(szName, bGlobal, "OSGSemaphore");
 285 }
 286
 287 Semaphore *Semaphore::find(const Char8 *szName)
 288 {
 289     return ThreadManager::the()->findSemaphore(szName);
 290 }
 291
 292
 293 /*------------------------------ Create -----------------------------------*/
 294
 295 Semaphore *Semaphore::create(const Char8 *szName, UInt32 uiId, bool bGlobal)
 296 {
 297     Semaphore *returnValue = NULL;
 298
 299     returnValue = new Semaphore(szName, uiId, bGlobal);
 300
 301     if(returnValue->init() == false)
 302     {
 303         delete returnValue;
 304         returnValue = NULL;
 305     }
 306
 307     return returnValue;
 308 }
 309
 310 /*--------------------------- Constructors --------------------------------*/
 311
 312 Semaphore::Semaphore(void) :
 313     Inherited()
 314 {
 315 }
 316
 317 Semaphore::Semaphore(const Char8 *szName, UInt32 uiId, bool bGlobal) :
 318     Inherited(szName, uiId, bGlobal)
 319 {
 320 }
 321
 322 /*---------------------------- Destructor ---------------------------------*/
 323
 324 Semaphore::~Semaphore(void)
 325 {
 326     _bGlobal = false;
 327
 328     ThreadManager::the()->remove(this);
 329
 330     shutdown();
 331 }
 332
 333
 334 OSG_END_NAMESPACE