blob: 9e1b5fbdaa0171e233ef156ac536617510f92274 [file] [log] [blame]
aliguorie5d355d2009-04-24 18:03:15 +00001/*
2 * Wrappers around mutex/cond/thread functions
3 *
4 * Copyright Red Hat, Inc. 2009
5 *
6 * Author:
7 * Marcelo Tosatti <mtosatti@redhat.com>
8 *
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.
11 *
12 */
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"
21
22static void error_exit(int err, const char *msg)
23{
24 fprintf(stderr, "qemu: %s: %s\n", msg, strerror(err));
Jan Kiszka53380ac2011-09-21 09:28:31 +020025 abort();
aliguorie5d355d2009-04-24 18:03:15 +000026}
27
28void qemu_mutex_init(QemuMutex *mutex)
29{
30 int err;
Paolo Bonzini89b48b52011-03-12 17:43:54 +010031 pthread_mutexattr_t mutexattr;
aliguorie5d355d2009-04-24 18:03:15 +000032
Paolo Bonzini89b48b52011-03-12 17:43:54 +010033 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);
aliguorie5d355d2009-04-24 18:03:15 +000037 if (err)
38 error_exit(err, __func__);
39}
40
Corentin Chary313b1d62010-07-07 20:58:01 +020041void qemu_mutex_destroy(QemuMutex *mutex)
42{
43 int err;
44
45 err = pthread_mutex_destroy(&mutex->lock);
46 if (err)
47 error_exit(err, __func__);
48}
49
aliguorie5d355d2009-04-24 18:03:15 +000050void qemu_mutex_lock(QemuMutex *mutex)
51{
52 int err;
53
54 err = pthread_mutex_lock(&mutex->lock);
55 if (err)
56 error_exit(err, __func__);
57}
58
59int qemu_mutex_trylock(QemuMutex *mutex)
60{
61 return pthread_mutex_trylock(&mutex->lock);
62}
63
aliguorie5d355d2009-04-24 18:03:15 +000064void qemu_mutex_unlock(QemuMutex *mutex)
65{
66 int err;
67
68 err = pthread_mutex_unlock(&mutex->lock);
69 if (err)
70 error_exit(err, __func__);
71}
72
73void qemu_cond_init(QemuCond *cond)
74{
75 int err;
76
77 err = pthread_cond_init(&cond->cond, NULL);
78 if (err)
79 error_exit(err, __func__);
80}
81
Corentin Chary313b1d62010-07-07 20:58:01 +020082void qemu_cond_destroy(QemuCond *cond)
83{
84 int err;
85
86 err = pthread_cond_destroy(&cond->cond);
87 if (err)
88 error_exit(err, __func__);
89}
90
aliguorie5d355d2009-04-24 18:03:15 +000091void qemu_cond_signal(QemuCond *cond)
92{
93 int err;
94
95 err = pthread_cond_signal(&cond->cond);
96 if (err)
97 error_exit(err, __func__);
98}
99
100void qemu_cond_broadcast(QemuCond *cond)
101{
102 int err;
103
104 err = pthread_cond_broadcast(&cond->cond);
105 if (err)
106 error_exit(err, __func__);
107}
108
109void qemu_cond_wait(QemuCond *cond, QemuMutex *mutex)
110{
111 int err;
112
113 err = pthread_cond_wait(&cond->cond, &mutex->lock);
114 if (err)
115 error_exit(err, __func__);
116}
117
aliguorie5d355d2009-04-24 18:03:15 +0000118void qemu_thread_create(QemuThread *thread,
119 void *(*start_routine)(void*),
Jan Kiszkacf218712011-12-12 17:21:31 +0100120 void *arg, int mode)
aliguorie5d355d2009-04-24 18:03:15 +0000121{
Jan Kiszkacf218712011-12-12 17:21:31 +0100122 sigset_t set, oldset;
aliguorie5d355d2009-04-24 18:03:15 +0000123 int err;
Jan Kiszka87630462011-12-12 17:21:32 +0100124 pthread_attr_t attr;
aliguorie5d355d2009-04-24 18:03:15 +0000125
Jan Kiszka87630462011-12-12 17:21:32 +0100126 err = pthread_attr_init(&attr);
127 if (err) {
128 error_exit(err, __func__);
129 }
130 if (mode == QEMU_THREAD_DETACHED) {
131 err = pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
132 if (err) {
133 error_exit(err, __func__);
134 }
135 }
Paolo Bonzini55541c82010-06-03 15:20:32 +0200136
Jan Kiszkacf218712011-12-12 17:21:31 +0100137 /* Leave signal handling to the iothread. */
Paolo Bonzini55541c82010-06-03 15:20:32 +0200138 sigfillset(&set);
139 pthread_sigmask(SIG_SETMASK, &set, &oldset);
Jan Kiszka87630462011-12-12 17:21:32 +0100140 err = pthread_create(&thread->thread, &attr, start_routine, arg);
aliguorie5d355d2009-04-24 18:03:15 +0000141 if (err)
142 error_exit(err, __func__);
Paolo Bonzini55541c82010-06-03 15:20:32 +0200143
144 pthread_sigmask(SIG_SETMASK, &oldset, NULL);
Jan Kiszka87630462011-12-12 17:21:32 +0100145
146 pthread_attr_destroy(&attr);
aliguorie5d355d2009-04-24 18:03:15 +0000147}
148
Jan Kiszkab7680cb2011-03-12 17:43:51 +0100149void qemu_thread_get_self(QemuThread *thread)
aliguorie5d355d2009-04-24 18:03:15 +0000150{
151 thread->thread = pthread_self();
152}
153
Jan Kiszkab7680cb2011-03-12 17:43:51 +0100154int qemu_thread_is_self(QemuThread *thread)
aliguorie5d355d2009-04-24 18:03:15 +0000155{
Jan Kiszkab7680cb2011-03-12 17:43:51 +0100156 return pthread_equal(pthread_self(), thread->thread);
aliguorie5d355d2009-04-24 18:03:15 +0000157}
158
Corentin Chary313b1d62010-07-07 20:58:01 +0200159void qemu_thread_exit(void *retval)
160{
161 pthread_exit(retval);
162}
Jan Kiszka87630462011-12-12 17:21:32 +0100163
164void *qemu_thread_join(QemuThread *thread)
165{
166 int err;
167 void *ret;
168
169 err = pthread_join(thread->thread, &ret);
170 if (err) {
171 error_exit(err, __func__);
172 }
173 return ret;
174}