raw_dispatch_message 流程

首先获取dispatch的函数

local f = p.dispatch

并创建coroutine

local co = co_create(f)
session_coroutine_id[co] = session
session_coroutine_address[co] = source
suspend(co, coroutine_resume(co, session,source, p.unpack(msg,sz)))

可以看到创建完协程后,首先调用了coroutine_resume来让协程执行下去

-- suspend is local function
function suspend(co, result, command)
    if not result then
        local session = session_coroutine_id[co]
        if session then -- coroutine may fork by others (session is nil)
            local addr = session_coroutine_address[co]
            if session ~= 0 then
                -- only call response error
                local tag = session_coroutine_tracetag[co]
                if tag then c.trace(tag, "error") end
                c.send(addr, skynet.PTYPE_ERROR, session, "")
            end
            session_coroutine_id[co] = nil
        end
        session_coroutine_address[co] = nil
        session_coroutine_tracetag[co] = nil
        skynet.fork(function() end) -- trigger command "SUSPEND"
        local tb = traceback(co,tostring(command))
        coroutine.close(co)
        error(tb)
    end
    if command == "SUSPEND" then
        return dispatch_wakeup()
    elseif command == "QUIT" then
        coroutine.close(co)
        -- service exit
        return
    elseif command == "USER" then
        -- See skynet.coutine for detail
        error("Call skynet.coroutine.yield out of skynet.coroutine.resume\n" .. traceback(co))
    elseif command == nil then
        -- debug trace
        return
    else
        error("Unknown command : " .. command .. "\n" .. traceback(co))
    end
end