X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2Fsm%2FMarkWeak.c;h=455b58628947116ce4f1cf60fc8552e4c8e33f27;hb=05b677fad57427a5639b36a1822c9ebd52cb3339;hp=49134da826150698a1c7a6fd3ce772d68d920d15;hpb=64c17c4561cf419a4c70511bafc0815ea670bb2e;p=ghc-hetmet.git

diff --git a/rts/sm/MarkWeak.c b/rts/sm/MarkWeak.c
index 49134da..455b586 100644
--- a/rts/sm/MarkWeak.c
+++ b/rts/sm/MarkWeak.c
@@ -284,17 +284,26 @@ traverseBlackholeQueue (void)
 {
     StgTSO *prev, *t, *tmp;
     rtsBool flag;
+    nat type;
 
     flag = rtsFalse;
     prev = NULL;
 
     for (t = blackhole_queue; t != END_TSO_QUEUE; prev=t, t = t->link) {
+        // if the thread is not yet alive...
 	if (! (tmp = (StgTSO *)isAlive((StgClosure*)t))) {
-	    if (isAlive(t->block_info.closure)) {
-		t = (StgTSO *)evacuate((StgClosure *)t);
-		if (prev) prev->link = t;
-		flag = rtsTrue;
-	    }
+            // if the closure it is blocked on is either (a) a
+            // reachable BLAKCHOLE or (b) not a BLACKHOLE, then we
+            // make the thread alive.
+	    if (!isAlive(t->block_info.closure)) {
+                type = get_itbl(t->block_info.closure)->type;
+                if (type == BLACKHOLE || type == CAF_BLACKHOLE) {
+                    continue;
+                }
+            }
+            t = (StgTSO *)evacuate((StgClosure *)t);
+            if (prev) prev->link = t;
+            flag = rtsTrue;
 	}
     }
     return flag;