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

bugfix: inc session before get channel

Browse Source
This commit is contained in:
Cloud Wu
2015-08-04 17:51:35 +08:00
parent 3b48beb428
commit 704b016f2c
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
service/clusterd.lua
View File

@@ -65,9 +65,11 @@ local function send_request(source, node, addr, msg, sz)
local session = node_session[node] or 1 local session = node_session[node] or 1
-- msg is a local pointer, cluster.packrequest will free it -- msg is a local pointer, cluster.packrequest will free it
local request, new_session = cluster.packrequest(addr, session, msg, sz) local request, new_session = cluster.packrequest(addr, session, msg, sz)
local c = node_channel[node]
node_session[node] = new_session node_session[node] = new_session
-- node_channel[node] may yield or throw error
local c = node_channel[node]
return c:request(request, session) return c:request(request, session)
end end