- unify common rows and row allocation functionality in the DB API core

git-svn-id: https://openser.svn.sourceforge.net/svnroot/openser/trunk@5362 689a6050-402a-0410-94f2-e92a70836424

modules/db_mysql/km_res.c

@@ -157,7 +157,7 @@ int db_mysql_get_columns(const db_con_t* _h, db_res_t* _r)
  */
 static inline int db_mysql_convert_rows(const db_con_t* _h, db_res_t* _r)
 {
-	int row, len;
+	int row;
 
 	if ((!_h) || (!_r)) {
 		LM_ERR("invalid parameter\n");
@@ -171,14 +171,10 @@ static inline int db_mysql_convert_rows(const db_con_t* _h, db_res_t* _r)
 		return 0;
 	}
 
-	len = sizeof(db_row_t) * RES_ROW_N(_r);
-	RES_ROWS(_r) = (struct db_row*)pkg_malloc(len);
-	if (!RES_ROWS(_r)) {
-		LM_ERR("no private memory left\n");
+	if (db_allocate_rows(_r) < 0) {
+		LM_ERR("could not allocate rows");
 		return -2;
 	}
-	LM_DBG("allocate %d bytes for rows at %p\n", len, RES_ROWS(_r));
-	memset(RES_ROWS(_r), 0, len);
 
 	for(row = 0; row < RES_ROW_N(_r); row++) {
 		CON_ROW(_h) = mysql_fetch_row(CON_RESULT(_h));

modules/db_mysql/km_row.c

@@ -47,26 +47,18 @@
 int db_mysql_convert_row(const db_con_t* _h, db_res_t* _res, db_row_t* _r)
 {
 	unsigned long* lengths;
-	int i, len;
+	int i;
 
 	if ((!_h) || (!_res) || (!_r)) {
 		LM_ERR("invalid parameter value\n");
 		return -1;
 	}
 
-	len = sizeof(db_val_t) * RES_COL_N(_res);
-	ROW_VALUES(_r) = (db_val_t*)pkg_malloc(len);
-	if (!ROW_VALUES(_r)) {
-		LM_ERR("no private memory left\n");
-		return -1;
+	if (db_allocate_row(_res, _r) != 0) {
+		LM_ERR("could not allocate row");
+		return -2;
 	}
-	LM_DBG("allocate %d bytes for row values at %p\n", len,
-			ROW_VALUES(_r));
-
-	memset(ROW_VALUES(_r), 0, len);
-	/* Save the number of columns in the ROW structure */
-	ROW_N(_r) = RES_COL_N(_res);
-
+	
 	lengths = mysql_fetch_lengths(CON_RESULT(_h));
 
 	for(i = 0; i < RES_COL_N(_res); i++) {