Search  

---

C:/temp/src/j2k/Deprecated/Posix.old/RecursiveMutex.cpp

Go to the documentation of this file.

#ifndef __J2K__PThread_RecursiveMutex_CPP__
#define __J2K__PThread_RecursiveMutex_CPP__

#include <j2k/Fred/PThread/RecursiveMutex.hpp>

RecursiveMutex::RecursiveMutex() : lockCount(0) { }

RecursiveMutex::~RecursiveMutex() { }

void RecursiveMutex::lock() {
  if ( !lockCount || !pthread_equal( owner, pthread_self() ) ) {
    Mutex::lock();
    owner = pthread_self();
  }

  ++lockCount;
}

void RecursiveMutex::unlock() {

  if ( lockCount <= 0 ) {
    cout << "Mutex is already unlocked.\n";
    return;
  }

  if ( !pthread_equal(owner, pthread_self()) )
    cout << "Mutex is locked by another thread.\n";
    return;
  }

  if ( --lockCount == 0 ) {
    Mutex::unlock();
  }
}

void RecursiveMutex::wait() {
  unsigned int saveCount = lockCount;
  lockCount = 0;
  Mutex::wait();
  owner = pthread_self();
  lockCount = saveCount;
}

#endif

---