sr-dev March 2018

sr-dev@lists.kamailio.org

17 participants
327 discussions

git:master:77b0c935: core: new parameter kemi.reply_route_callback
by Daniel-Constantin Mierla 12 Mar '18

12 Mar '18

Module: kamailio Branch: master Commit: 77b0c9355b13013ddeb3cab62de1bb21e0eb74f7 URL: https://github.com/kamailio/kamailio/commit/77b0c9355b13013ddeb3cab62de1bb2… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2018-03-12T12:56:24+01:00 core: new parameter kemi.reply_route_callback - set the name of kemi callback function to be executed on receiving a sip reply (equivalent of reply_route) - default: ksr_reply_route - set to empty or "none" to skip execution of this callback --- Modified: src/core/cfg.lex Modified: src/core/cfg.y Modified: src/core/kemi.c Modified: src/core/kemi.h Modified: src/core/receive.c --- Diff: https://github.com/kamailio/kamailio/commit/77b0c9355b13013ddeb3cab62de1bb2… Patch: https://github.com/kamailio/kamailio/commit/77b0c9355b13013ddeb3cab62de1bb2… --- diff --git a/src/core/cfg.lex b/src/core/cfg.lex index abe2c250f4..033512c845 100644 --- a/src/core/cfg.lex +++ b/src/core/cfg.lex @@ -447,6 +447,7 @@ SERVER_ID "server_id" KEMI "kemi" ONSEND_ROUTE_CALLBACK "onsend_route_callback" +REPLY_ROUTE_CALLBACK "reply_route_callback" MAX_RECURSIVE_LEVEL "max_recursive_level" MAX_BRANCHES_PARAM "max_branches"|"max_branches" @@ -933,6 +934,7 @@ IMPORTFILE "import_file" return VERBOSE_STARTUP; } <INITIAL>{SERVER_ID} { count(); yylval.strval=yytext; return SERVER_ID;} <INITIAL>{KEMI} { count(); yylval.strval=yytext; return KEMI;} +<INITIAL>{REPLY_ROUTE_CALLBACK} { count(); yylval.strval=yytext; return REPLY_ROUTE_CALLBACK;} <INITIAL>{ONSEND_ROUTE_CALLBACK} { count(); yylval.strval=yytext; return ONSEND_ROUTE_CALLBACK;} <INITIAL>{MAX_RECURSIVE_LEVEL} { count(); yylval.strval=yytext; return MAX_RECURSIVE_LEVEL;} <INITIAL>{MAX_BRANCHES_PARAM} { count(); yylval.strval=yytext; return MAX_BRANCHES_PARAM;} diff --git a/src/core/cfg.y b/src/core/cfg.y index e8f76d3537..99bac9c4f1 100644 --- a/src/core/cfg.y +++ b/src/core/cfg.y @@ -484,6 +484,7 @@ extern char *default_routename; %token SERVER_ID %token KEMI %token ONSEND_ROUTE_CALLBACK +%token REPLY_ROUTE_CALLBACK %token MAX_RECURSIVE_LEVEL %token MAX_BRANCHES_PARAM %token LATENCY_CFG_LOG @@ -1569,7 +1570,7 @@ assign_stm: | VERBOSE_STARTUP EQUAL NUMBER { ksr_verbose_startup=$3; } | VERBOSE_STARTUP EQUAL error { yyerror("boolean value expected"); } | SERVER_ID EQUAL NUMBER { server_id=$3; } - | SERVER_ID EQUAL error { yyerror("number expected"); } + | SERVER_ID EQUAL error { yyerror("number expected"); } | KEMI DOT ONSEND_ROUTE_CALLBACK EQUAL STRING { kemi_onsend_route_callback.s = $5; kemi_onsend_route_callback.len = strlen($5); @@ -1579,6 +1580,17 @@ assign_stm: kemi_onsend_route_callback.len = 0; } } + | KEMI DOT ONSEND_ROUTE_CALLBACK EQUAL error { yyerror("string expected"); } + | KEMI DOT REPLY_ROUTE_CALLBACK EQUAL STRING { + kemi_reply_route_callback.s = $5; + kemi_reply_route_callback.len = strlen($5); + if(kemi_reply_route_callback.len==4 + && strcasecmp(kemi_reply_route_callback.s, "none")==0) { + kemi_reply_route_callback.s = ""; + kemi_reply_route_callback.len = 0; + } + } + | KEMI DOT REPLY_ROUTE_CALLBACK EQUAL error { yyerror("string expected"); } | MAX_RECURSIVE_LEVEL EQUAL NUMBER { set_max_recursive_level($3); } | MAX_BRANCHES_PARAM EQUAL NUMBER { sr_dst_max_branches = $3; } | LATENCY_LOG EQUAL intno { default_core_cfg.latency_log=$3; } diff --git a/src/core/kemi.c b/src/core/kemi.c index 6e078af92c..625c55905c 100644 --- a/src/core/kemi.c +++ b/src/core/kemi.c @@ -42,7 +42,10 @@ #define SR_KEMI_HNAME_SIZE 128 +/* names for kemi callback functions */ str kemi_onsend_route_callback = str_init("ksr_onsend_route"); +str kemi_reply_route_callback = str_init("ksr_reply_route"); + /** * */ diff --git a/src/core/kemi.h b/src/core/kemi.h index 8b33c44aa3..89327e11df 100644 --- a/src/core/kemi.h +++ b/src/core/kemi.h @@ -38,6 +38,7 @@ #define SR_KEMI_PARAMS_MAX 6 extern str kemi_onsend_route_callback; +extern str kemi_reply_route_callback; typedef struct sr_kemi { str mname; /* sub-module name */ diff --git a/src/core/receive.c b/src/core/receive.c index 77294673ef..a4f28edaad 100644 --- a/src/core/receive.c +++ b/src/core/receive.c @@ -326,7 +326,9 @@ int receive_msg(char *buf, unsigned int len, struct receive_info *rcv_info) } /* exec the onreply routing script */ - keng = sr_kemi_eng_get(); + if(kemi_reply_route_callback.len>0) { + keng = sr_kemi_eng_get(); + } if(onreply_rt.rlist[DEFAULT_RT] != NULL || keng != NULL) { set_route_type(CORE_ONREPLY_ROUTE); ret = 1;

