sr-users April 2011

sr-users@lists.kamailio.org

64 participants
104 discussions

by Pavel Segeč

Hi, I would like ask you if there is a kamailio ims module documentation somewhere. I need some deeper information how some things are implemented, I have problem to setup NAT traversal with RTPproxy for our Kamailio IMS platform. There is no communication among the PCSCF and RTPproxy server over control udp sock. We tried unix socket also with the same results. Thanks palo73 http://nil.uniza.sk

13 years

Kamailio RPMs for v3.1.3

by Daniel-Constantin Mierla

Hello, the RPM packages for Kamailio recently released v3.1.3 are now available for CentOS, Fedora, RedHat and OpenSUSE, available on the opensuse.org build service: * https://build.opensuse.org/package/show?package=kamailio&project=home%3Akam… <https://build.opensuse.org/package/show?package=kamailio&project=home%3Akam…> Specific download links are: * http://download.opensuse.org/repositories/home:/kamailio:/telephony/CentOS_… * http://download.opensuse.org/repositories/home:/kamailio:/telephony/RedHat_… * http://download.opensuse.org/repositories/home:/kamailio:/telephony/Fedora_… * http://download.opensuse.org/repositories/home:/kamailio:/telephony/openSUS… Cheers, Daniel -- Daniel-Constantin Mierla http://www.asipto.com

13 years

Kamailio v3.1.3 Released

by Daniel-Constantin Mierla

Hello, Kamailio SIP Server v3.1.3 stable release is out. This is a maintenance release of latest stable branch, 3.1, that includes fixes since release of v3.1.2. There is no change to database schema or configuration language structure. Deployments running v3.1.0, v3.1.1 or 3.1.2 are strongly recommended to be upgraded to v3.1.3. For more details about version 3.1.3, visit: http://www.kamailio.org/w/2011/04/kamailio-v3-1-3-released/ Note: existing configuration files for installations on 64b operating systems may need to be updated to specify 'lib64' to the path where the modules are installed (to the value of parameter 'mpath'). See bottom note of the link provided above. Cheers, Daniel -- Daniel-Constantin Mierla http://www.asipto.com

13 years

tcp hangup

by Juha Heinanen

i have two sr proxies talking with each other over tcp. one is running 3.0 and the other 3.1. sometimes i notice that no sip requests or any other tcp packets get through from 3.0 sr host to 3.1 sr host. netstat on 3.0 sr host shows that tcp connection to 3.1 sr host is in ESTABLISHED state whereas netstat on 3.1 sr shows that the same tcp connection is in FIN_WAIT1 state. it takes several minutes before the hanging tcp connection is replaced by a new working one. there is no ip level connectivity problem between the two sr hosts. any suggestions on what might be going on? is there some known bug in 3.0 tcp implementation that could explain this? -- juha

13 years

[PATCH] modules_k/db_sqlite: new sql backend

by Timo Teräs

