(file) Return to Mutex.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/Mutex.cpp between version 1.9.16.3 and 1.18

version 1.9.16.3, 2007/09/12 03:24:32 version 1.18, 2009/02/27 08:28:13
Line 1 
Line 1 
 //%2006////////////////////////////////////////////////////////////////////////  //%LICENSE////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development  // Licensed to The Open Group (TOG) under one or more contributor license
 // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.  // agreements.  Refer to the OpenPegasusNOTICE.txt file distributed with
 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;  // this work for additional information regarding copyright ownership.
 // IBM Corp.; EMC Corporation, The Open Group.  // Each contributor licenses this file to you under the OpenPegasus Open
 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;  // Source License; you may not use this file except in compliance with the
 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.  // License.
 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;  //
 // EMC Corporation; VERITAS Software Corporation; The Open Group.  // Permission is hereby granted, free of charge, to any person obtaining a
 // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;  // copy of this software and associated documentation files (the "Software"),
 // EMC Corporation; Symantec Corporation; The Open Group.  // to deal in the Software without restriction, including without limitation
   // the rights to use, copy, modify, merge, publish, distribute, sublicense,
   // and/or sell copies of the Software, and to permit persons to whom the
   // Software is furnished to do so, subject to the following conditions:
   //
   // The above copyright notice and this permission notice shall be included
   // in all copies or substantial portions of the Software.
   //
   // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
   // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
   // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
   // IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
   // CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
   // TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
   // SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 // //
 // Permission is hereby granted, free of charge, to any person obtaining a copy  //////////////////////////////////////////////////////////////////////////
 // of this software and associated documentation files (the "Software"), to  
 // deal in the Software without restriction, including without limitation the  
 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or  
 // sell copies of the Software, and to permit persons to whom the Software is  
 // furnished to do so, subject to the following conditions:  
 //  
 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN  
 // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED  
 // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT  
 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR  
 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT  
 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN  
 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION  
 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.  
 //  
 //==============================================================================  
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
Line 35 
Line 33 
 #include "Time.h" #include "Time.h"
 #include "PegasusAssert.h" #include "PegasusAssert.h"
 #include "Once.h" #include "Once.h"
   #include "Exception.h"
   #include "System.h"
   
   #define MUTEX_LOCK_FAILED_KEY "Common.InternalException.MUTEX_LOCK_FAILED"
   #define MUTEX_LOCK_FAILED_MSG "Failed to acquire mutex lock: $0"
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
 //============================================================================== //==============================================================================
 // //
 // Mutex implementation with PTHREAD_MUTEX_RECURSIVE feature.  // PEGASUS_HAVE_PTHREADS
 // //
 //============================================================================== //==============================================================================
  
 #if defined(PEGASUS_HAVE_PTHREADS) && defined(PEGASUS_HAVE_RECURSIVE_MUTEXES)  #if defined(PEGASUS_HAVE_PTHREADS)
  
 static Once _once = PEGASUS_ONCE_INITIALIZER; static Once _once = PEGASUS_ONCE_INITIALIZER;
 static pthread_mutexattr_t _attr; static pthread_mutexattr_t _attr;
