Function sql_cache_dump

modules/sql_cacher/sql_cacher.c:2325–2369

}

static int sql_cache_dump(struct sip_msg *msg, db_handlers_t *dbh,
		pv_name_fix_t *cols, pvname_list_t *dst_avps)
{
	cache_entry_t *cache = dbh->c_entry;
	int i, n, ver;

	LM_DBG("dumping data from cache: %.*s\n", cache->id.len, cache->id.s);

	lock_start_read(cache->ref_lock);

	ver = get_rld_vers_from_cache(cache, dbh);
	if (ver < 0) {
		lock_stop_read(cache->ref_lock);
		LM_ERR("failed to get reload version\n");
		return -1;
	}

	if (cols[0].id.len != ver) {
		for (i = 0; cols[i].c_entry; i++) {
			optimize_cdb_decode(&cols[i]);
			LM_DBG("optimized fields for col '%.*s': %d/%d/%d\n",
					cols[i].col.len, cols[i].col.s, cols[i].col_offset,
					cols[i].col_nr, cols[i].last_str);
		}

		cols[0].id.len = ver;
	}

	_selected_cols = cols;
	_out_avps = dst_avps;
	_rld_ver = ver;
	_sip_msg = msg;

	n = dbh->cdbf.iter_keys(dbh->cdbcon, decode_kv2avps);
	if (n < 0) {
		lock_stop_read(cache->ref_lock);
		LM_ERR("failed to fully iterate through cache '%.*s'\n",
		       cache->id.len, cache->id.s);
		return -1;
	}

	lock_stop_read(cache->ref_lock);

	return n == 0 ? -2 : n;
}