Function db_sqlite_realloc_rows

modules/db_sqlite/res.c:296–339

* realloc function * used when entries added to the db since count(*) query */

 * used when entries added to the db since count(*) query
 */
int db_sqlite_realloc_rows(db_res_t* res, const unsigned int rows)
{
	unsigned int i, start;
	struct db_row* res_rows;
	db_val_t *prev_values;

	if (RES_ROW_N(res) >= rows)
		return 0;

	res_rows = res->rows = pkg_realloc(RES_ROWS(res),rows * sizeof *res_rows);
	if (!res_rows) {
		LM_ERR("no memory left\n");
		return -1;
	}

	memset(res_rows + RES_ROW_N(res), 0 ,
			(rows - RES_ROW_N(res)) * sizeof *res_rows);

	prev_values = res_rows[0].values;

	res_rows[0].values =
		pkg_realloc(res_rows[0].values, rows * sizeof(db_val_t) * RES_COL_N(res));
	if (! res_rows[0].values) {
		LM_ERR("no memory left\n");
		res_rows[0].values = prev_values;
		return -1;
	}

	memset( res_rows[0].values + RES_COL_N(res)*RES_ROW_N(res),
			0, (rows - RES_ROW_N(res)) * sizeof(db_val_t) * RES_COL_N(res));

	/* if the values was relocated, we need to re-point all values to the new block,
	 * otherwise only fix the new ones */
	start = (res_rows[0].values == prev_values?RES_ROW_N(res):0);

	for( i=start ; i<rows ; i++ ) {
		/* the values of the row i */
		res_rows[i].values = res_rows[0].values + RES_COL_N(res)*i;
		res_rows[i].n = RES_COL_N(res);
	}

	return 0;

}

/**
 * Convert rows from sqlite to db API representation