sr-dev April 2016

sr-dev@lists.kamailio.org

23 participants
430 discussions

[kamailio] kamailio crash when use http_query (#468)
by situnan 18 May '16

18 May '16

1file:modules/utils/functionsc 2Problem Description：Array Overflow and View Code Label：wsong@grandstreamcn size_t write_function( void *ptr, size_t size, size_t nmemb, void *stream_ptr) { http_res_stream_t *stream = (http_res_stream_t *) stream_ptr; stream->buf = (char *) pkg_realloc(stream->buf, stream->curr_size + (size * nmemb) + 1); if (stream->buf == NULL) { LM_ERR("cannot allocate memory for stream\n"); return CURLE_WRITE_ERROR; } memcpy(&stream->buf[stream->pos], (char *) ptr, (size * nmemb)); stream->curr_size += ((size * nmemb) + 1); stream->pos += (size * nmemb); //begin modify wsong@grandstreamcn // reason:stream->buf size begin with 0 // stream->buf[stream->pos + 1] = '\0'; stream->buf[stream->pos ] = '\0'; //end modify wsong@grandstreamcn return size * nmemb; } --- Reply to this email directly or view it on GitHub: https://github.com/kamailio/kamailio/issues/468

4 3

[kamailio/kamailio] sipcapture: table name corrupted (#566)
by Seudin Kasumovic 09 May '16

09 May '16

In commit c1863d7dc5d7504a8096e9a31dfc200f5e14dd03 added homer5 functionality and table name is built based on timestamp, but corrupted. The added functionality isn't documented too. Q: why it is mandatory to build table name based on time stamp? Kind regards, Seudin --- 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/issues/566

3 14

[kamailio] kazoo: missing documentation (#530)
by Niklas Larsson 06 May '16

06 May '16

modparam("kazoo", "pua_mode", 0) - missing in docs how to use an vhost in the connection url is missing: amqp://kamailio_ngpbx:password@rabbit01.example.com:5672/virthost01 --- Reply to this email directly or view it on GitHub: https://github.com/kamailio/kamailio/issues/530

2 4

library for copying sip_msg from shm to pvt memory?
by Jason Penton 05 May '16

05 May '16

Does anybody know if there is an existing library function/s to copy a sip_msg (typically request) from shm to pkg? I know there is already this functionality in the tmx module but I think it would be useful to move this into a library so it can be used by other modules? I am just wanting to make sure before I replicate code... *Reason for such functionality:* The main reason is where modules need to access specific headers from a sip request which they get from t->uas.request (generally in instances where only the rpl message is accessible). We all know that t->uas.request sits in SHM, so if any additional parsing is done on this message it's pointers will be polluted with pvt memory addresses of the processing parsing the request. This could ultimately lead to memory corruption and segfaults. I would therefore propose moving the pv_t_copy_msg and associated functions from tmx modules into the core library... any objections? Cheers Jason

2 1

[kamailio/kamailio] Kamailio system files for Oracle Enterprise Linux 6/7 (#591)
by Konstantin S. Vishnivetsky 02 May '16

02 May '16

Added Kamailio system files for Oracle Enterprise Linux 6/7 Created a directory structure under <SRCROOT>/pkg/kamailio directory for Oracle Enterprise Linux. File oracle/kamailio.spec moved to oracle/el6/kamailio.spec Added init scripts and defaults for kamailio under oracle/el6 directory. Added systemd service and sysconfig script for kamailio under oracle/el7 directory. You can view, comment on, or merge this pull request online at: https://github.com/kamailio/kamailio/pull/591 -- Commit Summary -- * Added Oracle Enterpise Linux 6 SPEC, init script and defaults script. * Added Oracle Enterpise Linux 7 SPEC, init script and defaults script. * Added logrotate and rsyslog samples for kamailio * FIX: do not enable kamailio service after installation, only reload systmd daemon -- File Changes -- A pkg/kamailio/oracle/el6/kamailio.default (30) A pkg/kamailio/oracle/el6/kamailio.init (128) R pkg/kamailio/oracle/el6/kamailio.spec (4) A pkg/kamailio/oracle/el7/kamailio.service (17) A pkg/kamailio/oracle/el7/kamailio.spec (854) A pkg/kamailio/oracle/el7/kamailio.sysconfig (36) A pkg/kamailio/oracle/kamailio.logrotate (7) A pkg/kamailio/oracle/kamailio.rsyslog (2) -- Patch Links -- https://github.com/kamailio/kamailio/pull/591.patch https://github.com/kamailio/kamailio/pull/591.diff --- 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/pull/591

2 2

git:master:ceccf4b9: msilo Minor edits to the README
by Olle E. Johansson 29 Apr '16

29 Apr '16

Module: kamailio Branch: master Commit: ceccf4b9d178e895ae5972f2cddf28e3ef108910 URL: https://github.com/kamailio/kamailio/commit/ceccf4b9d178e895ae5972f2cddf28e… Author: Olle E. Johansson <oej(a)edvina.net> Committer: Olle E. Johansson <oej(a)edvina.net> Date: 2016-04-29T13:55:47+02:00 msilo Minor edits to the README - Move the database field definitions close to the table definition - Fix typos, rewrite some parts --- Modified: modules/msilo/README Modified: modules/msilo/doc/msilo.cfg Modified: modules/msilo/doc/msilo_admin.xml --- Diff: https://github.com/kamailio/kamailio/commit/ceccf4b9d178e895ae5972f2cddf28e… Patch: https://github.com/kamailio/kamailio/commit/ceccf4b9d178e895ae5972f2cddf28e…

1 0

git:master:0031cefb: htable: exported htable slot locking functions to kemi
by Elena-Ramona Modroiu 29 Apr '16

29 Apr '16

Module: kamailio Branch: master Commit: 0031cefb1459ac7e621b9dd3a2b3056814324c49 URL: https://github.com/kamailio/kamailio/commit/0031cefb1459ac7e621b9dd3a2b3056… Author: Elena-Ramona Modroiu <ramona(a)asipto.com> Committer: Elena-Ramona Modroiu <ramona(a)asipto.com> Date: 2016-04-29T12:26:16+02:00 htable: exported htable slot locking functions to kemi - htable.sht_lock("hname", "key") - htable.sht_unlock("hname", "key") --- Modified: modules/htable/htable.c --- Diff: https://github.com/kamailio/kamailio/commit/0031cefb1459ac7e621b9dd3a2b3056… Patch: https://github.com/kamailio/kamailio/commit/0031cefb1459ac7e621b9dd3a2b3056… --- diff --git a/modules/htable/htable.c b/modules/htable/htable.c index 7ee4921..dd29cb7 100644 --- a/modules/htable/htable.c +++ b/modules/htable/htable.c @@ -1,5 +1,5 @@ /** - * Copyright (C) 2008-2014 Elena-Ramona Modroiu (asipto.com) + * Copyright (C) 2008-2016 Elena-Ramona Modroiu (asipto.com) * * This file is part of Kamailio, a free SIP server. * @@ -36,6 +36,7 @@ #include "../../ut.h" #include "../../rpc.h" #include "../../rpc_lookup.h" +#include "../../kemi.h" #include "../../lib/kmi/mi.h" #include "../../lib/kcore/faked_msg.h" @@ -464,6 +465,47 @@ static int w_ht_iterator_end(struct sip_msg* msg, char* iname, char* foo) return 1; } +static int ki_ht_slot_xlock(sip_msg_t *msg, str *htname, str *skey, int lmode) +{ + ht_t *ht; + unsigned int hid; + unsigned int idx; + + ht = ht_get_table(htname); + if(ht==NULL) { + LM_ERR("cannot get hash table by name [%.*s] (%d)\n", + htname->len, htname->s, lmode); + return -1; + } + + hid = ht_compute_hash(skey); + + idx = ht_get_entry(hid, ht->htsize); + + if(lmode==0) { + LM_DBG("locking slot %.*s[%u] for key %.*s\n", + htname->len, htname->s, + idx, skey->len, skey->s); + ht_slot_lock(ht, idx); + } else { + LM_DBG("unlocking slot %.*s[%u] for key %.*s\n", + htname->len, htname->s, + idx, skey->len, skey->s); + ht_slot_unlock(ht, idx); + } + return 1; +} + +static int ki_ht_slot_lock(sip_msg_t *msg, str *htname, str *skey) +{ + return ki_ht_slot_xlock(msg, htname, skey, 0); +} + +static int ki_ht_slot_unlock(sip_msg_t *msg, str *htname, str *skey) +{ + return ki_ht_slot_xlock(msg, htname, skey, 1); +} + /** * lock the slot for a given key in a hash table */ @@ -497,7 +539,7 @@ static int w_ht_slot_lock(struct sip_msg* msg, char* key, char* foo) idx = ht_get_entry(hid, hpv->ht->htsize); - LM_DBG("unlocking slot %.*s[%u] for key %.*s\n", + LM_DBG("locking slot %.*s[%u] for key %.*s\n", hpv->htname.len, hpv->htname.s, idx, skey.len, skey.s); @@ -1256,3 +1298,30 @@ static int htable_init_rpc(void) } return 0; } + +/** + * + */ +static sr_kemi_t sr_kemi_htable_exports[] = { + { str_init("htable"), str_init("sht_lock"), + SR_KEMIP_INT, ki_ht_slot_lock, + { SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("htable"), str_init("sht_unlock"), + SR_KEMIP_INT, ki_ht_slot_unlock, + { SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + + { {0, 0}, {0, 0}, 0, NULL, { 0, 0, 0, 0, 0, 0 } } +}; + +/** + * + */ +int mod_register(char *path, int *dlflags, void *p1, void *p2) +{ + sr_kemi_modules_add(sr_kemi_htable_exports); + return 0; +}

1 0

git:master:d0261b61: xlog: exported xlogging functions to kemi
by Elena-Ramona Modroiu 29 Apr '16

29 Apr '16

Module: kamailio Branch: master Commit: d0261b61d7cb23f437e69891e42a9c9fd3fa622b URL: https://github.com/kamailio/kamailio/commit/d0261b61d7cb23f437e69891e42a9c9… Author: Elena-Ramona Modroiu <ramona(a)asipto.com> Committer: Elena-Ramona Modroiu <ramona(a)asipto.com> Date: 2016-04-29T12:04:10+02:00 xlog: exported xlogging functions to kemi - xdbg(txt), xinfo(txt), xnotice(txt), xwarn(txt), xerr(txt), xalert(txt), xcrit(txt), xlog(lev, txt) - the txt can include kamailio variables even in the embedded lanaguage script, e.g.,: KSR.xlog.xinfo("received $rm from $si\n"); - if no kamailio variables are in the text, it is recommended to use the KSR core functions, e.g.,: KSR.info("received INVITE from 127.0.0.1\n"); - all the parameters are parsed and evaluated for each execution of the function, there is no fixup at startup that can be triggered by the non-native embedded interpreters --- Modified: modules/xlog/xlog.c --- Diff: https://github.com/kamailio/kamailio/commit/d0261b61d7cb23f437e69891e42a9c9… Patch: https://github.com/kamailio/kamailio/commit/d0261b61d7cb23f437e69891e42a9c9…

1 0

[kamailio/kamailio] v4.4.0 tcp disabled? (#585)
by lqxandxl 29 Apr '16

29 Apr '16

i used kamailio v4.1 part of kamailio.cfg for examples: disable_tcp=no auto_aliases=no port=5085 enable_tls=yes listen=udp:10.2.45.111:5085 listen=tcp:10.2.45.111:5085 listen=tls:10.2.45.111:5086 listen=tcp:10.2.45.111:5087 listen=tls:10.2.45.111:5088 and i excute /etc/init.d/kamailio start it can run but when on ka v4.4.0 the same contents in kamailio.cfg but can`t run both 4.1.x and 4.4.x when i change disable_tcp=yes it can run but only listen on udp 5085 v4.1 i change disable_tcp=no it can listen tls,tcp.udp i use modules： dispatcher v4.4 i setup a new modules : evapi why tcp can`t run properly? `#!KAMAILIO ####### Global Parameters ######### debug=0 log_stderror=no memdbg=5 memlog=5 log_facility=LOG_LOCAL1 fork=yes children=5 tcp_children=4 #disable_tcp=no auto_aliases=no port=5085 #4.1 enable_tls=yes listen=udp:10.2.45.111:5085 listen=tcp:10.2.45.111:5085 listen=tls:10.2.45.111:5086 listen=tcp:10.2.45.111:5087 listen=tls:10.2.45.111:5088 sip_warning=no #4.1 tcp_accept_no_cl=yes tcp_connection_lifetime=3604 tcp_rd_buf_size=16384 exit_timeout = 300 #4.1 mpath="/home/administrator/kamailio/modules_k/:/home/administrator/kamailio_proxy/lib64/kamailio/modules/" loadmodule "db_mysql.so" loadmodule "mi_fifo.so" loadmodule "kex.so" loadmodule "tm.so" loadmodule "tmx.so" loadmodule "sl.so" loadmodule "rr.so" loadmodule "pv.so" loadmodule "maxfwd.so" loadmodule "textops.so" loadmodule "siputils.so" loadmodule "xlog.so" loadmodule "sanity.so" loadmodule "ctl.so" loadmodule "mi_rpc.so" loadmodule "acc.so" loadmodule "dispatcher.so" #4.1 loadmodule "tls.so" loadmodule "auth.so" loadmodule "auth_db.so" loadmodule "xhttp.so" loadmodule "websocket.so" loadmodule "usrloc.so" loadmodule "nathelper.so" loadmodule "registrar.so" #4.1 #added by liqixin #loadmodule "evapi.so" #added by liqixin # ----------------- setting module-specific parameters --------------- # ----- mi_fifo params ----- modparam("mi_fifo", "fifo_name", "/tmp/kamailio_fifo") # ----- rr params ----- # add value to ;lr param to cope with most of the UAs modparam("rr", "enable_full_lr", 1) # do not append from tag to the RR (no need for this script) modparam("rr", "append_fromtag", 0) # ----- acc params ----- modparam("acc", "log_flag", 1) modparam("acc", "failed_transaction_flag", 3) modparam("acc", "log_extra", "src_user=$fU;src_domain=$fd;dst_ouser=$tU;dst_user=$rU;dst_domain=$rd;src_ip=$si") # ----- tm params ----- modparam("tm", "fr_timer", 2000) modparam("tm", "fr_inv_timer", 40000) # ----- dispatcher params ----- modparam("dispatcher", "db_url", "mysql://kamailio:kamailiorw@localhost/kamailio") modparam("dispatcher", "table_name", "dispatcher") modparam("dispatcher", "flags", 2) modparam("dispatcher", "dst_avp", "$avp(AVP_DST)") modparam("dispatcher", "grp_avp", "$avp(AVP_GRP)") modparam("dispatcher", "cnt_avp", "$avp(AVP_CNT)") #4.4 modparam("dispatcher", "sock_avp", "$avp(AVP_SOCK)") #4.4 #4.1 modparam("dispatcher", "ds_ping_method", "OPTIONS") modparam("dispatcher", "ds_ping_from", "sip:kamailio@10.2.45.111") modparam("dispatcher", "ds_ping_interval", 10) modparam("dispatcher", "ds_probing_threshold", 3) modparam("dispatcher", "ds_ping_reply_codes", "class=2;code=400;class=3") modparam("dispatcher", "ds_probing_mode", 1) #4.1 #4.1 # ----- usrloc params ----- /* enable DB persistency for location entries */ modparam("usrloc", "db_url", "mysql://kamailio:kamailiorw@localhost/kamailio") modparam("usrloc", "db_mode", 0) modparam("registrar", "method_filtering", 1) modparam("registrar", "max_expires", 3600) modparam("registrar", "gruu_enabled", 0) modparam("registrar", "use_path", 1) modparam("registrar", "path_mode", 1) modparam("registrar", "path_use_received", 0) modparam("nathelper|registrar", "received_avp", "$avp(RECEIVED)") modparam("usrloc", "nat_bflag", 6) #4.1 #4.1 # ----- tls params ----- #modparam("websocket", "cors_mode", 0); modparam("websocket", "keepalive_mechanism", 0); # ----- tls params ----- modparam("tls", "config", "/home/administrator/kamailio_proxy/etc/kamailio/tls.cfg") #4.1 #-------evapi---------- #modparam("evapi", "workers", 2) #modparam("evapi", "bind_addr", "10.2.45.111:5085") ####### Routing Logic ######## # main request routing logic route { route(REQINIT); #4.1 if (nat_uac_test(64)) { # Do NAT traversal stuff for requests from a WebSocket # connection - even if it is not behind a NAT! # This won't be needed in the future if Kamailio and the # WebSocket client support Outbound and Path. force_rport(); fix_nated_register(); add_contact_alias(); } if (is_method("CANCEL")) { if (t_check_trans()) t_relay(); exit; } #4.1 route(WITHINDLG); #4.4 # if (is_method("CANCEL")) # { # if (t_check_trans()) # t_relay(); # exit; # } #4.4 t_check_trans(); #4.4 # remove_hf("Route"); # if (is_method("INVITE|SUBSCRIBE")) # record_route(); # if (is_method("INVITE")) # { # setflag(1); # do accounting # } # route(PRESENCE); # route(REGISTRAR); # if ($rU==$null) # { # request with no Username in RURI # sl_send_reply("484","Address Incomplete"); # exit; # } #4.4 route(DISPATCH); #4.1 route(RELAY); #4.1 } #4.1 xlog route[RELAY] { if (!t_relay()) { sl_reply_error(); } exit; } #---4.1--- # Per SIP request initial checks route[REQINIT] { #4.4 if (!mf_process_maxfwd_header("10")) { sl_send_reply("483","Too Many Hops"); exit; } #4.4 if(!sanity_check("1511", "7")) { xlog("Malformed SIP message from $si:$sp\n"); exit; } } # Handle requests within SIP dialogs route[WITHINDLG] { if (has_totag()) { if (loose_route()) { if (is_method("BYE")) { setflag(1); # do accounting ... setflag(3); # ... even if the transaction fails } #4.1 # if ($du == "") { # handle_ruri_alias(); # } #4.1 route(RELAY); } else { #4.4 if (is_method("SUBSCRIBE") && uri == myself) { # in-dialog subscribe requests route(PRESENCE); exit; } #4.4 if ( is_method("ACK") ) { if ( t_check_trans() ) { t_relay(); exit; } else { exit; } } sl_send_reply("404","Not here"); #4.1 if ( is_method("ACK") ) { # if ( t_check_trans() ) { # t_relay(); # exit; # } else { # exit; # } # } # sl_send_reply("404","Not here"); } #4.1 route(RELAY); exit; } } # Handle SIP registrations 4.4 route[REGISTRAR] { if(!is_method("REGISTER")) return; sl_send_reply("404", "No registrar"); exit; } # Presence server route 4.4 route[PRESENCE] { if(!is_method("PUBLISH|SUBSCRIBE")) return; sl_send_reply("404", "Not here"); exit; } # Dispatch requests-------4.4 # route[DISPATCH] { # round robin dispatching on gateways group '1' # if(!ds_select_dst("1", "4")) # { # send_reply("404", "No destination"); # exit; # } # xlog("L_DBG", "--- SCRIPT: going to <$ru> via <$du>\n"); # t_on_failure("RTF_DISPATCH"); # route(RELAY); # exit; # } # Dispatch requests-------4.4 #4.1----------------dispatch # Dispatch requests route[DISPATCH] { # round robin dispatching on gateways group '1' if(is_method("REGISTER")){ if(ds_select_dst("1", "0")) { loose_route(); # route(RELAY); } else { send_reply("404", "No destination"); exit; } } else if (is_method("INVITE")) { if ($du == "") { if (!handle_ruri_alias()) { xlog("L_ERR", "Bad alias <$ru>\n"); sl_send_reply("400", "Bad Request"); exit; } } $avp(route)=$(hdr(Route)[0]); $avp(LastRouteParam)=$(avp(route){param.count})-1; if($(avp(route){param.name,$avp(LastRouteParam)})=="fccs>"){ #xlog("the method invite from sipserver \n"); loose_route(); if( $(ru{param.value,transport}) == "TCP"||$(ru{param.value,transport}) == "tcp" ){ record_route_preset("10.2.45.111:5085;transport=tcp","10.2.45.111:5085"); } else if( $(ru{param.value,transport}) == "TLS"||$(ru{param.value,transport}) == "tls" ){ record_route_preset("10.2.45.111:5086;transport=tls","10.2.45.111:5085"); } else if( $(ru{param.value,transport}) == "WS"||$(ru{param.value,transport}) == "ws" ){ record_route_preset("10.2.45.111:5087;transport=ws","10.2.45.111:5085"); } else if( $(ru{param.value,transport}) == "WSS"||$(ru{param.value,transport}) == "ws" ){ record_route_preset("10.2.45.111:5088;transport=wss","10.2.45.111:5085"); } else{ record_route_preset("10.2.45.111:5085","10.2.45.111:5085"); } route(RELAY); } else{ if (ds_select_dst("1", "6")) { #xlog("the first invite load balance \n"); if(proto==TCP){ record_route_preset("10.2.45.111:5085","10.2.45.111:5085;transport=tcp"); } else if(proto==TLS){ record_route_preset("10.2.45.111:5085","10.2.45.111:5086;transport=tls"); } else if(proto==WS){ record_route_preset("10.2.45.111:5085","10.2.45.111:5087;transport=ws"); } else if(proto==WSS){ record_route_preset("10.2.45.111:5085","10.2.45.111:5088;transport=wss"); } else{ record_route_preset("10.2.45.111:5085","10.2.45.111:5085"); } loose_route(); route(RELAY); } else{ send_reply("503","Invite Load_balance Service Unavailable"); exit; } } } else if(is_method("MESSAGE")||is_method("REFER")||is_method("PUBLISH")||is_method("SUBSCRIBE")||is_method("NOTIFY")){ $avp(route2)=$(hdr(Route)[0]); $avp(LastRouteParam2)=$(avp(route){param.count})-1; if($(avp(route2){param.name,$avp(LastRouteParam2)})=="fccs>"){ loose_route(); route(RELAY); } else{ if(ds_select_dst("1", "0")) { loose_route(); # route(RELAY); } else { send_reply("404", "No destination"); exit; } } } else{ send_reply("400","method not defined \n"); } xlog("L_DBG", "--- SCRIPT: going to <$ru> via <$du>\n"); t_on_failure("RTF_DISPATCH"); return; } #----------------4.1 dispatch # Sample failure route ----4.4 #failure_route[RTF_DISPATCH] { # if (t_is_canceled()) { # exit; # } # next DST - only for 500 or local timeout # if (t_check_status("500") # or (t_branch_timeout() and !t_branch_replied())) # { # if(ds_next_dst()) # { # t_on_failure("RTF_DISPATCH"); # route(RELAY); # exit; # } # } # } # Sample failure route ----4.4 # Sample failure route failure_route[RTF_DISPATCH] { if (t_is_canceled()) { exit; } # next DST - only for 500 or local timeout if (t_check_status("500") or (t_branch_timeout() and !t_branch_replied())) { if(ds_next_dst()) { t_on_failure("RTF_DISPATCH"); route(RELAY); exit; } #4.1 ds_mark_dst("ip"); # set to inactive and probing #4.1 } } #4.1 onreply_route { if (nat_uac_test(64)) { # Do NAT traversal stuff for replies to a WebSocket connection # - even if it is not behind a NAT! # This won't be needed in the future if Kamailio and the # WebSocket client support Outbound and Path. add_contact_alias(); } } #4.1 event_route[xhttp:request] { set_reply_close(); set_reply_no_connect(); #set_forward_close(); #set_forward_no_connect(); #t_relay(); if ($Rp != 5087 && $Rp != 5088) { xlog("L_WARN", "HTTP request received on $Rp\n"); xhttp_reply("403", "Forbidden", "", ""); exit; } xlog("L_DBG", "HTTP Request Received\n"); if ($hdr(Upgrade)=~"websocket" && $hdr(Connection)=~"Upgrade" && $rm=~"GET") { #xlog("websocket upgrade ok\n"); # Validate Host - make sure the client is using the correct # alias for WebSockets if ($hdr(Host) == $null || !is_myself("sip:" + $hdr(Host))) { xlog("L_WARN", "Bad host $hdr(Host)\n"); xhttp_reply("403", "Forbidden", "", ""); exit; } # Optional... validate Origin - make sure the client is from an # authorised website. For example, # # if ($hdr(Origin) != "http://communicator.MY_DOMAIN" # && $hdr(Origin) != "https://communicator.MY_DOMAIN") { # xlog("L_WARN", "Unauthorised client $hdr(Origin)\n"); # xhttp_reply("403", "Forbidden", "", ""); # exit; # } # Optional... perform HTTP authentication # ws_handle_handshake() exits (no further configuration file # processing of the request) when complete. if (ws_handle_handshake()) { # Optional... cache some information about the # successful connection exit; } } #route(RELAY); xhttp_reply("404", "Http Not Found", "", ""); } event_route[websocket:closed] { xlog("L_INFO", "WebSocket connection from $si:$sp has closed\n"); } #added by liqixin #event_route[evapi:connection-new] { # xlog("new connection from $evapi(srcaddr):$evapi(srcport)\n"); #} #event_route[evapi:connection-closed] { # xlog("connection closed by $evapi(srcaddr):$evapi(srcport)\n"); #} #added by liqixin` --- 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/issues/585

2 7

git:master:5e29aecb: examples/kemi: notes about use of os.exit() in python script
by Daniel-Constantin Mierla 29 Apr '16

29 Apr '16

Module: kamailio Branch: master Commit: 5e29aecbdc77498f95ce6d6fc764f402893eb65b URL: https://github.com/kamailio/kamailio/commit/5e29aecbdc77498f95ce6d6fc764f40… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2016-04-29T11:14:39+02:00 examples/kemi: notes about use of os.exit() in python script --- Modified: examples/kemi/kamailio-basic-kemi-python.py --- Diff: https://github.com/kamailio/kamailio/commit/5e29aecbdc77498f95ce6d6fc764f40… Patch: https://github.com/kamailio/kamailio/commit/5e29aecbdc77498f95ce6d6fc764f40… --- diff --git a/examples/kemi/kamailio-basic-kemi-python.py b/examples/kemi/kamailio-basic-kemi-python.py index ecd72eb..8d23a6b 100644 --- a/examples/kemi/kamailio-basic-kemi-python.py +++ b/examples/kemi/kamailio-basic-kemi-python.py @@ -4,6 +4,13 @@ ## Router - the old object exporting Kamailio functions ## +## Relevant remarks: +## * return code -255 is used to propagate the 'exit' behaviour to the +## parent route block function. The alternative is to use the native +## Python function os.exit() (or exit()) -- it throws an exception that +## is caught by Kamailio and previents the stop of the interpreter. + + import sys import Router.Logger as Logger import KSR as KSR

1 0

← Newer
1
2
3
4
5
6
7
8
...
43
Older →

Jump to page:

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev April 2016