1 0

Cleanup by server id
by Konstantin Polyakov 12 Mar '18

12 Mar '18

Hello All, I would like to propose improvement for feature "server_id filter" to make possible cleaning location table records by server_id too. That could be usefull when several kamailio instances are used with the same location table and in db mode 1 or 2 (cache). Currently in such configuration there is an issue - one proxy cleans records which are created and stored in the cache by another proxy. That breaks cache of another proxy. I made a fix and would like to open pull request but I don't have permissions to push my branch with changes into the kamailio repository. Could some grant me such permissions? Thank you. Best regards Konstantin

2 1

git:master:96a1367e: app_python3: renamed main files to match module name
by Daniel-Constantin Mierla 10 Mar '18

10 Mar '18

Module: kamailio Branch: master Commit: 96a1367ef9c0977c4b7ae378ad76ec22d393e990 URL: https://github.com/kamailio/kamailio/commit/96a1367ef9c0977c4b7ae378ad76ec2… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2018-03-10T12:18:28+01:00 app_python3: renamed main files to match module name --- Added: src/modules/app_python3/app_python3_mod.c Added: src/modules/app_python3/app_python3_mod.h Modified: src/modules/app_python3/mod_Core.c Modified: src/modules/app_python3/mod_Logger.c Modified: src/modules/app_python3/mod_Ranks.c Modified: src/modules/app_python3/mod_Router.c Modified: src/modules/app_python3/python_exec.c Modified: src/modules/app_python3/python_support.c Removed: src/modules/app_python3/app_python_mod.c Removed: src/modules/app_python3/app_python_mod.h --- Diff: https://github.com/kamailio/kamailio/commit/96a1367ef9c0977c4b7ae378ad76ec2… Patch: https://github.com/kamailio/kamailio/commit/96a1367ef9c0977c4b7ae378ad76ec2… --- diff --git a/src/modules/app_python3/app_python_mod.c b/src/modules/app_python3/app_python3_mod.c similarity index 99% rename from src/modules/app_python3/app_python_mod.c rename to src/modules/app_python3/app_python3_mod.c index 180bb74230..5d45f3f355 100644 --- a/src/modules/app_python3/app_python_mod.c +++ b/src/modules/app_python3/app_python3_mod.c @@ -31,7 +31,7 @@ #include "python_iface.h" #include "python_msgobj.h" #include "python_support.h" -#include "app_python_mod.h" +#include "app_python3_mod.h" #include "mod_Router.h" #include "mod_Core.h" diff --git a/src/modules/app_python3/app_python_mod.h b/src/modules/app_python3/app_python3_mod.h similarity index 94% rename from src/modules/app_python3/app_python_mod.h rename to src/modules/app_python3/app_python3_mod.h index 0c108e2d3f..b011036172 100644 --- a/src/modules/app_python3/app_python_mod.h +++ b/src/modules/app_python3/app_python3_mod.h @@ -19,8 +19,8 @@ * */ -#ifndef _PYTHON_MOD_H -#define _PYTHON_MOD_H +#ifndef _APP_PYTHON3_MOD_H +#define _APP_PYTHON3_MOD_H #include <Python.h> diff --git a/src/modules/app_python3/mod_Core.c b/src/modules/app_python3/mod_Core.c index 4572a1bb80..c8963b6011 100644 --- a/src/modules/app_python3/mod_Core.c +++ b/src/modules/app_python3/mod_Core.c @@ -33,7 +33,7 @@ // local includes #include "python_exec.h" -#include "app_python_mod.h" +#include "app_python3_mod.h" #include "python_iface.h" #include "python_msgobj.h" #include "python_support.h" diff --git a/src/modules/app_python3/mod_Logger.c b/src/modules/app_python3/mod_Logger.c index b723269bb8..424ed31bc9 100644 --- a/src/modules/app_python3/mod_Logger.c +++ b/src/modules/app_python3/mod_Logger.c @@ -33,7 +33,7 @@ // local includes #include "python_exec.h" -#include "app_python_mod.h" +#include "app_python3_mod.h" #include "python_iface.h" #include "python_msgobj.h" #include "python_support.h" diff --git a/src/modules/app_python3/mod_Ranks.c b/src/modules/app_python3/mod_Ranks.c index 80860284bd..118c2ca4f3 100644 --- a/src/modules/app_python3/mod_Ranks.c +++ b/src/modules/app_python3/mod_Ranks.c @@ -33,7 +33,7 @@ // local includes #include "python_exec.h" -#include "app_python_mod.h" +#include "app_python3_mod.h" #include "python_iface.h" #include "python_msgobj.h" #include "python_support.h" diff --git a/src/modules/app_python3/mod_Router.c b/src/modules/app_python3/mod_Router.c index 3fe96f08f1..04183ba47d 100644 --- a/src/modules/app_python3/mod_Router.c +++ b/src/modules/app_python3/mod_Router.c @@ -32,7 +32,7 @@ // local includes #include "python_exec.h" -#include "app_python_mod.h" +#include "app_python3_mod.h" #include "python_iface.h" #include "python_msgobj.h" #include "python_support.h" diff --git a/src/modules/app_python3/python_exec.c b/src/modules/app_python3/python_exec.c index 55f40c1e47..b402a2b9d6 100644 --- a/src/modules/app_python3/python_exec.c +++ b/src/modules/app_python3/python_exec.c @@ -33,7 +33,7 @@ #include "../../core/locking.h" #include "python_exec.h" -#include "app_python_mod.h" +#include "app_python3_mod.h" #include "python_msgobj.h" #include "python_support.h" diff --git a/src/modules/app_python3/python_support.c b/src/modules/app_python3/python_support.c index 2ad522901a..e7dc47d526 100644 --- a/src/modules/app_python3/python_support.c +++ b/src/modules/app_python3/python_support.c @@ -26,7 +26,7 @@ #include "../../core/dprint.h" #include "../../core/mem/mem.h" -#include "app_python_mod.h" +#include "app_python3_mod.h" #include "python_support.h" static char *make_message(const char *fmt, va_list args);

