mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-25 12:43:09 +00:00
61
Makefile
61
Makefile
@@ -45,10 +45,25 @@ update3rd :
|
|||||||
# skynet
|
# skynet
|
||||||
|
|
||||||
CSERVICE = snlua logger gate harbor
|
CSERVICE = snlua logger gate harbor
|
||||||
LUA_CLIB = skynet socketdriver bson mongo md5 netpack \
|
LUA_CLIB = skynet \
|
||||||
clientsocket memory profile multicast \
|
clientsocket \
|
||||||
cluster crypt sharedata stm sproto lpeg \
|
bson md5 sproto lpeg
|
||||||
mysqlaux debugchannel
|
|
||||||
|
LUA_CLIB_SKYNET = \
|
||||||
|
lua-skynet.c lua-seri.c \
|
||||||
|
lua-socket.c \
|
||||||
|
lua-mongo.c \
|
||||||
|
lua-netpack.c \
|
||||||
|
lua-memory.c \
|
||||||
|
lua-profile.c \
|
||||||
|
lua-multicast.c \
|
||||||
|
lua-cluster.c \
|
||||||
|
lua-crypt.c lsha1.c \
|
||||||
|
lua-sharedata.c \
|
||||||
|
lua-stm.c \
|
||||||
|
lua-mysqlaux.c \
|
||||||
|
lua-debugchannel.c \
|
||||||
|
\
|
||||||
|
|
||||||
SKYNET_SRC = skynet_main.c skynet_handle.c skynet_module.c skynet_mq.c \
|
SKYNET_SRC = skynet_main.c skynet_handle.c skynet_module.c skynet_mq.c \
|
||||||
skynet_server.c skynet_start.c skynet_timer.c skynet_error.c \
|
skynet_server.c skynet_start.c skynet_timer.c skynet_error.c \
|
||||||
@@ -76,60 +91,24 @@ endef
|
|||||||
|
|
||||||
$(foreach v, $(CSERVICE), $(eval $(call CSERVICE_TEMP,$(v))))
|
$(foreach v, $(CSERVICE), $(eval $(call CSERVICE_TEMP,$(v))))
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/skynet.so : lualib-src/lua-skynet.c lualib-src/lua-seri.c | $(LUA_CLIB_PATH)
|
$(LUA_CLIB_PATH)/skynet.so : $(addprefix lualib-src/,$(LUA_CLIB_SKYNET)) | $(LUA_CLIB_PATH)
|
||||||
$(CC) $(CFLAGS) $(SHARED) $^ -o $@ -Iskynet-src -Iservice-src -Ilualib-src
|
$(CC) $(CFLAGS) $(SHARED) $^ -o $@ -Iskynet-src -Iservice-src -Ilualib-src
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/socketdriver.so : lualib-src/lua-socket.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) $^ -o $@ -Iskynet-src -Iservice-src
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/bson.so : lualib-src/lua-bson.c | $(LUA_CLIB_PATH)
|
$(LUA_CLIB_PATH)/bson.so : lualib-src/lua-bson.c | $(LUA_CLIB_PATH)
|
||||||
$(CC) $(CFLAGS) $(SHARED) -Iskynet-src $^ -o $@ -Iskynet-src
|
$(CC) $(CFLAGS) $(SHARED) -Iskynet-src $^ -o $@ -Iskynet-src
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/mongo.so : lualib-src/lua-mongo.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) $^ -o $@ -Iskynet-src
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/md5.so : 3rd/lua-md5/md5.c 3rd/lua-md5/md5lib.c 3rd/lua-md5/compat-5.2.c | $(LUA_CLIB_PATH)
|
$(LUA_CLIB_PATH)/md5.so : 3rd/lua-md5/md5.c 3rd/lua-md5/md5lib.c 3rd/lua-md5/compat-5.2.c | $(LUA_CLIB_PATH)
|
||||||
$(CC) $(CFLAGS) $(SHARED) -I3rd/lua-md5 $^ -o $@
|
$(CC) $(CFLAGS) $(SHARED) -I3rd/lua-md5 $^ -o $@
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/netpack.so : lualib-src/lua-netpack.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) $^ -Iskynet-src -o $@
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/clientsocket.so : lualib-src/lua-clientsocket.c | $(LUA_CLIB_PATH)
|
$(LUA_CLIB_PATH)/clientsocket.so : lualib-src/lua-clientsocket.c | $(LUA_CLIB_PATH)
|
||||||
$(CC) $(CFLAGS) $(SHARED) $^ -o $@ -lpthread
|
$(CC) $(CFLAGS) $(SHARED) $^ -o $@ -lpthread
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/memory.so : lualib-src/lua-memory.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) -Iskynet-src $^ -o $@
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/profile.so : lualib-src/lua-profile.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) $^ -o $@
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/multicast.so : lualib-src/lua-multicast.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) -Iskynet-src $^ -o $@
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/cluster.so : lualib-src/lua-cluster.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) -Iskynet-src $^ -o $@
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/crypt.so : lualib-src/lua-crypt.c lualib-src/lsha1.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) $^ -o $@
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/sharedata.so : lualib-src/lua-sharedata.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) -Iskynet-src $^ -o $@
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/stm.so : lualib-src/lua-stm.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) -Iskynet-src $^ -o $@
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/sproto.so : lualib-src/sproto/sproto.c lualib-src/sproto/lsproto.c | $(LUA_CLIB_PATH)
|
$(LUA_CLIB_PATH)/sproto.so : lualib-src/sproto/sproto.c lualib-src/sproto/lsproto.c | $(LUA_CLIB_PATH)
|
||||||
$(CC) $(CFLAGS) $(SHARED) -Ilualib-src/sproto $^ -o $@
|
$(CC) $(CFLAGS) $(SHARED) -Ilualib-src/sproto $^ -o $@
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/lpeg.so : 3rd/lpeg/lpcap.c 3rd/lpeg/lpcode.c 3rd/lpeg/lpprint.c 3rd/lpeg/lptree.c 3rd/lpeg/lpvm.c | $(LUA_CLIB_PATH)
|
$(LUA_CLIB_PATH)/lpeg.so : 3rd/lpeg/lpcap.c 3rd/lpeg/lpcode.c 3rd/lpeg/lpprint.c 3rd/lpeg/lptree.c 3rd/lpeg/lpvm.c | $(LUA_CLIB_PATH)
|
||||||
$(CC) $(CFLAGS) $(SHARED) -I3rd/lpeg $^ -o $@
|
$(CC) $(CFLAGS) $(SHARED) -I3rd/lpeg $^ -o $@
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/mysqlaux.so : lualib-src/lua-mysqlaux.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) $^ -o $@
|
|
||||||
|
|
||||||
$(LUA_CLIB_PATH)/debugchannel.so : lualib-src/lua-debugchannel.c | $(LUA_CLIB_PATH)
|
|
||||||
$(CC) $(CFLAGS) $(SHARED) -Iskynet-src $^ -o $@
|
|
||||||
|
|
||||||
clean :
|
clean :
|
||||||
rm -f $(SKYNET_BUILD_PATH)/skynet $(CSERVICE_PATH)/*.so $(LUA_CLIB_PATH)/*.so
|
rm -f $(SKYNET_BUILD_PATH)/skynet $(CSERVICE_PATH)/*.so $(LUA_CLIB_PATH)/*.so
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local netpack = require "netpack"
|
local netpack = require "skynet.netpack"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
local sproto = require "sproto"
|
local sproto = require "sproto"
|
||||||
local sprotoloader = require "sprotoloader"
|
local sprotoloader = require "sprotoloader"
|
||||||
|
|
||||||
|
|||||||
@@ -5,7 +5,7 @@ if _VERSION ~= "Lua 5.3" then
|
|||||||
error "Use lua 5.3"
|
error "Use lua 5.3"
|
||||||
end
|
end
|
||||||
|
|
||||||
local socket = require "clientsocket"
|
local socket = require "skynet.clientsocket"
|
||||||
local proto = require "proto"
|
local proto = require "proto"
|
||||||
local sproto = require "sproto"
|
local sproto = require "sproto"
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local cluster = require "cluster"
|
local cluster = require "skynet.cluster"
|
||||||
local snax = require "snax"
|
local snax = require "skynet.snax"
|
||||||
|
|
||||||
skynet.start(function()
|
skynet.start(function()
|
||||||
cluster.reload {
|
cluster.reload {
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local cluster = require "cluster"
|
local cluster = require "skynet.cluster"
|
||||||
|
|
||||||
skynet.start(function()
|
skynet.start(function()
|
||||||
-- query name "sdb" of cluster db.
|
-- query name "sdb" of cluster db.
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local sharedata = require "sharedata"
|
local sharedata = require "skynet.sharedata"
|
||||||
|
|
||||||
local mode = ...
|
local mode = ...
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
local httpd = require "http.httpd"
|
local httpd = require "http.httpd"
|
||||||
local sockethelper = require "http.sockethelper"
|
local sockethelper = require "http.sockethelper"
|
||||||
local urllib = require "http.url"
|
local urllib = require "http.url"
|
||||||
|
|||||||
@@ -508,7 +508,7 @@ lconcat(lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_cluster_core(lua_State *L) {
|
luaopen_skynet_cluster_core(lua_State *L) {
|
||||||
luaL_Reg l[] = {
|
luaL_Reg l[] = {
|
||||||
{ "packrequest", lpackrequest },
|
{ "packrequest", lpackrequest },
|
||||||
{ "packpush", lpackpush },
|
{ "packpush", lpackpush },
|
||||||
|
|||||||
@@ -904,7 +904,7 @@ int lsha1(lua_State *L);
|
|||||||
int lhmac_sha1(lua_State *L);
|
int lhmac_sha1(lua_State *L);
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_crypt(lua_State *L) {
|
luaopen_skynet_crypt(lua_State *L) {
|
||||||
luaL_checkversion(L);
|
luaL_checkversion(L);
|
||||||
static int init = 0;
|
static int init = 0;
|
||||||
if (!init) {
|
if (!init) {
|
||||||
|
|||||||
@@ -271,7 +271,7 @@ static int db_sethook (lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_debugchannel(lua_State *L) {
|
luaopen_skynet_debugchannel(lua_State *L) {
|
||||||
luaL_Reg l[] = {
|
luaL_Reg l[] = {
|
||||||
{ "create", lcreate }, // for write
|
{ "create", lcreate }, // for write
|
||||||
{ "connect", lconnect }, // for read
|
{ "connect", lconnect }, // for read
|
||||||
|
|||||||
@@ -50,7 +50,7 @@ lcurrent(lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_memory(lua_State *L) {
|
luaopen_skynet_memory(lua_State *L) {
|
||||||
luaL_checkversion(L);
|
luaL_checkversion(L);
|
||||||
|
|
||||||
luaL_Reg l[] = {
|
luaL_Reg l[] = {
|
||||||
|
|||||||
@@ -532,7 +532,7 @@ reply_length(lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_mongo_driver(lua_State *L) {
|
luaopen_skynet_mongo_driver(lua_State *L) {
|
||||||
luaL_checkversion(L);
|
luaL_checkversion(L);
|
||||||
luaL_Reg l[] ={
|
luaL_Reg l[] ={
|
||||||
{ "query", op_query },
|
{ "query", op_query },
|
||||||
|
|||||||
@@ -146,7 +146,7 @@ mc_nextid(lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_multicast_core(lua_State *L) {
|
luaopen_skynet_multicast_core(lua_State *L) {
|
||||||
luaL_Reg l[] = {
|
luaL_Reg l[] = {
|
||||||
{ "pack", mc_packlocal },
|
{ "pack", mc_packlocal },
|
||||||
{ "unpack", mc_unpacklocal },
|
{ "unpack", mc_unpacklocal },
|
||||||
|
|||||||
@@ -158,7 +158,7 @@ static struct luaL_Reg mysqlauxlib[] = {
|
|||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
LUAMOD_API int luaopen_mysqlaux_c (lua_State *L) {
|
LUAMOD_API int luaopen_skynet_mysqlaux_c (lua_State *L) {
|
||||||
lua_newtable(L);
|
lua_newtable(L);
|
||||||
luaL_setfuncs(L, mysqlauxlib, 0);
|
luaL_setfuncs(L, mysqlauxlib, 0);
|
||||||
return 1;
|
return 1;
|
||||||
|
|||||||
@@ -465,7 +465,7 @@ ltostring(lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_netpack(lua_State *L) {
|
luaopen_skynet_netpack(lua_State *L) {
|
||||||
luaL_checkversion(L);
|
luaL_checkversion(L);
|
||||||
luaL_Reg l[] = {
|
luaL_Reg l[] = {
|
||||||
{ "pop", lpop },
|
{ "pop", lpop },
|
||||||
|
|||||||
@@ -200,7 +200,7 @@ lyield_co(lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_profile(lua_State *L) {
|
luaopen_skynet_profile(lua_State *L) {
|
||||||
luaL_checkversion(L);
|
luaL_checkversion(L);
|
||||||
luaL_Reg l[] = {
|
luaL_Reg l[] = {
|
||||||
{ "start", lstart },
|
{ "start", lstart },
|
||||||
|
|||||||
@@ -765,7 +765,7 @@ lupdate(lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_sharedata_core(lua_State *L) {
|
luaopen_skynet_sharedata_core(lua_State *L) {
|
||||||
luaL_Reg l[] = {
|
luaL_Reg l[] = {
|
||||||
// used by host
|
// used by host
|
||||||
{ "new", lnewconf },
|
{ "new", lnewconf },
|
||||||
|
|||||||
@@ -678,7 +678,7 @@ ludp_address(lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_socketdriver(lua_State *L) {
|
luaopen_skynet_socketdriver(lua_State *L) {
|
||||||
luaL_checkversion(L);
|
luaL_checkversion(L);
|
||||||
luaL_Reg l[] = {
|
luaL_Reg l[] = {
|
||||||
{ "buffer", lnewbuffer },
|
{ "buffer", lnewbuffer },
|
||||||
|
|||||||
@@ -235,7 +235,7 @@ lread(lua_State *L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
LUAMOD_API int
|
LUAMOD_API int
|
||||||
luaopen_stm(lua_State *L) {
|
luaopen_skynet_stm(lua_State *L) {
|
||||||
luaL_checkversion(L);
|
luaL_checkversion(L);
|
||||||
lua_createtable(L, 0, 3);
|
lua_createtable(L, 0, 3);
|
||||||
|
|
||||||
|
|||||||
1
lualib/compat10/cluster.lua
Normal file
1
lualib/compat10/cluster.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.cluster"
|
||||||
1
lualib/compat10/crypt.lua
Normal file
1
lualib/compat10/crypt.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.crypt"
|
||||||
1
lualib/compat10/datacenter.lua
Normal file
1
lualib/compat10/datacenter.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.datacenter"
|
||||||
1
lualib/compat10/dns.lua
Normal file
1
lualib/compat10/dns.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.dns"
|
||||||
1
lualib/compat10/memory.lua
Normal file
1
lualib/compat10/memory.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.memory"
|
||||||
1
lualib/compat10/mongo.lua
Normal file
1
lualib/compat10/mongo.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.db.mongo"
|
||||||
1
lualib/compat10/mqueue.lua
Normal file
1
lualib/compat10/mqueue.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.mqueue"
|
||||||
1
lualib/compat10/multicast.lua
Normal file
1
lualib/compat10/multicast.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.multicast"
|
||||||
1
lualib/compat10/mysql.lua
Normal file
1
lualib/compat10/mysql.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.db.mysql"
|
||||||
1
lualib/compat10/netpack.lua
Normal file
1
lualib/compat10/netpack.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.netpack"
|
||||||
1
lualib/compat10/profile.lua
Normal file
1
lualib/compat10/profile.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.profile"
|
||||||
1
lualib/compat10/redis.lua
Normal file
1
lualib/compat10/redis.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.db.redis"
|
||||||
1
lualib/compat10/sharedata.lua
Normal file
1
lualib/compat10/sharedata.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.sharedata"
|
||||||
1
lualib/compat10/sharemap.lua
Normal file
1
lualib/compat10/sharemap.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.sharemap"
|
||||||
1
lualib/compat10/snax.lua
Normal file
1
lualib/compat10/snax.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.snax"
|
||||||
1
lualib/compat10/socket.lua
Normal file
1
lualib/compat10/socket.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.socket"
|
||||||
1
lualib/compat10/socketchannel.lua
Normal file
1
lualib/compat10/socketchannel.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.socketchannel"
|
||||||
1
lualib/compat10/socketdriver.lua
Normal file
1
lualib/compat10/socketdriver.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.socketdriver"
|
||||||
1
lualib/compat10/stm.lua
Normal file
1
lualib/compat10/stm.lua
Normal file
@@ -0,0 +1 @@
|
|||||||
|
return require "skynet.stm"
|
||||||
@@ -2,7 +2,7 @@ local skynet = require "skynet"
|
|||||||
local socket = require "http.sockethelper"
|
local socket = require "http.sockethelper"
|
||||||
local url = require "http.url"
|
local url = require "http.url"
|
||||||
local internal = require "http.internal"
|
local internal = require "http.internal"
|
||||||
local dns = require "dns"
|
local dns = require "skynet.dns"
|
||||||
local string = string
|
local string = string
|
||||||
local table = table
|
local table = table
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
|
|
||||||
local readbytes = socket.read
|
local readbytes = socket.read
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ local pairs = pairs
|
|||||||
local pcall = pcall
|
local pcall = pcall
|
||||||
local table = table
|
local table = table
|
||||||
|
|
||||||
local profile = require "profile"
|
local profile = require "skynet.profile"
|
||||||
|
|
||||||
local coroutine_resume = profile.resume
|
local coroutine_resume = profile.resume
|
||||||
local coroutine_yield = profile.yield
|
local coroutine_yield = profile.yield
|
||||||
|
|||||||
@@ -30,7 +30,7 @@ function cluster.proxy(node, name)
|
|||||||
end
|
end
|
||||||
|
|
||||||
function cluster.snax(node, name, address)
|
function cluster.snax(node, name, address)
|
||||||
local snax = require "snax"
|
local snax = require "skynet.snax"
|
||||||
if not address then
|
if not address then
|
||||||
address = cluster.call(node, ".service", "QUERY", "snaxd" , name)
|
address = cluster.call(node, ".service", "QUERY", "snaxd" , name)
|
||||||
end
|
end
|
||||||
@@ -1,10 +1,10 @@
|
|||||||
local bson = require "bson"
|
local bson = require "bson"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
local socketchannel = require "socketchannel"
|
local socketchannel = require "skynet.socketchannel"
|
||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local driver = require "mongo.driver"
|
local driver = require "skynet.mongo.driver"
|
||||||
local md5 = require "md5"
|
local md5 = require "md5"
|
||||||
local crypt = require "crypt"
|
local crypt = require "skynet.crypt"
|
||||||
local rawget = rawget
|
local rawget = rawget
|
||||||
local assert = assert
|
local assert = assert
|
||||||
local table = table
|
local table = table
|
||||||
@@ -4,9 +4,9 @@
|
|||||||
-- The license is under the BSD license.
|
-- The license is under the BSD license.
|
||||||
-- Modified by Cloud Wu (remove bit32 for lua 5.3)
|
-- Modified by Cloud Wu (remove bit32 for lua 5.3)
|
||||||
|
|
||||||
local socketchannel = require "socketchannel"
|
local socketchannel = require "skynet.socketchannel"
|
||||||
local mysqlaux = require "mysqlaux.c"
|
local mysqlaux = require "skynet.mysqlaux.c"
|
||||||
local crypt = require "crypt"
|
local crypt = require "skynet.crypt"
|
||||||
|
|
||||||
|
|
||||||
local sub = string.sub
|
local sub = string.sub
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
local socketchannel = require "socketchannel"
|
local socketchannel = require "skynet.socketchannel"
|
||||||
|
|
||||||
local table = table
|
local table = table
|
||||||
local string = string
|
local string = string
|
||||||
@@ -65,7 +65,7 @@
|
|||||||
--]]
|
--]]
|
||||||
|
|
||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
|
|
||||||
local MAX_DOMAIN_LEN = 1024
|
local MAX_DOMAIN_LEN = 1024
|
||||||
local MAX_LABEL_LEN = 63
|
local MAX_LABEL_LEN = 63
|
||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local mc = require "multicast.core"
|
local mc = require "skynet.multicast.core"
|
||||||
|
|
||||||
local multicastd
|
local multicastd
|
||||||
local multicast = {}
|
local multicast = {}
|
||||||
9
lualib/skynet/reload.lua
Normal file
9
lualib/skynet/reload.lua
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
local core = require "skynet.reload.core"
|
||||||
|
local skynet = require "skynet"
|
||||||
|
|
||||||
|
local function reload(...)
|
||||||
|
local args = SERVICE_NAME .. " " .. table.concat({...}, " ")
|
||||||
|
print(args)
|
||||||
|
end
|
||||||
|
|
||||||
|
return reload
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local debugchannel = require "debugchannel"
|
local debugchannel = require "skynet.debugchannel"
|
||||||
local socketdriver = require "socketdriver"
|
local socketdriver = require "skynet.socketdriver"
|
||||||
local injectrun = require "skynet.injectcode"
|
local injectrun = require "skynet.injectcode"
|
||||||
local table = table
|
local table = table
|
||||||
local debug = debug
|
local debug = debug
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local sd = require "sharedata.corelib"
|
local sd = require "skynet.sharedata.corelib"
|
||||||
|
|
||||||
local service
|
local service
|
||||||
|
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
local core = require "sharedata.core"
|
local core = require "skynet.sharedata.core"
|
||||||
local type = type
|
local type = type
|
||||||
local rawset = rawset
|
local rawset = rawset
|
||||||
|
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
local stm = require "stm"
|
local stm = require "skynet.stm"
|
||||||
local sprotoloader = require "sprotoloader"
|
local sprotoloader = require "sprotoloader"
|
||||||
local sproto = require "sproto"
|
local sproto = require "sproto"
|
||||||
local setmetatable = setmetatable
|
local setmetatable = setmetatable
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
local driver = require "socketdriver"
|
local driver = require "skynet.socketdriver"
|
||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local skynet_core = require "skynet.core"
|
local skynet_core = require "skynet.core"
|
||||||
local assert = assert
|
local assert = assert
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
local socketdriver = require "socketdriver"
|
local socketdriver = require "skynet.socketdriver"
|
||||||
|
|
||||||
-- channel support auto reconnect , and capture socket error in request/response transaction
|
-- channel support auto reconnect , and capture socket error in request/response transaction
|
||||||
-- { host = "", port = , auth = function(so) , response = function(so) session, data }
|
-- { host = "", port = , auth = function(so) , response = function(so) session, data }
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local netpack = require "netpack"
|
local netpack = require "skynet.netpack"
|
||||||
local socketdriver = require "socketdriver"
|
local socketdriver = require "skynet.socketdriver"
|
||||||
|
|
||||||
local gateserver = {}
|
local gateserver = {}
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
require "skynet.manager"
|
require "skynet.manager"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
local crypt = require "crypt"
|
local crypt = require "skynet.crypt"
|
||||||
local table = table
|
local table = table
|
||||||
local string = string
|
local string = string
|
||||||
local assert = assert
|
local assert = assert
|
||||||
|
|||||||
@@ -1,8 +1,8 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local gateserver = require "snax.gateserver"
|
local gateserver = require "snax.gateserver"
|
||||||
local netpack = require "netpack"
|
local netpack = require "skynet.netpack"
|
||||||
local crypt = require "crypt"
|
local crypt = require "skynet.crypt"
|
||||||
local socketdriver = require "socketdriver"
|
local socketdriver = require "skynet.socketdriver"
|
||||||
local assert = assert
|
local assert = assert
|
||||||
local b64encode = crypt.base64encode
|
local b64encode = crypt.base64encode
|
||||||
local b64decode = crypt.base64decode
|
local b64decode = crypt.base64decode
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local harbor = require "skynet.harbor"
|
local harbor = require "skynet.harbor"
|
||||||
require "skynet.manager" -- import skynet.launch, ...
|
require "skynet.manager" -- import skynet.launch, ...
|
||||||
local memory = require "memory"
|
local memory = require "skynet.memory"
|
||||||
|
|
||||||
skynet.start(function()
|
skynet.start(function()
|
||||||
local sharestring = tonumber(skynet.getenv "sharestring" or 4096)
|
local sharestring = tonumber(skynet.getenv "sharestring" or 4096)
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local sc = require "socketchannel"
|
local sc = require "skynet.socketchannel"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
local cluster = require "cluster.core"
|
local cluster = require "skynet.cluster.core"
|
||||||
|
|
||||||
local config_name = skynet.getenv "cluster"
|
local config_name = skynet.getenv "cluster"
|
||||||
local node_address = {}
|
local node_address = {}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local cluster = require "cluster"
|
local cluster = require "skynet.cluster"
|
||||||
require "skynet.manager" -- inject skynet.forward_type
|
require "skynet.manager" -- inject skynet.forward_type
|
||||||
|
|
||||||
local node, address = ...
|
local node, address = ...
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
|
|
||||||
--[[
|
--[[
|
||||||
master manage data :
|
master manage data :
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local memory = require "memory"
|
local memory = require "skynet.memory"
|
||||||
|
|
||||||
memory.dumpinfo()
|
memory.dumpinfo()
|
||||||
--memory.dump()
|
--memory.dump()
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local snax = require "snax"
|
local snax = require "skynet.snax"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
|
|
||||||
local function split_cmdline(cmdline)
|
local function split_cmdline(cmdline)
|
||||||
local split = {}
|
local split = {}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
require "skynet.manager" -- import skynet.launch, ...
|
require "skynet.manager" -- import skynet.launch, ...
|
||||||
local table = table
|
local table = table
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local debugchannel = require "debugchannel"
|
local debugchannel = require "skynet.debugchannel"
|
||||||
|
|
||||||
local CMD = {}
|
local CMD = {}
|
||||||
|
|
||||||
|
|||||||
@@ -1,9 +1,9 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local codecache = require "skynet.codecache"
|
local codecache = require "skynet.codecache"
|
||||||
local core = require "skynet.core"
|
local core = require "skynet.core"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
local snax = require "snax"
|
local snax = require "skynet.snax"
|
||||||
local memory = require "memory"
|
local memory = require "skynet.memory"
|
||||||
local httpd = require "http.httpd"
|
local httpd = require "http.httpd"
|
||||||
local sockethelper = require "http.sockethelper"
|
local sockethelper = require "http.sockethelper"
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local gateserver = require "snax.gateserver"
|
local gateserver = require "snax.gateserver"
|
||||||
local netpack = require "netpack"
|
local netpack = require "skynet.netpack"
|
||||||
|
|
||||||
local watchdog
|
local watchdog
|
||||||
local connection = {} -- fd -> connection : { fd , client, agent , ip, mode }
|
local connection = {} -- fd -> connection : { fd , client, agent , ip, mode }
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local mc = require "multicast.core"
|
local mc = require "skynet.multicast.core"
|
||||||
local datacenter = require "datacenter"
|
local datacenter = require "skynet.datacenter"
|
||||||
|
|
||||||
local harbor_id = skynet.harbor(skynet.self())
|
local harbor_id = skynet.harbor(skynet.self())
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
require "skynet.manager" -- import skynet.register
|
require "skynet.manager" -- import skynet.register
|
||||||
local snax = require "snax"
|
local snax = require "skynet.snax"
|
||||||
|
|
||||||
local cmd = {}
|
local cmd = {}
|
||||||
local service = {}
|
local service = {}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local sharedata = require "sharedata.corelib"
|
local sharedata = require "skynet.sharedata.corelib"
|
||||||
local table = table
|
local table = table
|
||||||
local cache = require "skynet.codecache"
|
local cache = require "skynet.codecache"
|
||||||
cache.mode "OFF" -- turn off codecache, because CMD.new may load data file
|
cache.mode "OFF" -- turn off codecache, because CMD.new may load data file
|
||||||
|
|||||||
@@ -1,8 +1,8 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local c = require "skynet.core"
|
local c = require "skynet.core"
|
||||||
local snax_interface = require "snax.interface"
|
local snax_interface = require "snax.interface"
|
||||||
local profile = require "profile"
|
local profile = require "skynet.profile"
|
||||||
local snax = require "snax"
|
local snax = require "skynet.snax"
|
||||||
|
|
||||||
local snax_name = tostring(...)
|
local snax_name = tostring(...)
|
||||||
local loaderpath = skynet.getenv"snax_loader"
|
local loaderpath = skynet.getenv"snax_loader"
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local queue = require "skynet.queue"
|
local queue = require "skynet.queue"
|
||||||
local snax = require "snax"
|
local snax = require "skynet.snax"
|
||||||
|
|
||||||
local i = 0
|
local i = 0
|
||||||
local hello = "hello"
|
local hello = "hello"
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
-- You should use skynet.coroutine instead of origin coroutine in skynet
|
-- You should use skynet.coroutine instead of origin coroutine in skynet
|
||||||
local coroutine = require "skynet.coroutine"
|
local coroutine = require "skynet.coroutine"
|
||||||
local profile = require "profile"
|
local profile = require "skynet.profile"
|
||||||
|
|
||||||
local function status(co)
|
local function status(co)
|
||||||
repeat
|
repeat
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local datacenter = require "datacenter"
|
local datacenter = require "skynet.datacenter"
|
||||||
|
|
||||||
local function f1()
|
local function f1()
|
||||||
print("====1==== wait hello")
|
print("====1==== wait hello")
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local dns = require "dns"
|
local dns = require "skynet.dns"
|
||||||
|
|
||||||
skynet.start(function()
|
skynet.start(function()
|
||||||
print("nameserver:", dns.server()) -- set nameserver
|
print("nameserver:", dns.server()) -- set nameserver
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local httpc = require "http.httpc"
|
local httpc = require "http.httpc"
|
||||||
local dns = require "dns"
|
local dns = require "skynet.dns"
|
||||||
|
|
||||||
local function main()
|
local function main()
|
||||||
httpc.dns() -- set dns server
|
httpc.dns() -- set dns server
|
||||||
|
|||||||
@@ -1,6 +1,15 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
|
|
||||||
local names = {"cluster", "dns", "mongo", "mysql", "redis", "sharedata", "socket", "sproto"}
|
local names = {
|
||||||
|
"cluster",
|
||||||
|
"skynet.db.dns",
|
||||||
|
"skynet.db.mongo",
|
||||||
|
"skynet.db.mysql",
|
||||||
|
"skynet.db.redis",
|
||||||
|
"sharedata",
|
||||||
|
"skynet.socket",
|
||||||
|
"sproto"
|
||||||
|
}
|
||||||
|
|
||||||
-- set sandbox memory limit to 1M, must set here (at start, out of skynet.start)
|
-- set sandbox memory limit to 1M, must set here (at start, out of skynet.start)
|
||||||
skynet.memlimit(1 * 1024 * 1024)
|
skynet.memlimit(1 * 1024 * 1024)
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local mongo = require "mongo"
|
local mongo = require "skynet.db.mongo"
|
||||||
local bson = require "bson"
|
local bson = require "bson"
|
||||||
|
|
||||||
local host, db_name = ...
|
local host, db_name = ...
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local mc = require "multicast"
|
local mc = require "skynet.multicast"
|
||||||
local dc = require "datacenter"
|
local dc = require "skynet.datacenter"
|
||||||
|
|
||||||
local mode = ...
|
local mode = ...
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local dc = require "datacenter"
|
local dc = require "skynet.datacenter"
|
||||||
local mc = require "multicast"
|
local mc = require "skynet.multicast"
|
||||||
|
|
||||||
skynet.start(function()
|
skynet.start(function()
|
||||||
print("remote start")
|
print("remote start")
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local mysql = require "mysql"
|
local mysql = require "skynet.db.mysql"
|
||||||
|
|
||||||
local function dump(obj)
|
local function dump(obj)
|
||||||
local getIndent, quoteStr, wrapKey, wrapVal, dumpObj
|
local getIndent, quoteStr, wrapKey, wrapVal, dumpObj
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local snax = require "snax"
|
local snax = require "skynet.snax"
|
||||||
|
|
||||||
skynet.start(function()
|
skynet.start(function()
|
||||||
local ps = snax.newservice ("pingserver", "hello world")
|
local ps = snax.newservice ("pingserver", "hello world")
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local redis = require "redis"
|
local redis = require "skynet.db.redis"
|
||||||
|
|
||||||
local conf = {
|
local conf = {
|
||||||
host = "127.0.0.1",
|
host = "127.0.0.1",
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local snax = require "snax"
|
local snax = require "skynet.snax"
|
||||||
|
|
||||||
skynet.start(function()
|
skynet.start(function()
|
||||||
local ps = snax.uniqueservice ("pingserver", "test queue")
|
local ps = snax.uniqueservice ("pingserver", "test queue")
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local redis = require "redis"
|
local redis = require "skynet.db.redis"
|
||||||
|
|
||||||
local conf = {
|
local conf = {
|
||||||
host = "127.0.0.1" ,
|
host = "127.0.0.1" ,
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local redis = require "redis"
|
local redis = require "skynet.db.redis"
|
||||||
|
|
||||||
local db
|
local db
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local crypt = require "crypt"
|
local crypt = require "skynet.crypt"
|
||||||
|
|
||||||
local function sha1(text)
|
local function sha1(text)
|
||||||
local c = crypt.sha1(text)
|
local c = crypt.sha1(text)
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local sharemap = require "sharemap"
|
local sharemap = require "skynet.sharemap"
|
||||||
|
|
||||||
local mode = ...
|
local mode = ...
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
|
|
||||||
local mode , id = ...
|
local mode , id = ...
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local stm = require "stm"
|
local stm = require "skynet.stm"
|
||||||
|
|
||||||
local mode = ...
|
local mode = ...
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
local skynet = require "skynet"
|
local skynet = require "skynet"
|
||||||
local socket = require "socket"
|
local socket = require "skynet.socket"
|
||||||
|
|
||||||
local function server()
|
local function server()
|
||||||
local host
|
local host
|
||||||
|
|||||||
Reference in New Issue
Block a user