Implements the kamailio database API for SQLite. Signed-off-by: Timo Teräs <timo.teras(a)iki.fi> --- modules_k/db_sqlite/Makefile | 15 ++ modules_k/db_sqlite/db_sqlite.c | 90 +++++++ modules_k/db_sqlite/dbase.c | 515 +++++++++++++++++++++++++++++++++++++++ modules_k/db_sqlite/dbase.h | 72 ++++++ 4 files changed, 692 insertions(+), 0 deletions(-) create mode 100644 modules_k/db_sqlite/Makefile create mode 100644 modules_k/db_sqlite/db_sqlite.c create mode 100644 modules_k/db_sqlite/dbase.c create mode 100644 modules_k/db_sqlite/dbase.h diff --git a/modules_k/db_sqlite/Makefile b/modules_k/db_sqlite/Makefile new file mode 100644 index 0000000..9a75593 --- /dev/null +++ b/modules_k/db_sqlite/Makefile @@ -0,0 +1,15 @@ +# $Id$ +# +# WARNING: do not run this directly, it should be run by the master Makefile + +include ../../Makefile.defs +auto_gen= +NAME=db_sqlite.so + +LIBS +=-lsqlite3 + +DEFS+=-DOPENSER_MOD_INTERFACE + +SERLIBPATH=../../lib +SER_LIBS+=$(SERLIBPATH)/srdb1/srdb1 +include ../../Makefile.modules diff --git a/modules_k/db_sqlite/db_sqlite.c b/modules_k/db_sqlite/db_sqlite.c new file mode 100644 index 0000000..8ec16e3 --- /dev/null +++ b/modules_k/db_sqlite/db_sqlite.c @@ -0,0 +1,90 @@ +/* + * $Id$ + * + * SQlite module interface + * + * Copyright (C) 2010 Timo Teräs + * + * This file is part of Kamailio, a free SIP server. + * + * Kamailio is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version + * + * Kamailio is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +#include <sys/time.h> +#include <sqlite3.h> + +#include "../../sr_module.h" +#include "../../lib/srdb1/db.h" +#include "dbase.h" + +MODULE_VERSION + +static int sqlite_bind_api(db_func_t *dbb) +{ + if(dbb==NULL) + return -1; + + memset(dbb, 0, sizeof(db_func_t)); + + dbb->use_table = db_sqlite_use_table; + dbb->init = db_sqlite_init; + dbb->close = db_sqlite_close; + dbb->free_result = db_sqlite_free_result; + dbb->query = db_sqlite_query; + dbb->insert = db_sqlite_insert; + dbb->delete = db_sqlite_delete; + dbb->update = db_sqlite_update; + dbb->raw_query = db_sqlite_raw_query; + + return 0; +} + +static cmd_export_t cmds[] = { + {"db_bind_api", (cmd_function)sqlite_bind_api, 0, 0, 0, 0}, + {0, 0, 0, 0, 0, 0} +}; + +static int sqlite_mod_init(void) +{ + sqlite3_initialize(); + + LM_INFO("SQlite library version %s (compiled using %s)\n", + sqlite3_libversion(), + SQLITE_VERSION); + return 0; +} + + +static void sqlite_mod_destroy(void) +{ + LM_INFO("SQlite terminate\n"); + + sqlite3_shutdown(); +} + +struct module_exports exports = { + "db_sqlite", + DEFAULT_DLFLAGS, /* dlopen flags */ + cmds, /* module commands */ + 0, /* module parameters */ + 0, /* exported statistics */ + 0, /* exported MI functions */ + 0, /* exported pseudo-variables */ + 0, /* extra processes */ + sqlite_mod_init, /* module initialization function */ + 0, /* response function*/ + sqlite_mod_destroy, /* destroy function */ + 0 /* per-child init function */ +}; diff --git a/modules_k/db_sqlite/dbase.c b/modules_k/db_sqlite/dbase.c new file mode 100644 index 0000000..b64b327 --- /dev/null +++ b/modules_k/db_sqlite/dbase.c @@ -0,0 +1,515 @@ +/* + * $Id$ + * + * SQlite module core functions + * + * Copyright (C) 2010 Timo Teräs + * + * This file is part of Kamailio, a free SIP server. + * + * Kamailio is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version + * + * Kamailio is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +#include "../../mem/mem.h" +#include "../../dprint.h" +#include "../../lib/srdb1/db_pool.h" +#include "../../lib/srdb1/db_ut.h" +#include "../../lib/srdb1/db_res.h" +#include "../../lib/srdb1/db_query.h" +#include "dbase.h" + +static time_t sqlite_to_timet(double rT) +{ + return 86400.0*(rT - 2440587.5) + 0.5; +} + +static double timet_to_sqlite(time_t t) +{ + return ((((double) t) - 0.5) / 86400.0) + 2440587.5; +} + +/* + * Initialize database module + * No function should be called before this + */ + +static struct sqlite_connection * db_sqlite_new_connection(const struct db_id* id) +{ + struct sqlite_connection *con; + int rc; + + con = pkg_malloc(sizeof(*con)); + if (!con) { + LM_ERR("failed to allocate driver connection\n"); + return NULL; + } + + memset(con, 0, sizeof(*con)); + con->hdr.ref = 1; + con->hdr.id = (struct db_id*) id; /* set here - freed on error */ + + rc = sqlite3_open_v2(id->database, &con->conn, + SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE, NULL); + if (rc != SQLITE_OK) { + pkg_free(con); + LM_ERR("failed to open sqlite database '%s'\n", id->database); + return NULL; + } + + return con; +} + +db1_con_t* db_sqlite_init(const str* _url) +{ + return db_do_init(_url, (void *) db_sqlite_new_connection); +} + + +/* + * Shut down database module + * No function should be called after this + */ + +static void db_sqlite_free_connection(struct sqlite_connection* con) +{ + if (!con) return; + + sqlite3_close(con->conn); + free_db_id(con->hdr.id); + pkg_free(con); +} + +void db_sqlite_close(db1_con_t* _h) +{ + db_do_close(_h, db_sqlite_free_connection); +} + +/* + * Release a result set from memory + */ +int db_sqlite_free_result(db1_con_t* _h, db1_res_t* _r) +{ + if (!_h || !_r) { + LM_ERR("invalid parameter value\n"); + return -1; + } + + if (db_free_result(_r) < 0) + { + LM_ERR("failed to free result structure\n"); + return -1; + } + return 0; +} + +/* + * Store name of table that will be used by + * subsequent database functions + */ +int db_sqlite_use_table(db1_con_t* _h, const str* _t) +{ + return db_use_table(_h, _t); +} + +/* + * Reset query context + */ +static void db_sqlite_cleanup_query(const db1_con_t* _c) +{ + struct sqlite_connection *conn = CON_SQLITE(_c); + int rc; + + if (conn->stmt != NULL) { + rc = sqlite3_finalize(conn->stmt); + if (rc != SQLITE_OK) + LM_ERR("finalize failed: %s\n", + sqlite3_errmsg(conn->conn)); + } + + conn->stmt = NULL; + conn->bindpos = 0; +} + +/* + * Convert value to sql-string as db bind index + */ +static int db_sqlite_val2str(const db1_con_t* _c, const db_val_t* _v, char* _s, int* _len) +{ + struct sqlite_connection *conn; + int ret; + + if (!_c || !_v || !_s || !_len || *_len <= 0) { + LM_ERR("invalid parameter value\n"); + return -1; + } + + conn = CON_SQLITE(_c); + if (conn->bindpos >= DB_SQLITE_MAX_BINDS) { + LM_ERR("too many bindings, recompile with larger DB_SQLITE_MAX_BINDS\n"); + return -2; + } + + conn->bindarg[conn->bindpos] = _v; + ret = snprintf(_s, *_len, "?%u", ++conn->bindpos); + if ((unsigned)ret >= (unsigned) *_len) + return -11; + + *_len = ret; + return 0; +} + +/* + * Send an SQL query to the server + */ +static int db_sqlite_submit_query(const db1_con_t* _h, const str* _s) +{ + struct sqlite_connection *conn = CON_SQLITE(_h); + sqlite3_stmt *stmt; + const db_val_t *val; + int rc, i; + + LM_DBG("submit_query: %.*s\n", _s->len, _s->s); + + rc = sqlite3_prepare_v2(conn->conn, _s->s, _s->len, &stmt, NULL); + if (rc != SQLITE_OK) { + LM_ERR("failed to prepare statement: %s\n", + sqlite3_errmsg(conn->conn)); + return -1; + } + conn->stmt = stmt; + + for (i = 1; i <= conn->bindpos; i++) { + val = conn->bindarg[i-1]; + if (VAL_NULL(val)) { + rc = sqlite3_bind_null(stmt, i); + } else switch (VAL_TYPE(val)) { + case DB1_INT: + rc = sqlite3_bind_int(stmt, i, VAL_INT(val)); + break; + case DB1_BIGINT: + rc = sqlite3_bind_int64(stmt, i, VAL_BIGINT(val)); + break; + case DB1_DOUBLE: + rc = sqlite3_bind_double(stmt, i, VAL_DOUBLE(val)); + break; + case DB1_STRING: + rc = sqlite3_bind_text(stmt, i, + VAL_STRING(val), -1, NULL); + break; + case DB1_STR: + rc = sqlite3_bind_text(stmt, i, + VAL_STR(val).s, VAL_STR(val).len, NULL); + break; + case DB1_DATETIME: + rc = sqlite3_bind_double(stmt, i, timet_to_sqlite(VAL_TIME(val))); + break; + case DB1_BLOB: + rc = sqlite3_bind_blob(stmt, i, + VAL_BLOB(val).s, VAL_BLOB(val).len, + NULL); + break; + case DB1_BITMAP: + rc = sqlite3_bind_int(stmt, i, VAL_BITMAP(val)); + break; + default: + LM_ERR("unknown bind value type %d\n", VAL_TYPE(val)); + return -1; + } + if (rc != SQLITE_OK) { + LM_ERR("Parameter bind failed: %s\n", + sqlite3_errmsg(conn->conn)); + return -1; + } + } + + return 0; +} + +static int decltype_to_dbtype(const char *decltype) +{ + /* SQlite3 has dynamic typing. It does not store the actual + * exact type, instead it uses 'affinity' depending on the + * value. We have to go through the declaration types to see + * what to return. */ + if (strstr(decltype, "INT") != NULL || + strncasecmp(decltype, "SERIAL", 6) == 0) + return DB1_INT; + if (strstr(decltype, "CHAR") != NULL) + return DB1_STRING; + if (strstr(decltype, "TEXT") != NULL) + return DB1_STR; + if (strstr(decltype, "REAL") != NULL || + strstr(decltype, "FLOA") != NULL || + strstr(decltype, "DOUB") != NULL) + return DB1_DOUBLE; + if (strstr(decltype, "BLOB") != NULL) + return DB1_BLOB; + if (strncasecmp(decltype, "TIME", 4) == 0 || + strncasecmp(decltype, "DATE", 4) == 0) + return DB1_DATETIME; + + LM_ERR("sqlite decltype '%s' not recognized, defaulting to int", + decltype); + return DB1_INT; +} + +static str* str_dup(const char *_s) +{ + str *s; + int len = strlen(_s); + + s = (str*) pkg_malloc(sizeof(str)+len+1); + s->len = len; + s->s = ((char*)s) + sizeof(str); + memcpy(s->s, _s, len); + s->s[len] = '\0'; + + return s; +} + +static void str_assign(str* s, const char *_s, int len) +{ + s->s = (char *) pkg_malloc(len + 1); + s->len = len; + memcpy(s->s, _s, len); + s->s[len] = 0; +} + +/* + * Read database answer and fill the structure + */ +int db_sqlite_store_result(const db1_con_t* _h, db1_res_t** _r) +{ + struct sqlite_connection *conn = CON_SQLITE(_h); + db1_res_t *res; + int i, rc, num_rows = 0, num_alloc = 0; + db_row_t *rows = NULL, *row; + db_val_t *val; + + res = db_new_result(); + if (res == NULL) + goto no_mem; + + while (1) { + rc = sqlite3_step(conn->stmt); + if (rc == SQLITE_DONE) { + *_r = res; + return 0; + } + if (rc != SQLITE_ROW) { + LM_INFO("sqlite3_step failed: %s\n", sqlite3_errmsg(conn->conn)); + goto err; + } + if (num_rows == 0) { + /* get column types */ + rc = sqlite3_column_count(conn->stmt); + if (db_allocate_columns(res, rc) != 0) + goto err; + RES_COL_N(res) = rc; + + for (i = 0; i < RES_COL_N(res); i++) { + RES_NAMES(res)[i] = str_dup(sqlite3_column_name(conn->stmt, i)); + RES_TYPES(res)[i] = decltype_to_dbtype(sqlite3_column_decltype(conn->stmt, i)); + } + } + if (num_rows >= num_alloc) { + if (num_alloc) + num_alloc *= 2; + else + num_alloc = 8; + rows = pkg_realloc(rows, sizeof(db_row_t) * num_alloc); + if (rows == NULL) + goto no_mem; + RES_ROWS(res) = rows; + } + + row = &RES_ROWS(res)[num_rows]; + num_rows++; + RES_ROW_N(res) = num_rows; /* rows in this result set */ + RES_NUM_ROWS(res) = num_rows; /* rows in total */ + + if (db_allocate_row(res, row) != 0) + goto no_mem; + + for (i = 0, val = ROW_VALUES(row); i < RES_COL_N(res); i++, val++) { + VAL_TYPE(val) = RES_TYPES(res)[i]; + VAL_NULL(val) = 0; + VAL_FREE(val) = 0; + if (sqlite3_column_type(conn->stmt, i) == SQLITE_NULL) { + VAL_NULL(val) = 1; + } else switch (VAL_TYPE(val)) { + case DB1_INT: + VAL_INT(val) = sqlite3_column_int(conn->stmt, i); + break; + case DB1_BIGINT: + VAL_BIGINT(val) = sqlite3_column_int64(conn->stmt, i); + break; + case DB1_STRING: + /* first field of struct str* is the char* so we can just + * do whatever DB1_STR case does */ + case DB1_STR: + str_assign(&VAL_STR(val), + (const char*) sqlite3_column_text(conn->stmt, i), + sqlite3_column_bytes(conn->stmt, i)); + VAL_FREE(val) = 1; + break; + case DB1_DOUBLE: + VAL_DOUBLE(val) = sqlite3_column_double(conn->stmt, i); + break; + case DB1_DATETIME: + VAL_TIME(val) = sqlite_to_timet(sqlite3_column_double(conn->stmt, i)); + break; + case DB1_BLOB: + str_assign(&VAL_BLOB(val), + (const char*) sqlite3_column_blob(conn->stmt, i), + sqlite3_column_bytes(conn->stmt, i)); + VAL_FREE(val) = 1; + break; + default: + LM_ERR("unhandled db-type\n"); + goto err; + } + } + } + +no_mem: + LM_ERR("no private memory left\n"); +err: + if (res) + db_free_result(res); + return -1; +} + +/* + * Query table for specified rows + * _h: structure representing database connection + * _k: key names + * _op: operators + * _v: values of the keys that must match + * _c: column names to return + * _n: number of key=values pairs to compare + * _nc: number of columns to return + * _o: order by the specified column + */ +int db_sqlite_query(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _op, + const db_val_t* _v, const db_key_t* _c, int _n, int _nc, + const db_key_t _o, db1_res_t** _r) +{ + int rc; + + rc = db_do_query(_h, _k, _op, _v, _c, _n, _nc, _o, _r, + db_sqlite_val2str, + db_sqlite_submit_query, + db_sqlite_store_result); + db_sqlite_cleanup_query(_h); + + return rc; +} + +static int db_sqlite_commit(const db1_con_t* _h) +{ + struct sqlite_connection *conn = CON_SQLITE(_h); + int rc; + + rc = sqlite3_step(conn->stmt); + if (rc != SQLITE_DONE && rc != SQLITE_OK) { + LM_ERR("sqlite commit failed: %s\n", + sqlite3_errmsg(conn->conn)); + return -1; + } + + return 0; +} + +/* + * Insert a row into specified table + * _h: structure representing database connection + * _k: key names + * _v: values of the keys + * _n: number of key=value pairs + */ +int db_sqlite_insert(const db1_con_t* _h, const db_key_t* _k, const db_val_t* _v, + int _n) +{ + int rc = -1; + + rc = db_do_insert(_h, _k, _v, _n, + db_sqlite_val2str, + db_sqlite_submit_query); + if (rc == 0) + rc = db_sqlite_commit(_h); + db_sqlite_cleanup_query(_h); + + return rc; +} + + +/* + * Delete a row from the specified table + * _h: structure representing database connection + * _k: key names + * _o: operators + * _v: values of the keys that must match + * _n: number of key=value pairs + */ +int db_sqlite_delete(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _o, + const db_val_t* _v, int _n) +{ + int rc; + + rc = db_do_delete(_h, _k, _o, _v, _n, + db_sqlite_val2str, + db_sqlite_submit_query); + if (rc == 0) + rc = db_sqlite_commit(_h); + db_sqlite_cleanup_query(_h); + + return rc; +} + + +/* + * Update some rows in the specified table + * _h: structure representing database connection + * _k: key names + * _o: operators + * _v: values of the keys that must match + * _uk: updated columns + * _uv: updated values of the columns + * _n: number of key=value pairs + * _un: number of columns to update + */ +int db_sqlite_update(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _o, + const db_val_t* _v, const db_key_t* _uk, const db_val_t* _uv, + int _n, int _un) +{ + int rc; + + rc = db_do_update(_h, _k, _o, _v, _uk, _uv, _n, _un, + db_sqlite_val2str, + db_sqlite_submit_query); + if (rc == 0) + rc = db_sqlite_commit(_h); + db_sqlite_cleanup_query(_h); + + return rc; +} + +int db_sqlite_raw_query(const db1_con_t* _h, const str* _s, db1_res_t** _r) +{ + return db_do_raw_query(_h, _s, _r, + db_sqlite_submit_query, + db_sqlite_store_result); +} diff --git a/modules_k/db_sqlite/dbase.h b/modules_k/db_sqlite/dbase.h new file mode 100644 index 0000000..de006bf --- /dev/null +++ b/modules_k/db_sqlite/dbase.h @@ -0,0 +1,72 @@ +/* + * $Id$ + * + * SQlite module core functions + * + * Copyright (C) 2010 Timo Teräs + * + * This file is part of Kamailio, a free SIP server. + * + * Kamailio is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version + * + * Kamailio is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + + +#ifndef DBASE_H +#define DBASE_H + +#include <sqlite3.h> + +#include "../../lib/srdb1/db_pool.h" +#include "../../lib/srdb1/db_con.h" +#include "../../lib/srdb1/db_res.h" +#include "../../lib/srdb1/db_key.h" +#include "../../lib/srdb1/db_op.h" +#include "../../lib/srdb1/db_val.h" + +#define DB_SQLITE_MAX_BINDS 64 + +struct sqlite_connection { + struct pool_con hdr; + + sqlite3 *conn; + int bindpos; + + sqlite3_stmt *stmt; + const db_val_t *bindarg[DB_SQLITE_MAX_BINDS]; +}; + +#define CON_SQLITE(db_con) ((struct sqlite_connection *) db_con->tail) + +db1_con_t* db_sqlite_init(const str* _sqlurl); +void db_sqlite_close(db1_con_t* _h); + +int db_sqlite_free_result(db1_con_t* _h, db1_res_t* _r); + +int db_sqlite_query(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _op, + const db_val_t* _v, const db_key_t* _c, int _n, int _nc, + const db_key_t _o, db1_res_t** _r); +int db_sqlite_insert(const db1_con_t* _h, const db_key_t* _k, const db_val_t* _v, + int _n); +int db_sqlite_delete(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _o, + const db_val_t* _v, int _n); +int db_sqlite_update(const db1_con_t* _h, const db_key_t* _k, const db_op_t* _o, + const db_val_t* _v, const db_key_t* _uk, const db_val_t* _uv, + int _n, int _un); +int db_sqlite_raw_query(const db1_con_t* _h, const str* _s, db1_res_t** _r); + +int db_sqlite_use_table(db1_con_t* _h, const str* _t); + + +#endif /* DBASE_H */ -- 1.7.1

