5f7d05ecfd
SynthFS needs a QLIST_INSERT_HEAD_RCU to make sure list instructions are not re-ordered and therefore avoiding a crash. There may be parallel readers which should be allowed for lock-free access and this variant allows us to get rid of rwlocks used by readers. SynthFS is a special case where we dont really need full RCU capabilities as it doesnt allow list entry deletion but concurrent readers/writers and instruction re-ordering should not result in a crash. Also, once the real rcu is available, dummy rcu macro definitions will go away and the code will still work as expected. This patchwork is based on inputs from Paolo Bonzini. Signed-off-by: Harsh Prateek Bora <harsh@linux.vnet.ibm.com> Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
45 lines
1.2 KiB
C
45 lines
1.2 KiB
C
#ifndef __QEMU_THREAD_H
|
|
#define __QEMU_THREAD_H 1
|
|
|
|
#include <inttypes.h>
|
|
|
|
typedef struct QemuMutex QemuMutex;
|
|
typedef struct QemuCond QemuCond;
|
|
typedef struct QemuThread QemuThread;
|
|
|
|
#ifdef _WIN32
|
|
#include "qemu-thread-win32.h"
|
|
#else
|
|
#include "qemu-thread-posix.h"
|
|
#endif
|
|
|
|
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);
|
|
|
|
#define rcu_read_lock() do { } while (0)
|
|
#define rcu_read_unlock() do { } while (0)
|
|
|
|
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_thread_create(QemuThread *thread,
|
|
void *(*start_routine)(void*),
|
|
void *arg);
|
|
void qemu_thread_get_self(QemuThread *thread);
|
|
int qemu_thread_is_self(QemuThread *thread);
|
|
void qemu_thread_exit(void *retval);
|
|
|
|
#endif
|