equeue posix impl: make queue mutex reentrant

maciejbocianski · maciejbocianski · commit b336f73e7702 · 2019-08-29T15:02:40.000+02:00
diff --git a/UNITTESTS/stubs/EqueuePosix_stub.c b/UNITTESTS/stubs/EqueuePosix_stub.c
@@ -40,7 +40,10 @@ unsigned equeue_tick(void)
 // Mutex operations
 int equeue_mutex_create(equeue_mutex_t *m)
 {
-    return pthread_mutex_init(m, 0);
+    pthread_mutexattr_t attr;
+    pthread_mutexattr_init(&attr);
+    pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE);
+    return pthread_mutex_init(m, &attr);
 }
 
 void equeue_mutex_destroy(equeue_mutex_t *m)
diff --git a/events/source/equeue_posix.c b/events/source/equeue_posix.c
@@ -40,7 +40,10 @@ unsigned equeue_tick(void)
 // Mutex operations
 int equeue_mutex_create(equeue_mutex_t *m)
 {
-    return pthread_mutex_init(m, 0);
+    pthread_mutexattr_t attr;
+    pthread_mutexattr_init(&attr);
+    pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE);
+    return pthread_mutex_init(m, &attr);
 }
 
 void equeue_mutex_destroy(equeue_mutex_t *m)

Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,10 @@ unsigned equeue_tick(void)`
`40`	`40`	`// Mutex operations`
`41`	`41`	`int equeue_mutex_create(equeue_mutex_t *m)`
`42`	`42`	`{`
`43`		`- return pthread_mutex_init(m, 0);`
	`43`	`+ pthread_mutexattr_t attr;`
	`44`	`+ pthread_mutexattr_init(&attr);`
	`45`	`+ pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE);`
	`46`	`+ return pthread_mutex_init(m, &attr);`
`44`	`47`	`}`
`45`	`48`
`46`	`49`	`void equeue_mutex_destroy(equeue_mutex_t *m)`