lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-25 04:33:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

snax now use independent protocol PTYPE_SNAX 11

Browse Source
This commit is contained in:
Cloud Wu
2014-04-28 15:52:54 +08:00
parent 45df4f2e71
commit c17ec76e94
3 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
lualib/skynet.lua
View File

@@ -24,7 +24,8 @@ local skynet = {
PTYPE_ERROR = 7,
PTYPE_QUEUE = 8,
PTYPE_DEBUG = 9,
PTYPE_LUA = 10
PTYPE_LUA = 10,
PTYPE_SNAX = 11,
}
-- code cache

18
lualib/snax.lua
View File

@@ -6,6 +6,14 @@ local typeclass = {}
local G = { require = function() end }
skynet.register_protocol {
name = "snax",
id = skynet.PTYPE_SNAX,
pack = skynet.pack,
unpack = skynet.unpack,
}
function snax.interface(name)
if typeclass[name] then
return typeclass[name]
@@ -38,7 +46,7 @@ local function gen_post(type, handle)
__index = function( t, k )
local id = assert(type.accept[k] , string.format("post %s no exist", k))
return function(...)
skynet_send(handle, "lua", id, ...)
skynet_send(handle, "snax", id, ...)
end
end })
end
@@ -48,7 +56,7 @@ local function gen_req(type, handle)
__index = function( t, k )
local id = assert(type.response[k] , string.format("request %s no exist", k))
return function(...)
return skynet_call(handle, "lua", id, ...)
return skynet_call(handle, "snax", id, ...)
end
end })
end
@@ -69,7 +77,7 @@ function snax.newservice(name, ...)
local handle = skynet.newservice("snaxd", name)
assert(handle_cache[handle] == nil)
if t.system.init then
skynet.call(handle, "lua", t.system.init, ...)
skynet.call(handle, "snax", t.system.init, ...)
end
local ret = wrapper(handle, name, t)
handle_cache[handle] = ret
@@ -90,7 +98,7 @@ end
function snax.kill(obj, ...)
local t = snax.interface(obj.type)
skynet_call(obj.handle, "lua", t.system.exit, ...)
skynet_call(obj.handle, "snax", t.system.exit, ...)
end
local function test_result(ok, ...)
@@ -103,7 +111,7 @@ end
function snax.hotfix(obj, source, ...)
local t = snax.interface(obj.type)
return test_result(skynet_call(obj.handle, "lua", t.system.hotfix, source, ...))
return test_result(skynet_call(obj.handle, "snax", t.system.hotfix, source, ...))
end
return snax