add pthread_mutexattr_setrobust_np

matyhtf · matyhtf · commit 4bcf8355aa87 · 2017-06-22T13:18:41.000+08:00
diff --git a/src/lock/Mutex.c b/src/lock/Mutex.c
@@ -30,6 +30,7 @@ int swMutex_create(swLock *lock, int use_in_process)
     if (use_in_process == 1)
     {
         pthread_mutexattr_setpshared(&lock->object.mutex.attr, PTHREAD_PROCESS_SHARED);
+        pthread_mutexattr_setrobust_np(&lock->object.mutex.attr, PTHREAD_MUTEX_ROBUST_NP);
     }
     if ((ret = pthread_mutex_init(&lock->object.mutex._lock, &lock->object.mutex.attr)) < 0)
     {
@@ -95,5 +96,6 @@ int swMutex_lockwait(swLock *lock, int timeout_msec)
 
 static int swMutex_free(swLock *lock)
 {
+    pthread_mutexattr_destroy(&lock->object.mutex.attr);
     return pthread_mutex_destroy(&lock->object.mutex._lock);
 }

Original file line number	Diff line number	Diff line change
`@@ -30,6 +30,7 @@ int swMutex_create(swLock *lock, int use_in_process)`
`30`	`30`	`if (use_in_process == 1)`
`31`	`31`	`{`
`32`	`32`	`pthread_mutexattr_setpshared(&lock->object.mutex.attr, PTHREAD_PROCESS_SHARED);`
	`33`	`+ pthread_mutexattr_setrobust_np(&lock->object.mutex.attr, PTHREAD_MUTEX_ROBUST_NP);`
`33`	`34`	`}`
`34`	`35`	`if ((ret = pthread_mutex_init(&lock->object.mutex._lock, &lock->object.mutex.attr)) < 0)`
`35`	`36`	`{`
`@@ -95,5 +96,6 @@ int swMutex_lockwait(swLock *lock, int timeout_msec)`
`95`	`96`
`96`	`97`	`static int swMutex_free(swLock *lock)`
`97`	`98`	`{`
	`99`	`+ pthread_mutexattr_destroy(&lock->object.mutex.attr);`
`98`	`100`	`return pthread_mutex_destroy(&lock->object.mutex._lock);`
`99`	`101`	`}`