MWE for Channel failure

[macd]

It looks like take! is not getting all that was put! into the Channel

julia (v1.2)> include("chantest.jl")
Test Failed at /home/macd/jlang/dev/JuliaInterpreter.jl/test/chantest.jl:15
  Expression: pvals == tvals
   Evaluated: [1, 2, 3, 4, 5, 6, 7, 8, 9, 10  …  999991, 999992, 999993, 999994, 999995, 999996, 999997, 999998, 999999, 1000000] == [1, 2, 3, 4, 5, 6, 7, 8, 9, 10  …  999735, 999736, 999737, 999738, 999739, 999740, 999741, 999742, 999743, 999744]
ERROR: Error while loading expression starting at /home/macd/jlang/dev/JuliaInterpreter.jl/test/chantest.jl:21
caused by [exception 1]
There was an error during testing

Here is the MWE

include("utils.jl")

module ChanTest
using Random
using Test
end

m = ChanTest

ex = quote
    c = Channel{Int}(Inf)
    pvals = map(i->put!(c,i), 1:10^6)
    tvals = Int[take!(c) for i in 1:10^6]
    @test pvals == tvals
end

nstmts = 100000

modexs, _ = JuliaInterpreter.split_expressions(m, ex)
for modex in modexs
    frame = JuliaInterpreter.prepare_thunk(modex)
    nstmtsleft = nstmts
    while true
        ret, nstmtsleft = evaluate_limited!(frame, nstmtsleft, true)
        if isa(ret, Aborted)
            JuliaInterpreter.finish_stack!(Compiled(), frame, true)
            break
        elseif isa(ret, Some)
            break
        end
    end
end

[goerch]

For me the critical test case in channels is

@testset "multiple for loops waiting on the same channel" begin
    # Test multiple "for" loops waiting on the same channel which
    # is closed after adding a few elements.
    c = Channel(32)
    results = []
    @sync begin
        for i in 1:20
            @async for ii in c
                @show i ii
                push!(results, ii)
            end
        end
        sleep(1.0)
        for i in 1:5
            @show i
            put!(c,i)
        end
        close(c)
    end
    @test sum(results) == 15
end

Trying an interpretation with

using JuliaInterpreter, Test

@interpret (
quote
    # Test multiple "for" loops waiting on the same channel which
    # is closed after adding a few elements.
    c = Channel(32)
    results = []
    @sync begin
        for i in 1:20
            @async for ii in c
                @show i ii
                push!(results, ii)
            end
        end
        sleep(1.0)
        for i in 1:5
            @show i
            put!(c,i)
        end
        close(c)
    end
    @test sum(results) == 15
end) 

yields

i = 1
i = 2
i = 3
i = 4
i = 5
i = 1
ii = 1
i = 2
ii = 2
i = 3
ii = 3
i = 4
ii = 4
i = 5
ii = 5
ERROR: LoadError: MethodError: objects of type Test.Pass are not callable

and expanding the macros I see

begin
    c = Channel(32)
    results = []
    begin
        let var"##sync#41" = Base.Channel(Base.Inf)
            var"#30#v" = begin
                    for i = 1:20
                        begin
                            let
                                local var"#31#task" = Base.Task((()->begin
                                                    for ii = c
                                                        begin
                                                            Base.println("i = ", Base.repr(begin
                                                                        local var"#33#value" = i
                                                                    end))
                                                            Base.println("ii = ", Base.repr(begin
                                                                        local var"#33#value" = ii
                                                                    end))
                                                            var"#33#value"
                                                        end
                                                        push!(results, ii)
                                                    end
                                                end))
                                if $(Expr(:islocal, Symbol("##sync#41")))
                                    Base.put!(var"##sync#41", var"#31#task")
                                end
                                Base.schedule(var"#31#task")
                                var"#31#task"
                            end
                        end
                    end
                    sleep(1.0)
                    for i = 1:5
                        begin
                            Base.println("i = ", Base.repr(begin
                                        local var"#34#value" = i
                                    end))
                            var"#34#value"
                        end
                        put!(c, i)
                    end
                    close(c)
                end
            Base.sync_end(var"##sync#41")
            var"#30#v"
        end
    end
    [...]
end

where I specifically don't understand this construction

                                if $(Expr(:islocal, Symbol("##sync#41")))

Any hints?