Mercurial > repos > rhope
annotate nworker.rhope @ 20:b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
author | Mike Pavone <pavone@retrodev.com> |
---|---|
date | Wed, 27 May 2009 21:42:37 -0400 |
parents | 90c20dc3f4e5 |
children | e9272f7ebd26 |
rev | line source |
---|---|
2 | 1 Import extendlib.rhope |
20
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
2 Import cbackend.rhope |
2 | 3 |
4 Set@Range[range,index,val:out] | |
5 { | |
6 out <- [[()]Concatenate[range] | |
7 ]Set[index,val] | |
8 } | |
9 | |
10 List of Lists[num:out] | |
11 { | |
12 out <- Fold[["Append"]Set Input[1, ()],(), Range[0,num]] | |
13 } | |
14 | |
15 Blueprint Worker Ref | |
16 { | |
17 Name | |
18 Convention | |
19 Inputs | |
20 Outputs | |
21 } | |
22 | |
23 Worker Ref[name,convention,inputs,outputs:out] | |
24 { | |
25 out <- [[[[Build["Worker Ref"]]Name <<[name]]Convention <<[convention]]Inputs <<[inputs]]Outputs <<[outputs] | |
26 } | |
27 | |
28 Blueprint Node Ref | |
29 { | |
30 Index | |
31 IO Num | |
32 } | |
33 | |
34 Node Ref[index,ionum:out] | |
35 { | |
36 out <- [[Build["Node Ref"]]Index <<[index]]IO Num <<[ionum] | |
37 } | |
38 | |
39 =@Node Ref[left,right:out] | |
40 { | |
41 ,out <- If[[[left]Index >>] = [[right]Index >>]] | |
42 { | |
43 out <- [[left]IO Num>>] = [[right]IO Num >>] | |
44 } | |
45 } | |
46 | |
47 Blueprint NWorker Node | |
48 { | |
49 Type | |
50 Data | |
51 Inputs | |
52 Outputs | |
53 Wires From | |
54 Wires To | |
55 } | |
56 | |
57 Wire To@NWorker Node[node,from,output,input:out] | |
58 { | |
59 out <- [node]Wires To <<[ | |
60 [[node]Wires To >>]Set[input, | |
61 [[[node]Wires To >>]Index[input] | |
62 ]Append[Node Ref[from,output]] | |
63 ] | |
64 ] | |
65 } | |
66 | |
67 Wire From@NWorker Node[node,to,input,output:out] | |
68 { | |
69 out <- [node]Wires From <<[ | |
70 [[node]Wires From >>]Set[output, | |
71 [[[node]Wires From >>]Index[output] | |
72 ]Append[Node Ref[to,input]] | |
73 ] | |
74 ] | |
75 } | |
76 | |
77 _Dependency[dlist,ref:out] | |
78 { | |
79 [dlist]Find[ref] | |
80 { | |
81 out <- dlist | |
82 }{ | |
83 out <- [dlist]Append[ref] | |
84 } | |
85 } | |
86 | |
87 Dependencies@NWorker Node[node:out] | |
88 { | |
89 out <- Fold[["Fold"]Set Input[0, "_Dependency"], (), [node]Wires To >>] | |
90 } | |
91 | |
92 | |
93 NWorker Node[type,data,inputs,outputs:out] | |
94 { | |
95 out <- [[[[[[Build["NWorker Node"] | |
96 ]Type <<[type] | |
97 ]Data <<[data] | |
98 ]Inputs <<[inputs] | |
99 ]Outputs <<[outputs] | |
100 ]Wires From <<[List of Lists[outputs]] | |
101 ]Wires To <<[List of Lists[inputs]] | |
102 } | |
103 | |
104 Blueprint NWorker | |
105 { | |
106 Convention | |
107 Nodes | |
108 Inputs | |
109 Outputs | |
19
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
110 NodeResults |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
111 Free Temps |
2 | 112 } |
113 | |
114 NWorker[convention:out] | |
115 { | |
116 out <- [[[[Build["NWorker"]]Convention <<[convention]]Nodes <<[()]]Inputs <<[()]]Outputs <<[()] | |
117 } | |
118 | |
119 Add Node@NWorker[worker,type,data,inputs,outputs:out,node index] | |
120 { | |
121 out <- [worker]Nodes <<[[[worker]Nodes >>]Append[NWorker Node[type,data,inputs,outputs]]] | |
122 node index <- [[worker]Nodes >>]Length | |
123 } | |
124 | |
125 Add Worker Call@NWorker[worker,tocall:out,node index] | |
126 { | |
127 out, node index <- [worker]Add Node["call",tocall,[tocall]Inputs >>,[tocall]Outputs >>] | |
128 } | |
129 | |
130 Add Constant@NWorker[worker,constant:out,node index] | |
131 { | |
132 out, node index <- [worker]Add Node["const",constant,0,1] | |
133 } | |
134 | |
135 Add Input@NWorker[worker,name,number:out,node index] | |
136 { | |
137 ,node index <- [worker]Add Node["input",number,0,1] | |
138 { out <- [~]Inputs <<[[[~]Inputs >>]Set[number,name]] } | |
139 } | |
140 | |
141 Add Output@NWorker[worker,name,number:out,node index] | |
142 { | |
143 ,node index <- [worker]Add Node["output",number,1,0] | |
144 { out <- [~]Outputs <<[[[~]Outputs >>]Set[number,name]] } | |
145 } | |
146 | |
147 Add Wire@NWorker[worker,from,output,to,input:out] | |
148 { | |
149 fromw <- [[[worker]Nodes >>]Index[from]]Wire From[to,input,output] | |
150 tow <- [[[worker]Nodes >>]Index[to]]Wire To[from,output,input] | |
151 nodes <- [[[worker]Nodes >>]Set[from, fromw]]Set[to, tow] | |
152 out <- [worker]Nodes <<[nodes] | |
153 } | |
154 | |
155 _No Dependencies[list,node,index:out] | |
156 { | |
157 [[node]Wires To>>]First | |
158 { | |
159 out <- Val[list] | |
160 }{ | |
161 out <- [list]Append[index] | |
162 } | |
163 } | |
164 | |
165 No Dependencies@NWorker[worker:out] | |
166 { | |
167 out <- Fold["_No Dependencies", (), [worker]Nodes >>] | |
168 } | |
169 | |
170 _Collect Dests[candidates,wire:out] | |
171 { | |
172 out <- [candidates]Set[[wire]Index >>, Yes] | |
173 } | |
174 | |
175 Collect Dests@NWorker[worker,candidates,node index:out] | |
176 { | |
177 out <- Fold[["Fold"]Set Input[0, "_Collect Dests"], candidates, [[[worker]Nodes >>]Index[node index]]Wires From >>] | |
178 } | |
179 | |
180 Check Dependency@NWorker[worker,nodes,wires,wire index:met?] | |
181 { | |
182 ref <- [wires]Index[wire index] | |
183 [nodes]Find[[ref]Index >>] | |
184 { | |
185 [wires]Next[wire index] | |
186 { | |
187 met? <- [worker]Check Dependency[nodes,wires,~] | |
188 }{ | |
189 met? <- Yes | |
190 } | |
191 }{ | |
192 Print[[ref]Index >>] | |
193 met? <- No | |
194 } | |
195 } | |
196 _Check Dependencies@NWorker[worker,nodes,inputs,input index:met?] | |
197 { | |
198 wires <- [inputs]Index[input index] | |
199 [wires]First | |
200 { | |
201 current met? <- [worker]Check Dependency[nodes, wires, ~] | |
202 }{ | |
203 current met? <- Yes | |
204 } | |
205 If[current met?] | |
206 { | |
207 [inputs]Next[input index] | |
208 { | |
209 met? <- [worker]_Check Dependencies[nodes,inputs,~] | |
210 }{ | |
211 met? <- Yes | |
212 } | |
213 }{ | |
214 met? <- No | |
215 } | |
216 } | |
217 | |
218 Check Dependencies@NWorker[worker,nodes,candidate:met?] | |
219 { | |
220 inputs <- [[[worker]Nodes >>]Index[candidate]]Wires To >> | |
221 [inputs]First | |
222 { | |
223 met? <- [worker]_Check Dependencies[nodes, inputs, ~] | |
224 }{ | |
225 met? <- Yes | |
226 } | |
227 } | |
228 | |
229 Dependants@NWorker[worker,direct nodes,nodes:out] | |
230 { | |
231 candidates <- Keys[Fold[["Collect Dests"]Set Input[0,worker], (), direct nodes]] | |
232 out <- Filter[candidates, [["Check Dependencies"]Set Input[0, worker]]Set Input[1, nodes]] | |
233 } | |
234 | |
235 _Dependency Groups@NWorker[worker,last,all,grouped:out] | |
236 { | |
237 current <- [worker]Dependants[last,all] | |
238 [current]First | |
239 { | |
240 out <- [worker]_Dependency Groups[current, [all]Concatenate[current], [grouped]Append[current]] | |
241 }{ | |
242 out <- grouped | |
243 } | |
244 } | |
245 Dependency Groups@NWorker[worker:out] | |
246 { | |
247 no deps <- [worker]No Dependencies | |
248 out <- [worker]_Dependency Groups[no deps, no deps, [()]Append[no deps]] | |
249 } | |
250 | |
19
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
251 Compile Node@NWorker[worker,program,func,nodes,current:out] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
252 { |
20
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
253 Print[[node]Type >>] |
19
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
254 node <- [[worker]Nodes >>]Index[[nodes]Index[current]] |
20
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
255 If[[[node]Type >>] = ["call"]] |
19
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
256 { |
20
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
257 [program]Method?[[[node]Data >>]Name >>] |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
258 { |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
259 nfunc <- [func]Method Call[[[node]Data >>]Name >>, ()] |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
260 }{ |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
261 nfunc <- [func]Call[[[node]Data >>]Name >>, ()] |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
262 } |
19
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
263 }{ |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
264 nfunc <- Val[func] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
265 } |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
266 [nodes]Next[current] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
267 { |
20
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
268 out <- [worker]Compile Node[program,nfunc,nodes,~] |
19
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
269 }{ |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
270 out <- Val[nfunc] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
271 } |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
272 } |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
273 |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
274 Compile Group@NWorker[worker,program,func,groups,current:out] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
275 { |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
276 nodes <- [groups]Index[current] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
277 [nodes]First |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
278 { |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
279 nfunc <- [worker]Compile Node[program,func,nodes,~] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
280 }{ |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
281 nfunc <- Val[func] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
282 } |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
283 [groups]Next[current] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
284 { |
20
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
285 out <- [worker]Compile Group[program,nfunc,groups,~] |
19
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
286 }{ |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
287 out <- Val[nfunc] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
288 } |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
289 } |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
290 |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
291 Compile Worker@NWorker[worker,program,name:out] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
292 { |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
293 func <- [program]Create Function[name,[worker]Inputs >>, [worker]Outputs >>, [worker]Convention >>] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
294 groups <- [worker]Dependency Groups |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
295 [groups]First |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
296 { |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
297 final func <- [worker]Compile Group[program,func,groups, ~] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
298 }{ |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
299 final func <- Val[func] |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
300 } |
20
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
301 out <- [program]Store Function[final func] |
19
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
302 } |
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
303 |
2 | 304 Test[:out] |
305 { | |
306 ref+ <- Worker Ref["+","cdecl",2,1] | |
307 ref* <- Worker Ref["*","cdecl",2,1] | |
308 ,a <- [NWorker["cdecl"] | |
309 ]Add Input["a", 0] { | |
310 ,b <- [~]Add Input["b", 1] { | |
311 ,c <- [~]Add Input["c", 2] { | |
312 ,outref <- [~]Add Output["out", 0] { | |
313 ,call+ <- [~]Add Worker Call[ref+] { | |
314 ,call* <- [~]Add Worker Call[ref*] { | |
315 out <- [[[[[~]Add Wire[a,0,call+,0] | |
316 ]Add Wire[b,0,call+,1] | |
317 ]Add Wire[call+,0,call*,0] | |
318 ]Add Wire[c,0,call*,1] | |
319 ]Add Wire[call*,0,outref,0] | |
320 }}}}}} | |
19
90c20dc3f4e5
Initial work on compiling dataflow graphs to a backend
Mike Pavone <pavone@retrodev.com>
parents:
2
diff
changeset
|
321 } |
20
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
322 |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
323 Test Compile[:out] |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
324 { |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
325 out <- [Test[]]Compile Worker[C Program[] "Test"] |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
326 } |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
327 |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
328 Main[] |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
329 { |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
330 Pretty Print[Test Compile[], ""] |
b715532225c0
Differentiate between method and normal calls in dataflow graph compiler
Mike Pavone <pavone@retrodev.com>
parents:
19
diff
changeset
|
331 } |