actix-lua 0.3.0

Define Actix actor with Lua
Documentation 
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

__threads = {}
__thread_id_seq = 0
__scripts = {}

ctx = { state = {} }

function __load(script, name)
    local f, err = load(script, name, "bt")
    if f == nil then
        error(err)
    end
    __scripts[name] = f
end

-- create a new coroutine from given script
function __run(script_name, msg)
    ctx.thread_id = __thread_id_seq
    __thread_id_seq = __thread_id_seq + 1

    ctx.notify = notify
    ctx.notify_later = notify_later
    ctx.new_actor = function (path)
        return __new_actor(path, ctx.thread_id)
    end
    ctx.send = function (recipient_name, msg)
        send(recipient_name, msg, ctx.thread_id)
        return coroutine.yield()
    end
    ctx.do_send = do_send
    ctx.terminate = terminate

    ctx.msg = msg

    local thread = coroutine.create(__scripts[script_name])

    local ok, ret = coroutine.resume(thread)
    -- save the thread and its context if the thread yielded
    if coroutine.status(thread) == "suspended" then
        __threads[ctx.thread_id] = { thread = thread, msg = msg }
    end
    ctx.msg = nil
    ctx.thread_id = nil
    return ret
end

-- resume a existing coroutine
function __resume(thread_id, args)
    print("__resume", thread_id, args)
    local thread = __threads[thread_id]
    ctx.thread_id = thread_id
    ctx.msg = thread.msg
    local ok, ret = coroutine.resume(thread.thread, args)
    if coroutine.status(thread.thread) == "dead" then
        __threads[ctx.thread_id] = nil
    end
    ctx.msg = nil
    ctx.thread_id = nil
    return ret
end