From mboxrd@z Thu Jan  1 00:00:00 1970
From: Ben Guthro <bguthro@virtualiron.com>
Subject: [PATCH][QEMU] Make active-timers thread-safe
Date: Mon, 27 Aug 2007 14:58:26 -0400
Message-ID: <46D31ED2.8070602@virtualiron.com>
Mime-Version: 1.0
Content-Type: multipart/mixed; boundary="------------050709060602060609080402"
Return-path: <xen-devel-bounces@lists.xensource.com>
List-Unsubscribe: <http://lists.xensource.com/cgi-bin/mailman/listinfo/xen-devel>,
	<mailto:xen-devel-request@lists.xensource.com?subject=unsubscribe>
List-Post: <mailto:xen-devel@lists.xensource.com>
List-Help: <mailto:xen-devel-request@lists.xensource.com?subject=help>
List-Subscribe: <http://lists.xensource.com/cgi-bin/mailman/listinfo/xen-devel>,
	<mailto:xen-devel-request@lists.xensource.com?subject=subscribe>
Sender: xen-devel-bounces@lists.xensource.com
Errors-To: xen-devel-bounces@lists.xensource.com
To: xen-devel@lists.xensource.com, Gary Grebus <ggrebus@virtualiron.com>
List-Id: xen-devel@lists.xenproject.org

This is a multi-part message in MIME format.

--------------050709060602060609080402
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit

Protect active_timers[] lists with mutexes so timers can be safely used from different threads.

Signed-off-by: Ben Guthro <bguthro@vrtualiron.com>
Signed-off-by: Gary Grebus <ggrebus@virtualiron.com>


--------------050709060602060609080402
Content-Type: text/x-patch;
 name="qemu-threadsafe-timers.patch"
Content-Transfer-Encoding: 7bit
Content-Disposition: inline;
 filename="qemu-threadsafe-timers.patch"

diff -r 475eda44cd99 tools/ioemu/vl.c
--- a/tools/ioemu/vl.c	Mon Aug 27 14:14:56 2007 -0400
+++ b/tools/ioemu/vl.c	Mon Aug 27 14:14:56 2007 -0400
@@ -759,6 +759,7 @@ QEMUClock *vm_clock;
 QEMUClock *vm_clock;
 
 static QEMUTimer *active_timers[2];
+static pthread_mutex_t active_timers_lock[2];
 #ifdef _WIN32
 static MMRESULT timerID;
 static HANDLE host_alarm = NULL;
@@ -795,7 +796,7 @@ void qemu_free_timer(QEMUTimer *ts)
 }
 
 /* stop a timer, but do not dealloc it */
-void qemu_del_timer(QEMUTimer *ts)
+static void qemu_del_timer_nolock(QEMUTimer *ts)
 {
     QEMUTimer **pt, *t;
 
@@ -808,10 +809,18 @@ void qemu_del_timer(QEMUTimer *ts)
             break;
         if (t == ts) {
             *pt = t->next;
+	    t->next = NULL;
             break;
         }
         pt = &t->next;
     }
+}
+
+void qemu_del_timer(QEMUTimer *ts)
+{
+    pthread_mutex_lock(&active_timers_lock[ts->clock->type]);
+    qemu_del_timer_nolock(ts);
+    pthread_mutex_unlock(&active_timers_lock[ts->clock->type]);
 }
 
 void qemu_advance_timer(QEMUTimer *ts, int64_t expire_time)
@@ -826,11 +835,13 @@ void qemu_mod_timer(QEMUTimer *ts, int64
 {
     QEMUTimer **pt, *t;
 
-    qemu_del_timer(ts);
-
-    /* add the timer in the sorted list */
     /* NOTE: this code must be signal safe because
        qemu_timer_expired() can be called from a signal. */
+    pthread_mutex_lock(&active_timers_lock[ts->clock->type]);
+
+    qemu_del_timer_nolock(ts);
+
+    /* add the timer in the sorted list */
     pt = &active_timers[ts->clock->type];
     for(;;) {
         t = *pt;
@@ -843,16 +854,20 @@ void qemu_mod_timer(QEMUTimer *ts, int64
     ts->expire_time = expire_time;
     ts->next = *pt;
     *pt = ts;
+    pthread_mutex_unlock(&active_timers_lock[ts->clock->type]);
 }
 
 int qemu_timer_pending(QEMUTimer *ts)
 {
     QEMUTimer *t;
+    pthread_mutex_lock(&active_timers_lock[ts->clock->type]);
     for(t = active_timers[ts->clock->type]; t != NULL; t = t->next) {
         if (t == ts)
-            return 1;
-    }
-    return 0;
+            break;
+    }
+    pthread_mutex_unlock(&active_timers_lock[ts->clock->type]);
+    return !!t;
+
 }
 
 static inline int qemu_timer_expired(QEMUTimer *timer_head, int64_t current_time)
@@ -865,7 +880,12 @@ static void qemu_run_timers(QEMUTimer **
 static void qemu_run_timers(QEMUTimer **ptimer_head, int64_t current_time)
 {
     QEMUTimer *ts;
+    int clock_type;
     
+    if (*ptimer_head == NULL)
+	return;
+    clock_type = (*ptimer_head)->clock->type;
+    pthread_mutex_lock(&active_timers_lock[clock_type]);
     for(;;) {
         ts = *ptimer_head;
         if (!ts || ts->expire_time > current_time)
@@ -875,8 +895,11 @@ static void qemu_run_timers(QEMUTimer **
         ts->next = NULL;
         
         /* run the callback (the timer list can be modified) */
+	pthread_mutex_unlock(&active_timers_lock[clock_type]);
         ts->cb(ts->opaque);
-    }
+	pthread_mutex_lock(&active_timers_lock[clock_type]);
+    }
+    pthread_mutex_unlock(&active_timers_lock[clock_type]);
 }
 
 int64_t qemu_get_clock(QEMUClock *clock)

--------------050709060602060609080402
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Content-Disposition: inline

_______________________________________________
Xen-devel mailing list
Xen-devel@lists.xensource.com
http://lists.xensource.com/xen-devel

--------------050709060602060609080402--