options['dbname'] = redis_params['db']
end
- return rspamd_redis.make_request(options),addr
+ local ret,conn = rspamd_redis.make_request(options)
+ return ret,conn,addr
end
function rspamd_str_split(s, sep)
/* Check for flag */
if (g_hash_table_lookup (rule->mappings,
- GINT_TO_POINTER (flag)) == NULL) {
+ GINT_TO_POINTER (flag)) == NULL) {
msg_info_task ("skip rule %s as it has no flag %d defined"
" false", rule->name, flag);
cur = g_list_next (cur);
ret,_,upstream = rspamd_redis_make_request(task,
redis_params, -- connect params
key, -- hash key
- false, -- is write
+ true, -- is write
rate_set_cb, --callback
cmd, -- command
fun.totable(fun.map(function(l) return l[2] end, args)) -- arguments