Module: kamailio Branch: 5.1 Commit: 36bd57d902f990f9d05e1cd6589f2fa3f0ef6897 URL: https://github.com/kamailio/kamailio/commit/36bd57d902f990f9d05e1cd6589f2fa3...

Author: Daniel-Constantin Mierla miconda@gmail.com Committer: Daniel-Constantin Mierla miconda@gmail.com Date: 2019-04-03T11:56:02+02:00

lib/srdb1: use system time to compute db query execution duration

(cherry picked from commit ce8d36f301d7688255597a67693e47dc14448650) (cherry picked from commit a2de837273c84c42233dd12829a8aca57257ce9f)

---

Modified: src/lib/srdb1/db_query.c

---

Diff: https://github.com/kamailio/kamailio/commit/36bd57d902f990f9d05e1cd6589f2fa3... Patch: https://github.com/kamailio/kamailio/commit/36bd57d902f990f9d05e1cd6589f2fa3...

---

diff --git a/src/lib/srdb1/db_query.c b/src/lib/srdb1/db_query.c index b1900e4c2e..b2cd9056dc 100644 --- a/src/lib/srdb1/db_query.c +++ b/src/lib/srdb1/db_query.c @@ -32,6 +32,7 @@

#include <stdio.h> #include <stdlib.h> +#include <time.h> #include "../../core/dprint.h" #include "db_ut.h" #include "db_query.h" @@ -45,19 +46,26 @@ static inline int db_do_submit_query(const db1_con_t* _h, const str *_query, int (*submit_query)(const db1_con_t*, const str*)) { int ret; - unsigned int ms = 0; + struct timeval tvb, tve; + struct timezone tz; + unsigned int tdiff;

- if(unlikely(cfg_get(core, core_cfg, latency_limit_db)>0)) - ms = TICKS_TO_MS(get_ticks_raw()); + if(unlikely(cfg_get(core, core_cfg, latency_limit_db)>0) + && is_printable(cfg_get(core, core_cfg, latency_log))) { + gettimeofday(&tvb, &tz); + }

ret = submit_query(_h, _query);

- if(unlikely(cfg_get(core, core_cfg, latency_limit_db)>0)) { - ms = TICKS_TO_MS(get_ticks_raw()) - ms; - if(ms >= cfg_get(core, core_cfg, latency_limit_db)) { - LOG(cfg_get(core, core_cfg, latency_log), - "alert - query execution too long [%u ms] for [%.*s]\n", - ms, _query->len<50?_query->len:50, _query->s); + if(unlikely(cfg_get(core, core_cfg, latency_limit_db)>0) + && is_printable(cfg_get(core, core_cfg, latency_log))) { + gettimeofday(&tve, &tz); + tdiff = (tve.tv_sec - tvb.tv_sec) * 1000000 + + (tve.tv_usec - tvb.tv_usec); + if(tdiff >= cfg_get(core, core_cfg, latency_limit_db)) { + LOG(cfg_get(core, core_cfg, latency_log), + "alert - query execution too long [%u us] for [%.*s]\n", + tdiff, _query->len<100?_query->len:100, _query->s); } }