lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-24 20:23:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix #1341

Browse Source
This commit is contained in:
Cloud Wu
2021-02-22 12:00:32 +08:00
parent 51a942d095
commit eebd44da9d
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
lualib/skynet/db/redis.lua
View File

@@ -96,7 +96,17 @@ local count_cache = make_cache(function(t,k)
return s return s
end) end)
local command_np_cache = make_cache(function(t, cmd)
local s = "*1" .. command_cache[cmd] .. "\r\n"
t[cmd] = s
return s
end)
local function compose_message(cmd, msg) local function compose_message(cmd, msg)
if msg == nil then
return command_np_cache[cmd]
end
local t = type(msg) local t = type(msg)
local lines = {} local lines = {}
@@ -160,7 +170,9 @@ end
setmetatable(command, { __index = function(t,k) setmetatable(command, { __index = function(t,k)
local cmd = string.upper(k) local cmd = string.upper(k)
local f = function (self, v, ...) local f = function (self, v, ...)
if type(v) == "table" then if v == nil then
return self[1]:request(compose_message(cmd), read_response)
elseif type(v) == "table" then
return self[1]:request(compose_message(cmd, v), read_response) return self[1]:request(compose_message(cmd, v), read_response)
else else
return self[1]:request(compose_message(cmd, table.pack(v, ...)), read_response) return self[1]:request(compose_message(cmd, table.pack(v, ...)), read_response)