opt.task = task
opt.callback = function(err, data)
if err then
+ logger.errx(task, 'cannot upload script to %s: %s',
+ opt.upstream:get_addr(), err)
opt.upstream:fail()
else
opt.upstream:ok()
logger.infox(task,
- "loaded redis script with id %s, sha: %s", script.id, data)
+ "uploaded redis script to %s with id %s, sha: %s",
+ opt.upstream:get_addr(), script.id, data)
script.sha = data -- We assume that sha is the same on all servers
end
script.in_flight = script.in_flight - 1
local ret = rspamd_redis.make_request(opt)
if not ret then
- logger.errx('cannot execute redis request to load script')
+ logger.errx('cannot execute redis request to load script on %s',
+ opt.upstream:get_addr())
script.in_flight = script.in_flight - 1
opt.upstream:fail()
end
opt.ev_base = ev_base
opt.callback = function(err, data)
if err then
+ logger.errx(cfg, 'cannot upload script to %s: %s',
+ opt.upstream:get_addr(), err)
opt.upstream:fail()
else
opt.upstream:ok()
logger.infox(cfg,
- "loaded redis script with id %s, sha: %s", script.id, data)
+ "uploaded redis script to %s with id %s, sha: %s",
+ opt.upstream:get_addr(), script.id, data)
script.sha = data -- We assume that sha is the same on all servers
end
script.in_flight = script.in_flight - 1
local ret = rspamd_redis.make_request(opt)
if not ret then
- logger.errx('cannot execute redis request to load script')
+ logger.errx('cannot execute redis request to load script on %s',
+ opt.upstream:get_addr())
script.in_flight = script.in_flight - 1
opt.upstream:fail()
end