kenmirrors
/
freeswitch
mirror of https://github.com/signalwire/freeswitch.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

update 

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@1456 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
Anthony Minessale 2006-05-13 01:32:50 +00:00
parent 2a07e46e34
commit 43b6962933
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/mod/endpoints/mod_exosip/mod_exosip.c
View File

@ -41,7 +41,7 @@
#include <osip2/osip_mt.h> #include <osip2/osip_mt.h>
#include <osip_rfc3264.h> #include <osip_rfc3264.h>
#include <osipparser2/osip_port.h> #include <osipparser2/osip_port.h>
#define DBFILE "exosip.db" #define DBFILE "exosip"
static const char modname[] = "mod_exosip"; static const char modname[] = "mod_exosip";
#define STRLEN 15 #define STRLEN 15
@ -142,6 +142,7 @@ struct private_object {
static char create_interfaces_sql[] = static char create_interfaces_sql[] =
"CREATE TABLE sip_registrations (\n" "CREATE TABLE sip_registrations (\n"
" key VARCHAR(255),\n" " key VARCHAR(255),\n"
" host VARCHAR(255),\n"
" url VARCHAR(255),\n" " url VARCHAR(255),\n"
" expires INTEGER(8)" " expires INTEGER(8)"
");\n"; ");\n";
@ -941,6 +942,8 @@ static char *find_reg_url(switch_core_db_t *db, char *key, char *val, switch_siz
char *errmsg; char *errmsg;
switch_core_db_t *udb = NULL; switch_core_db_t *udb = NULL;
struct callback_t cbt = {0}; struct callback_t cbt = {0};
char buf[1024];
char *host = NULL;
if (db) { if (db) {
udb = db; udb = db;
@ -948,10 +951,20 @@ static char *find_reg_url(switch_core_db_t *db, char *key, char *val, switch_siz
udb = switch_core_db_open_file(DBFILE); udb = switch_core_db_open_file(DBFILE);
} }
switch_copy_string(buf, key, sizeof(buf));
key = buf;
if ((host = strchr(key, '%'))) {
*host++ = '\0';
}
cbt.val = val; cbt.val = val;
cbt.len = len; cbt.len = len;
switch_mutex_lock(globals.reg_mutex); switch_mutex_lock(globals.reg_mutex);
snprintf(val, len, "select url from sip_registrations where key='%s'", key); if (host) {
snprintf(val, len, "select url from sip_registrations where key='%s' and host='%s'", key, host);
} else {
snprintf(val, len, "select url from sip_registrations where key='%s'", key);
}
switch_core_db_exec(udb, val, find_callback, &cbt, &errmsg); switch_core_db_exec(udb, val, find_callback, &cbt, &errmsg);
if (errmsg) { if (errmsg) {
@ -1517,8 +1530,9 @@ static void handle_message_new(eXosip_event_t *je)
if (!find_reg_url(globals.db, je->request->from->url->username, sql, sizeof(sql))) { if (!find_reg_url(globals.db, je->request->from->url->username, sql, sizeof(sql))) {
snprintf(sql, sizeof(sql), "insert into sip_registrations values ('%s','%s',%ld)", snprintf(sql, sizeof(sql), "insert into sip_registrations values ('%s','%s','%s',%ld)",
je->request->from->url->username, je->request->from->url->username,
je->request->from->url->host,
url, exptime); url, exptime);
} else { } else {
snprintf(sql, sizeof(sql), "update sip_registrations set url='%s', expires=%ld where key = '%s'", snprintf(sql, sizeof(sql), "update sip_registrations set url='%s', expires=%ld where key = '%s'",