sr-dev November 2015

sr-dev@lists.kamailio.org

27 participants
315 discussions

git:master:a37257d4: rtpengine: Add hash_table_size modparam

by Stefan Mititelu

Module: kamailio Branch: master Commit: a37257d48702c494c080f7f7c86a2dc18957b242 URL: https://github.com/kamailio/kamailio/commit/a37257d48702c494c080f7f7c86a2dc… Author: Stefan Mititelu <stefan.mititelu(a)1and1.ro> Committer: Stefan Mititelu <stefan.mititelu(a)1and1.ro> Date: 2015-11-23T12:12:27+02:00 rtpengine: Add hash_table_size modparam Allow configurable table size. Updated doku. --- Modified: modules/rtpengine/doc/rtpengine_admin.xml Modified: modules/rtpengine/rtpengine.c Modified: modules/rtpengine/rtpengine_hash.c Modified: modules/rtpengine/rtpengine_hash.h --- Diff: https://github.com/kamailio/kamailio/commit/a37257d48702c494c080f7f7c86a2dc… Patch: https://github.com/kamailio/kamailio/commit/a37257d48702c494c080f7f7c86a2dc…

8 years, 12 months

git:master:fefe1e63: rtpengine: Update doku for node enable/disable

by Stefan Mititelu

Module: kamailio Branch: master Commit: fefe1e63a175ce475a44ae11bb89929e5c5f67d3 URL: https://github.com/kamailio/kamailio/commit/fefe1e63a175ce475a44ae11bb89929… Author: Stefan Mititelu <stefan.mititelu(a)1and1.ro> Committer: Stefan Mititelu <stefan.mititelu(a)1and1.ro> Date: 2015-11-23T12:12:27+02:00 rtpengine: Update doku for node enable/disable This is my understanding of the current shared memory node list implementation. Correct me if I'm wrong. --- Modified: modules/rtpengine/doc/rtpengine_admin.xml --- Diff: https://github.com/kamailio/kamailio/commit/fefe1e63a175ce475a44ae11bb89929… Patch: https://github.com/kamailio/kamailio/commit/fefe1e63a175ce475a44ae11bb89929… --- diff --git a/modules/rtpengine/doc/rtpengine_admin.xml b/modules/rtpengine/doc/rtpengine_admin.xml index bcb1c03..2454db2 100644 --- a/modules/rtpengine/doc/rtpengine_admin.xml +++ b/modules/rtpengine/doc/rtpengine_admin.xml @@ -73,6 +73,38 @@ If the set was selected using setid_avp, the avp needs to be set only once before rtpengine_offer() or rtpengine_manage() call. </para> + <para> + From the current implementation point of view, the sets of rtpproxy nodes + are shared memory(shm), so all processes can see a common list of nodes. + There is no locking when setting the nodes enabled/disabled (to keep the + memory access as fast as possible). Thus, problems related to node state + might appear for concurent processes that might set the nodes + enabled/disabled(e.g. by fifo command). This robustness problems are overcomed as follows. + </para> + + <para> + If the current process sees the selected node as disabled, the node is + <emphasis>force tested</emphasis> before the current process actually + takes the disabled decision. If the test succeeds, the process will set + the node as enabled (but other concurrent process might still see it as disabled). +. + </para> + + <para> + If the current process sees the selected node as enabled, it does no additional checks + and sends the command which will fail in case the machine is actually broken. + The process will set the node as disabled (but other concurrent process might still see it as enabled). + </para> + + <para> + The 'kamctl fifo' commands (including rtpengin ones) are executed by an exclusive + process which operate on the same shared memory node list. + </para> + + <para> + All the nodes are pinged in the beginning by all the processes, + even if the node list is shared memory. + </para> </section> <section>

8 years, 12 months

git:master:fef0593a: rtpengine: hash table to keep the selected nodes

by Stefan Mititelu

Module: kamailio Branch: master Commit: fef0593a49fd6c6a08a7a1f3220e3b7f0cc030fe URL: https://github.com/kamailio/kamailio/commit/fef0593a49fd6c6a08a7a1f3220e3b7… Author: Stefan Mititelu <stefan.mititelu(a)1and1.ro> Committer: Stefan Mititelu <stefan.mititelu(a)1and1.ro> Date: 2015-11-23T12:12:27+02:00 rtpengine: hash table to keep the selected nodes Shared memory hash table with global hashtable lock. Add state maintaining the selected rtp node, for a given callid. Hashtable entry expiration time configurable using hash_entry_tout modparam. The actual deletion happens on the fly while insert/remove/lookup are called. Updated doku. --- Added: modules/rtpengine/rtpengine_hash.c Added: modules/rtpengine/rtpengine_hash.h Modified: modules/rtpengine/doc/rtpengine_admin.xml Modified: modules/rtpengine/rtpengine.c --- Diff: https://github.com/kamailio/kamailio/commit/fef0593a49fd6c6a08a7a1f3220e3b7… Patch: https://github.com/kamailio/kamailio/commit/fef0593a49fd6c6a08a7a1f3220e3b7…

8 years, 12 months

