daemon: add nice value in service file to improve performance

[platform/upstream/pulseaudio.git] / src / pulsecore / mutex-posix.c

diff --git a/src/pulsecore/mutex-posix.c b/src/pulsecore/mutex-posix.c
index a835be1..865df53 100644 (file)
--- a/src/pulsecore/mutex-posix.c
+++ b/src/pulsecore/mutex-posix.c
@@ -23,15 +23,28 @@
 
 #include <pthread.h>
 #include <errno.h>
+#ifdef __TIZEN__
+#include <sys/time.h>
+#endif
 
 #include <pulse/xmalloc.h>
+
+#include <pulsecore/core-error.h>
 #include <pulsecore/macro.h>
 
 #include "mutex.h"
 
+#ifdef __TIZEN__
+struct pa_mutex {
+    unsigned int lock;
+    pthread_mutex_t mutex;
+    unsigned int unlock;
+};
+#else
 struct pa_mutex {
     pthread_mutex_t mutex;
 };
+#endif
 
 struct pa_cond {
     pthread_cond_t cond;
@@ -74,20 +87,46 @@ pa_mutex* pa_mutex_new(bool recursive, bool inherit_priority) {
     }
 #endif
 
+#ifdef __TIZEN__
+    m->lock = 0;
+    m->unlock = 0;
+#endif
+
     return m;
 }
 
 void pa_mutex_free(pa_mutex *m) {
+#ifdef __TIZEN__
+    int ret;
+#endif
     pa_assert(m);
 
+#ifdef __TIZEN__
+    ret = pthread_mutex_destroy(&m->mutex);
+    if (ret != 0)
+        pa_log_error("pthread_mutex_destroy [%p] error [%d], (%d/%d)", &m->mutex, ret, m->lock, m->unlock);
+    pa_assert_se(ret == 0);
+#else
     pa_assert_se(pthread_mutex_destroy(&m->mutex) == 0);
+#endif
     pa_xfree(m);
 }
 
 void pa_mutex_lock(pa_mutex *m) {
+#ifdef __TIZEN__
+    int ret;
+#endif
     pa_assert(m);
 
+#ifdef __TIZEN__
+    ret = pthread_mutex_lock(&m->mutex);
+    if (ret != 0)
+        pa_log_error("pthread_mutex_lock [%p] error [%d], (%d/%d)", &m->mutex, ret, m->lock, m->unlock);
+    pa_assert_se(ret == 0);
+    m->lock++;
+#else
     pa_assert_se(pthread_mutex_lock(&m->mutex) == 0);
+#endif
 }
 
 bool pa_mutex_try_lock(pa_mutex *m) {
@@ -103,9 +142,21 @@ bool pa_mutex_try_lock(pa_mutex *m) {
 }
 
 void pa_mutex_unlock(pa_mutex *m) {
+    int err;
+
     pa_assert(m);
 
-    pa_assert_se(pthread_mutex_unlock(&m->mutex) == 0);
+    if ((err = pthread_mutex_unlock(&m->mutex)) != 0) {
+#ifdef __TIZEN__
+        pa_log_error("pthread_mutex_unlock [%p] error [%d], (%d/%d)", &m->mutex, err, m->lock, m->unlock);
+#else
+        pa_log("pthread_mutex_unlock() failed: %s", pa_cstrerror(err));
+#endif
+        pa_assert_not_reached();
+    }
+#ifdef __TIZEN__
+    m->unlock++;
+#endif
 }
 
 pa_cond *pa_cond_new(void) {
@@ -139,6 +190,29 @@ int pa_cond_wait(pa_cond *c, pa_mutex *m) {
     return pthread_cond_wait(&c->cond, &m->mutex);
 }
 
+#ifdef __TIZEN__
+int pa_cond_timedwait(pa_cond *c, pa_mutex *m, int ms_to_wait) {
+    struct timeval now;
+    struct timeval wait;
+    struct timeval wait_until;
+    struct timespec wait_until_ts;
+
+    pa_assert(c);
+    pa_assert(m);
+
+    gettimeofday(&now, NULL);
+
+    wait.tv_sec = ms_to_wait / 1000L;
+    wait.tv_usec = (ms_to_wait % 1000L) * 1000L;
+
+    timeradd(&now, &wait, &wait_until);
+
+    wait_until_ts.tv_sec = wait_until.tv_sec;
+    wait_until_ts.tv_nsec = wait_until.tv_usec * 1000L;
+
+    return pthread_cond_timedwait(&c->cond, &m->mutex, &wait_until_ts);
+}
+#endif
 pa_mutex* pa_static_mutex_get(pa_static_mutex *s, bool recursive, bool inherit_priority) {
     pa_mutex *m;