1 0

git:master:ba992b12: app_python3: skip execution of child_init() for rank PROC_INIT
by Daniel-Constantin Mierla 10 Mar '18

10 Mar '18

Module: kamailio Branch: master Commit: ba992b122eec30c5022d4c3e77af4e2f6eb0752a URL: https://github.com/kamailio/kamailio/commit/ba992b122eec30c5022d4c3e77af4e2… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2018-03-10T08:24:21+01:00 app_python3: skip execution of child_init() for rank PROC_INIT - this is a particular execution in main process after all modules were initialized, not in a forked child process --- Modified: src/modules/app_python3/app_python_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/ba992b122eec30c5022d4c3e77af4e2… Patch: https://github.com/kamailio/kamailio/commit/ba992b122eec30c5022d4c3e77af4e2… --- diff --git a/src/modules/app_python3/app_python_mod.c b/src/modules/app_python3/app_python_mod.c index c6f1098e60..180bb74230 100644 --- a/src/modules/app_python3/app_python_mod.c +++ b/src/modules/app_python3/app_python_mod.c @@ -174,6 +174,9 @@ static int mod_init(void) */ static int child_init(int rank) { + if(rank==PROC_INIT) { + return 0; + } _apy_process_rank = rank; PyOS_AfterFork(); return apy_init_script(rank);

