librewolf
/
bunkerized-nginx
mirror of https://github.com/bunkerity/bunkerized-nginx
4
0
Fork 1
Code Issues Projects Releases Wiki Activity

use shared redis connection pool in cachestore when we can

This commit is contained in:
florian 2023-05-21 18:42:52 +02:00
parent d6ca98ed15
commit 40e30ed441
No known key found for this signature in database
GPG Key ID: 3D80806F12602A7C
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/bw/lua/bunkerweb/cachestore.lua
View File

@ -48,15 +48,17 @@ function cachestore:initialize(use_redis, new_cs)
self.logger = module_logger
if new_cs then
self.clusterstore = clusterstore:new(false)
self.shared_cs = false
else
self.clusterstore = utils.get_ctx_obj("clusterstore")
self.shared_cs = true
end
end
function cachestore:get(key)
local callback = function(key)
local callback = function(key, cs)
-- Connect to redis
local clusterstore = require "bunkerweb.clusterstore":new(false)
local clusterstore = cs or require "bunkerweb.clusterstore":new(false)
local ok, err, reused = clusterstore:connect()
if not ok then
return nil, "can't connect to redis : " .. err, nil
@ -95,7 +97,11 @@ function cachestore:get(key)
end
local value, err, hit_level
if self.use_redis and utils.is_cosocket_available() then
value, err, hit_level = self.cache:get(key, nil, callback, key)
local cs = nil
if self.shared_cs then
cs = self.clusterstore
end
value, err, hit_level = self.cache:get(key, nil, callback, key, cs)
else
value, err, hit_level = self.cache:get(key, nil, callback_no_miss)
end