RemoteEval

RemoteEval.jl

module RemoteEval

    @enum Messages DONE=1

    function start_server()
        port, server = listenany(8000)

        @async begin
            while true
                sock = accept(server)
                @async while isopen(sock)
                    data = deserialize(sock)
                    response = process_message_server(data)
                    serialize(sock, response)
                end
            end
        end
        port, server
    end

    function process_message_server(data)
        println(data)
        DONE
    end

    function process_message_server(data::Tuple{Module,Expr})
        eval(data...)
    end
    function remote_eval(client, mod::Module, ex::Expr)
        serialize(client, (mod, ex) )
        deserialize(client)
    end

end # module

port, server = RemoteEval.start_server()

client = connect(port)
serialize(client,"test")
deserialize(client)

RemoteEval.remote_eval(client,Main,:(x=rand(19)))