1 0

git:master:988cc68d: app_python: skip execution of child_init() for rank PROC_INIT
by Daniel-Constantin Mierla 10 Mar '18

10 Mar '18

Module: kamailio Branch: master Commit: 988cc68d62b8a00a69786e43f99417c05572aef6 URL: https://github.com/kamailio/kamailio/commit/988cc68d62b8a00a69786e43f99417c… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2018-03-10T08:21:20+01:00 app_python: skip execution of child_init() for rank PROC_INIT - this is a particular execution in main process after all modules were initialized, not in a forked child process --- Modified: src/modules/app_python/app_python_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/988cc68d62b8a00a69786e43f99417c… Patch: https://github.com/kamailio/kamailio/commit/988cc68d62b8a00a69786e43f99417c… --- diff --git a/src/modules/app_python/app_python_mod.c b/src/modules/app_python/app_python_mod.c index 3f5463bd0a..5c5278f42d 100644 --- a/src/modules/app_python/app_python_mod.c +++ b/src/modules/app_python/app_python_mod.c @@ -174,6 +174,9 @@ static int mod_init(void) */ static int child_init(int rank) { + if(rank==PROC_INIT) { + return 0; + } _apy_process_rank = rank; PyOS_AfterFork(); return apy_init_script(rank);

1 0

git:master:11e918e1: app_python: call PyOS_AfterFork() in child
by AnthonyA 10 Mar '18

10 Mar '18

Module: kamailio Branch: master Commit: 11e918e1bb8cd1fce4ead00cc532669618b539ba URL: https://github.com/kamailio/kamailio/commit/11e918e1bb8cd1fce4ead00cc532669… Author: AntonyA <ascanio.alba7(a)gmail.com> Committer: AnthonyA <ascanio.alba7(a)gmail.com> Date: 2018-03-10T10:41:31+08:00 app_python: call PyOS_AfterFork() in child --- Modified: src/modules/app_python/app_python_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/11e918e1bb8cd1fce4ead00cc532669… Patch: https://github.com/kamailio/kamailio/commit/11e918e1bb8cd1fce4ead00cc532669… --- diff --git a/src/modules/app_python/app_python_mod.c b/src/modules/app_python/app_python_mod.c index 98738ee66c..3f5463bd0a 100644 --- a/src/modules/app_python/app_python_mod.c +++ b/src/modules/app_python/app_python_mod.c @@ -175,6 +175,7 @@ static int mod_init(void) static int child_init(int rank) { _apy_process_rank = rank; + PyOS_AfterFork(); return apy_init_script(rank); }

1 0

git:master:60816e1e: app_python3: call PyOS_AfterFork() in child
by AnthonyA 10 Mar '18

10 Mar '18

Module: kamailio Branch: master Commit: 60816e1eb9f83fbe4803f1096fdb15e3be390594 URL: https://github.com/kamailio/kamailio/commit/60816e1eb9f83fbe4803f1096fdb15e… Author: AntonyA <ascanio.alba7(a)gmail.com> Committer: AnthonyA <ascanio.alba7(a)gmail.com> Date: 2018-03-10T10:41:31+08:00 app_python3: call PyOS_AfterFork() in child --- Modified: src/modules/app_python3/app_python_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/60816e1eb9f83fbe4803f1096fdb15e… Patch: https://github.com/kamailio/kamailio/commit/60816e1eb9f83fbe4803f1096fdb15e… --- diff --git a/src/modules/app_python3/app_python_mod.c b/src/modules/app_python3/app_python_mod.c index c3229b181d..c6f1098e60 100644 --- a/src/modules/app_python3/app_python_mod.c +++ b/src/modules/app_python3/app_python_mod.c @@ -175,6 +175,7 @@ static int mod_init(void) static int child_init(int rank) { _apy_process_rank = rank; + PyOS_AfterFork(); return apy_init_script(rank); }

