mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-24 20:23:06 +00:00
Fix spell error (#2098)
This commit is contained in:
@@ -8,7 +8,7 @@ local function timeout_check(ti)
|
|||||||
end
|
end
|
||||||
skynet.sleep(ti) -- sleep 10 sec
|
skynet.sleep(ti) -- sleep 10 sec
|
||||||
for k,v in pairs(list) do
|
for k,v in pairs(list) do
|
||||||
skynet.error("timout",ti,k,v)
|
skynet.error("timeout",ti,k,v)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|||||||
@@ -265,7 +265,7 @@ unpackreq_number(lua_State *L, const uint8_t * buf, int sz) {
|
|||||||
return_buffer(L, (const char *)buf+9, sz-9);
|
return_buffer(L, (const char *)buf+9, sz-9);
|
||||||
if (session == 0) {
|
if (session == 0) {
|
||||||
lua_pushnil(L);
|
lua_pushnil(L);
|
||||||
lua_pushboolean(L,1); // is_push, no reponse
|
lua_pushboolean(L,1); // is_push, no response
|
||||||
return 6;
|
return 6;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -326,7 +326,7 @@ unpackreq_string(lua_State *L, const uint8_t * buf, int sz) {
|
|||||||
return_buffer(L, (const char *)buf+2+namesz+4, sz - namesz - 6);
|
return_buffer(L, (const char *)buf+2+namesz+4, sz - namesz - 6);
|
||||||
if (session == 0) {
|
if (session == 0) {
|
||||||
lua_pushnil(L);
|
lua_pushnil(L);
|
||||||
lua_pushboolean(L,1); // is_push, no reponse
|
lua_pushboolean(L,1); // is_push, no response
|
||||||
return 6;
|
return 6;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -67,9 +67,9 @@ local function open_channel(t, key)
|
|||||||
-- no sender or closed, always succ
|
-- no sender or closed, always succ
|
||||||
succ = true
|
succ = true
|
||||||
else
|
else
|
||||||
-- trun off the sender
|
-- turn off the sender
|
||||||
succ, err = pcall(skynet.call, c, "lua", "changenode", false)
|
succ, err = pcall(skynet.call, c, "lua", "changenode", false)
|
||||||
if succ then --trun off failed, wait next index todo turn off
|
if succ then --turn off failed, wait next index todo turn off
|
||||||
node_sender_closed[key] = true
|
node_sender_closed[key] = true
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
@@ -118,7 +118,7 @@ local function loadconfig(tmp)
|
|||||||
end
|
end
|
||||||
local ct = connecting[name]
|
local ct = connecting[name]
|
||||||
if ct and ct.namequery and not config.nowaiting then
|
if ct and ct.namequery and not config.nowaiting then
|
||||||
skynet.error(string.format("Cluster node [%s] resloved : %s", name, address))
|
skynet.error(string.format("Cluster node [%s] resolved : %s", name, address))
|
||||||
skynet.wakeup(ct.namequery)
|
skynet.wakeup(ct.namequery)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -25,7 +25,7 @@ local function test()
|
|||||||
end
|
end
|
||||||
|
|
||||||
skynet.start(function()
|
skynet.start(function()
|
||||||
skynet.trace_timeout(true) -- trun on trace for timeout, skynet.task will returns more info.
|
skynet.trace_timeout(true) -- turn on trace for timeout, skynet.task will returns more info.
|
||||||
test()
|
test()
|
||||||
|
|
||||||
skynet.fork(wakeup, coroutine.running())
|
skynet.fork(wakeup, coroutine.running())
|
||||||
|
|||||||
Reference in New Issue
Block a user