X-Git-Url: http://git.megacz.com/?p=ghc-hetmet.git;a=blobdiff_plain;f=rts%2FSTM.c;h=b9be955f55dfb5e8ebb94ee03e40ec03d1b40f3f;hp=b5dcc54884bac1368682ce1ca1a552d94adc3f49;hb=9ecd4a3e69829f4c4ca6207043256cd40146556d;hpb=a970a3775856642e6d3690b5421e7dcb3e420d36 diff --git a/rts/STM.c b/rts/STM.c index b5dcc54..b9be955 100644 --- a/rts/STM.c +++ b/rts/STM.c @@ -306,7 +306,7 @@ static StgClosure *lock_tvar(StgTRecHeader *trec, do { do { result = s -> current_value; - } while (GET_INFO(result) == &stg_TREC_HEADER_info); + } while (GET_INFO(UNTAG_CLOSURE(result)) == &stg_TREC_HEADER_info); } while (cas((void *)&(s -> current_value), (StgWord)result, (StgWord)trec) != (StgWord)result); return result; @@ -388,8 +388,8 @@ static void unpark_tso(Capability *cap, StgTSO *tso) { static void unpark_waiters_on(Capability *cap, StgTVar *s) { StgTVarWatchQueue *q; - TRACE("unpark_waiters_on tvar=%p", s); StgTVarWatchQueue *trail; + TRACE("unpark_waiters_on tvar=%p", s); // unblock TSOs in reverse order, to be a bit fairer (#2319) for (q = s -> first_watch_queue_entry, trail = q; q != END_STM_WATCH_QUEUE; @@ -1573,7 +1573,7 @@ static StgClosure *read_current_value(StgTRecHeader *trec STG_UNUSED, StgTVar *t result = tvar -> current_value; #if defined(STM_FG_LOCKS) - while (GET_INFO(result) == &stg_TREC_HEADER_info) { + while (GET_INFO(UNTAG_CLOSURE(result)) == &stg_TREC_HEADER_info) { TRACE("%p : read_current_value(%p) saw %p", trec, tvar, result); result = tvar -> current_value; }