Line 91 
Line 94 
 { {
     PEGASUS_DEBUG_ASSERT(_magic);     PEGASUS_DEBUG_ASSERT(_magic);
  
     switch (pthread_mutex_lock(&_rep.mutex))      int r = pthread_mutex_lock(&_rep.mutex);
   
       if (r == 0)
     {     {
         case 0:  
 #if defined(PEGASUS_DEBUG) #if defined(PEGASUS_DEBUG)
             _rep.count++;             _rep.count++;
 #endif #endif
             break;      }
       else
       {
           if (r != -1)
           {
               // Special behavior for Single UNIX Specification, Version 3
               errno = r;
           }
  
         default:          throw Exception(MessageLoaderParms(
             throw WaitFailed(Threads::self());              MUTEX_LOCK_FAILED_KEY,
               MUTEX_LOCK_FAILED_MSG,
               PEGASUS_SYSTEM_ERRORMSG_NLS));
     }     }
 } }
  
 void Mutex::try_lock()  Boolean Mutex::try_lock()
 { {
     PEGASUS_DEBUG_ASSERT(_magic);     PEGASUS_DEBUG_ASSERT(_magic);
  
     int r = pthread_mutex_trylock(&_rep.mutex);     int r = pthread_mutex_trylock(&_rep.mutex);
     if (r == -1)  
         r=errno;      if (r == 0)
     switch (r)  
     {     {
         case 0:  
 #if defined(PEGASUS_DEBUG) #if defined(PEGASUS_DEBUG)
             _rep.count++;             _rep.count++;
 #endif #endif
             break;          return true;
       }
  
         case EBUSY:      if (r != -1)
             throw AlreadyLocked(Threads::self());      {
           // Special behavior for Single UNIX Specification, Version 3
           errno = r;
       }
  
         default:      if (errno == EBUSY)
             throw WaitFailed(Threads::self());      {
           return false;
     }     }
   
       throw Exception(MessageLoaderParms(
           MUTEX_LOCK_FAILED_KEY,
           MUTEX_LOCK_FAILED_MSG,
           PEGASUS_SYSTEM_ERRORMSG_NLS));
 } }
  
 void Mutex::timed_lock(Uint32 milliseconds)  Boolean Mutex::timed_lock(Uint32 milliseconds)
 { {
     PEGASUS_DEBUG_ASSERT(_magic);  
   
     struct timeval now;     struct timeval now;
     struct timeval finish;     struct timeval finish;
     struct timeval remaining;     struct timeval remaining;
Line 144 
Line 163 
         finish.tv_usec = usec % 1000000;         finish.tv_usec = usec % 1000000;
     }     }
  
     for (;;)      while (!try_lock())
     {  
         int r=pthread_mutex_trylock(&_rep.mutex);  
         if (r == -1)  
             r = errno;  
         switch (r)  
         {  
             case 0:  
 #if defined(PEGASUS_DEBUG)  
                 _rep.count++;  
 #endif  
                 return;  
   
             case EBUSY:  
             {             {
                 gettimeofday(&now, NULL);                 gettimeofday(&now, NULL);
  
                 if (Time::subtract(&remaining, &finish, &now))                 if (Time::subtract(&remaining, &finish, &now))
                     throw TimeOut(Threads::self());          {
               return false;
           }
  
                 Threads::yield();                 Threads::yield();
                 break;  
             }             }
  
             default:      return true;
                 throw WaitFailed(Threads::self());  
         }  
     }  
 } }
  
 void Mutex::unlock() void Mutex::unlock()
Line 183 
Line 187 
     _rep.count--;     _rep.count--;
 #endif #endif
  
     if (pthread_mutex_unlock(&_rep.mutex) != 0)      int rc = pthread_mutex_unlock(&_rep.mutex);
         throw Permission(Threads::self());      // All documented error codes represent coding errors.
       PEGASUS_ASSERT(rc == 0);
 } }
  
 #if defined(PEGASUS_OS_LINUX) #if defined(PEGASUS_OS_LINUX)
