7911747bd4
This includes a (mangled) copy of the liburcu code. The main changes
are: 1) removing dependencies on many other header files in liburcu; 2)
removing for simplicity the tentative busy waiting in synchronize_rcu,
which has limited performance effects; 3) replacing futexes in
synchronize_rcu with QemuEvents for Win32 portability. The API is
the same as liburcu, so it should be possible in the future to require
liburcu on POSIX systems for example and use our copy only on Windows.
Among the various versions available I chose urcu-mb, which is the
least invasive implementation even though it does not have the
fastest rcu_read_{lock,unlock} implementation. The urcu flavor can
be changed later, after benchmarking.
Reviewed-by: Fam Zheng <famz@redhat.com>
Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
66 lines
2 KiB
C
66 lines
2 KiB
C
#ifndef __QEMU_THREAD_H
|
|
#define __QEMU_THREAD_H 1
|
|
|
|
#include <inttypes.h>
|
|
#include <stdbool.h>
|
|
|
|
typedef struct QemuMutex QemuMutex;
|
|
typedef struct QemuCond QemuCond;
|
|
typedef struct QemuSemaphore QemuSemaphore;
|
|
typedef struct QemuEvent QemuEvent;
|
|
typedef struct QemuThread QemuThread;
|
|
|
|
#ifdef _WIN32
|
|
#include "qemu/thread-win32.h"
|
|
#else
|
|
#include "qemu/thread-posix.h"
|
|
#endif
|
|
|
|
#define QEMU_THREAD_JOINABLE 0
|
|
#define QEMU_THREAD_DETACHED 1
|
|
|
|
void qemu_mutex_init(QemuMutex *mutex);
|
|
void qemu_mutex_destroy(QemuMutex *mutex);
|
|
void qemu_mutex_lock(QemuMutex *mutex);
|
|
int qemu_mutex_trylock(QemuMutex *mutex);
|
|
void qemu_mutex_unlock(QemuMutex *mutex);
|
|
|
|
void qemu_cond_init(QemuCond *cond);
|
|
void qemu_cond_destroy(QemuCond *cond);
|
|
|
|
/*
|
|
* IMPORTANT: The implementation does not guarantee that pthread_cond_signal
|
|
* and pthread_cond_broadcast can be called except while the same mutex is
|
|
* held as in the corresponding pthread_cond_wait calls!
|
|
*/
|
|
void qemu_cond_signal(QemuCond *cond);
|
|
void qemu_cond_broadcast(QemuCond *cond);
|
|
void qemu_cond_wait(QemuCond *cond, QemuMutex *mutex);
|
|
|
|
void qemu_sem_init(QemuSemaphore *sem, int init);
|
|
void qemu_sem_post(QemuSemaphore *sem);
|
|
void qemu_sem_wait(QemuSemaphore *sem);
|
|
int qemu_sem_timedwait(QemuSemaphore *sem, int ms);
|
|
void qemu_sem_destroy(QemuSemaphore *sem);
|
|
|
|
void qemu_event_init(QemuEvent *ev, bool init);
|
|
void qemu_event_set(QemuEvent *ev);
|
|
void qemu_event_reset(QemuEvent *ev);
|
|
void qemu_event_wait(QemuEvent *ev);
|
|
void qemu_event_destroy(QemuEvent *ev);
|
|
|
|
void qemu_thread_create(QemuThread *thread, const char *name,
|
|
void *(*start_routine)(void *),
|
|
void *arg, int mode);
|
|
void *qemu_thread_join(QemuThread *thread);
|
|
void qemu_thread_get_self(QemuThread *thread);
|
|
bool qemu_thread_is_self(QemuThread *thread);
|
|
void qemu_thread_exit(void *retval);
|
|
void qemu_thread_naming(bool enable);
|
|
|
|
struct Notifier;
|
|
void qemu_thread_atexit_add(struct Notifier *notifier);
|
|
void qemu_thread_atexit_remove(struct Notifier *notifier);
|
|
|
|
#endif
|