shelve

1 files changed, 6 insertions, 5 deletions

diff --git a/script/brave/brave.lua b/script/brave/brave.lua
index f07fb00f..9ad7ebd1 100644
--- a/script/brave/brave.lua
+++ b/script/brave/brave.lua
@@ -42,22 +42,23 @@ end
 
 --- 开始找工作
 function m.start(privatePad)
-    local myPad = privatePad and thread.channel('private:' .. privatePad) or taskPad
+    local reqPad = privatePad and thread.channel('req:' .. privatePad) or taskPad
+    local resPad = privatePad and thread.channel('res:' .. privatePad) or waiter
     m.push('mem', collectgarbage 'count')
     while true do
-        local name, id, params = myPad:bpop()
+        local name, id, params = reqPad:bpop()
         local ability = m.ability[name]
         -- TODO
         if not ability then
-            waiter:push(m.id, id)
+            resPad:push(m.id, id)
             log.error('Brave can not handle this work: ' .. name)
             goto CONTINUE
         end
         local ok, res = xpcall(ability, log.error, params)
         if ok then
-            waiter:push(m.id, id, res)
+            resPad:push(m.id, id, res)
         else
-            waiter:push(m.id, id)
+            resPad:push(m.id, id)
         end
         m.push('mem', collectgarbage 'count')
         ::CONTINUE::