From: wolfgang.thaller@gmx.net <unknown>
Date: Sun, 12 Feb 2006 03:47:36 +0000 (+0000)
Subject: SMP bugfix: reload capability from task->cap after scheduleDoGC
X-Git-Url: http://git.megacz.com/?p=ghc-hetmet.git;a=commitdiff_plain;h=e1e8149d4f59a23e3e00c2d7abdb9ebdfbd40094

SMP bugfix: reload capability from task->cap after scheduleDoGC
---

diff --git a/ghc/rts/Schedule.c b/ghc/rts/Schedule.c
index 935a916..6fa21b7 100644
--- a/ghc/rts/Schedule.c
+++ b/ghc/rts/Schedule.c
@@ -445,6 +445,9 @@ schedule (Capability *initialCapability, Task *task)
     scheduleCheckBlockedThreads(cap);
 
     scheduleDetectDeadlock(cap,task);
+#if defined(THREADED_RTS)
+    cap = task->cap;    // reload cap, it might have changed
+#endif
 
     // Normally, the only way we can get here with no threads to
     // run is if a keyboard interrupt received during 
@@ -678,7 +681,12 @@ run_thread:
     }
 
     if (scheduleDoHeapProfile(ready_to_gc)) { ready_to_gc = rtsFalse; }
-    if (ready_to_gc) { scheduleDoGC(cap,task,rtsFalse,GetRoots); }
+    if (ready_to_gc) {
+      scheduleDoGC(cap,task,rtsFalse,GetRoots);
+#if defined(THREADED_RTS)
+      cap = task->cap;    // reload cap, it might have changed  
+#endif
+    }
   } /* end of while() */
 
   IF_PAR_DEBUG(verbose,
@@ -915,6 +923,10 @@ scheduleDetectDeadlock (Capability *cap, Task *task)
 	// exception.  Any threads thus released will be immediately
 	// runnable.
 	scheduleDoGC( cap, task, rtsTrue/*force  major GC*/, GetRoots );
+#if defined(THREADED_RTS)
+	cap = task->cap;    // reload cap, it might have changed
+#endif
+
 	recent_activity = ACTIVITY_DONE_GC;
 	
 	if ( !emptyRunQueue(cap) ) return;
@@ -1899,7 +1911,7 @@ scheduleDoGC (Capability *cap, Task *task USED_IF_THREADS,
 	    IF_DEBUG(scheduler, sched_belch("someone else is trying to GC..."));
 	    if (cap) yieldCapability(&cap,task);
 	} while (waiting_for_gc);
-	return;
+	return;  // NOTE: task->cap might have changed here
     }
 
     for (i=0; i < n_capabilities; i++) {