PPC: e500: msync is 440 only, e500 has real sync
[qemu.git] / qemu-thread-posix.c
1 /*
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
22 static void error_exit(int err, const char *msg)
23 {
24 fprintf(stderr, "qemu: %s: %s\n", msg, strerror(err));
25 abort();
26 }
27
28 void qemu_mutex_init(QemuMutex *mutex)
29 {
30 int err;
31 pthread_mutexattr_t mutexattr;
32
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__);
39 }
40
41 void 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
50 void 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
59 int qemu_mutex_trylock(QemuMutex *mutex)
60 {
61 return pthread_mutex_trylock(&mutex->lock);
62 }
63
64 void 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
73 void 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
82 void 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
91 void 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
100 void 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
109 void 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
118 void qemu_thread_create(QemuThread *thread,
119 void *(*start_routine)(void*),
120 void *arg, int mode)
121 {
122 sigset_t set, oldset;
123 int err;
124 pthread_attr_t attr;
125
126 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 }
136
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__);
143
144 pthread_sigmask(SIG_SETMASK, &oldset, NULL);
145
146 pthread_attr_destroy(&attr);
147 }
148
149 void qemu_thread_get_self(QemuThread *thread)
150 {
151 thread->thread = pthread_self();
152 }
153
154 int qemu_thread_is_self(QemuThread *thread)
155 {
156 return pthread_equal(pthread_self(), thread->thread);
157 }
158
159 void qemu_thread_exit(void *retval)
160 {
161 pthread_exit(retval);
162 }
163
164 void *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 }