1 0

Re: [sr-dev] [kamailio/kamailio] db_mongodb: check mongo-c-driver version at least 1.5.0 to use projection (cdbee5a)
by kelchy 09 Mar '18

09 Mar '18

looks good daniel, i will test more -- You are receiving this because you are subscribed to this thread. Reply to this email directly or view it on GitHub: https://github.com/kamailio/kamailio/commit/cdbee5a536920c4fab3ec619c8467c1…

1 0

git:master:d12eba62: db_redis: Fix free(0) on update
by Andreas Granig 09 Mar '18

09 Mar '18

Module: kamailio Branch: master Commit: d12eba62bfaefa0db85e66cb21678c9cccda658b URL: https://github.com/kamailio/kamailio/commit/d12eba62bfaefa0db85e66cb21678c9… Author: Andreas Granig <agranig(a)sipwise.com> Committer: Andreas Granig <agranig(a)sipwise.com> Date: 2018-03-09T11:54:34+01:00 db_redis: Fix free(0) on update --- Modified: src/modules/db_redis/redis_dbase.c --- Diff: https://github.com/kamailio/kamailio/commit/d12eba62bfaefa0db85e66cb21678c9… Patch: https://github.com/kamailio/kamailio/commit/d12eba62bfaefa0db85e66cb21678c9… --- diff --git a/src/modules/db_redis/redis_dbase.c b/src/modules/db_redis/redis_dbase.c index 247627189d..48bcf343d3 100644 --- a/src/modules/db_redis/redis_dbase.c +++ b/src/modules/db_redis/redis_dbase.c @@ -28,7 +28,7 @@ #include "redis_table.h" static void db_redis_dump_reply(redisReply *reply) { - int i; + int i; if (reply->type == REDIS_REPLY_STRING) { LM_DBG("%s\n", reply->str); } else if (reply->type == REDIS_REPLY_INTEGER) { @@ -218,7 +218,7 @@ static int db_redis_return_version(const db1_con_t* _h, km_redis_con_t *con, con } static int db_redis_build_entry_manual_keys(redis_table_t *table, const db_key_t *_k, - const db_val_t *_v, const int _n, int **manual_keys, int *manual_key_count) { + const db_val_t *_v, const int _n, int **manual_keys, int *manual_key_count) { // TODO: we also put keys here which are already part of type mapping! // there must be removed for performance reasons @@ -264,8 +264,8 @@ static int db_redis_build_entry_manual_keys(redis_table_t *table, const db_key_t } static int db_redis_find_query_key(redis_key_t *key, const str *table_name, - str *type_name, const db_key_t *_k, const db_val_t *_v, const int _n, - str *key_name, int *key_found) { + str *type_name, const db_key_t *_k, const db_val_t *_v, const int _n, + str *key_name, int *key_found) { unsigned int len; str val = {NULL, 0}; @@ -564,7 +564,7 @@ static int db_redis_build_query_keys(km_redis_con_t *con, const str *table_name, db_redis_free_reply(&reply); break; } else { - int i; + int i; LM_DBG("populating query keys list with result of type query\n"); *query_keys_count = reply->elements; for (i = 0; i < reply->elements; ++i) { @@ -1597,7 +1597,8 @@ static int db_redis_perform_update(const db1_con_t* _h, km_redis_con_t *con, con LM_ERR("Failed to add key to update query\n"); goto error; } - pkg_free(v.s); + if (v.s) + pkg_free(v.s); } update_queries++; if (db_redis_append_command_argv(con, query_v, 1) != REDIS_OK) {

1 0

git:master:cdbee5a5: db_mongodb: check mongo-c-driver version at least 1.5.0 to use projection
by Daniel-Constantin Mierla 09 Mar '18

09 Mar '18