git:master:490fa49f: pv: $snd(sproto) returns sending protocol as string

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 490fa49f72022b334340a58a92d63b5b6f661c87 URL: https://github.com/kamailio/kamailio/commit/490fa49f72022b334340a58a92d63b5… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2015-11-23T09:54:36+01:00 pv: $snd(sproto) returns sending protocol as string --- Modified: modules/pv/pv_branch.c --- Diff: https://github.com/kamailio/kamailio/commit/490fa49f72022b334340a58a92d63b5… Patch: https://github.com/kamailio/kamailio/commit/490fa49f72022b334340a58a92d63b5… --- diff --git a/modules/pv/pv_branch.c b/modules/pv/pv_branch.c index 34626b3..738c06c 100644 --- a/modules/pv/pv_branch.c +++ b/modules/pv/pv_branch.c @@ -425,6 +425,11 @@ int pv_get_sndfrom(struct sip_msg *msg, pv_param_t *param, case 5: /* len */ return pv_get_uintval(msg, param, res, (int)snd_inf->len); + case 6: /* sproto */ + if(get_valid_proto_string((int)snd_inf->send_sock->proto, + 0, 0, &s)<0) + return pv_get_null(msg, param, res); + return pv_get_strval(msg, param, res, &s); default: /* 0 - ip */ return pv_get_strval(msg, param, res, @@ -463,6 +468,11 @@ int pv_get_sndto(struct sip_msg *msg, pv_param_t *param, case 5: /* len */ return pv_get_uintval(msg, param, res, (int)snd_inf->len); + case 6: /* sproto */ + if(get_valid_proto_string((int)snd_inf->send_sock->proto, + 0, 0, &s)<0) + return pv_get_null(msg, param, res); + return pv_get_strval(msg, param, res, &s); default: /* 0 - ip */ su2ip_addr(&ip, snd_inf->to); @@ -505,6 +515,11 @@ int pv_parse_snd_name(pv_spec_p sp, str *in) sp->pvp.pvn.u.isname.name.n = 3; else goto error; break; + case 6: + if(strncmp(in->s, "sproto", 6)==0) + sp->pvp.pvn.u.isname.name.n = 6; + else goto error; + break; default: goto error; }

8 years, 12 months

git:master:5a142f7c: core: relocate dbg message before killing children at shut down

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 5a142f7cc2899090b007654529f08b1b2f4e70b1 URL: https://github.com/kamailio/kamailio/commit/5a142f7cc2899090b007654529f08b1… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2015-11-22T10:02:36+01:00 core: relocate dbg message before killing children at shut down - can race with per module log level, debugger module can be destroyed --- Modified: main.c --- Diff: https://github.com/kamailio/kamailio/commit/5a142f7cc2899090b007654529f08b1… Patch: https://github.com/kamailio/kamailio/commit/5a142f7cc2899090b007654529f08b1… --- diff --git a/main.c b/main.c index 94f64ff..da30f12 100644 --- a/main.c +++ b/main.c @@ -752,9 +752,9 @@ void handle_sigs(void) } LM_INFO("terminating due to SIGCHLD\n"); #endif + LM_DBG("terminating due to SIGCHLD\n"); /* exit */ shutdown_children(SIGTERM, 1); - LM_DBG("terminating due to SIGCHLD\n"); if (WIFSIGNALED(chld_status)) { exit(1); } else {

9 years

