lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-24 12:20:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

keep skynet.wakeup order, see issue #587

Browse Source
This commit is contained in:
Cloud Wu
2017-03-13 17:01:41 +08:00
parent feab147563
commit cb19ab54e9
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lualib/skynet.lua
View File

@@ -5,6 +5,7 @@ local coroutine = coroutine
local assert = assert local assert = assert
local pairs = pairs local pairs = pairs
local pcall = pcall local pcall = pcall
local table = table
local profile = require "profile" local profile = require "profile"
@@ -46,7 +47,7 @@ local session_coroutine_address = {}
local session_response = {} local session_response = {}
local unresponse = {} local unresponse = {}
local wakeup_session = {} local wakeup_queue = {}
local sleep_session = {} local sleep_session = {}
local watching_service = {} local watching_service = {}
@@ -116,9 +117,8 @@ local function co_create(f)
end end
local function dispatch_wakeup() local function dispatch_wakeup()
local co = next(wakeup_session) local co = table.remove(wakeup_queue,1)
if co then if co then
wakeup_session[co] = nil
local session = sleep_session[co] local session = sleep_session[co]
if session then if session then
session_id_coroutine[session] = "BREAK" session_id_coroutine[session] = "BREAK"
@@ -414,8 +414,8 @@ function skynet.retpack(...)
end end
function skynet.wakeup(co) function skynet.wakeup(co)
if sleep_session[co] and wakeup_session[co] == nil then if sleep_session[co] then
wakeup_session[co] = true table.insert(wakeup_queue, co)
return true return true
end end
end end