Merge remote-tracking branch 'stefanha/trivial-patches' into staging
[qemu.git] / qemu-thread-posix.c
blob9e1b5fbdaa0171e233ef156ac536617510f92274
1 /*
2 * Wrappers around mutex/cond/thread functions
4 * Copyright Red Hat, Inc. 2009
6 * Author:
7 * Marcelo Tosatti <mtosatti@redhat.com>
9 * This work is licensed under the terms of the GNU GPL, version 2 or later.
10 * See the COPYING file in the top-level directory.
13 #include <stdlib.h>
14 #include <stdio.h>
15 #include <errno.h>
16 #include <time.h>
17 #include <signal.h>
18 #include <stdint.h>
19 #include <string.h>
20 #include "qemu-thread.h"
22 static void error_exit(int err, const char *msg)
24 fprintf(stderr, "qemu: %s: %s\n", msg, strerror(err));
25 abort();
28 void qemu_mutex_init(QemuMutex *mutex)
30 int err;
31 pthread_mutexattr_t mutexattr;
33 pthread_mutexattr_init(&mutexattr);
34 pthread_mutexattr_settype(&mutexattr, PTHREAD_MUTEX_ERRORCHECK);
35 err = pthread_mutex_init(&mutex->lock, &mutexattr);
36 pthread_mutexattr_destroy(&mutexattr);
37 if (err)
38 error_exit(err, __func__);
41 void qemu_mutex_destroy(QemuMutex *mutex)
43 int err;
45 err = pthread_mutex_destroy(&mutex->lock);
46 if (err)
47 error_exit(err, __func__);
50 void qemu_mutex_lock(QemuMutex *mutex)
52 int err;
54 err = pthread_mutex_lock(&mutex->lock);
55 if (err)
56 error_exit(err, __func__);
59 int qemu_mutex_trylock(QemuMutex *mutex)
61 return pthread_mutex_trylock(&mutex->lock);
64 void qemu_mutex_unlock(QemuMutex *mutex)
66 int err;
68 err = pthread_mutex_unlock(&mutex->lock);
69 if (err)
70 error_exit(err, __func__);
73 void qemu_cond_init(QemuCond *cond)
75 int err;
77 err = pthread_cond_init(&cond->cond, NULL);
78 if (err)
79 error_exit(err, __func__);
82 void qemu_cond_destroy(QemuCond *cond)
84 int err;
86 err = pthread_cond_destroy(&cond->cond);
87 if (err)
88 error_exit(err, __func__);
91 void qemu_cond_signal(QemuCond *cond)
93 int err;
95 err = pthread_cond_signal(&cond->cond);
96 if (err)
97 error_exit(err, __func__);
100 void qemu_cond_broadcast(QemuCond *cond)
102 int err;
104 err = pthread_cond_broadcast(&cond->cond);
105 if (err)
106 error_exit(err, __func__);
109 void qemu_cond_wait(QemuCond *cond, QemuMutex *mutex)
111 int err;
113 err = pthread_cond_wait(&cond->cond, &mutex->lock);
114 if (err)
115 error_exit(err, __func__);
118 void qemu_thread_create(QemuThread *thread,
119 void *(*start_routine)(void*),
120 void *arg, int mode)
122 sigset_t set, oldset;
123 int err;
124 pthread_attr_t attr;
126 err = pthread_attr_init(&attr);
127 if (err) {
128 error_exit(err, __func__);
130 if (mode == QEMU_THREAD_DETACHED) {
131 err = pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
132 if (err) {
133 error_exit(err, __func__);
137 /* Leave signal handling to the iothread. */
138 sigfillset(&set);
139 pthread_sigmask(SIG_SETMASK, &set, &oldset);
140 err = pthread_create(&thread->thread, &attr, start_routine, arg);
141 if (err)
142 error_exit(err, __func__);
144 pthread_sigmask(SIG_SETMASK, &oldset, NULL);
146 pthread_attr_destroy(&attr);
149 void qemu_thread_get_self(QemuThread *thread)
151 thread->thread = pthread_self();
154 int qemu_thread_is_self(QemuThread *thread)
156 return pthread_equal(pthread_self(), thread->thread);
159 void qemu_thread_exit(void *retval)
161 pthread_exit(retval);
164 void *qemu_thread_join(QemuThread *thread)
166 int err;
167 void *ret;
169 err = pthread_join(thread->thread, &ret);
170 if (err) {
171 error_exit(err, __func__);
173 return ret;