[kamailio] Adding publish in registration functionality, sending "closed" NOTIFY when presense has expired (#177)

by barabasp

The commit contains pua_usrloc modifications, which simplifies the publish and regisration processes: in every REGISTER an implicit publish is built in. In this way, a device e.g. do not need to send two individual request towards kamailio (REGISTER, PUBLISH), it can be achieved in a single but extended REGISTER request. Another small fix is that if the publication is expired (due to broken TCP e.g.), a "closed" NOTIFY should be sent to the contacts. You can view, comment on, or merge this pull request online at: https://github.com/kamailio/kamailio/pull/177 -- Commit Summary -- * Adding publish in registration functionality -- File Changes -- M modules/pua_usrloc/pua_usrloc.c (4) M modules/pua_usrloc/ul_publish.c (152) -- Patch Links -- https://github.com/kamailio/kamailio/pull/177.patch https://github.com/kamailio/kamailio/pull/177.diff --- Reply to this email directly or view it on GitHub: https://github.com/kamailio/kamailio/pull/177

9 years

[kamailio] DMQ under high load kills Kamailio (#399)

by Sebastian Damm

We started a Kamailio handling about 30k registrations with dmq_usrloc module enabled (only sending the traffic to one other host). It crashes almost right away. That's what the log says for the instance. You see, there are not only about 45 seconds from starting up to crashing. ``` root@pleisse:~# grep '\[35833\]' /var/log/kamailio/proxy.log Nov 17 14:46:40 pleisse /usr/sbin/kamailio[35833]: WARNING: tm [t_funcs.c:384]: init_avp_params(): using AVP for TM fr_timer is deprecated, use t_set_fr(...) instead Nov 17 14:46:40 pleisse /usr/sbin/kamailio[35833]: WARNING: tm [t_funcs.c:416]: init_avp_params(): using AVP for TM fr_inv_timer is deprecated, use t_set_fr(...) instead Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: ALERT: <core> [main.c:728]: handle_sigs(): child process 35911 exited by a signal 6 Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: ALERT: <core> [main.c:731]: handle_sigs(): core was generated Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: ERROR: tm [uac.c:296]: t_uac_prepare(): t_uac: short of cell shmem Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: ERROR: dmq [dmq_funcs.c:243]: dmq_send_message(): error in tmb.t_request_within Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: : <core> [mem/q_malloc.c:453]: qm_free(): BUG: qm_free: freeing already freed pointer (0x7f3c896c11c0), called from <core>: parser/parse_param.c: do_free_params(623), first free <core>: parser/parse_param.c: do_free_params(623) - aborting ``` We first thought, it is a problem with shm, so we doubled it (from 512 to 1024M), but the problem stays. Those are the last lines from the log. ``` Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35911]: ERROR: tm [uac.c:296]: t_uac_prepare(): t_uac: short of cell shmem Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35911]: ERROR: dmq [dmq_funcs.c:243]: dmq_send_message(): error in tmb.t_request_within Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35838]: ERROR: <core> [sip_msg_clone.c:497]: sip_msg_shm_clone(): cannot allocate memory Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35838]: ERROR: dmq [worker.c:164]: add_dmq_job(): error cloning sip message Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35912]: ERROR: tm [uac.c:296]: t_uac_prepare(): t_uac: short of cell shmem Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35838]: ERROR: dmq [message.c:67]: dmq_handle_message(): failed to add dmq job Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35912]: ERROR: dmq [dmq_funcs.c:243]: dmq_send_message(): error in tmb.t_request_within Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35871]: ERROR: <core> [sip_msg_clone.c:497]: sip_msg_shm_clone(): cannot allocate memory Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35871]: ERROR: dmq [worker.c:164]: add_dmq_job(): error cloning sip message Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35911]: ERROR: tm [uac.c:296]: t_uac_prepare(): t_uac: short of cell shmem Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35871]: ERROR: dmq [message.c:67]: dmq_handle_message(): failed to add dmq job Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35911]: ERROR: dmq [dmq_funcs.c:243]: dmq_send_message(): error in tmb.t_request_within Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35909]: ERROR: tm [uac.c:296]: t_uac_prepare(): t_uac: short of cell shmem Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35910]: ERROR: tm [uac.c:296]: t_uac_prepare(): t_uac: short of cell shmem Nov 17 14:47:22 pleisse /usr/sbin/kamailio[35911]: : <core> [mem/q_malloc.c:453]: qm_free(): BUG: qm_free: freeing already freed pointer (0x7f3c896c11c0), called from <core>: parser /parse_param.c: do_free_params(623), first free <core>: parser/parse_param.c: do_free_params(623) - aborting Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: ALERT: <core> [main.c:728]: handle_sigs(): child process 35911 exited by a signal 6 Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: ALERT: <core> [main.c:731]: handle_sigs(): core was generated Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: ERROR: tm [uac.c:296]: t_uac_prepare(): t_uac: short of cell shmem Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: ERROR: dmq [dmq_funcs.c:243]: dmq_send_message(): error in tmb.t_request_within Nov 17 14:47:24 pleisse /usr/sbin/kamailio[35833]: : <core> [mem/q_malloc.c:453]: qm_free(): BUG: qm_free: freeing already freed pointer (0x7f3c896c11c0), called from <core>: parser/parse_param.c: do_free_params(623), first free <core>: parser/parse_param.c: do_free_params(623) - aborting ``` This is the core dump of process 35833: ``` GNU gdb (GDB) 7.4.1-debian Copyright (C) 2012 Free Software Foundation, Inc. License GPLv3+: GNU GPL version 3 or later <http://gnu.org/licenses/gpl.html> This is free software: you are free to change and redistribute it. There is NO WARRANTY, to the extent permitted by law. Type "show copying" and "show warranty" for details. This GDB was configured as "x86_64-linux-gnu". For bug reporting instructions, please see: <http://www.gnu.org/software/gdb/bugs/>... Reading symbols from /usr/sbin/kamailio...Reading symbols from /usr/lib/debug/.build-id/c3/a4fc0cef8da17048bce2dc080e543509e39d37.debug...done. done. [New LWP 35833] warning: Can't read pathname for load map: Input/output error. [Thread debugging using libthread_db enabled] Using host libthread_db library "/lib/x86_64-linux-gnu/libthread_db.so.1". Core was generated by `/usr/sbin/kamailio -f /etc/kamailio/kamailio_sip_proxy.cfg -P /var/run/kamailio'. Program terminated with signal 6, Aborted. #0 0x00007f3ccc4a6165 in raise () from /lib/x86_64-linux-gnu/libc.so.6 Thread 1 (Thread 0x7f3ccce2e700 (LWP 35833)): #0 0x00007f3ccc4a6165 in raise () from /lib/x86_64-linux-gnu/libc.so.6 #1 0x00007f3ccc4a93e0 in abort () from /lib/x86_64-linux-gnu/libc.so.6 #2 0x00000000005f29ae in qm_free (qm=<optimized out>, p=<optimized out>, file=<optimized out>, func=<optimized out>, line=623) at mem/q_malloc.c:441 #3 0x0000000000624dd8 in do_free_params (_shm=1, _p=0x0) at parser/parse_param.c:623 #4 shm_free_params (_p=<optimized out>) at parser/parse_param.c:643 #5 0x00007f3cc3af95c9 in destroy_dmq_node (node=0x7f3cc3484c98, shm=<optimized out>) at dmqnode.c:252 #6 destroy_dmq_node (node=0x7f3cc3484c98, shm=<optimized out>) at dmqnode.c:248 #7 0x00007f3cc3af3a6a in dmq_send_message (peer=peer@entry=0x7f3c837c9658, body=body@entry=0x7f3cca9992f0, node=node@entry=0x7f3c89c16880, resp_cback=resp_cback@entry=0x7f3cc3d11650, max_forwards=max_forwards@entry=1, content_type=content_type@entry=0x7f3cc3d11660) at dmq_funcs.c:258 #8 0x00007f3cc3af49b5 in bcast_dmq_message (peer=0x7f3c837c9658, body=body@entry=0x7f3cca9992f0, except=except@entry=0x0, resp_cback=resp_cback@entry=0x7f3cc3d11650, max_forwards=max_forwards@entry=1, content_type=content_type@entry=0x7f3cc3d11660) at dmq_funcs.c:167 #9 0x00007f3cc3b044a2 in request_nodelist (node=<optimized out>, forward=forward@entry=1) at notification_peer.c:562 #10 0x00007f3cc3aee88f in destroy () at dmq.c:331 #11 0x000000000056e872 in destroy_modules () at sr_module.c:805 #12 0x00000000004a410d in cleanup (show_status=show_status@entry=1) at main.c:513 #13 0x00000000004a4d98 in shutdown_children (show_status=1, sig=15) at main.c:655 #14 0x00000000004a66e8 in handle_sigs () at main.c:746 #15 0x00000000004aa976 in main_loop () at main.c:1701 #16 0x0000000000427292 in main (argc=<optimized out>, argv=<optimized out>) at main.c:2547 #0 0x00007f3ccc4a6165 in raise () from /lib/x86_64-linux-gnu/libc.so.6 No symbol table info available. #1 0x00007f3ccc4a93e0 in abort () from /lib/x86_64-linux-gnu/libc.so.6 No symbol table info available. #2 0x00000000005f29ae in qm_free (qm=<optimized out>, p=<optimized out>, file=<optimized out>, func=<optimized out>, line=623) at mem/q_malloc.c:441 f = <optimized out> size = <optimized out> next = <optimized out> prev = <optimized out> __FUNCTION__ = "qm_free" #3 0x0000000000624dd8 in do_free_params (_shm=1, _p=0x0) at parser/parse_param.c:623 ptr = <optimized out> #4 shm_free_params (_p=<optimized out>) at parser/parse_param.c:643 No locals. #5 0x00007f3cc3af95c9 in destroy_dmq_node (node=0x7f3cc3484c98, shm=<optimized out>) at dmqnode.c:252 No locals. #6 destroy_dmq_node (node=0x7f3cc3484c98, shm=<optimized out>) at dmqnode.c:248 No locals. #7 0x00007f3cc3af3a6a in dmq_send_message (peer=peer@entry=0x7f3c837c9658, body=body@entry=0x7f3cca9992f0, node=node@entry=0x7f3c89c16880, resp_cback=resp_cback@entry=0x7f3cc3d11650, max_forwards=max_forwards@entry=1, content_type=content_type@entry=0x7f3cc3d11660) at dmq_funcs.c:258 uac_r = {method = 0x7f3cc3d11340, headers = 0x7ffd03cd77d0, body = 0x7f3cca9992f0, ssock = 0x7f3cc3d116e0, dialog = 0x0, cb_flags = 1024, cb = 0x7f3cc3af1e70 <dmq_tm_callback>, cbp = 0x7f3cc34646c8, callid = 0x0} str_hdr = {s = 0x7f3cca711348 "Max-Forwards: 1\r\nContent-Type: text/plain\r\n", len = 43} from = {s = 0x7f3cca999368 "sip:notification_peer@172.20.40.5:5060ain\r\n", len = 38} to = {s = 0x7f3cca999408 "sip:notification_peer@217.116.118.19:5060", len = 41} cb_param = <optimized out> result = <optimized out> len = <optimized out> __FUNCTION__ = "dmq_send_message" #8 0x00007f3cc3af49b5 in bcast_dmq_message (peer=0x7f3c837c9658, body=body@entry=0x7f3cca9992f0, except=except@entry=0x0, resp_cback=resp_cback@entry=0x7f3cc3d11650, max_forwards=max_forwards@entry=1, content_type=content_type@entry=0x7f3cc3d11660) at dmq_funcs.c:167 node = 0x7f3c89c16880 __FUNCTION__ = "bcast_dmq_message" #9 0x00007f3cc3b044a2 in request_nodelist (node=<optimized out>, forward=forward@entry=1) at notification_peer.c:562 body = 0x7f3cca9992f0 ret = <optimized out> __FUNCTION__ = "request_nodelist" #10 0x00007f3cc3aee88f in destroy () at dmq.c:331 __FUNCTION__ = "destroy" #11 0x000000000056e872 in destroy_modules () at sr_module.c:805 t = <optimized out> foo = 0x7f3cca4d5f20 __FUNCTION__ = "destroy_modules" #12 0x00000000004a410d in cleanup (show_status=show_status@entry=1) at main.c:513 memlog = <optimized out> __FUNCTION__ = "cleanup" #13 0x00000000004a4d98 in shutdown_children (show_status=1, sig=15) at main.c:655 No locals. #14 0x00000000004a66e8 in handle_sigs () at main.c:746 chld = 0 chld_status = 134 memlog = <optimized out> __FUNCTION__ = "handle_sigs" #15 0x00000000004aa976 in main_loop () at main.c:1701 i = <optimized out> pid = <optimized out> si = <optimized out> si_desc = "udp receiver child=31 sock=172.20.40.5:5060\000\000\000\000\000\030\216\231\312<\177\000\000\016\000\000\000\000\000\000\000\003\000\000\000\000\000\000\000(\245K\203<\177\000\000\001\000\000\000\000\000\000\000\000Bp\367\353\301<~ \000\000\000\000\000\000\000\002\000\000\000\000\000\000\000\310\222\241\000\000\000\000\000\300\222\241\000\000\000\000" nrprocs = <optimized out> __FUNCTION__ = "main_loop" #16 0x0000000000427292 in main (argc=<optimized out>, argv=<optimized out>) at main.c:2547 cfg_stream = <optimized out> c = <optimized out> r = <optimized out> tmp = 0x7ffd03cd9f15 "" tmp_len = 0 port = 1 proto = 1 options = 0x6baf50 ":f:cm:M:dVIhEeb:l:L:n:vKrRDTN:W:w:t:u:g:P:G:SQ:O:a:A:" ret = -1 seed = 3232125741 rfd = 4 debug_save = <optimized out> debug_flag = <optimized out> dont_fork_cnt = <optimized out> n_lst = 0x21 p = <optimized out> st = {st_dev = 14, st_ino = 23606, st_nlink = 2, st_mode = 16877, st_uid = 110, st_gid = 301, __pad0 = 0, st_rdev = 0, st_size = 200, st_blksize = 4096, st_blocks = 0, st_atim = {tv_sec = 1447757500, tv_nsec = 873437536}, st_mtim = {tv_sec = 1447767996, tv_nsec = 445431681}, st_ctim = {tv_sec = 1447768000, tv_nsec = 253521630}, __unused = {0, 0, 0}} __FUNCTION__ = "main" ``` There is also a core dump of PID 35911: ``` GNU gdb (GDB) 7.4.1-debian Copyright (C) 2012 Free Software Foundation, Inc. License GPLv3+: GNU GPL version 3 or later <http://gnu.org/licenses/gpl.html> This is free software: you are free to change and redistribute it. There is NO WARRANTY, to the extent permitted by law. Type "show copying" and "show warranty" for details. This GDB was configured as "x86_64-linux-gnu". For bug reporting instructions, please see: <http://www.gnu.org/software/gdb/bugs/>... Reading symbols from /usr/sbin/kamailio...Reading symbols from /usr/lib/debug/.build-id/c3/a4fc0cef8da17048bce2dc080e543509e39d37.debug...done. done. [New LWP 35911] warning: Can't read pathname for load map: Input/output error. [Thread debugging using libthread_db enabled] Using host libthread_db library "/lib/x86_64-linux-gnu/libthread_db.so.1". Core was generated by `/usr/sbin/kamailio -f /etc/kamailio/kamailio_sip_proxy.cfg -P /var/run/kamailio'. Program terminated with signal 6, Aborted. #0 0x00007f3ccc4a6165 in raise () from /lib/x86_64-linux-gnu/libc.so.6 Thread 1 (Thread 0x7f3ccce2e700 (LWP 35911)): #0 0x00007f3ccc4a6165 in raise () from /lib/x86_64-linux-gnu/libc.so.6 #1 0x00007f3ccc4a93e0 in abort () from /lib/x86_64-linux-gnu/libc.so.6 #2 0x00000000005f29ae in qm_free (qm=<optimized out>, p=<optimized out>, file=<optimized out>, func=<optimized out>, line=623) at mem/q_malloc.c:441 #3 0x0000000000624dd8 in do_free_params (_shm=1, _p=0x0) at parser/parse_param.c:623 #4 shm_free_params (_p=<optimized out>) at parser/parse_param.c:643 #5 0x00007f3cc3af95c9 in destroy_dmq_node (node=0x7f3cc3484218, shm=<optimized out>) at dmqnode.c:252 #6 destroy_dmq_node (node=0x7f3cc3484218, shm=<optimized out>) at dmqnode.c:248 #7 0x00007f3cc3af3a6a in dmq_send_message (peer=<optimized out>, body=0x7ffd03cd7540, node=<optimized out>, resp_cback=<optimized out>, max_forwards=<optimized out>, content_type=<optimized out>) at dmq_funcs.c:258 #8 0x00007f3cc38e00b2 in usrloc_dmq_send (body=body@entry=0x7ffd03cd7540, node=node@entry=0x7f3c89c16880) at usrloc_sync.c:261 #9 0x00007f3cc38e13fe in usrloc_dmq_send_contact (ptr=<optimized out>, aor=..., action=action@entry=1, node=node@entry=0x7f3c89c16880) at usrloc_sync.c:505 #10 0x00007f3cc38e1bfc in usrloc_get_all_ucontact (node=node@entry=0x7f3c89c16880) at usrloc_sync.c:211 #11 0x00007f3cc38e2e96 in usrloc_dmq_handle_msg (msg=<optimized out>, resp=0x7ffd03cd7880, node=0x7f3c89c16880) at usrloc_sync.c:398 #12 0x00007f3cc3b0710b in worker_loop (id=id@entry=2) at worker.c:105 #13 0x00007f3cc3aee1e8 in child_init (rank=<optimized out>) at dmq.c:293 #14 child_init (rank=<optimized out>) at dmq.c:279 #15 0x000000000056d4f8 in init_mod_child (m=0x7f3cca4d6b38, rank=rank@entry=0) at sr_module.c:915 #16 0x000000000056d442 in init_mod_child (m=0x7f3cca4d7030, rank=rank@entry=0) at sr_module.c:912 #17 0x000000000056d442 in init_mod_child (m=0x7f3cca4d7308, rank=rank@entry=0) at sr_module.c:912 #18 0x000000000056d442 in init_mod_child (m=0x7f3cca4d7930, rank=rank@entry=0) at sr_module.c:912 #19 0x000000000056e91b in init_child (rank=rank@entry=0) at sr_module.c:941 #20 0x00000000004aa78c in main_loop () at main.c:1650 #21 0x0000000000427292 in main (argc=<optimized out>, argv=<optimized out>) at main.c:2547 #0 0x00007f3ccc4a6165 in raise () from /lib/x86_64-linux-gnu/libc.so.6 No symbol table info available. #1 0x00007f3ccc4a93e0 in abort () from /lib/x86_64-linux-gnu/libc.so.6 No symbol table info available. #2 0x00000000005f29ae in qm_free (qm=<optimized out>, p=<optimized out>, file=<optimized out>, func=<optimized out>, line=623) at mem/q_malloc.c:441 f = <optimized out> size = <optimized out> next = <optimized out> prev = <optimized out> __FUNCTION__ = "qm_free" #3 0x0000000000624dd8 in do_free_params (_shm=1, _p=0x0) at parser/parse_param.c:623 ptr = <optimized out> #4 shm_free_params (_p=<optimized out>) at parser/parse_param.c:643 No locals. #5 0x00007f3cc3af95c9 in destroy_dmq_node (node=0x7f3cc3484218, shm=<optimized out>) at dmqnode.c:252 No locals. #6 destroy_dmq_node (node=0x7f3cc3484218, shm=<optimized out>) at dmqnode.c:248 No locals. #7 0x00007f3cc3af3a6a in dmq_send_message (peer=<optimized out>, body=0x7ffd03cd7540, node=<optimized out>, resp_cback=<optimized out>, max_forwards=<optimized out>, content_type=<optimized out>) at dmq_funcs.c:258 uac_r = {method = 0x7f3cc3d11340, headers = 0x7ffd03cd73c0, body = 0x7ffd03cd7540, ssock = 0x7f3cc3d116e0, dialog = 0x0, cb_flags = 1024, cb = 0x7f3cc3af1e70 <dmq_tm_callback>, cbp = 0x7f3cc34844c8, callid = 0x0} str_hdr = {s = 0x7f3cca713a20 "Max-Forwards: 1\r\nContent-Type: application/json\r\n", len = 49} from = {s = 0x7f3cca713918 "sip:usrloc@172.20.40.5:50600/UDP\300\300\300\300", len = 27} to = {s = 0x7f3cca713998 "sip:usrloc@217.116.118.19:506047698f4.9e\300\300\300\300", len = 30} cb_param = <optimized out> result = <optimized out> len = <optimized out> __FUNCTION__ = "dmq_send_message" #8 0x00007f3cc38e00b2 in usrloc_dmq_send (body=body@entry=0x7ffd03cd7540, node=node@entry=0x7f3c89c16880) at usrloc_sync.c:261 __FUNCTION__ = "usrloc_dmq_send" #9 0x00007f3cc38e13fe in usrloc_dmq_send_contact (ptr=<optimized out>, aor=..., action=action@entry=1, node=node@entry=0x7f3c89c16880) at usrloc_sync.c:505 jdoc = {root = 0xd71160, flags = 0, buf = { s = 0xd70070 "{\"action\":1,\"aor\":\"2241474e0(a)sipgate.de\",\"ruid\":\"uloc-564b246e-7416-dec\",\"c\":\"sip:2241474@192.168.0.140:5060\",\"received\":\"sip:87.79.157.233:1027\",\"path\":\"<sip:217.10.79.9;lr;received=sip:87.79.157.233"..., len = 414}, malloc_fn = 0x7f3ccc4eea00 <malloc>, free_fn = 0x7f3ccc4ee920 <free>} flags = <optimized out> __FUNCTION__ = "usrloc_dmq_send_contact" #10 0x00007f3cc38e1bfc in usrloc_get_all_ucontact (node=node@entry=0x7f3c89c16880) at usrloc_sync.c:211 rval = <optimized out> len = <optimized out> buf = 0x7f3cca9c8080 cp = 0x7f3ccab62a49 ruid = {s = 0x7f3ccab62a2f "uloc-564b246e-7416-dec\337\321z\205\036", len = 22} aorhash = <optimized out> send_sock = <optimized out> flags = <optimized out> aor = {s = 0x7f3c8608a528 "2241474e0(a)sipgate.de", len = 20} r = 0x7f3c8608a488 _d = 0x7f3c837257a0 ptr = 0x7f3c8608a5a0 res = <optimized out> __FUNCTION__ = "usrloc_get_all_ucontact" #11 0x00007f3cc38e2e96 in usrloc_dmq_handle_msg (msg=<optimized out>, resp=0x7ffd03cd7880, node=0x7f3c89c16880) at usrloc_sync.c:398 content_length = <optimized out> body = <optimized out> jdoc = {root = 0xd69490, flags = 0, buf = {s = 0x7f3c8eb7f378 "{\"action\":3}", len = 12}, malloc_fn = 0x7f3ccc4eea00 <malloc>, free_fn = 0x7f3ccc4ee920 <free>} it = <optimized out> ci = {ruid = {s = 0x0, len = 0}, c = 0x7ffd03cd7750, received = {s = 0x0, len = 0}, path = 0x7ffd03cd7760, expires = 0, q = 0, callid = 0x7ffd03cd7770, cseq = 0, flags = 2, cflags = 0, user_agent = 0x7ffd03cd7780, sock = 0x0, methods = 0, instance = {s = 0x0, len = 0}, reg_id = 0, server_id = 0, tcpconn_id = -1, keepalive = 0, xavp = 0x0, last_modified = 0} action = <optimized out> expires = <optimized out> cseq = <optimized out> flags = <optimized out> cflags = <optimized out> q = <optimized out> last_modified = <optimized out> methods = <optimized out> reg_id = <optimized out> aor = {s = <optimized out>, len = 0} ruid = <optimized out> c = {s = 0x0, len = 0} received = <optimized out> path = {s = 0x0, len = 0} callid = {s = 0x0, len = 0} user_agent = {s = 0x0, len = 0} instance = <optimized out> __FUNCTION__ = "usrloc_dmq_handle_msg" #12 0x00007f3cc3b0710b in worker_loop (id=id@entry=2) at worker.c:105 worker = 0x7f3c837c9560 current_job = 0x7f3c8eb7bdd8 peer_response = {resp_code = 0, content_type = {s = 0x0, len = 0}, reason = {s = 0x0, len = 0}, body = {s = 0x0, len = 0}} ret_value = <optimized out> not_parsed = 1 dmq_node = 0x7f3c89c16880 __FUNCTION__ = "worker_loop" #13 0x00007f3cc3aee1e8 in child_init (rank=<optimized out>) at dmq.c:293 i = <optimized out> newpid = <optimized out> #14 child_init (rank=<optimized out>) at dmq.c:279 No locals. #15 0x000000000056d4f8 in init_mod_child (m=0x7f3cca4d6b38, rank=rank@entry=0) at sr_module.c:915 __FUNCTION__ = "init_mod_child" #16 0x000000000056d442 in init_mod_child (m=0x7f3cca4d7030, rank=rank@entry=0) at sr_module.c:912 __FUNCTION__ = "init_mod_child" #17 0x000000000056d442 in init_mod_child (m=0x7f3cca4d7308, rank=rank@entry=0) at sr_module.c:912 __FUNCTION__ = "init_mod_child" #18 0x000000000056d442 in init_mod_child (m=0x7f3cca4d7930, rank=rank@entry=0) at sr_module.c:912 __FUNCTION__ = "init_mod_child" #19 0x000000000056e91b in init_child (rank=rank@entry=0) at sr_module.c:941 No locals. #20 0x00000000004aa78c in main_loop () at main.c:1650 i = <optimized out> pid = <optimized out> si = <optimized out> si_desc = "udp receiver child=31 sock=172.20.40.5:5060\000\000\000\000\000\030\216\231\312<\177\000\000\016\000\000\000\000\000\000\000\003\000\000\000\000\000\000\000(\245K\203<\177\000\000\001\000\000\000\000\000\000\000\000Bp\367\353\301<~ \000\000\000\000\000\000\000\002\000\000\000\000\000\000\000\310\222\241\000\000\000\000\000\300\222\241\000\000\000\000" nrprocs = <optimized out> __FUNCTION__ = "main_loop" #21 0x0000000000427292 in main (argc=<optimized out>, argv=<optimized out>) at main.c:2547 cfg_stream = <optimized out> c = <optimized out> r = <optimized out> tmp = 0x7ffd03cd9f15 "" tmp_len = 0 port = 1 proto = 1 options = 0x6baf50 ":f:cm:M:dVIhEeb:l:L:n:vKrRDTN:W:w:t:u:g:P:G:SQ:O:a:A:" ret = -1 seed = 3232125741 rfd = 4 debug_save = <optimized out> debug_flag = <optimized out> dont_fork_cnt = <optimized out> n_lst = 0x21 p = <optimized out> st = {st_dev = 14, st_ino = 23606, st_nlink = 2, st_mode = 16877, st_uid = 110, st_gid = 301, __pad0 = 0, st_rdev = 0, st_size = 200, st_blksize = 4096, st_blocks = 0, st_atim = {tv_sec = 1447757500, tv_nsec = 873437536}, st_mtim = {tv_sec = 1447767996, tv_nsec = 445431681}, st_ctim = {tv_sec = 1447768000, tv_nsec = 253521630}, __unused = {0, 0, 0}} __FUNCTION__ = "main" ``` --- Reply to this email directly or view it on GitHub: https://github.com/kamailio/kamailio/issues/399

9 years

git:master:31fa9c50: dmq_usrloc: documentation for batch_size and batch_usleep params

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 31fa9c50bd6193851c53c1d66b8d517da5f67a15 URL: https://github.com/kamailio/kamailio/commit/31fa9c50bd6193851c53c1d66b8d517… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2015-11-20T12:33:19+01:00 dmq_usrloc: documentation for batch_size and batch_usleep params --- Modified: modules/dmq_usrloc/README Modified: modules/dmq_usrloc/doc/dmq_usrloc_admin.xml --- Diff: https://github.com/kamailio/kamailio/commit/31fa9c50bd6193851c53c1d66b8d517… Patch: https://github.com/kamailio/kamailio/commit/31fa9c50bd6193851c53c1d66b8d517… --- diff --git a/modules/dmq_usrloc/README b/modules/dmq_usrloc/README index db19233..5325413 100644 --- a/modules/dmq_usrloc/README +++ b/modules/dmq_usrloc/README @@ -28,11 +28,15 @@ Andrey Rybkin 3.1. enable (int) 3.2. sync (int) + 3.3. batch_size (int) + 3.4. batch_usleep (int) List of Examples 1.1. Set enable parameter 1.2. Set sync parameter + 1.3. Set batch size parameter + 1.4. Set batch_usleep parameter Chapter 1. Admin Guide @@ -47,6 +51,8 @@ Chapter 1. Admin Guide 3.1. enable (int) 3.2. sync (int) + 3.3. batch_size (int) + 3.4. batch_usleep (int) 1. Overview @@ -67,6 +73,8 @@ Chapter 1. Admin Guide 3.1. enable (int) 3.2. sync (int) + 3.3. batch_size (int) + 3.4. batch_usleep (int) 3.1. enable (int) @@ -95,3 +103,34 @@ modparam("dmq_usrloc", "enable", 1) ... modparam("dmq_usrloc", "sync", 0) ... + +3.3. batch_size (int) + + The parameter controls whetner to throttle synchronization of all + contacts in batches. Once a batch of SIP requests is sent out, then + sleep for 'batch_usleep' microseconds. The value can be: + * <=0 - disabled (no batching) + * >0 - how many records to be sent in a batch + + Default value is 0. + + Example 1.3. Set batch size parameter +... +modparam("dmq_usrloc", "batch_size", 4000) +... + +3.4. batch_usleep (int) + + The parameter controls whetner to throttle synchronization of all + contacts in batches. Once a batch of SIP requests is sent out, then + sleep for 'batch_usleep' microseconds. The value can be: + * <=0 - no sleep (it disables the batching) + * >0 - how many microseconds to sleep before sending out another + batch of usrloc records. + + Default value is 0. + + Example 1.4. Set batch_usleep parameter +... +modparam("dmq_usrloc", "batch_usleep", 1000) +... diff --git a/modules/dmq_usrloc/doc/dmq_usrloc_admin.xml b/modules/dmq_usrloc/doc/dmq_usrloc_admin.xml index a7da61d..3c0e2b1 100644 --- a/modules/dmq_usrloc/doc/dmq_usrloc_admin.xml +++ b/modules/dmq_usrloc/doc/dmq_usrloc_admin.xml @@ -108,6 +108,75 @@ modparam("dmq_usrloc", "sync", 0) </programlisting> </example> </section> + <section id="usrloc_dmq.p.batch_size"> + <title><varname>batch_size</varname> (int)</title> + <para> + The parameter controls whetner to throttle synchronization of + all contacts in batches. Once a batch of SIP requests is sent out, + then sleep for 'batch_usleep' microseconds. + The value can be: + <itemizedlist> + <listitem> + <para> + <=0 - disabled (no batching) + </para> + </listitem> + <listitem> + <para> + >0 - how many records to be sent in a batch + </para> + </listitem> + </itemizedlist> + </para> + <para> + <emphasis> + Default value is 0. + </emphasis> + </para> + <example> + <title>Set <varname>batch size</varname> parameter</title> + <programlisting format="linespecific"> +... +modparam("dmq_usrloc", "batch_size", 4000) +... +</programlisting> + </example> + </section> + <section id="usrloc_dmq.p.batch_usleep"> + <title><varname>batch_usleep</varname> (int)</title> + <para> + The parameter controls whetner to throttle synchronization of + all contacts in batches. Once a batch of SIP requests is sent out, + then sleep for 'batch_usleep' microseconds. + The value can be: + <itemizedlist> + <listitem> + <para> + <=0 - no sleep (it disables the batching) + </para> + </listitem> + <listitem> + <para> + >0 - how many microseconds to sleep before sending + out another batch of usrloc records. + </para> + </listitem> + </itemizedlist> + </para> + <para> + <emphasis> + Default value is 0. + </emphasis> + </para> + <example> + <title>Set <varname>batch_usleep</varname> parameter</title> + <programlisting format="linespecific"> +... +modparam("dmq_usrloc", "batch_usleep", 1000) +... +</programlisting> + </example> + </section> </section> </chapter>

9 years

git:master:167668b4: dmq_usrloc: support for throttling sync of all usrloc records

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 167668b4e31d7e613f00baf548671c4361189d79 URL: https://github.com/kamailio/kamailio/commit/167668b4e31d7e613f00baf548671c4… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2015-11-20T12:33:19+01:00 dmq_usrloc: support for throttling sync of all usrloc records - batch_size and batch_usleep parameters can control how many records can be sent out at once, after that sleep for batch_usleep microseconds before sending the next batch --- Modified: modules/dmq_usrloc/dmq_usrloc.c Modified: modules/dmq_usrloc/usrloc_sync.c --- Diff: https://github.com/kamailio/kamailio/commit/167668b4e31d7e613f00baf548671c4… Patch: https://github.com/kamailio/kamailio/commit/167668b4e31d7e613f00baf548671c4… --- diff --git a/modules/dmq_usrloc/dmq_usrloc.c b/modules/dmq_usrloc/dmq_usrloc.c index c3ec54d..6000b2a 100644 --- a/modules/dmq_usrloc/dmq_usrloc.c +++ b/modules/dmq_usrloc/dmq_usrloc.c @@ -36,6 +36,8 @@ static int child_init(int); int dmq_usrloc_enable = 0; int _dmq_usrloc_sync = 1; +int _dmq_usrloc_batch_size = 0; +int _dmq_usrloc_batch_usleep = 0; usrloc_api_t dmq_ul; @@ -44,6 +46,8 @@ MODULE_VERSION static param_export_t params[] = { {"enable", INT_PARAM, &dmq_usrloc_enable}, {"sync", INT_PARAM, &_dmq_usrloc_sync}, + {"batch_size", INT_PARAM, &_dmq_usrloc_batch_size}, + {"batch_usleep", INT_PARAM, &_dmq_usrloc_batch_usleep}, {0, 0, 0} }; diff --git a/modules/dmq_usrloc/usrloc_sync.c b/modules/dmq_usrloc/usrloc_sync.c index 7752c3e..15da075 100644 --- a/modules/dmq_usrloc/usrloc_sync.c +++ b/modules/dmq_usrloc/usrloc_sync.c @@ -25,6 +25,7 @@ #include "../usrloc/ul_callback.h" #include "../usrloc/dlist.h" #include "../../dprint.h" +#include "../../ut.h" #include "../../parser/parse_from.h" #include "../../parser/parse_addr_spec.h" @@ -44,6 +45,8 @@ int usrloc_dmq_send_contact(ucontact_t* ptr, str aor, int action, dmq_node_t* no #define MAX_AOR_LEN 256 extern int _dmq_usrloc_sync; +extern int _dmq_usrloc_batch_size; +extern int _dmq_usrloc_batch_usleep; static int add_contact(str aor, ucontact_info_t* ci) { @@ -146,6 +149,7 @@ void usrloc_get_all_ucontact(dmq_node_t* node) udomain_t* _d; ucontact_t* ptr = 0; int res; + int n; if (dmq_ul.get_all_ucontacts == NULL){ LM_ERR("dmq_ul.get_all_ucontacts is NULL\n"); @@ -180,6 +184,7 @@ void usrloc_get_all_ucontact(dmq_node_t* node) if (buf == NULL) goto done; cp = buf; + n = 0; while (1) { memcpy(&(c.len), cp, sizeof(c.len)); if (c.len == 0) @@ -214,10 +219,17 @@ void usrloc_get_all_ucontact(dmq_node_t* node) while (ptr) { usrloc_dmq_send_contact(ptr, aor, DMQ_UPDATE, node); + n++; ptr = ptr->next; } dmq_ul.release_urecord(r); dmq_ul.unlock_udomain(_d, &aor); + if(_dmq_usrloc_batch_size>0 && _dmq_usrloc_batch_usleep>0) { + if(n>=_dmq_usrloc_batch_size) { + n = 0; + sleep_us(_dmq_usrloc_batch_usleep); + } + } } dmq_usrloc_free(buf);

9 years

git:master:5f3f499b: dmq_usrloc: use system malloc for fetching all contacts

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 5f3f499bc8f7ea0227b62494f73fbd734a820fa1 URL: https://github.com/kamailio/kamailio/commit/5f3f499bc8f7ea0227b62494f73fbd7… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2015-11-20T12:33:19+01:00 dmq_usrloc: use system malloc for fetching all contacts - this is a very rare operation, thus not making sense to allocate a lot of pkg for it (the memory is freed immediately) --- Modified: modules/dmq_usrloc/usrloc_sync.c --- Diff: https://github.com/kamailio/kamailio/commit/5f3f499bc8f7ea0227b62494f73fbd7… Patch: https://github.com/kamailio/kamailio/commit/5f3f499bc8f7ea0227b62494f73fbd7… --- diff --git a/modules/dmq_usrloc/usrloc_sync.c b/modules/dmq_usrloc/usrloc_sync.c index d1c534f..7752c3e 100644 --- a/modules/dmq_usrloc/usrloc_sync.c +++ b/modules/dmq_usrloc/usrloc_sync.c @@ -124,6 +124,9 @@ static int delete_contact(str aor, ucontact_info_t* ci) return 0; } +#define dmq_usrloc_malloc malloc +#define dmq_usrloc_free free + void usrloc_get_all_ucontact(dmq_node_t* node) { int rval, len=0; @@ -161,16 +164,16 @@ void usrloc_get_all_ucontact(dmq_node_t* node) } if (rval > 0) { if (buf != NULL) - pkg_free(buf); + dmq_usrloc_free(buf); len = rval * 2; - buf = pkg_malloc(len); + buf = dmq_usrloc_malloc(len); if (buf == NULL) { LM_ERR("out of pkg memory\n"); goto done; } rval = dmq_ul.get_all_ucontacts(buf, len, 0, 0, 1, 0); if (rval != 0) { - pkg_free(buf); + dmq_usrloc_free(buf); goto done; } } @@ -216,7 +219,7 @@ void usrloc_get_all_ucontact(dmq_node_t* node) dmq_ul.release_urecord(r); dmq_ul.unlock_udomain(_d, &aor); } - pkg_free(buf); + dmq_usrloc_free(buf); done: c.s = ""; c.len = 0;

9 years

← Newer
1
...
13
14
15
16
17
18
19
...
32
Older →

Jump to page:

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev November 2015