13 years

SIP NOTIFY problem in "presence_dialoginfo" module?

by Klaus Feichtinger

Hello list, I have a special situation in which string characters of the "root-line" of the notify-body are overwritten by Kamailio. In detail: the root-line of the NOTIFY message sent to the subscriber looks like: <dialog-info xmlns="urn:ietf:params:xml:ns:dialog-info" version="1" ll" entity="sip:117090@10.16.10.99"> instead of <dialog-info xmlns="urn:ietf:params:xml:ns:dialog-info" version="1" state="full" entity="sip:117090@10.16.10.99"> In other words: the string state="full" is overwritten by space characters. Therefore the message is no longer "valid" and the parser of the subscriber-user agent has problems.... The exact scenario in my use case is, that user agents can subscribe the events "presence" and "dialog" on Kamailio. The information about presence and dialog-states is published to Kamailio by PUBLISH messages from the user agents themselves. Kamailio does not have to generate this information itself. In the following lines I have an excerpt of the signalisation: 1) initial subscription of party A, 2) the responded notification (without body) 3) subscription of party B 4) the responded notification (with body) 5) a publish message of the subscribed party B with actual dialog information and 6) the notification with body to the subscriber A. 1) Initial SUBSCRIBE message of party A: ======================================SUBSCRIBE sip:117090@10.16.10.99 SIP/2.0 Via: SIP/2.0/UDP 10.16.10.93:5060;rport;branch=z9hG4bK1411449981 From: <sip:117093@10.16.10.99>;tag=2453899634-24035392-1301468026894 To: <sip:117090@10.16.10.99> Call-ID: 2442490492-24035392-1301468026894(a)10.16.10.93 CSeq: 20 SUBSCRIBE Contact: <sip:117093@10.16.10.93:5060> Max-Forwards: 70 User-Agent: SipTapi Expires: 3600 Event: dialog Content-Length: 0 2) Responded NOTIFY message from Kamailio: ========================================NOTIFY sip:117093@10.16.10.93:5060 SIP/2.0 Via: SIP/2.0/UDP 10.16.10.99;branch=z9hG4bK7cc7.08e060b6000000000000000000000000.0 To: sip:117093@10.16.10.99;tag=2453899634-24035392-1301468026894 From: sip:117090@10.16.10.99;tag=a23c71953194c2c72e41c4d20e4f7127-86e1 CSeq: 1 NOTIFY Call-ID: 2442490492-24035392-1301468026894(a)10.16.10.93 Content-Length: 0 User-Agent: kamailio (3.1.2 (i386/linux)) Max-Forwards: 70 Event: dialog Contact: <sip:10.16.10.99:5060> Subscription-State: active;expires=3670 3) Initial SUBSCRIBE message of party B: ======================================SUBSCRIBE sip:117093@10.16.10.99 SIP/2.0 Via: SIP/2.0/UDP 10.16.10.90:5060;rport;branch=z9hG4bK4016956575 From: <sip:117090@10.16.10.99>;tag=2605346227-26329880-1301468174702 To: <sip:117093@10.16.10.99> Call-ID: 2982039389-26329880-1301468174702(a)10.16.10.90 CSeq: 20 SUBSCRIBE Contact: <sip:117090@10.16.10.90:5060> Max-Forwards: 70 User-Agent: SipTapi Expires: 3600 Event: dialog Content-Length: 0 4) Responded NOTIFY message from Kamailio (with version number "00000000000"!!!!): ==============================================================================NOTIFY sip:117090@10.16.10.90:5060 SIP/2.0 Via: SIP/2.0/UDP 10.16.10.99;branch=z9hG4bK10e8.31cb2284000000000000000000000000.0 To: sip:117090@10.16.10.99;tag=2605346227-26329880-1301468174702 From: sip:117093@10.16.10.99;tag=a23c71953194c2c72e41c4d20e4f7127-5f56 CSeq: 1 NOTIFY Call-ID: 2982039389-26329880-1301468174702(a)10.16.10.90 Content-Length: 593 User-Agent: kamailio (3.1.2 (i386/linux)) Max-Forwards: 70 Event: dialog Contact: <sip:10.16.10.99:5060> Subscription-State: active;expires=3670 Content-Type: application/dialog-info+xml <?xml version="1.0"?> <dialog-info xmlns="urn:ietf:params:xml:ns:dialog-info" version="00000000000" state="full" entity="117093(a)10.16.10.99"> <dialog id="3375446242-26591296-1301467877329(a)10.16.10.93" call-id="3375446242-26591296-1301467877329(a)10.16.10.93" direction="initiator"> <state>terminated</state> <remote> <identity>sip:019992116002@10.16.10.99</identity> <target uri="sip:019992116002@10.16.10.99"/> </remote> <local> <identity>sip:117093@10.16.10.99</identity> <target uri="sip:117093@10.16.10.99"/> </local> </dialog> </dialog-info> 5) The subscribed party is sending a PUBLISH message with following information: ============================================================================PUBLISH sip:117090@10.16.10.99 SIP/2.0 Via: SIP/2.0/UDP 10.16.10.90:5060;rport;branch=z9hG4bK348084694 From: <sip:117090@10.16.10.99>;tag=3644648667-26329880-1301468223499 To: <sip:117090@10.16.10.99> Call-ID: 332031778-26329880-1301468223499(a)10.16.10.90 CSeq: 20 PUBLISH Max-Forwards: 70 User-Agent: SipTapi Content-Disposition: render;handling=required Expires: 3600 Event: dialog Content-Type: application/dialog-info+xml Content-Length: 592 <?xml version="1.0"?> <dialog-info xmlns="urn:ietf:params:xml:ns:dialog-info" version="4" state="full" entity="sip:117090@10.16.10.99"> <dialog id="2769397361-26329880-1301468223108(a)10.16.10.90" call-id="2769397361-26329880-1301468223108(a)10.16.10.90" direction="initiator"> <state>confirmed</state> <remote> <identity><sip:116001@10.16.10.99></identity> <target uri="<sip:116001@10.16.10.99>"/> </remote> <local> <identity>sip:117090@10.16.10.99</identity> <target uri="sip:117090@10.16.10.99"/> </local> </dialog> </dialog-info> 6) Status informative NOTIFY message from Kamailio (built from the PUBLISH message above - with correct version but string overwriting!!!): =======================================================================================================================================NOTIFY sip:117093@10.16.10.93:5060 SIP/2.0 Via: SIP/2.0/UDP 10.16.10.99;branch=z9hG4bK4cc7.faa8dc87000000000000000000000000.0 To: sip:117093@10.16.10.99;tag=2453899634-24035392-1301468026894 From: sip:117090@10.16.10.99;tag=a23c71953194c2c72e41c4d20e4f7127-86e1 CSeq: 2 NOTIFY Call-ID: 2442490492-24035392-1301468026894(a)10.16.10.93 Content-Length: 592 User-Agent: kamailio (3.1.2 (i386/linux)) Max-Forwards: 70 Event: dialog Contact: <sip:10.16.10.99:5060> Subscription-State: active;expires=3570 Content-Type: application/dialog-info+xml <?xml version="1.0"?> <dialog-info xmlns="urn:ietf:params:xml:ns:dialog-info" version="1" ll" entity="sip:117090@10.16.10.99"> <dialog id="2769397361-26329880-1301468223108(a)10.16.10.90" call-id="2769397361-26329880-1301468223108(a)10.16.10.90" direction="initiator"> <state>confirmed</state> <remote> <identity><sip:116001@10.16.10.99></identity> <target uri="<sip:116001@10.16.10.99>"/> </remote> <local> <identity>sip:117090@10.16.10.99</identity> <target uri="sip:117090@10.16.10.99"/> </local> </dialog> </dialog-info> Debug information of Kamailio and information in the source code show that the version number "00000000000" is a placeholder only, which should be replaced with a valid version number. However, it seems that there is a problem in handling these strings. The version number is replaced, but in case that the version id is only one character long, ten space characters are inserted- overwriting other information...... Can anybody comment this problem? Is this a bug of the presence_dialoginfo- or another module? Thanks in advance! Regards, Klaus P.S. additional information from source code an debug output of kamailio: notify_body.c: [...] /* The version must be increased for each new document and is a 32bit int. As the version is different for each watcher, we can not set here the correct value. Thus, we just put here a placeholder which will be replaced by the correct value in the aux_body_processing callback. Thus we have CPU intensive XML aggregation only once and can use quick search&replace in the per-watcher aux_body_processing callback. We use 11 chracters as an signed int (although RFC says unsigned int we use signed int as presence module stores "version" in DB as signed int) has max. 10 characters + 1 character for the sign */ [...] Debug information from Kamailio: Ad 4) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:67]: [pres_user]=117093 [pres_domain]= 10.16.10.99, [n]=1 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:107]: [pres_user]=117093 [pres_domain]= 10.16.10.99, [n]=1 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:199]: node type: Element, name: dialog SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:73]: [n_body]=0x835fe54 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:76]: [*n_body]=<?xml version="1.0"?>#012<dialog-info xmlns="urn:ietf:params:xml:ns:dialog-info" version="00000000000" state="full" entity="117093(a)10.16.10.99">#012 <dialog id="6b1de4df-6c9ce978(a)10.16.10.203" call-id="6b1de4df-6c9ce978(a)10.16.10.203" direction="recipient">#012 <state>confirmed</state>#012 <remote>#012 <identity>sip:116001@10.16.10.99</identity>#012 <target uri="sip:116001@10.16.10.99"/>#012 </remote>#012 <local>#012 <identity>sip:117093@10.16.10.99</identity>#012 <target uri="sip:117093@10.16.10.99"/>#012 </local>#012 </dialog>#012</dialog-info>#012 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:328]: replace version with "1" SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:1461]: dialog info: SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:122]: #012#011[pres_uri]= sip:117093@10.16.10.99#012#011[to_user]117093#011[to_domain]= 10.16.10.99#012#011[w_user]= 117090#011[w_domain]10.16.10.99#012#011[event]= dialog#012#011[status]= active#012#011[expires]3519#012#011[callid]3119346140-8635704-1301477522967(a)10.16.10.90#011[local_cseq]=1#012#011[to_tag ]= a23c71953194c2c72e41c4d20e4f7127-7529#011[from_tag]2282475328-8635704-1301477522967#012#011[contact]sip:117090@10.16.10.90:5060#011[record_route]SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:234]: expires 3519 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:1555]: headers:#012Max-Forwards: 70#015#012Event: dialog#015#012Contact: <sip:10.16.10.99:5060>#015#012Subscription-State: active;expires=3570#015#012Content-Type: application/dialog-info+xml#015#012 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:940]: CONTACT sip:117090@10.16.10.90:5060 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [socket_info.c:501]: grep_sock_info - checking if host==us: 11==11 && [10.16.10.99] =[10.16.10.99] SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [socket_info.c:504]: grep_sock_info - checking if port 5060 matches port 5060 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:1729]: ==22/6/37 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: tm [uac.c:240]: DEBUG:tm:t_uac: next_hop=<sip:117090@10.16.10.90:5060> SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: tm [uac.c:181]: DEBUG: dlg2hash: 27355 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: INFO: presence [notify.c:1586]: NOTIFY sip:117090@10.16.10.99 via sip:117090@10.16.10.90:5060 on behalf of sip:117093@10.16.10.99 for event dialog Ad 6) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:67]: [pres_user]=117093 [pres_domain]= 10.16.10.99, [n]=1 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:107]: [pres_user]=117093 [pres_domain]= 10.16.10.99, [n]=1 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:199]: node type: Element, name: dialog SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:73]: [n_body]=0x835fcb0 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:76]: [*n_body]=<?xml version="1.0"?>#012<dialog-info xmlns="urn:ietf:params:xml:ns:dialog-info" version="00000000000" state="full" entity="117093(a)10.16.10.99">#012 <dialog id="6b1de4df-6c9ce978(a)10.16.10.203" call-id="6b1de4df-6c9ce978(a)10.16.10.203" direction="recipient">#012 <state>terminated</state>#012 <remote>#012 <identity>sip:116001@10.16.10.99</identity>#012 <target uri="sip:116001@10.16.10.99"/>#012 </remote>#012 <local>#012 <identity>sip:117093@10.16.10.99</identity>#012 <target uri="sip:117093@10.16.10.99"/>#012 </local>#012 </dialog>#012</dialog-info>#012 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence_dialoginfo [notify_body.c:328]: replace version with "2" SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:1461]: dialog info: SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:122]: #012#011[pres_uri]= sip:117093@10.16.10.99#012#011[to_user]117093#011[to_domain]= 10.16.10.99#012#011[w_user]= 117090#011[w_domain]10.16.10.99#012#011[event]= dialog#012#011[status]= active#012#011[expires]3242#012#011[callid]3119346140-8635704-1301477522967(a)10.16.10.90#011[local_cseq]=2#012#011[to_tag ]= a23c71953194c2c72e41c4d20e4f7127-7529#011[from_tag]2282475328-8635704-1301477522967#012#011[contact]sip:117090@10.16.10.90:5060#011[record_route]= SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:234]: expires 3242 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:1555]: headers:#012Max-Forwards: 70#015#012Event: dialog#015#012Contact: <sip:10.16.10.99:5060>#015#012Subscription-State: active;expires=3270#015#012Content-Type: application/dialog-info+xml#015#012 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:940]: CONTACT sip:117090@10.16.10.90:5060 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [socket_info.c:501]: grep_sock_info - checking if host==us: 11==11 && [10.16.10.99] =[10.16.10.99] SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [socket_info.c:504]: grep_sock_info - checking if port 5060 matches port 5060 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: presence [notify.c:1729]: ==22/6/37 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: tm [uac.c:240]: DEBUG:tm:t_uac: next_hop=<sip:117090@10.16.10.90:5060> SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: tm [uac.c:181]: DEBUG: dlg2hash: 27356 SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: DEBUG: <core> [usr_avp.c:646]: DEBUG:destroy_avp_list: destroying list (nil) SipSrv1 /usr/sbin/kamailio[26764]: INFO: presence [notify.c:1586]: NOTIFY sip:117090@10.16.10.99 via sip:117090@10.16.10.90:5060 on behalf of sip:117093@10.16.10.99 for event dialog