Line 197 
Line 202 
 } }
 #endif #endif
  
 #endif /* PEGASUS_HAVE_PTHREADS && PEGASUS_HAVE_RECURSIVE_MUTEXES */  #endif /* PEGASUS_HAVE_PTHREADS */
   
 //==============================================================================  
 //  
 // Mutex implementation without PTHREAD_MUTEX_RECURSIVE feature.  
 //  
 //==============================================================================  
   
 #if defined(PEGASUS_HAVE_PTHREADS) && !defined(PEGASUS_HAVE_RECURSIVE_MUTEXES)  
   
 Mutex::Mutex()  
 {  
     memset(&_rep, 0, sizeof(_rep));  
     _rep.recursive = 1;  
     pthread_mutex_init(&_rep.mutex, NULL);  
     pthread_cond_init(&_rep.cond, NULL);  
     _rep.owner = 0;  
     _rep.count = 0;  
 }  
   
 Mutex::Mutex(RecursiveTag)  
 {  
     memset(&_rep, 0, sizeof(_rep));  
     _rep.recursive = 1;  
     pthread_mutex_init(&_rep.mutex, NULL);  
     pthread_cond_init(&_rep.cond, NULL);  
     _rep.owner = 0;  
     _rep.count = 0;  
 }  
   
 Mutex::Mutex(NonRecursiveTag)  
 {  
     memset(&_rep, 0, sizeof(_rep));  
     _rep.recursive = 0;  
     pthread_mutex_init(&_rep.mutex, NULL);  
 }  
   
 Mutex::~Mutex()  
 {  
     PEGASUS_DEBUG_ASSERT(_magic);  
     pthread_mutex_destroy(&_rep.mutex);  
   
     if (_rep.recursive)  
         pthread_cond_destroy(&_rep.cond);  
 }  
   
 void Mutex::lock()  
 {  
     PEGASUS_DEBUG_ASSERT(_magic);  
   
     if (_rep.recursive)  
     {  
         pthread_t self = pthread_self();  
   
         pthread_mutex_lock(&_rep.mutex);  
         {  
             if (_rep.count == 0)  
             {  
                 _rep.owner = self;  
             }  
             else if (!pthread_equal(_rep.owner, self))  
             {  
                 while (_rep.count > 0)  
                     pthread_cond_wait(&_rep.cond, &_rep.mutex);  
   
                 _rep.owner = self;  
             }  
   
             _rep.count++;  
         }  
         pthread_mutex_unlock(&_rep.mutex);  
     }  
     else  
     {  
         if (pthread_mutex_lock(&_rep.mutex) != 0)  
         {  
             throw WaitFailed(Threads::self());  
         }  
     }  
 }  
   
 void Mutex::try_lock()  
 {  
     PEGASUS_DEBUG_ASSERT(_magic);  
   
     if (_rep.recursive)  
     {  
         pthread_t self = pthread_self();  
   
         pthread_mutex_lock(&_rep.mutex);  
         {  
             if (_rep.count == 0)  
             {  
                 _rep.owner = self;  
                 _rep.count = 1;  
             }  
             else if (pthread_equal(_rep.owner, self))  
             {  
                 _rep.count++;  
             }  
             else  
             {  
                 pthread_mutex_unlock(&_rep.mutex);  
                 throw AlreadyLocked(Threads::self());  
             }  
         }  
         pthread_mutex_unlock(&_rep.mutex);  
     }  
     else  
     {  
         int r = pthread_mutex_trylock(&_rep.mutex);  
   
         if (r == -1)  
             r = errno;  
   
         switch (r)  
         {  
             case 0:  
                 break;  
   
             case EBUSY:  
                 throw AlreadyLocked(Threads::self());  
   
             default:  
                 throw WaitFailed(Threads::self());  
         }  
     }  
 }  
   
 void Mutex::timed_lock(Uint32 milliseconds)  
 {  
     PEGASUS_DEBUG_ASSERT(_magic);  
   
     if (_rep.recursive)  
     {  
         pthread_t self = pthread_self();  
   
         pthread_mutex_lock(&_rep.mutex);  
         {  
             if (_rep.count == 0)  
             {  
                 _rep.owner = self;  
             }  
             else if (!pthread_equal(_rep.owner, self))  
             {  
                 timespec ts;  
                 clock_gettime(CLOCK_REALTIME, &ts);  
   
                 ts.tv_sec += milliseconds / 1000;  
                 ts.tv_nsec += (milliseconds % 1000) * 1000000;  
   
                 while (_rep.count > 0)  
                 {  
                     if (pthread_cond_timedwait(  
                         &_rep.cond, &_rep.mutex, &ts) != 0)  
                     {  
                         pthread_mutex_unlock(&_rep.mutex);  
                         throw TimeOut(Threads::self());  
                     }  
                 }  
   
                 _rep.owner = self;  
             }  
   
             _rep.count++;  
         }  
         pthread_mutex_unlock(&_rep.mutex);  
     }  
     else  
     {  
         struct timeval now;  
         struct timeval finish;  
         struct timeval remaining;  
         {  
             Uint32 usec;  
             gettimeofday(&finish, NULL);  
             finish.tv_sec += (milliseconds / 1000 );  
             milliseconds %= 1000;  
             usec = finish.tv_usec + ( milliseconds * 1000 );  
             finish.tv_sec += (usec / 1000000);  
             finish.tv_usec = usec % 1000000;  
         }  
   
         for (;;)  
         {  
             int r = pthread_mutex_trylock(&_rep.mutex);  
   
             if (r == -1)  
                 r = errno;  
   
             switch (r)  
             {  
                 case 0:  
                     return;  
   
                 case EBUSY:  
                 {  
                     gettimeofday(&now, NULL);  
   
                     if (Time::subtract(&remaining, &finish, &now))  
                         throw TimeOut(Threads::self());  
   
                     Threads::yield();  
                     break;  
                 }  
   
                 default:  
                     throw WaitFailed(Threads::self());  
             }  
         }  
     }  
 }  
   
 void Mutex::unlock()  
 {  
     PEGASUS_DEBUG_ASSERT(_magic);  
   
     if (_rep.recursive)  
     {  
         pthread_t self = pthread_self();  
   
         pthread_mutex_lock(&_rep.mutex);  
         {  
             // If not locked or if calling thread is not the locker.  
   
             if (_rep.count == 0 || !pthread_equal(_rep.owner, self))  
                 PEGASUS_DEBUG_ASSERT(0);  
   
             _rep.count--;  
             _rep.owner = 0;  
   
             pthread_cond_signal(&_rep.cond);  
         }  
         pthread_mutex_unlock(&_rep.mutex);  
     }  
     else  
     {  
         if (pthread_mutex_unlock(&_rep.mutex) != 0)  
             throw Permission(Threads::self());  
     }  
 }  
   
 #endif /* PEGASUS_HAVE_PTHREADS && !PEGASUS_HAVE_RECURSIVE_MUTEXES */  
  
 //============================================================================== //==============================================================================
 // //
