int (*redis_query)(REDISSOCK **dissocket_p, REDIS_INST *inst, char *query);
int (*redis_finish_query)(REDISSOCK *dissocket);
- size_t (*redis_escape_func)(char *out, size_t outlen, const char *in);
+ size_t (*redis_escape_func)(REQUEST *request, char *out, size_t outlen, const char *in, void *);
} rlm_redis_t;
*/
if (request) {
if (!radius_xlat(query, sizeof (query), fmt, request,
- data->redis_inst->redis_escape_func,
- data->redis_inst)) {
+ inst->redis_inst->redis_escape_func,
+ inst->redis_inst)) {
radlog(L_ERR, "rediswho_command: xlat failed on: '%s'", query);
return 0;
}
return RLM_MODULE_NOOP;
}
- dv = dict_valbyattr(vp->attr, vp->vendor, vp->vp_integer);
+ dv = dict_valbyattr(vp->attribute, vp->vendor, vp->vp_integer);
if (!dv) {
RDEBUG("Unknown Acct-Status-Type %u", vp->vp_integer);
return RLM_MODULE_NOOP;
return RLM_MODULE_FAIL;
}
- insert = cf_pair_value(cf_pair_find(cs, "insert");
- trim = cf_pair_value(cf_pair_find(cs, "trim");
- expire = cf_pair_value(cf_pair_find(cs, "expire");
+ insert = cf_pair_value(cf_pair_find(cs, "insert"));
+ trim = cf_pair_value(cf_pair_find(cs, "trim"));
+ expire = cf_pair_value(cf_pair_find(cs, "expire"));
rcode = rediswho_accounting_all(&dissocket, inst, request,
- inst->start_insert,
- inst->start_trim,
- inst->start_expire);
+ insert,
+ trim,
+ expire);
if (dissocket) fr_connection_release(inst->redis_inst->pool, dissocket);