X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FWeak.c;h=94bead37527ef6a3c76e1c17221f4b175e8ecaf2;hb=0417404f5d1230c9d291ea9f73e2831121c8ec99;hp=17150f6b3cc7357d04aee573cb3a1d3d04bb9530;hpb=348e8f801ab659d84acfb49a5c7bbac63646e73a;p=ghc-hetmet.git diff --git a/rts/Weak.c b/rts/Weak.c index 17150f6..94bead3 100644 --- a/rts/Weak.c +++ b/rts/Weak.c @@ -8,13 +8,12 @@ #include "PosixSource.h" #include "Rts.h" +#include "RtsAPI.h" + #include "RtsUtils.h" -#include "SchedAPI.h" -#include "RtsFlags.h" #include "Weak.h" #include "Schedule.h" #include "Prelude.h" -#include "RtsAPI.h" #include "Trace.h" // ForeignPtrs with C finalizers rely on weak pointers inside weak_ptr_list @@ -26,7 +25,7 @@ StgWeak *weak_ptr_list; rtsBool running_finalizers = rtsFalse; void -runCFinalizer(StgVoid *fn, StgVoid *ptr, StgVoid *env, StgWord flag) +runCFinalizer(void *fn, void *ptr, void *env, StgWord flag) { if (flag) ((void (*)(void *, void *))fn)(env, ptr); @@ -47,9 +46,9 @@ runAllCFinalizers(StgWeak *list) farr = (StgArrWords *)UNTAG_CLOSURE(w->cfinalizer); if ((StgClosure *)farr != &stg_NO_FINALIZER_closure) - runCFinalizer((StgVoid *)farr->payload[0], - (StgVoid *)farr->payload[1], - (StgVoid *)farr->payload[2], + runCFinalizer((void *)farr->payload[0], + (void *)farr->payload[1], + (void *)farr->payload[2], farr->payload[3]); } @@ -77,7 +76,8 @@ scheduleFinalizers(Capability *cap, StgWeak *list) StgWeak *w; StgTSO *t; StgMutArrPtrs *arr; - nat n; + StgWord size; + nat n, i; running_finalizers = rtsTrue; @@ -97,9 +97,9 @@ scheduleFinalizers(Capability *cap, StgWeak *list) farr = (StgArrWords *)UNTAG_CLOSURE(w->cfinalizer); if ((StgClosure *)farr != &stg_NO_FINALIZER_closure) - runCFinalizer((StgVoid *)farr->payload[0], - (StgVoid *)farr->payload[1], - (StgVoid *)farr->payload[2], + runCFinalizer((void *)farr->payload[0], + (void *)farr->payload[1], + (void *)farr->payload[2], farr->payload[3]); #ifdef PROFILING @@ -121,10 +121,12 @@ scheduleFinalizers(Capability *cap, StgWeak *list) debugTrace(DEBUG_weak, "weak: batching %d finalizers", n); - arr = (StgMutArrPtrs *)allocateLocal(cap, sizeofW(StgMutArrPtrs) + n); + size = n + mutArrPtrsCardTableSize(n); + arr = (StgMutArrPtrs *)allocate(cap, sizeofW(StgMutArrPtrs) + size); TICK_ALLOC_PRIM(sizeofW(StgMutArrPtrs), n, 0); SET_HDR(arr, &stg_MUT_ARR_PTRS_FROZEN_info, CCS_SYSTEM); arr->ptrs = n; + arr->size = size; n = 0; for (w = list; w; w = w->link) { @@ -133,6 +135,10 @@ scheduleFinalizers(Capability *cap, StgWeak *list) n++; } } + // set all the cards to 1 + for (i = n; i < size; i++) { + arr->payload[i] = (StgClosure *)(W_)(-1); + } t = createIOThread(cap, RtsFlags.GcFlags.initialStkSize,