Line 452 
Line 215 
 static inline void _initialize(MutexRep& rep) static inline void _initialize(MutexRep& rep)
 { {
     rep.handle = CreateMutex(NULL, FALSE, NULL);     rep.handle = CreateMutex(NULL, FALSE, NULL);
       if (rep.handle == NULL)
       {
           throw Exception(MessageLoaderParms(
               "Common.InternalException.CREATE_MUTEX_FAILED",
               "CreateMutex failed : $0",
               PEGASUS_SYSTEM_ERRORMSG_NLS));
       }
     rep.count = 0;     rep.count = 0;
 } }
  
Line 485 
Line 255 
     DWORD rc = WaitForSingleObject(_rep.handle, INFINITE);     DWORD rc = WaitForSingleObject(_rep.handle, INFINITE);
  
     if (rc == WAIT_FAILED)     if (rc == WAIT_FAILED)
         throw WaitFailed(Threads::self());      {
           throw Exception(MessageLoaderParms(
               MUTEX_LOCK_FAILED_KEY,
               MUTEX_LOCK_FAILED_MSG,
               PEGASUS_SYSTEM_ERRORMSG_NLS));
       }
  
     _rep.count++;     _rep.count++;
 } }
  
 void Mutex::try_lock()  Boolean Mutex::try_lock()
 { {
     PEGASUS_DEBUG_ASSERT(_magic);     PEGASUS_DEBUG_ASSERT(_magic);
  
     DWORD rc = WaitForSingleObject(_rep.handle, 0);     DWORD rc = WaitForSingleObject(_rep.handle, 0);
  
     if (rc == WAIT_TIMEOUT)     if (rc == WAIT_TIMEOUT)
         throw AlreadyLocked(Threads::self());      {
           return false;
       }
  
     if (rc == WAIT_FAILED)     if (rc == WAIT_FAILED)
         throw WaitFailed(Threads::self());      {
           throw Exception(MessageLoaderParms(
               MUTEX_LOCK_FAILED_KEY,
               MUTEX_LOCK_FAILED_MSG,
               PEGASUS_SYSTEM_ERRORMSG_NLS));
       }
  
     _rep.count++;     _rep.count++;
       return true;
 } }
  
 void Mutex::timed_lock(Uint32 milliseconds)  Boolean Mutex::timed_lock(Uint32 milliseconds)
 { {
     PEGASUS_DEBUG_ASSERT(_magic);     PEGASUS_DEBUG_ASSERT(_magic);
  
     DWORD rc = WaitForSingleObject(_rep.handle, milliseconds);     DWORD rc = WaitForSingleObject(_rep.handle, milliseconds);
  
     if (rc == WAIT_TIMEOUT)     if (rc == WAIT_TIMEOUT)
         throw TimeOut(Threads::self());          return false;
  
     if (rc == WAIT_FAILED)     if (rc == WAIT_FAILED)
         throw WaitFailed(Threads::self());      {
           throw Exception(MessageLoaderParms(
               MUTEX_LOCK_FAILED_KEY,
               MUTEX_LOCK_FAILED_MSG,
               PEGASUS_SYSTEM_ERRORMSG_NLS));
       }
  
     _rep.count++;     _rep.count++;
       return true;
 } }
  
 void Mutex::unlock() void Mutex::unlock()

Legend:
Removed from v.1.9.16.3  
changed lines
  Added in v.1.18
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2