vga: Unbreak ISA support
[qemu.git] / qemu-thread-posix.c
blobac3c0c9d14b81024b470a2f6ee4af14fbbcc2c1a
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)
122 int err;
124 /* Leave signal handling to the iothread. */
125 sigset_t set, oldset;
127 sigfillset(&set);
128 pthread_sigmask(SIG_SETMASK, &set, &oldset);
129 err = pthread_create(&thread->thread, NULL, start_routine, arg);
130 if (err)
131 error_exit(err, __func__);
133 pthread_sigmask(SIG_SETMASK, &oldset, NULL);
136 void qemu_thread_get_self(QemuThread *thread)
138 thread->thread = pthread_self();
141 int qemu_thread_is_self(QemuThread *thread)
143 return pthread_equal(pthread_self(), thread->thread);
146 void qemu_thread_exit(void *retval)
148 pthread_exit(retval);