13 years

Suggestion dialog module / $dlg_ctx() problem.

by Alexandre Abreu

Hello. Using K 3.1.2. Before the setflag() that creates the dialog, I tried to use: $dlg_ctx(flags) = 1; Mar 30 12:29:03 devel kamailio: ERROR: dialog [dlg_var.c:165]: unknown PV name flags Mar 30 12:29:03 devel kamailio: ERROR: <core> [pvapi.c:565]: pvar "dlg_ctx" has an invalid name param [flags] Mar 30 12:29:03 devel kamailio: ERROR: <core> [pvapi.c:720]: wrong char [)/41] in [$dlg_ctx(flags)] at [14 (5)] Mar 30 12:29:03 devel kamailio: : <core> [cfg.y:3409]: parse error in config file /usr/local/etc/kamailio/kamailio.cfg, line 308, column 9-23: unknown script pseudo variable $dlg_ctx(flags) Right now, my goal is to add the user-agent content header ($ua) from caller/callee and list them through 'dlg_list_ctx'. I would suggest something like that: Request route: $dlg_ctx(set->ua_src) = $ua; On reply route: $dlg_ctx(set->ua_dst) = $ua; dlg_list_ctx: . ua_src:: X-Lite 3.0 build 666 ua_dst:: Linksys PAP2 . Does this suggestion make sense? Using another approach is it possible to execute this today? Thanks, Alexandre

