rspamd_logger.infox(task, 'trimmed url set to %s elements',
settings.top_urls_count)
end
+ rspamd_plugins.surbl.continue_process(url, param)
end
-- Cleanup logic
)
if not ret then
rspamd_logger.errx(task, 'cannot trim top urls set')
+ rspamd_plugins.surbl.continue_process(url, param)
else
rspamd_logger.infox(task, 'need to trim urls set from %s to %s elements',
data,
settings.top_urls_count)
+ return
end
end
end
end
+
+ rspamd_plugins.surbl.continue_process(url, param)
end
local function redis_set_cb(err, _)
)
if not ret then
rspamd_logger.errx(task, 'cannot make redis request to cache results')
+ rspamd_plugins.surbl.continue_process(url, param)
end
end
- rspamd_plugins.surbl.continue_process(url, param)
end
local ret,conn,_ = rspamd_redis_make_request(task,
local function redis_reserve_cb(nerr, ndata)
if nerr then
rspamd_logger.errx(task, 'got error while setting redirect keys: %s', nerr)
- elseif ndata == 1 then
+ elseif ndata == 'OK' then
orig_url = url
resolve_url()
end