mirror of
https://github.com/glest/glest-source.git
synced 2025-09-30 01:18:58 +02:00
Fixed the god-awful indentation
This commit is contained in:
mathusummut
@@ -38,503 +38,519 @@ using namespace std;
|
||||
using namespace Shared::PlatformCommon;
|
||||
#endif
|
||||
|
||||
namespace Shared { namespace PlatformCommon {
|
||||
class Chrono;
|
||||
}};
|
||||
|
||||
namespace Shared { namespace Platform {
|
||||
|
||||
class Mutex;
|
||||
//class uint32;
|
||||
|
||||
enum ThreadState {
|
||||
thrsNew,
|
||||
thrsStarting,
|
||||
thrsExecuteStart,
|
||||
thrsExecuting,
|
||||
thrsExecuted,
|
||||
thrsExecuteAutoClean,
|
||||
thrsExecuteComplete
|
||||
|
||||
namespace Shared {
|
||||
namespace PlatformCommon {
|
||||
class Chrono;
|
||||
}
|
||||
};
|
||||
|
||||
class Thread {
|
||||
public:
|
||||
enum Priority {
|
||||
pIdle = 0,
|
||||
pLow = 1,
|
||||
pNormal = 2,
|
||||
pHigh = 3,
|
||||
pRealTime = 4
|
||||
};
|
||||
namespace Shared {
|
||||
namespace Platform {
|
||||
|
||||
private:
|
||||
SDL_Thread* thread;
|
||||
//std::auto_ptr<Mutex> mutexthreadAccessor;
|
||||
Mutex *mutexthreadAccessor;
|
||||
ThreadState currentState;
|
||||
bool threadObjectValid();
|
||||
class Mutex;
|
||||
//class uint32;
|
||||
|
||||
bool deleteAfterExecute;
|
||||
static Mutex mutexthreadList;
|
||||
static vector<Thread *> threadList;
|
||||
static bool enableVerboseMode;
|
||||
static unsigned long mainThreadId;
|
||||
enum ThreadState {
|
||||
thrsNew,
|
||||
thrsStarting,
|
||||
thrsExecuteStart,
|
||||
thrsExecuting,
|
||||
thrsExecuted,
|
||||
thrsExecuteAutoClean,
|
||||
thrsExecuteComplete
|
||||
|
||||
protected:
|
||||
void addThreadToList();
|
||||
void removeThreadFromList();
|
||||
void queueAutoCleanThread();
|
||||
bool isThreadExecuteCompleteStatus();
|
||||
};
|
||||
|
||||
public:
|
||||
Thread();
|
||||
virtual ~Thread();
|
||||
class Thread {
|
||||
public:
|
||||
enum Priority {
|
||||
pIdle = 0,
|
||||
pLow = 1,
|
||||
pNormal = 2,
|
||||
pHigh = 3,
|
||||
pRealTime = 4
|
||||
};
|
||||
|
||||
static unsigned long getCurrentThreadId();
|
||||
static unsigned long getMainThreadId() { return mainThreadId; }
|
||||
static void setMainThreadId();
|
||||
static bool isCurrentThreadMainThread();
|
||||
private:
|
||||
SDL_Thread* thread;
|
||||
//std::auto_ptr<Mutex> mutexthreadAccessor;
|
||||
Mutex *mutexthreadAccessor;
|
||||
ThreadState currentState;
|
||||
bool threadObjectValid();
|
||||
|
||||
static void setEnableVerboseMode(bool value) { enableVerboseMode = value; }
|
||||
static bool getEnableVerboseMode() { return enableVerboseMode; }
|
||||
bool deleteAfterExecute;
|
||||
static Mutex mutexthreadList;
|
||||
static vector<Thread *> threadList;
|
||||
static bool enableVerboseMode;
|
||||
static unsigned long mainThreadId;
|
||||
|
||||
static std::vector<Thread *> getThreadList();
|
||||
static void shutdownThreads();
|
||||
protected:
|
||||
void addThreadToList();
|
||||
void removeThreadFromList();
|
||||
void queueAutoCleanThread();
|
||||
bool isThreadExecuteCompleteStatus();
|
||||
|
||||
void setDeleteAfterExecute(bool value) { deleteAfterExecute = value; }
|
||||
bool getDeleteAfterExecute() const { return deleteAfterExecute; }
|
||||
public:
|
||||
Thread();
|
||||
virtual ~Thread();
|
||||
|
||||
void start();
|
||||
virtual void execute()=0;
|
||||
void setPriority(Thread::Priority threadPriority);
|
||||
void suspend();
|
||||
void resume();
|
||||
void kill();
|
||||
static unsigned long getCurrentThreadId();
|
||||
static unsigned long getMainThreadId() {
|
||||
return mainThreadId;
|
||||
}
|
||||
static void setMainThreadId();
|
||||
static bool isCurrentThreadMainThread();
|
||||
|
||||
private:
|
||||
static int beginExecution(void *param);
|
||||
};
|
||||
|
||||
// =====================================================
|
||||
// class Mutex
|
||||
// =====================================================
|
||||
|
||||
class Mutex {
|
||||
private:
|
||||
|
||||
SDL_mutex* mutex;
|
||||
int refCount;
|
||||
string ownerId;
|
||||
string deleteownerId;
|
||||
|
||||
SDL_mutex* mutexAccessor;
|
||||
string lastownerId;
|
||||
|
||||
int maxRefCount;
|
||||
Shared::PlatformCommon::Chrono *chronoPerf;
|
||||
|
||||
bool isStaticMutexListMutex;
|
||||
static auto_ptr<Mutex> mutexMutexList;
|
||||
static vector<Mutex *> mutexList;
|
||||
|
||||
public:
|
||||
Mutex(string ownerId="");
|
||||
~Mutex();
|
||||
inline void setOwnerId(string ownerId) {
|
||||
if(this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
}
|
||||
inline void p() {
|
||||
SDL_LockMutex(mutex);
|
||||
refCount++;
|
||||
}
|
||||
// Returns return 0, SDL_MUTEX_TIMEDOUT, or -1 on error;
|
||||
// call SDL_GetError() for more information.
|
||||
inline int TryLock(int millisecondsToWait=0) {
|
||||
int result = SDL_TryLockMutex(mutex);
|
||||
if(result == 0) {
|
||||
refCount++;
|
||||
}
|
||||
return result;
|
||||
}
|
||||
inline void v() {
|
||||
refCount--;
|
||||
SDL_UnlockMutex(mutex);
|
||||
}
|
||||
inline int getRefCount() const { return refCount; }
|
||||
|
||||
inline SDL_mutex* getMutex() { return mutex; }
|
||||
};
|
||||
|
||||
class MutexSafeWrapper {
|
||||
protected:
|
||||
Mutex *mutex;
|
||||
string ownerId;
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
Chrono chrono;
|
||||
#endif
|
||||
|
||||
public:
|
||||
|
||||
MutexSafeWrapper(Mutex *mutex,string ownerId="") {
|
||||
this->mutex = mutex;
|
||||
if(this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
Lock();
|
||||
}
|
||||
~MutexSafeWrapper() {
|
||||
ReleaseLock();
|
||||
}
|
||||
|
||||
inline void setMutex(Mutex *mutex,string ownerId="") {
|
||||
this->mutex = mutex;
|
||||
if(this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
Lock();
|
||||
}
|
||||
inline int setMutexAndTryLock(Mutex *mutex,string ownerId="") {
|
||||
this->mutex = mutex;
|
||||
if(this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
return this->mutex->TryLock();
|
||||
}
|
||||
|
||||
inline bool isValidMutex() const {
|
||||
return(this->mutex != NULL);
|
||||
}
|
||||
|
||||
inline void Lock() {
|
||||
if(this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("Locking Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
this->mutex->p();
|
||||
if(this->mutex != NULL) {
|
||||
this->mutex->setOwnerId(ownerId);
|
||||
static void setEnableVerboseMode(bool value) {
|
||||
enableVerboseMode = value;
|
||||
}
|
||||
static bool getEnableVerboseMode() {
|
||||
return enableVerboseMode;
|
||||
}
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if(chrono.getMillis() > 5) printf("In [%s::%s Line: %d] MUTEX LOCK took msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n",__FILE__,__FUNCTION__,__LINE__,(long long int)chrono.getMillis(),this->mutex->getRefCount(),ownerId.c_str());
|
||||
chrono.start();
|
||||
#endif
|
||||
static std::vector<Thread *> getThreadList();
|
||||
static void shutdownThreads();
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("Locked Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
}
|
||||
}
|
||||
|
||||
inline int TryLock(int millisecondsToWait=0) {
|
||||
if(this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("TryLocking Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
int result = this->mutex->TryLock(millisecondsToWait);
|
||||
if(result == 0 && this->mutex != NULL) {
|
||||
this->mutex->setOwnerId(ownerId);
|
||||
void setDeleteAfterExecute(bool value) {
|
||||
deleteAfterExecute = value;
|
||||
}
|
||||
bool getDeleteAfterExecute() const {
|
||||
return deleteAfterExecute;
|
||||
}
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if(chrono.getMillis() > 5) printf("In [%s::%s Line: %d] MUTEX LOCK took msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n",__FILE__,__FUNCTION__,__LINE__,(long long int)chrono.getMillis(),this->mutex->getRefCount(),ownerId.c_str());
|
||||
chrono.start();
|
||||
#endif
|
||||
void start();
|
||||
virtual void execute() = 0;
|
||||
void setPriority(Thread::Priority threadPriority);
|
||||
void suspend();
|
||||
void resume();
|
||||
void kill();
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("Locked Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
private:
|
||||
static int beginExecution(void *param);
|
||||
};
|
||||
|
||||
return result;
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
// =====================================================
|
||||
// class Mutex
|
||||
// =====================================================
|
||||
|
||||
inline void ReleaseLock(bool keepMutex=false,bool deleteMutexOnRelease=false) {
|
||||
if(this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("UnLocking Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
class Mutex {
|
||||
private:
|
||||
|
||||
this->mutex->v();
|
||||
SDL_mutex* mutex;
|
||||
int refCount;
|
||||
string ownerId;
|
||||
string deleteownerId;
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if(chrono.getMillis() > 100) printf("In [%s::%s Line: %d] MUTEX UNLOCKED and held locked for msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n",__FILE__,__FUNCTION__,__LINE__,(long long int)chrono.getMillis(),this->mutex->getRefCount(),ownerId.c_str());
|
||||
#endif
|
||||
SDL_mutex* mutexAccessor;
|
||||
string lastownerId;
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("UnLocked Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
int maxRefCount;
|
||||
Shared::PlatformCommon::Chrono *chronoPerf;
|
||||
|
||||
if(deleteMutexOnRelease == true) {
|
||||
delete this->mutex;
|
||||
this->mutex = NULL;
|
||||
bool isStaticMutexListMutex;
|
||||
static auto_ptr<Mutex> mutexMutexList;
|
||||
static vector<Mutex *> mutexList;
|
||||
|
||||
public:
|
||||
Mutex(string ownerId = "");
|
||||
~Mutex();
|
||||
inline void setOwnerId(string ownerId) {
|
||||
if (this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
}
|
||||
inline void p() {
|
||||
SDL_LockMutex(mutex);
|
||||
refCount++;
|
||||
}
|
||||
// Returns return 0, SDL_MUTEX_TIMEDOUT, or -1 on error;
|
||||
// call SDL_GetError() for more information.
|
||||
inline int TryLock(int millisecondsToWait = 0) {
|
||||
int result = SDL_TryLockMutex(mutex);
|
||||
if (result == 0) {
|
||||
refCount++;
|
||||
}
|
||||
return result;
|
||||
}
|
||||
inline void v() {
|
||||
refCount--;
|
||||
SDL_UnlockMutex(mutex);
|
||||
}
|
||||
inline int getRefCount() const {
|
||||
return refCount;
|
||||
}
|
||||
|
||||
if(keepMutex == false) {
|
||||
this->mutex = NULL;
|
||||
inline SDL_mutex* getMutex() {
|
||||
return mutex;
|
||||
}
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
// =====================================================
|
||||
// class Semaphore
|
||||
// =====================================================
|
||||
|
||||
class Semaphore {
|
||||
private:
|
||||
SDL_sem* semaphore;
|
||||
|
||||
public:
|
||||
Semaphore(Uint32 initialValue = 0);
|
||||
~Semaphore();
|
||||
void signal();
|
||||
int waitTillSignalled(int waitMilliseconds=-1);
|
||||
bool tryDecrement();
|
||||
|
||||
uint32 getSemValue();
|
||||
void resetSemValue(Uint32 initialValue);
|
||||
};
|
||||
|
||||
|
||||
class ReadWriteMutex
|
||||
{
|
||||
public:
|
||||
ReadWriteMutex(int maxReaders = 32);
|
||||
|
||||
void LockRead();
|
||||
void UnLockRead();
|
||||
|
||||
void LockWrite();
|
||||
void UnLockWrite();
|
||||
|
||||
int maxReaders();
|
||||
void setOwnerId(string ownerId) {
|
||||
if(this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
}
|
||||
|
||||
private:
|
||||
Semaphore semaphore;
|
||||
Mutex mutex;
|
||||
int maxReadersCount;
|
||||
|
||||
string ownerId;
|
||||
};
|
||||
|
||||
|
||||
class ReadWriteMutexSafeWrapper {
|
||||
protected:
|
||||
ReadWriteMutex *mutex;
|
||||
string ownerId;
|
||||
bool isReadLock;
|
||||
};
|
||||
|
||||
class MutexSafeWrapper {
|
||||
protected:
|
||||
Mutex *mutex;
|
||||
string ownerId;
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
Chrono chrono;
|
||||
Chrono chrono;
|
||||
#endif
|
||||
|
||||
public:
|
||||
public:
|
||||
|
||||
ReadWriteMutexSafeWrapper(ReadWriteMutex *mutex,bool isReadLock=true, string ownerId="") {
|
||||
this->mutex = mutex;
|
||||
if(this->isReadLock != isReadLock) {
|
||||
this->isReadLock = isReadLock;
|
||||
}
|
||||
if(this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
Lock();
|
||||
}
|
||||
~ReadWriteMutexSafeWrapper() {
|
||||
ReleaseLock();
|
||||
}
|
||||
|
||||
void setReadWriteMutex(ReadWriteMutex *mutex,bool isReadLock=true,string ownerId="") {
|
||||
this->mutex = mutex;
|
||||
if(this->isReadLock != isReadLock) {
|
||||
this->isReadLock = isReadLock;
|
||||
}
|
||||
if(this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
Lock();
|
||||
}
|
||||
bool isValidReadWriteMutex() const {
|
||||
return(this->mutex != NULL);
|
||||
}
|
||||
|
||||
void Lock() {
|
||||
if(this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("Locking Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
if(this->isReadLock == true) {
|
||||
this->mutex->LockRead();
|
||||
}
|
||||
else {
|
||||
this->mutex->LockWrite();
|
||||
}
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if(chrono.getMillis() > 5) printf("In [%s::%s Line: %d] MUTEX LOCK took msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n",__FILE__,__FUNCTION__,__LINE__,(long long int)chrono.getMillis(),this->mutex->getRefCount(),ownerId.c_str());
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("Locked Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
}
|
||||
}
|
||||
void ReleaseLock(bool keepMutex=false) {
|
||||
if(this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("UnLocking Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
if(this->isReadLock == true) {
|
||||
this->mutex->UnLockRead();
|
||||
}
|
||||
else {
|
||||
this->mutex->UnLockWrite();
|
||||
}
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if(chrono.getMillis() > 100) printf("In [%s::%s Line: %d] MUTEX UNLOCKED and held locked for msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n",__FILE__,__FUNCTION__,__LINE__,(long long int)chrono.getMillis(),this->mutex->getRefCount(),ownerId.c_str());
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if(this->ownerId != "") {
|
||||
printf("UnLocked Mutex [%s] refCount: %d\n",this->ownerId.c_str(),this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
if(keepMutex == false) {
|
||||
this->mutex = NULL;
|
||||
MutexSafeWrapper(Mutex *mutex, string ownerId = "") {
|
||||
this->mutex = mutex;
|
||||
if (this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
Lock();
|
||||
}
|
||||
}
|
||||
~MutexSafeWrapper() {
|
||||
ReleaseLock();
|
||||
}
|
||||
|
||||
inline void setMutex(Mutex *mutex, string ownerId = "") {
|
||||
this->mutex = mutex;
|
||||
if (this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
Lock();
|
||||
}
|
||||
inline int setMutexAndTryLock(Mutex *mutex, string ownerId = "") {
|
||||
this->mutex = mutex;
|
||||
if (this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
return this->mutex->TryLock();
|
||||
}
|
||||
|
||||
inline bool isValidMutex() const {
|
||||
return(this->mutex != NULL);
|
||||
}
|
||||
|
||||
inline void Lock() {
|
||||
if (this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("Locking Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
this->mutex->p();
|
||||
if (this->mutex != NULL) {
|
||||
this->mutex->setOwnerId(ownerId);
|
||||
}
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if (chrono.getMillis() > 5) printf("In [%s::%s Line: %d] MUTEX LOCK took msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n", __FILE__, __FUNCTION__, __LINE__, (long long int)chrono.getMillis(), this->mutex->getRefCount(), ownerId.c_str());
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("Locked Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
}
|
||||
}
|
||||
|
||||
inline int TryLock(int millisecondsToWait = 0) {
|
||||
if (this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("TryLocking Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
int result = this->mutex->TryLock(millisecondsToWait);
|
||||
if (result == 0 && this->mutex != NULL) {
|
||||
this->mutex->setOwnerId(ownerId);
|
||||
}
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if (chrono.getMillis() > 5) printf("In [%s::%s Line: %d] MUTEX LOCK took msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n", __FILE__, __FUNCTION__, __LINE__, (long long int)chrono.getMillis(), this->mutex->getRefCount(), ownerId.c_str());
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("Locked Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
return result;
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
inline void ReleaseLock(bool keepMutex = false, bool deleteMutexOnRelease = false) {
|
||||
if (this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("UnLocking Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
this->mutex->v();
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if (chrono.getMillis() > 100) printf("In [%s::%s Line: %d] MUTEX UNLOCKED and held locked for msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n", __FILE__, __FUNCTION__, __LINE__, (long long int)chrono.getMillis(), this->mutex->getRefCount(), ownerId.c_str());
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("UnLocked Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
if (deleteMutexOnRelease == true) {
|
||||
delete this->mutex;
|
||||
this->mutex = NULL;
|
||||
}
|
||||
|
||||
if (keepMutex == false) {
|
||||
this->mutex = NULL;
|
||||
}
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
// =====================================================
|
||||
// class Semaphore
|
||||
// =====================================================
|
||||
|
||||
class Semaphore {
|
||||
private:
|
||||
SDL_sem* semaphore;
|
||||
|
||||
public:
|
||||
Semaphore(Uint32 initialValue = 0);
|
||||
~Semaphore();
|
||||
void signal();
|
||||
int waitTillSignalled(int waitMilliseconds = -1);
|
||||
bool tryDecrement();
|
||||
|
||||
uint32 getSemValue();
|
||||
void resetSemValue(Uint32 initialValue);
|
||||
};
|
||||
|
||||
|
||||
class ReadWriteMutex {
|
||||
public:
|
||||
ReadWriteMutex(int maxReaders = 32);
|
||||
|
||||
void LockRead();
|
||||
void UnLockRead();
|
||||
|
||||
void LockWrite();
|
||||
void UnLockWrite();
|
||||
|
||||
int maxReaders();
|
||||
void setOwnerId(string ownerId) {
|
||||
if (this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
}
|
||||
|
||||
private:
|
||||
Semaphore semaphore;
|
||||
Mutex mutex;
|
||||
int maxReadersCount;
|
||||
|
||||
string ownerId;
|
||||
};
|
||||
|
||||
|
||||
class ReadWriteMutexSafeWrapper {
|
||||
protected:
|
||||
ReadWriteMutex *mutex;
|
||||
string ownerId;
|
||||
bool isReadLock;
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
Chrono chrono;
|
||||
#endif
|
||||
|
||||
public:
|
||||
|
||||
ReadWriteMutexSafeWrapper(ReadWriteMutex *mutex, bool isReadLock = true, string ownerId = "") {
|
||||
this->mutex = mutex;
|
||||
if (this->isReadLock != isReadLock) {
|
||||
this->isReadLock = isReadLock;
|
||||
}
|
||||
if (this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
Lock();
|
||||
}
|
||||
~ReadWriteMutexSafeWrapper() {
|
||||
ReleaseLock();
|
||||
}
|
||||
|
||||
void setReadWriteMutex(ReadWriteMutex *mutex, bool isReadLock = true, string ownerId = "") {
|
||||
this->mutex = mutex;
|
||||
if (this->isReadLock != isReadLock) {
|
||||
this->isReadLock = isReadLock;
|
||||
}
|
||||
if (this->ownerId != ownerId) {
|
||||
this->ownerId = ownerId;
|
||||
}
|
||||
Lock();
|
||||
}
|
||||
bool isValidReadWriteMutex() const {
|
||||
return(this->mutex != NULL);
|
||||
}
|
||||
|
||||
void Lock() {
|
||||
if (this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("Locking Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
if (this->isReadLock == true) {
|
||||
this->mutex->LockRead();
|
||||
} else {
|
||||
this->mutex->LockWrite();
|
||||
}
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if (chrono.getMillis() > 5) printf("In [%s::%s Line: %d] MUTEX LOCK took msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n", __FILE__, __FUNCTION__, __LINE__, (long long int)chrono.getMillis(), this->mutex->getRefCount(), ownerId.c_str());
|
||||
chrono.start();
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("Locked Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
}
|
||||
}
|
||||
void ReleaseLock(bool keepMutex = false) {
|
||||
if (this->mutex != NULL) {
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("UnLocking Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
if (this->isReadLock == true) {
|
||||
this->mutex->UnLockRead();
|
||||
} else {
|
||||
this->mutex->UnLockWrite();
|
||||
}
|
||||
|
||||
#ifdef DEBUG_PERFORMANCE_MUTEXES
|
||||
if (chrono.getMillis() > 100) printf("In [%s::%s Line: %d] MUTEX UNLOCKED and held locked for msecs: %lld, this->mutex->getRefCount() = %d ownerId [%s]\n", __FILE__, __FUNCTION__, __LINE__, (long long int)chrono.getMillis(), this->mutex->getRefCount(), ownerId.c_str());
|
||||
#endif
|
||||
|
||||
#ifdef DEBUG_MUTEXES
|
||||
if (this->ownerId != "") {
|
||||
printf("UnLocked Mutex [%s] refCount: %d\n", this->ownerId.c_str(), this->mutex->getRefCount());
|
||||
}
|
||||
#endif
|
||||
|
||||
if (keepMutex == false) {
|
||||
this->mutex = NULL;
|
||||
}
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
const bool debugMasterSlaveThreadController = false;
|
||||
// =====================================================
|
||||
// class Trigger
|
||||
// =====================================================
|
||||
|
||||
class Trigger {
|
||||
private:
|
||||
SDL_cond* trigger;
|
||||
Mutex *mutex;
|
||||
|
||||
public:
|
||||
Trigger(Mutex *mutex);
|
||||
~Trigger();
|
||||
void signal(bool allThreads = false);
|
||||
int waitTillSignalled(Mutex *mutex, int waitMilliseconds = -1);
|
||||
};
|
||||
|
||||
class MasterSlaveThreadController;
|
||||
|
||||
class SlaveThreadControllerInterface {
|
||||
public:
|
||||
virtual void setMasterController(MasterSlaveThreadController *master) = 0;
|
||||
virtual void signalSlave(void *userdata) = 0;
|
||||
virtual ~SlaveThreadControllerInterface() {
|
||||
}
|
||||
};
|
||||
|
||||
class MasterSlaveThreadController {
|
||||
private:
|
||||
static const int triggerBaseCount = 1;
|
||||
|
||||
Mutex *mutex;
|
||||
Semaphore *slaveTriggerSem;
|
||||
int slaveTriggerCounter;
|
||||
|
||||
std::vector<SlaveThreadControllerInterface *> slaveThreadList;
|
||||
|
||||
void init(std::vector<SlaveThreadControllerInterface *> &newSlaveThreadList);
|
||||
public:
|
||||
|
||||
MasterSlaveThreadController();
|
||||
MasterSlaveThreadController(std::vector<SlaveThreadControllerInterface *> &slaveThreadList);
|
||||
~MasterSlaveThreadController();
|
||||
|
||||
void setSlaves(std::vector<SlaveThreadControllerInterface *> &slaveThreadList);
|
||||
void clearSlaves(bool clearListOnly = false);
|
||||
|
||||
void signalSlaves(void *userdata);
|
||||
void triggerMaster(int waitMilliseconds = -1);
|
||||
bool waitTillSlavesTrigger(int waitMilliseconds = -1);
|
||||
|
||||
};
|
||||
|
||||
class MasterSlaveThreadControllerSafeWrapper {
|
||||
protected:
|
||||
MasterSlaveThreadController *master;
|
||||
string ownerId;
|
||||
int waitMilliseconds;
|
||||
|
||||
public:
|
||||
|
||||
MasterSlaveThreadControllerSafeWrapper(MasterSlaveThreadController *master, int waitMilliseconds = -1, string ownerId = "") {
|
||||
if (debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n", __FILE__, __FUNCTION__, __LINE__);
|
||||
|
||||
this->master = master;
|
||||
this->waitMilliseconds = waitMilliseconds;
|
||||
this->ownerId = ownerId;
|
||||
|
||||
if (debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n", __FILE__, __FUNCTION__, __LINE__);
|
||||
}
|
||||
~MasterSlaveThreadControllerSafeWrapper() {
|
||||
if (debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n", __FILE__, __FUNCTION__, __LINE__);
|
||||
|
||||
if (master != NULL) {
|
||||
if (debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n", __FILE__, __FUNCTION__, __LINE__);
|
||||
|
||||
master->triggerMaster(this->waitMilliseconds);
|
||||
}
|
||||
|
||||
if (debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n", __FILE__, __FUNCTION__, __LINE__);
|
||||
}
|
||||
};
|
||||
|
||||
}
|
||||
};
|
||||
|
||||
const bool debugMasterSlaveThreadController = false;
|
||||
// =====================================================
|
||||
// class Trigger
|
||||
// =====================================================
|
||||
|
||||
class Trigger {
|
||||
private:
|
||||
SDL_cond* trigger;
|
||||
Mutex *mutex;
|
||||
|
||||
public:
|
||||
Trigger(Mutex *mutex);
|
||||
~Trigger();
|
||||
void signal(bool allThreads=false);
|
||||
int waitTillSignalled(Mutex *mutex, int waitMilliseconds=-1);
|
||||
};
|
||||
|
||||
class MasterSlaveThreadController;
|
||||
|
||||
class SlaveThreadControllerInterface {
|
||||
public:
|
||||
virtual void setMasterController(MasterSlaveThreadController *master) = 0;
|
||||
virtual void signalSlave(void *userdata) = 0;
|
||||
virtual ~SlaveThreadControllerInterface() {}
|
||||
};
|
||||
|
||||
class MasterSlaveThreadController {
|
||||
private:
|
||||
static const int triggerBaseCount = 1;
|
||||
|
||||
Mutex *mutex;
|
||||
Semaphore *slaveTriggerSem;
|
||||
int slaveTriggerCounter;
|
||||
|
||||
std::vector<SlaveThreadControllerInterface *> slaveThreadList;
|
||||
|
||||
void init(std::vector<SlaveThreadControllerInterface *> &newSlaveThreadList);
|
||||
public:
|
||||
|
||||
MasterSlaveThreadController();
|
||||
MasterSlaveThreadController(std::vector<SlaveThreadControllerInterface *> &slaveThreadList);
|
||||
~MasterSlaveThreadController();
|
||||
|
||||
void setSlaves(std::vector<SlaveThreadControllerInterface *> &slaveThreadList);
|
||||
void clearSlaves(bool clearListOnly=false);
|
||||
|
||||
void signalSlaves(void *userdata);
|
||||
void triggerMaster(int waitMilliseconds=-1);
|
||||
bool waitTillSlavesTrigger(int waitMilliseconds=-1);
|
||||
|
||||
};
|
||||
|
||||
class MasterSlaveThreadControllerSafeWrapper {
|
||||
protected:
|
||||
MasterSlaveThreadController *master;
|
||||
string ownerId;
|
||||
int waitMilliseconds;
|
||||
|
||||
public:
|
||||
|
||||
MasterSlaveThreadControllerSafeWrapper(MasterSlaveThreadController *master, int waitMilliseconds=-1, string ownerId="") {
|
||||
if(debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n",__FILE__,__FUNCTION__,__LINE__);
|
||||
|
||||
this->master = master;
|
||||
this->waitMilliseconds = waitMilliseconds;
|
||||
this->ownerId = ownerId;
|
||||
|
||||
if(debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n",__FILE__,__FUNCTION__,__LINE__);
|
||||
}
|
||||
~MasterSlaveThreadControllerSafeWrapper() {
|
||||
if(debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n",__FILE__,__FUNCTION__,__LINE__);
|
||||
|
||||
if(master != NULL) {
|
||||
if(debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n",__FILE__,__FUNCTION__,__LINE__);
|
||||
|
||||
master->triggerMaster(this->waitMilliseconds);
|
||||
}
|
||||
|
||||
if(debugMasterSlaveThreadController) printf("In [%s::%s Line: %d]\n",__FILE__,__FUNCTION__,__LINE__);
|
||||
}
|
||||
};
|
||||
|
||||
}}//end namespace
|
||||
}//end namespace
|
||||
|
||||
#endif
|
||||
|
||||
Reference in New Issue
Block a user