13 years

preparing kamailio v3.1.3

by Daniel-Constantin Mierla

Hello, it is almost 2 months since we packaged 3.1.2, there are commits accumulated in branch 3.1, therefore I plan to package 3.1.3 Monday or Tuesday next week. If anyone has something to add in this regards, please reply. Cheers, Daniel -- Daniel-Constantin Mierla http://www.asipto.com

13 years

library dir for x86_64 - lib or lib64

by Daniel-Constantin Mierla

Hello, iirc this was at some point discussed, however, I want to go through it again. Many x86_64 distros expect libraries to be placed under a lib64 directory. For example the RPM spec file language returns /usr/lib64 for %{_libdir} variable. In the master branch I committed a patch that does this detection. As I saw some people saying that 'lib' should be the default also for x86_64, my question is then what do you think we should use? Using 'lib' will definitely make building rpms fail unless we do a patch specific for these distros. Cheers, Daniel -- Daniel-Constantin Mierla http://www.asipto.com

13 years

meeting in thailand bangkoke

by Meftah Tayeb

hi guys i'm in thailand right now this week i'm staying in bangkoke anyone want to meet please drop me an email thank you -- Meftah Tayeb inum: +883510001288000 phone: +13477595883

13 years, 1 month

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

2005

2004

2003

2002

sr-users April 2011