cope with ThreadRelocated on the sleeping_queue
authorSimon Marlow <marlowsd@gmail.com>
Tue, 17 Feb 2009 13:27:57 +0000 (13:27 +0000)
committerSimon Marlow <marlowsd@gmail.com>
Tue, 17 Feb 2009 13:27:57 +0000 (13:27 +0000)
rts/posix/Select.c

index bf4b7ae..32dca96 100644 (file)
@@ -60,9 +60,15 @@ wakeUpSleepingThreads(lnat ticks)
     StgTSO *tso;
     rtsBool flag = rtsFalse;
 
-    while (sleeping_queue != END_TSO_QUEUE &&
-          (int)(ticks - sleeping_queue->block_info.target) >= 0) {
+    while (sleeping_queue != END_TSO_QUEUE) {
        tso = sleeping_queue;
+        if (tso->what_next == ThreadRelocated) {
+            sleeping_queue = tso->_link;
+            continue;
+        }
+        if (((long)ticks - (long)tso->block_info.target) < 0) {
+            break;
+        }
        sleeping_queue = tso->_link;
        tso->why_blocked = NotBlocked;
        tso->_link = END_TSO_QUEUE;