[sr-dev] git:master: db_cluster: safey check to be sure the command is implemented by db connector
Daniel-Constantin Mierla
miconda at gmail.com
Mon Oct 13 11:59:17 CEST 2014
Module: sip-router
Branch: master
Commit: d1541b8299581cdfaf84169e307f47116def5cbf
URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=d1541b8299581cdfaf84169e307f47116def5cbf
Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Daniel-Constantin Mierla <miconda at 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));
}
More information about the sr-dev
mailing list