Module: kamailio Branch: master Commit: cdbee5a536920c4fab3ec619c8467c152d6f110a URL: https://github.com/kamailio/kamailio/commit/cdbee5a536920c4fab3ec619c8467c1… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2018-03-09T10:39:40+01:00 db_mongodb: check mongo-c-driver version at least 1.5.0 to use projection - reported by GH #1479 --- Modified: src/modules/db_mongodb/mongodb_dbase.c --- Diff: https://github.com/kamailio/kamailio/commit/cdbee5a536920c4fab3ec619c8467c1… Patch: https://github.com/kamailio/kamailio/commit/cdbee5a536920c4fab3ec619c8467c1… --- diff --git a/src/modules/db_mongodb/mongodb_dbase.c b/src/modules/db_mongodb/mongodb_dbase.c index aee5a1ba0a..72d6647689 100644 --- a/src/modules/db_mongodb/mongodb_dbase.c +++ b/src/modules/db_mongodb/mongodb_dbase.c @@ -316,7 +316,9 @@ int db_mongodb_get_columns(const db1_con_t* _h, db1_res_t* _r) int col; db_mongodb_result_t *mgres; bson_iter_t riter; +#if MONGOC_CHECK_VERSION(1, 5, 0) bson_iter_t titer; +#endif bson_iter_t citer; bson_t *cdoc; const char *colname; @@ -360,6 +362,7 @@ int db_mongodb_get_columns(const db1_con_t* _h, db1_res_t* _r) } if(cdocproj == 1) { +#if MONGOC_CHECK_VERSION(1, 5, 0) if (!bson_iter_init (&titer, cdoc)) { LM_ERR("failed to initialize columns iterator\n"); return -3; @@ -373,6 +376,12 @@ int db_mongodb_get_columns(const db1_con_t* _h, db1_res_t* _r) LM_ERR("failed to init projection iterator\n"); return -3; } +#else + if (!bson_iter_init (&citer, cdoc)) { + LM_ERR("failed to initialize columns iterator\n"); + return -3; + } +#endif } else { if (!bson_iter_init (&citer, cdoc)) { LM_ERR("failed to initialize columns iterator\n"); @@ -506,7 +515,9 @@ static int db_mongodb_convert_bson(const db1_con_t* _h, db1_res_t* _r, const char *colname; bson_type_t coltype; bson_iter_t riter; +#if MONGOC_CHECK_VERSION(1, 5, 0) bson_iter_t titer; +#endif bson_iter_t citer; bson_iter_t *piter; db_val_t* dval; @@ -527,6 +538,7 @@ static int db_mongodb_convert_bson(const db1_con_t* _h, db1_res_t* _r, } } else { cdoc = (bson_t*)mgres->colsdoc; +#if MONGOC_CHECK_VERSION(1, 5, 0) if (!bson_iter_init (&titer, cdoc)) { LM_ERR("failed to initialize columns iterator\n"); return -3; @@ -540,6 +552,12 @@ static int db_mongodb_convert_bson(const db1_con_t* _h, db1_res_t* _r, LM_ERR("failed to init projection iterator\n"); return -3; } +#else + if (!bson_iter_init (&citer, cdoc)) { + LM_ERR("failed to initialize columns iterator\n"); + return -3; + } +#endif } if(mgres->colsdoc) { @@ -864,7 +882,9 @@ int db_mongodb_query(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _op km_mongodb_con_t *mgcon; mongoc_client_t *client; bson_t *seldoc = NULL; +#if MONGOC_CHECK_VERSION(1, 5, 0) bson_t bcols; +#endif char *cname; char b1; char *jstr; @@ -944,23 +964,31 @@ int db_mongodb_query(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _op LM_ERR("cannot initialize columns bson document\n"); goto error; } +#if MONGOC_CHECK_VERSION(1, 5, 0) if(!bson_append_document_begin (mgcon->colsdoc, "projection", 10, &bcols)) { LM_ERR("failed to start projection of fields\n"); goto error; } +#endif for(i = 0; i < _nc; i++) { +#if MONGOC_CHECK_VERSION(1, 5, 0) if(!bson_append_int32(&bcols, _c[i]->s, _c[i]->len, 1)) +#else + if(!bson_append_int32(mgcon->colsdoc, _c[i]->s, _c[i]->len, 1)) +#endif { LM_ERR("failed to append int to columns bson %.*s = %d [%d]\n", _c[i]->len, _c[i]->s, 1, i); goto error; } } +#if MONGOC_CHECK_VERSION(1, 5, 0) if(!bson_append_document_end (mgcon->colsdoc, &bcols)) { LM_ERR("failed to end projection of fields\n"); goto error; } +#endif if(is_printable(L_DBG)) { jstr = bson_as_json (mgcon->colsdoc, NULL); LM_DBG("columns filter: %s\n", jstr);

1 0

← Newer
1
...
19
20
21
22
23
24
25
...
33
Older →

Jump to page:

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev March 2018