@@ -90,6 +90,46 @@ void qemu_mutex_unlock(QemuMutex *mutex)
error_exit(err, __func__);
}
+void qemu_rwmutex_init(QemuRWMutex *mutex)
+{
+ int err;
+
+ err = pthread_rwlock_init(&mutex->lock, NULL);
+ if (err) {
+ error_exit(err, __func__);
+ }
+}
+
+void qemu_rwmutex_rdlock(QemuRWMutex *mutex)
+{
+ int err;
+
+ err = pthread_rwlock_rdlock(&mutex->lock);
+ if (err) {
+ error_exit(err, __func__);
+ }
+}
+
+void qemu_rwmutex_wrlock(QemuRWMutex *mutex)
+{
+ int err;
+
+ err = pthread_rwlock_wrlock(&mutex->lock);
+ if (err) {
+ error_exit(err, __func__);
+ }
+}
+
+void qemu_rwmutex_unlock(QemuRWMutex *mutex)
+{
+ int err;
+
+ err = pthread_rwlock_unlock(&mutex->lock);
+ if (err) {
+ error_exit(err, __func__);
+ }
+}
+
void qemu_cond_init(QemuCond *cond)
{
int err;
@@ -7,6 +7,10 @@ struct QemuMutex {
pthread_mutex_t lock;
};
+struct QemuRWMutex {
+ pthread_rwlock_t lock;
+};
+
struct QemuCond {
pthread_cond_t cond;
};
@@ -16,6 +20,7 @@ struct QemuThread {
};
typedef struct QemuMutex QemuMutex;
+typedef struct QemuRWMutex QemuRWMutex;
typedef struct QemuCond QemuCond;
typedef struct QemuThread QemuThread;
@@ -26,6 +31,11 @@ int qemu_mutex_trylock(QemuMutex *mutex);
int qemu_mutex_timedlock(QemuMutex *mutex, uint64_t msecs);
void qemu_mutex_unlock(QemuMutex *mutex);
+void qemu_rwmutex_init(QemuRWMutex *mutex);
+void qemu_rwmutex_rdlock(QemuRWMutex *mutex);
+void qemu_rwmutex_wrlock(QemuRWMutex *mutex);
+void qemu_rwmutex_unlock(QemuRWMutex *mutex);
+
void qemu_cond_init(QemuCond *cond);
void qemu_cond_destroy(QemuCond *cond);
void qemu_cond_signal(QemuCond *cond);