1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
|
/*----------------------------------------------------------------------
*
* (c) The GHC Team, 1998-2004
*
* STM interface definition
*
*----------------------------------------------------------------------
STM.h defines the C-level interface to the STM.
The design follows that of the PPoPP 2005 paper "Composable memory
transactions" extended to include fine-grained locking of TVars.
Three different implementations can be built. In overview:
STM_UNIPROC -- no locking at all: not safe for concurrent invocations
STM_CG_LOCK -- coarse-grained locking : a single mutex protects all
TVars
STM_FG_LOCKS -- per-TVar exclusion : each TVar can be owned by at
most one TRec at any time. This allows dynamically
non-conflicting transactions to commit in parallel.
The implementation treats reads optimisitcally --
extra versioning information is retained in the
saw_update_by field of the TVars so that they do not
need to be locked for reading.
STM.C contains more details about the locking schemes used.
*/
#pragma once
#if defined(THREADED_RTS)
//#define STM_CG_LOCK
#define STM_FG_LOCKS
#else
#define STM_UNIPROC
#endif
#include "BeginPrivate.h"
/*----------------------------------------------------------------------
GC interaction
--------------
*/
void stmPreGCHook(Capability *cap);
/*----------------------------------------------------------------------
Transaction context management
------------------------------
*/
/* Create and enter a new transaction context */
StgTRecHeader *stmStartTransaction(Capability *cap, StgTRecHeader *outer);
StgTRecHeader *stmStartNestedTransaction(Capability *cap, StgTRecHeader *outer
);
/*
* Roll back the current transatcion context. NB: if this is a nested tx
* then we merge its read set into its parents. This is because a change
* to that read set could change whether or not the tx should abort.
*/
void stmAbortTransaction(Capability *cap, StgTRecHeader *trec);
void stmFreeAbortedTRec(Capability *cap, StgTRecHeader *trec);
/*
* Ensure that a subsequent commit / validation will fail. We use this
* in our current handling of transactions that may have become invalid
* and started looping. We strip their stack back to the ATOMICALLY_FRAME,
* and, when the thread is next scheduled, discover it to be invalid and
* re-execute it. However, we need to force the transaction to stay invalid
* in case other threads' updates make it valid in the mean time.
*/
void stmCondemnTransaction(Capability *cap, StgTRecHeader *trec);
/*----------------------------------------------------------------------
Validation
----------
Test whether the specified transaction record, and all those within which
it is nested, are still valid.
Note: the caller can assume that once stmValidateTransaction has
returned false for a given trec then that transaction will never
again be valid -- we rely on this in Schedule.c when kicking invalid
threads at GC (in case they are stuck looping)
*/
StgBool stmValidateNestOfTransactions(Capability *cap, StgTRecHeader *trec);
/*----------------------------------------------------------------------
Commit/wait/rewait operations
-----------------------------
These four operations return boolean results which should be interpreted
as follows:
true => The transaction record was definitely valid
false => The transaction record may not have been valid
Note that, for nested operations, validity here is solely in terms
of the specified trec: it does not say whether those that it may be
nested are themselves valid. Callers can check this with
stmValidateNestOfTransactions.
The user of the STM should ensure that it is always safe to assume that a
transaction context is not valid when in fact it is (i.e. to return false in
place of true, with side-effects as defined below). This may cause
needless retries of transactions (in the case of validate and commit), or it
may cause needless spinning instead of blocking (in the case of wait and
rewait).
In defining the behaviour of wait and rewait we distinguish between two
different aspects of a thread's runnability:
- We say that a thread is "blocked" when it is not running or
runnable as far as the scheduler is concerned.
- We say that a thread is "waiting" when its StgTRecHeader is linked on an
tvar's wait queue.
Considering only STM operations, (blocked) => (waiting). The user of the STM
should ensure that they are prepared for threads to be unblocked spuriously
and for wait/reWait to return false even when the previous transaction context
is actually still valid.
*/
/*
* Test whether the current transaction context is valid and, if so,
* commit its memory accesses to the heap. stmCommitTransaction must
* unblock any threads which are waiting on tvars that updates have
* been committed to.
*/
StgBool stmCommitTransaction(Capability *cap, StgTRecHeader *trec);
StgBool stmCommitNestedTransaction(Capability *cap, StgTRecHeader *trec);
/*
* Test whether the current transaction context is valid and, if so,
* start the thread waiting for updates to any of the tvars it has
* ready from and mark it as blocked. It is an error to call stmWait
* if the thread is already waiting.
*/
StgBool stmWait(Capability *cap, StgTSO *tso, StgTRecHeader *trec);
void stmWaitUnlock(Capability *cap, StgTRecHeader *trec);
/*
* Test whether the current transaction context is valid and, if so,
* leave the thread waiting and mark it as blocked again. If the
* transaction context is no longer valid then stop the thread waiting
* and leave it as unblocked. It is an error to call stmReWait if the
* thread is not waiting.
*/
StgBool stmReWait(Capability *cap, StgTSO *tso);
/*----------------------------------------------------------------------
Data access operations
----------------------
*/
/*
* Return the logical contents of 'tvar' within the context of the
* thread's current transaction.
*/
StgClosure *stmReadTVar(Capability *cap,
StgTRecHeader *trec,
StgTVar *tvar);
/* Update the logical contents of 'tvar' within the context of the
* thread's current transaction.
*/
void stmWriteTVar(Capability *cap,
StgTRecHeader *trec,
StgTVar *tvar,
StgClosure *new_value);
/*----------------------------------------------------------------------*/
/* NULLs */
#define END_STM_WATCH_QUEUE ((StgTVarWatchQueue *)(void *)&stg_END_STM_WATCH_QUEUE_closure)
#define END_STM_CHUNK_LIST ((StgTRecChunk *)(void *)&stg_END_STM_CHUNK_LIST_closure)
#define NO_TREC ((StgTRecHeader *)(void *)&stg_NO_TREC_closure)
/*----------------------------------------------------------------------*/
#include "EndPrivate.h"
|
