|
78 | 78 |
|
79 | 79 |
|
80 | 80 | function LoopSet(q::Expr, mod::Symbol = :Main)
|
81 |
| - contract_pass!(q) |
82 | 81 | ls = LoopSet(mod)
|
| 82 | + check_inputs!(q, ls.prepreamble) |
| 83 | + contract_pass!(q) |
83 | 84 | copyto!(ls, q)
|
84 | 85 | resize!(ls.loop_order, num_loops(ls))
|
85 | 86 | ls
|
@@ -157,23 +158,70 @@ function process_args(
|
157 | 158 | inline, check_empty, u₁, u₂, v, threads, warncheckarg
|
158 | 159 | end
|
159 | 160 | # check if the body of loop is a block, if not convert it to a block issue#395
|
160 |
| -function check_loopbody!(q) |
161 |
| - if q isa Expr && q.head == :for |
| 161 | +# and check if the range of loop is an enumerate, if it is replace it, issue#393 |
| 162 | +function check_inputs!(q, prepreamble) |
| 163 | + if Meta.isexpr(q, :for) |
162 | 164 | if !Meta.isexpr(q.args[2], :block)
|
163 | 165 | q.args[2] = Expr(:block, q.args[2])
|
164 |
| - else |
| 166 | + replace_enumerate!(q, prepreamble) # must after warp block |
| 167 | + else # maybe inner loops in block |
| 168 | + replace_enumerate!(q, prepreamble) |
165 | 169 | for arg in q.args[2].args
|
166 |
| - check_loopbody!(arg) # check recursively for inner loop |
| 170 | + check_inputs!(arg, prepreamble) # check recursively for inner loop |
167 | 171 | end
|
168 | 172 | end
|
169 | 173 | end
|
170 | 174 | return q
|
171 | 175 | end
|
| 176 | +function replace_enumerate!(q, prepreamble) |
| 177 | + looprange = q.args[1] |
| 178 | + if Meta.isexpr(looprange, :block) |
| 179 | + for i in 1:length(looprange.args) |
| 180 | + replace_single_enumerate!(q, prepreamble, i) |
| 181 | + end |
| 182 | + else |
| 183 | + replace_single_enumerate!(q, prepreamble) |
| 184 | + end |
| 185 | + return q |
| 186 | +end |
| 187 | +function replace_single_enumerate!(q, prepreamble, i=nothing) |
| 188 | + if isnothing(i) # not nest loop |
| 189 | + looprange, body = q.args[1], q.args[2] |
| 190 | + else # nest loop |
| 191 | + looprange, body = q.args[1].args[i], q.args[2] |
| 192 | + end |
| 193 | + @assert Meta.isexpr(looprange, :(=), 2) |
| 194 | + itersyms, r = looprange.args |
| 195 | + if Meta.isexpr(r, :call, 2) && r.args[1] == :enumerate |
| 196 | + _iter = r.args[2] |
| 197 | + if _iter isa Symbol |
| 198 | + iter = _iter |
| 199 | + else # name complex expr |
| 200 | + iter = gensym(:iter) |
| 201 | + push!(prepreamble.args, :($iter = $_iter)) |
| 202 | + end |
| 203 | + if Meta.isexpr(itersyms, :tuple, 2) |
| 204 | + indsym, varsym = itersyms.args[1]::Symbol, itersyms.args[2]::Symbol |
| 205 | + _replace_looprange!(q, i, indsym, iter) |
| 206 | + pushfirst!(body.args, :($varsym = $iter[$indsym + firstindex($iter) - 1])) |
| 207 | + elseif Meta.isexpr(itersyms, :tuple, 1) # like `for (i,) in enumerate(...)` |
| 208 | + indsym = itersyms.args[1]::Symbol |
| 209 | + _replace_looprange!(q, i, indsym, iter) |
| 210 | + elseif itersyms isa Symbol # if itersyms are not unbox in loop range |
| 211 | + throw(ArgumentError("`for $itersyms in enumerate($r)` is not supported, |
| 212 | + please use `for ($(itersyms)_i, $(itersyms)_v) in enumerate($r)` instead.")) |
| 213 | + else |
| 214 | + throw(ArgumentError("Don't know how to handle expression `$itersyms`.")) |
| 215 | + end |
| 216 | + end |
| 217 | + return q |
| 218 | +end |
| 219 | +_replace_looprange!(q, ::Nothing, indsym, iter) = q.args[1] = :($indsym = Base.OneTo(length($iter))) |
| 220 | +_replace_looprange!(q, i::Int, indsym, iter) = q.args[1].args[i] = :($indsym = Base.OneTo(length($iter))) |
172 | 221 |
|
173 | 222 | function turbo_macro(mod, src, q, args...)
|
174 | 223 | q = macroexpand(mod, q)
|
175 | 224 | if q.head === :for
|
176 |
| - check_loopbody!(q) |
177 | 225 | ls = LoopSet(q, mod)
|
178 | 226 | inline, check_empty, u₁, u₂, v, threads, warncheckarg = process_args(args)
|
179 | 227 | esc(setup_call(ls, q, src, inline, check_empty, u₁, u₂, v, threads, warncheckarg))
|
|
0 commit comments