mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-24 20:23:06 +00:00
see #870
This commit is contained in:
@@ -10,10 +10,9 @@ gate = tonumber(gate)
|
|||||||
fd = tonumber(fd)
|
fd = tonumber(fd)
|
||||||
|
|
||||||
local large_request = {}
|
local large_request = {}
|
||||||
local register_name = {}
|
|
||||||
local inquery_name = {}
|
local inquery_name = {}
|
||||||
|
|
||||||
setmetatable(register_name, { __index =
|
local register_name_mt = { __index =
|
||||||
function(self, name)
|
function(self, name)
|
||||||
local waitco = inquery_name[name]
|
local waitco = inquery_name[name]
|
||||||
if waitco then
|
if waitco then
|
||||||
@@ -35,7 +34,13 @@ setmetatable(register_name, { __index =
|
|||||||
return addr
|
return addr
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
})
|
}
|
||||||
|
|
||||||
|
local function new_register_name()
|
||||||
|
return setmetatable({}, register_name_mt)
|
||||||
|
end
|
||||||
|
|
||||||
|
local register_name = new_register_name()
|
||||||
|
|
||||||
local tracetag
|
local tracetag
|
||||||
|
|
||||||
@@ -132,7 +137,7 @@ skynet.start(function()
|
|||||||
socket.close(fd)
|
socket.close(fd)
|
||||||
skynet.exit()
|
skynet.exit()
|
||||||
elseif cmd == "namechange" then
|
elseif cmd == "namechange" then
|
||||||
register_name = {}
|
register_name = new_register_name()
|
||||||
else
|
else
|
||||||
skynet.error(string.format("Invalid command %s from %s", cmd, skynet.address(source)))
|
skynet.error(string.format("Invalid command %s from %s", cmd, skynet.address(source)))
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user