qemu-devel
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[Qemu-devel] [PATCH 1/9] Add read-write lock to QEMU


From: Arun R Bharadwaj
Subject: [Qemu-devel] [PATCH 1/9] Add read-write lock to QEMU
Date: Thu, 14 Oct 2010 17:53:20 +0530
User-agent: StGit/0.15

From: Sripathi Kodi <address@hidden>

Signed-off-by: Sripathi Kodi <address@hidden>
---
 qemu-thread.c |   40 ++++++++++++++++++++++++++++++++++++++++
 qemu-thread.h |   10 ++++++++++
 2 files changed, 50 insertions(+), 0 deletions(-)

diff --git a/qemu-thread.c b/qemu-thread.c
index fbc78fe..42774ff 100644
--- a/qemu-thread.c
+++ b/qemu-thread.c
@@ -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;
diff --git a/qemu-thread.h b/qemu-thread.h
index 19bb30c..1b0267e 100644
--- a/qemu-thread.h
+++ b/qemu-thread.h
@@ -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);




reply via email to

[Prev in Thread] Current Thread [Next in Thread]