mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-25 12:43:09 +00:00
fix issue #156
This commit is contained in:
@@ -33,7 +33,7 @@ local function update(db, key, value, ...)
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
local function wakeup(db, key1, key2, value, ...)
|
local function wakeup(db, key1, key2, ...)
|
||||||
if key1 == nil then
|
if key1 == nil then
|
||||||
return
|
return
|
||||||
end
|
end
|
||||||
@@ -43,7 +43,7 @@ local function wakeup(db, key1, key2, value, ...)
|
|||||||
end
|
end
|
||||||
if q[mode] == "queue" then
|
if q[mode] == "queue" then
|
||||||
db[key1] = nil
|
db[key1] = nil
|
||||||
if value then
|
if key2 then
|
||||||
-- throw error because can't wake up a branch
|
-- throw error because can't wake up a branch
|
||||||
for _,response in ipairs(q) do
|
for _,response in ipairs(q) do
|
||||||
response(false)
|
response(false)
|
||||||
@@ -53,7 +53,7 @@ local function wakeup(db, key1, key2, value, ...)
|
|||||||
end
|
end
|
||||||
else
|
else
|
||||||
-- it's branch
|
-- it's branch
|
||||||
return wakeup(q , key2, value, ...)
|
return wakeup(q , key2, ...)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user