[sr-dev] git:master: db_cluster: safey check to be sure the command is implemented by db connector

Module: sip-router Branch: master Commit: d1541b8299581cdfaf84169e307f47116def5cbf URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=d1541b8… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Mon Oct 13 11:57:48 2014 +0200 db_cluster: safey check to be sure the command is implemented by db connector - reported by Miguel Reis, FS#476 --- modules/db_cluster/dbcl_api.c | 40 ++++++++++++++++++++++++++++++---------- 1 files changed, 30 insertions(+), 10 deletions(-) diff --git a/modules/db_cluster/dbcl_api.c b/modules/db_cluster/dbcl_api.c index 9e833d9..abb52d6 100644 --- a/modules/db_cluster/dbcl_api.c +++ b/modules/db_cluster/dbcl_api.c @@ -40,7 +40,7 @@ extern int dbcl_max_query_length; -#define DBCL_READ(command) \ +#define DBCL_READ(qfunc, command) \ do {\ int ret;\ int i;\ @@ -65,6 +65,10 @@ extern int dbcl_max_query_length; cls->name.len, cls->name.s, i, j);\ sec = get_ticks();\ dbh = cls->rlist[i].clist[j]->dbh;\ + if(cls->rlist[i].clist[j]->dbf.qfunc==NULL) {\ + LM_ERR("unsupported command by db connector\n");\ + return -1;\ + }\ ret = cls->rlist[i].clist[j]->dbf.command;\ if (ret==0) {\ cls->usedcon = cls->rlist[i].clist[j];\ @@ -92,6 +96,10 @@ extern int dbcl_max_query_length; cls->name.len, cls->name.s, i, j);\ sec = get_ticks();\ dbh = cls->rlist[i].clist[j]->dbh;\ + if(cls->rlist[i].clist[j]->dbf.qfunc==NULL) {\ + LM_ERR("unsupported command by db connector\n");\ + return -1;\ + }\ ret = cls->rlist[i].clist[j]->dbf.command;\ if (ret==0)\ {\ @@ -121,7 +129,7 @@ extern int dbcl_max_query_length; return ret;\ } while(0) -#define DBCL_WRITE(command) \ +#define DBCL_WRITE(qfunc, command) \ do {\ int ret;\ int rc;\ @@ -150,6 +158,10 @@ extern int dbcl_max_query_length; cls->name.len, cls->name.s, i, j);\ sec = get_ticks();\ dbh = cls->wlist[i].clist[j]->dbh;\ + if(cls->rlist[i].clist[j]->dbf.qfunc==NULL) {\ + LM_ERR("unsupported command by db connector\n");\ + return -1;\ + }\ ret = cls->wlist[i].clist[j]->dbf.command;\ if (ret==0) {\ cls->usedcon = cls->wlist[i].clist[j];\ @@ -177,6 +189,10 @@ extern int dbcl_max_query_length; cls->name.len, cls->name.s, i, j);\ sec = get_ticks();\ dbh = cls->wlist[i].clist[j]->dbh;\ + if(cls->rlist[i].clist[j]->dbf.qfunc==NULL) {\ + LM_ERR("unsupported command by db connector\n");\ + return -1;\ + }\ ret = cls->wlist[i].clist[j]->dbf.command;\ if (ret==0)\ {\ @@ -205,6 +221,10 @@ extern int dbcl_max_query_length; cls->name.len, cls->name.s, i, j);\ sec = get_ticks();\ dbh = cls->wlist[i].clist[j]->dbh;\ + if(cls->rlist[i].clist[j]->dbf.qfunc==NULL) {\ + LM_ERR("unsupported command by db connector\n");\ + return -1;\ + }\ rc = cls->wlist[i].clist[j]->dbf.command;\ if(rc==0) {\ cls->usedcon = cls->wlist[i].clist[j];\ @@ -321,7 +341,7 @@ int db_cluster_query(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _op const db_key_t _o, db1_res_t** _r) { LM_DBG("executing db cluster query command\n"); - DBCL_READ(query(dbh, _k, _op, _v, _c, _n, _nc, _o, _r)); + DBCL_READ(query, query(dbh, _k, _op, _v, _c, _n, _nc, _o, _r)); } @@ -346,7 +366,7 @@ int db_cluster_fetch_result(const db1_con_t* _h, db1_res_t** _r, const int nrows int db_cluster_raw_query(const db1_con_t* _h, const str* _s, db1_res_t** _r) { LM_DBG("executing db cluster raw query command\n"); - DBCL_READ(raw_query(dbh, _s, _r)); + DBCL_READ(raw_query, raw_query(dbh, _s, _r)); } @@ -356,7 +376,7 @@ int db_cluster_raw_query(const db1_con_t* _h, const str* _s, db1_res_t** _r) int db_cluster_insert(const db1_con_t* _h, const db_key_t* _k, const db_val_t* _v, const int _n) { LM_DBG("executing db cluster insert command\n"); - DBCL_WRITE(insert(dbh, _k, _v, _n)); + DBCL_WRITE(insert, insert(dbh, _k, _v, _n)); } @@ -367,7 +387,7 @@ int db_cluster_delete(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _o, const db_val_t* _v, const int _n) { LM_DBG("executing db cluster delete command\n"); - DBCL_WRITE(delete(dbh, _k, _o, _v, _n)); + DBCL_WRITE(delete, delete(dbh, _k, _o, _v, _n)); } @@ -379,7 +399,7 @@ int db_cluster_update(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _o const int _un) { LM_DBG("executing db cluster update command\n"); - DBCL_WRITE(update(dbh, _k, _o, _v, _uk, _uv, _n, _un)); + DBCL_WRITE(update, update(dbh, _k, _o, _v, _uk, _uv, _n, _un)); } @@ -390,7 +410,7 @@ int db_cluster_replace(const db1_con_t* _h, const db_key_t* _k, const db_val_t* _v, const int _n, const int _un, const int _m) { LM_DBG("executing db cluster replace command\n"); - DBCL_WRITE(replace(dbh, _k, _v, _n, _un, _m)); + DBCL_WRITE(replace, replace(dbh, _k, _v, _n, _un, _m)); } /*! \brief @@ -430,7 +450,7 @@ int db_cluster_insert_update(const db1_con_t* _h, const db_key_t* _k, const db_v const int _n) { LM_DBG("executing db cluster insert-update command\n"); - DBCL_WRITE(insert_update(dbh, _k, _v, _n)); + DBCL_WRITE(insert_update, insert_update(dbh, _k, _v, _n)); } @@ -441,7 +461,7 @@ int db_cluster_insert_delayed(const db1_con_t* _h, const db_key_t* _k, const db_val_t* _v, const int _n) { LM_DBG("executing db cluster insert delayed command\n"); - DBCL_WRITE(insert_delayed(dbh, _k, _v, _n)); + DBCL_WRITE(insert_delayed, insert_delayed(dbh, _k, _v, _n)); }