sr-dev September 2014

sr-dev@lists.kamailio.org

33 participants
375 discussions

git:lazedo/kazoo: proposed change for dbtext query results.

by Luis Azedo

Module: sip-router Branch: lazedo/kazoo Commit: dae74e974a028082a3250805da83223220123c10 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=dae74e9… Author: Luis Azedo <luis(a)2600hz.com> Committer: Luis Azedo <luis(a)2600hz.com> Date: Wed Sep 10 15:23:45 2014 +0100 proposed change for dbtext query results. this behaviour was observed by interacting with module presence. presentity clean runs from timer every 6 secs. if the first run returns a large set of rows, it iterates all rows doing some notifications and deleting the presentity. if it takes more then 6 secs to complete, the next run will override the results internal structure pointer maintained in the connection level. the proposed patch, maintains the query result internal structure within the result, using the ptr field for that. --- modules/db_text/dbt_api.c | 86 ++++++++++++++++++++----------------------- modules/db_text/dbt_api.h | 3 +- modules/db_text/dbt_base.c | 27 +++++++------- modules/db_text/dbt_res.c | 4 ++- modules/db_text/dbt_res.h | 6 --- 5 files changed, 59 insertions(+), 67 deletions(-) Diff: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commitdiff;h=dae…

10 years, 2 months

git:lazedo/kazoo: kazoo : remove expires parameters for presence. they should be in the

by Luis Azedo

Module: sip-router Branch: lazedo/kazoo Commit: fb66389261c03d57d6c182cf490c5730d97c7e22 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=fb66389… Author: Luis Azedo <luis(a)2600hz.com> Committer: Luis Azedo <luis(a)2600hz.com> Date: Sat Sep 13 05:07:26 2014 +0100 kazoo : remove expires parameters for presence. they should be in the payload. handle expires = 0 --- modules/kazoo/doc/kazoo_admin.xml | 59 +----------------------------------- modules/kazoo/kazoo.c | 13 ++++---- modules/kazoo/kz_pua.c | 17 ++++++---- 3 files changed, 19 insertions(+), 70 deletions(-) diff --git a/modules/kazoo/doc/kazoo_admin.xml b/modules/kazoo/doc/kazoo_admin.xml index 4134d8b..5f2dac8 100644 --- a/modules/kazoo/doc/kazoo_admin.xml +++ b/modules/kazoo/doc/kazoo_admin.xml @@ -495,11 +495,9 @@ modparam("kazoo", "amqp_query_timout_micro", 200000) <section> <title><varname>db_url</varname>(str)</title> <para> - The database url. + The database for the presentity table. </para> - <para>If set, the module is a fully operational - presence server. Otherwise, it is used as a 'library', for - its exported functions. + <para>If set, the kazoo_ppua_publish function will update the presentity status in the database. </para> <para> <emphasis>Default value is <quote>NULL</quote>.</emphasis> @@ -532,59 +530,6 @@ modparam("kazoo", "presentity_table", "my_presentity_table") </example> </section> - <section> - <title><varname>dialog_expires</varname>(str)</title> - <para> - The default Expires value for dialog event. - </para> - <para> - <emphasis>Default value is 30.</emphasis> - </para> - <example> - <title>Set <varname>dialog_expires</varname> parameter</title> - <programlisting format="linespecific"> -... -modparam("kazoo", "dialog_expires", 3600) -... -</programlisting> - </example> - </section> - - <section> - <title><varname>presence_expires</varname>(str)</title> - <para> - The default Expires value for presence event. - </para> - <para> - <emphasis>Default value is 3600.</emphasis> - </para> - <example> - <title>Set <varname>presence_expires</varname> parameter</title> - <programlisting format="linespecific"> -... -modparam("kazoo", "presence_expires", 600) -... -</programlisting> - </example> - </section> - - <section> - <title><varname>mwi_expires</varname>(str)</title> - <para> - The default Expires value for message-summary (mwi) event. - </para> - <para> - <emphasis>Default value is 3600.</emphasis> - </para> - <example> - <title>Set <varname>mwi_expires</varname> parameter</title> - <programlisting format="linespecific"> -... -modparam("kazoo", "mwi_expires", 600) -... -</programlisting> - </example> - </section> </section> diff --git a/modules/kazoo/kazoo.c b/modules/kazoo/kazoo.c index 0514ab8..af98c33 100644 --- a/modules/kazoo/kazoo.c +++ b/modules/kazoo/kazoo.c @@ -57,9 +57,9 @@ int dbk_reconn_retries = 8; int dbk_presentity_phtable_size = 4096; -int dbk_dialog_expires = 30; -int dbk_presence_expires = 3600; -int dbk_mwi_expires = 3600; +//int dbk_dialog_expires = 30; +//int dbk_presence_expires = 3600; +//int dbk_mwi_expires = 3600; int dbk_create_empty_dialog = 1; int dbk_channels = 50; @@ -140,9 +140,9 @@ static cmd_export_t cmds[] = { static param_export_t params[] = { {"node_hostname", STR_PARAM, &dbk_node_hostname.s}, - {"dialog_expires", INT_PARAM, &dbk_dialog_expires}, - {"presence_expires", INT_PARAM, &dbk_presence_expires}, - {"mwi_expires", INT_PARAM, &dbk_mwi_expires}, + // {"dialog_expires", INT_PARAM, &dbk_dialog_expires}, + // {"presence_expires", INT_PARAM, &dbk_presence_expires}, + // {"mwi_expires", INT_PARAM, &dbk_mwi_expires}, {"amqp_connection", STR_PARAM|USE_FUNC_PARAM,(void*)kz_amqp_add_connection}, {"amqp_max_channels", INT_PARAM, &dbk_channels}, {"amqp_consumer_ack_timeout_micro", INT_PARAM, &kz_ack_tv.tv_usec}, @@ -248,6 +248,7 @@ static int mod_init(void) { } register_procs(total_workers); + cfg_register_child(total_workers); return 0; } diff --git a/modules/kazoo/kz_pua.c b/modules/kazoo/kz_pua.c index 256e1fe..1efe96b 100644 --- a/modules/kazoo/kz_pua.c +++ b/modules/kazoo/kz_pua.c @@ -18,9 +18,6 @@ #include "const.h" -extern int dbk_dialog_expires; -extern int dbk_presence_expires; -extern int dbk_mwi_expires; extern int dbk_include_entity; extern int dbk_pua_mode; @@ -87,7 +84,7 @@ int kz_pua_update_presentity(str* event, str* realm, str* user, str* etag, str* query_cols[n_query_cols] = &str_expires_col; query_vals[n_query_cols].type = DB1_INT; query_vals[n_query_cols].nul = 0; - query_vals[n_query_cols].val.int_val = expires+(int)time(NULL); + query_vals[n_query_cols].val.int_val = expires; n_query_cols++; if (kz_pa_dbf.use_table(kz_pa_db, &kz_presentity_table) < 0) @@ -173,7 +170,7 @@ int kz_pua_publish_presence_to_presentity(struct json_object *json_obj) { str activity = str_init(""); str note = str_init("Idle"); str status = str_presence_status_online; - int expires = dbk_presence_expires; + int expires = 0; char *body = (char *)pkg_malloc(PRESENCE_BODY_BUFFER_SIZE); if(body == NULL) { @@ -197,6 +194,8 @@ int kz_pua_publish_presence_to_presentity(struct json_object *json_obj) { struct json_object* ExpiresObj = json_object_object_get(json_obj, BLF_JSON_EXPIRES); if(ExpiresObj != NULL) { expires = json_object_get_int(ExpiresObj); + if(expires > 0) + expires += (int)time(NULL); } if (!from_user.len || !to_user.len || !state.len) { @@ -250,7 +249,7 @@ int kz_pua_publish_mwi_to_presentity(struct json_object *json_obj) { mwi_new = { 0, 0 }, mwi_saved = { 0, 0 }, mwi_urgent = { 0, 0 }, mwi_urgent_saved = { 0, 0 }, mwi_account = { 0, 0 }, mwi_body = { 0, 0 }; - int expires = dbk_mwi_expires; + int expires = 0; char *body = (char *)pkg_malloc(MWI_BODY_BUFFER_SIZE); if(body == NULL) { @@ -280,6 +279,8 @@ int kz_pua_publish_mwi_to_presentity(struct json_object *json_obj) { struct json_object* ExpiresObj = json_object_object_get(json_obj, BLF_JSON_EXPIRES); if(ExpiresObj != NULL) { expires = json_object_get_int(ExpiresObj); + if(expires > 0) + expires += (int)time(NULL); } sprintf(body, MWI_BODY, mwi_waiting.len, mwi_waiting.s, @@ -314,7 +315,7 @@ int kz_pua_publish_dialoginfo_to_presentity(struct json_object *json_obj) { char sender_buf[1024]; str sender = {0, 0}; str dialoginfo_body = {0 , 0}; - int expires = dbk_dialog_expires; + int expires = 0; str event = str_init("dialog"); int reset = 0; @@ -341,6 +342,8 @@ int kz_pua_publish_dialoginfo_to_presentity(struct json_object *json_obj) { struct json_object* ExpiresObj = json_object_object_get(json_obj, BLF_JSON_EXPIRES); if(ExpiresObj != NULL) { expires = json_object_get_int(ExpiresObj); + if(expires > 0) + expires += (int)time(NULL); } ExpiresObj = json_object_object_get(json_obj, "Flush-Level");

10 years, 2 months

git:lazedo/kazoo: kazoo : remove spaces between xml elements

by Luis Azedo

Module: sip-router Branch: lazedo/kazoo Commit: 3d8082cf1a1c0a24ab2693fd881a1beea87a7755 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=3d8082c… Author: lazedo <luis.azedo(a)factorlusitano.com> Committer: lazedo <luis.azedo(a)factorlusitano.com> Date: Fri Sep 12 20:43:46 2014 +0100 kazoo : remove spaces between xml elements --- modules/kazoo/defs.h | 78 +++++++++++++++++++++++++------------------------- 1 files changed, 39 insertions(+), 39 deletions(-) diff --git a/modules/kazoo/defs.h b/modules/kazoo/defs.h index 850cf4d..c4627d8 100644 --- a/modules/kazoo/defs.h +++ b/modules/kazoo/defs.h @@ -48,53 +48,53 @@ #define PRESENCE_BODY_BUFFER_SIZE 4096 #define MWI_BODY "Messages-Waiting: %.*s\r\nMessage-Account: %.*s\r\nVoice-Message: %.*s/%.*s (%.*s/%.*s)\r\n" -#define PRESENCE_BODY "<?xml version=\"1.0\" encoding=\"UTF-8\"?> \ +#define PRESENCE_BODY "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\ <presence xmlns=\"urn:ietf:params:xml:ns:pidf\" xmlns:dm=\"urn:ietf:params:xml:ns:pidf:data-model\" xmlns:rpid=\"urn:ietf:params:xml:ns:pidf:rpid\" xmlns:c=\"urn:ietf:params:xml:ns:pidf:cipid\" entity=\"%s\"> \ - <tuple xmlns=\"urn:ietf:params:xml:ns:pidf\" id=\"%s\"> \ - <status> \ - <basic>%s</basic> \ - </status> \ - </tuple> \ - <note xmlns=\"urn:ietf:params:xml:ns:pidf\">%s</note> \ - <dm:person xmlns:dm=\"urn:ietf:params:xml:ns:pidf:data-model\" xmlns:rpid=\"urn:ietf:params:xml:ns:pidf:rpid\" id=\"1\"> \ - <rpid:activities>%s</rpid:activities> \ - <dm:note>%s</dm:note> \ - </dm:person> \ +<tuple xmlns=\"urn:ietf:params:xml:ns:pidf\" id=\"%s\">\ +<status>\ +<basic>%s</basic>\ +</status>\ +</tuple>\ +<note xmlns=\"urn:ietf:params:xml:ns:pidf\">%s</note>\ +<dm:person xmlns:dm=\"urn:ietf:params:xml:ns:pidf:data-model\" xmlns:rpid=\"urn:ietf:params:xml:ns:pidf:rpid\" id=\"1\">\ +<rpid:activities>%s</rpid:activities>\ +<dm:note>%s</dm:note>\ +</dm:person>\ </presence>" -#define DIALOGINFO_EMPTY_BODY "<?xml version=\"1.0\" encoding=\"UTF-8\"?> \ +#define DIALOGINFO_EMPTY_BODY "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\ <dialog-info xmlns=\"urn:ietf:params:xml:ns:dialog-info\" version=\"1\" state=\"full\" entity=\"%.*s\"> \ - <dialog direction=\"initiator\"> \ - <state>terminated</state> \ - </dialog> \ +<dialog direction=\"initiator\">\ +<state>terminated</state>\ +</dialog>\ </dialog-info>" -#define DIALOGINFO_BODY "<?xml version=\"1.0\" encoding=\"UTF-8\"?> \ -<dialog-info xmlns=\"urn:ietf:params:xml:ns:dialog-info\" version=\"1\" state=\"full\" entity=\"%.*s\"> \ - <dialog id=\"%.*s\" call-id=\"%.*s\" local-tag=\"%.*s\" remote-tag=\"%.*s\" direction=\"%.*s\"> \ - <state>%.*s</state> \ - <local> \ - <identity>%.*s</identity> \ - <target uri=\"sip:%.*s\"/> \ - </local> \ - <remote> \ - <identity>%.*s</identity> \ - <target uri=\"sip:%.*s\"/> \ - </remote> \ - </dialog> \ +#define DIALOGINFO_BODY "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\ +<dialog-info xmlns=\"urn:ietf:params:xml:ns:dialog-info\" version=\"1\" state=\"full\" entity=\"%.*s\">\ +<dialog id=\"%.*s\" call-id=\"%.*s\" local-tag=\"%.*s\" remote-tag=\"%.*s\" direction=\"%.*s\">\ +<state>%.*s</state>\ +<local>\ +<identity>%.*s</identity>\ +<target uri=\"sip:%.*s\"/>\ +</local>\ +<remote>\ +<identity>%.*s</identity>\ +<target uri=\"sip:%.*s\"/>\ +</remote>\ +</dialog>\ </dialog-info>" -#define DIALOGINFO_BODY_2 "<?xml version=\"1.0\" encoding=\"UTF-8\"?> \ -<dialog-info xmlns=\"urn:ietf:params:xml:ns:dialog-info\" version=\"1\" state=\"full\" entity=\"%.*s\"> \ - <dialog id=\"%.*s\" call-id=\"%.*s\" local-tag=\"%.*s\" remote-tag=\"%.*s\" direction=\"%.*s\"> \ - <state>%.*s</state> \ - <local> \ - <identity>%.*s</identity> \ - </local> \ - <remote> \ - <identity>%.*s</identity> \ - </remote> \ - </dialog> \ +#define DIALOGINFO_BODY_2 "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\ +<dialog-info xmlns=\"urn:ietf:params:xml:ns:dialog-info\" version=\"1\" state=\"full\" entity=\"%.*s\">\ +<dialog id=\"%.*s\" call-id=\"%.*s\" local-tag=\"%.*s\" remote-tag=\"%.*s\" direction=\"%.*s\">\ +<state>%.*s</state>\ +<local>\ +<identity>%.*s</identity>\ +</local>\ +<remote>\ +<identity>%.*s</identity>\ +</remote>\ +</dialog>\ </dialog-info>" #define json_extract_field(json_name, field) do { \

10 years, 2 months

git:master: dialog: fix warning: unused variable [-Wunused-variable]

by Ovidiu Sas

Module: sip-router Branch: master Commit: cc7b8a9a050afe245831c20356b1000e09b6e749 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=cc7b8a9… Author: Ovidiu Sas <osas(a)voipembedded.com> Committer: Ovidiu Sas <osas(a)voipembedded.com> Date: Fri Sep 12 21:13:14 2014 -0400 dialog: fix warning: unused variable [-Wunused-variable] --- modules/dialog/dlg_profile.c | 3 --- 1 files changed, 0 insertions(+), 3 deletions(-) diff --git a/modules/dialog/dlg_profile.c b/modules/dialog/dlg_profile.c index 436c9fe..69f1788 100644 --- a/modules/dialog/dlg_profile.c +++ b/modules/dialog/dlg_profile.c @@ -448,7 +448,6 @@ static void link_profile(struct dlg_profile_link *linker, str *vkey) { unsigned int hash; struct dlg_profile_entry *p_entry; - struct dlg_entry *d_entry; /* calculate the hash position */ hash = calc_hash_profile(&linker->hash_linker.value, vkey, linker->profile); @@ -477,8 +476,6 @@ static void link_profile(struct dlg_profile_link *linker, str *vkey) */ static void link_dlg_profile(struct dlg_profile_link *linker, struct dlg_cell *dlg) { - unsigned int hash; - struct dlg_profile_entry *p_entry; struct dlg_entry *d_entry; /* add the linker to the dialog */

10 years, 2 months

[tracker] Comment added: coredump when invoking 'kamcmd ul.add ...' with path parameter set to 's:0' and debug level >= 3

by sip-router

THIS IS AN AUTOMATED MESSAGE, DO NOT REPLY. The following task has a new comment added: FS#467 - coredump when invoking 'kamcmd ul.add ...' with path parameter set to 's:0' and debug level >= 3 User who did this - Thomas Arimont (topotomaso) ---------- Yes, you're right. I'm sorry. ---------- More information can be found at the following URL: http://sip-router.org/tracker/index.php?do=details&task_id=467#comment1621 You are receiving this message because you have requested it from the Flyspray bugtracking system. If you did not expect this message or don't want to receive mails in future, you can change your notification settings at the URL shown above.

10 years, 2 months

git:master: git failed to do fast forward and rebase to avoid the merge notification

by Daniel-Constantin Mierla

Module: sip-router Branch: master Commit: 19ceb74638b7e53fbe6d01a7b51ac07470738d42 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=19ceb74… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Fri Sep 12 20:44:08 2014 +0200 git failed to do fast forward and rebase to avoid the merge notification Merge branch 'master' of ssh://git.sip-router.org/kamailio * 'master' of ssh://git.sip-router.org/kamailio: Rollback accidental changes from commit (74f53b7d7f6ff00144152aff453e6b388447320c) pkg/kamailio/deb: update to 4.2.0~pre0 ---

10 years, 2 months

git:master: usrloc: safety check for debug message printing path value from rpc add command

by Daniel-Constantin Mierla

Module: sip-router Branch: master Commit: b1ba03f1fe41522b62aa727966c4dec3062cbbb9 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=b1ba03f… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Fri Sep 12 20:41:55 2014 +0200 usrloc: safety check for debug message printing path value from rpc add command - reported and patch by Thomas Arimont, FS#467 --- modules/usrloc/ul_rpc.c | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/modules/usrloc/ul_rpc.c b/modules/usrloc/ul_rpc.c index 50e5343..938328e 100644 --- a/modules/usrloc/ul_rpc.c +++ b/modules/usrloc/ul_rpc.c @@ -552,7 +552,7 @@ static void ul_rpc_add(rpc_t* rpc, void* ctx) } LM_DBG("ret: %d table:%.*s aor:%.*s contact:%.*s expires:%d dtemp:%f path:%.*s flags:%d bflags:%d methods:%d\n", ret, table.len, table.s, aor.len, aor.s, contact.len, contact.s, - (int) ci.expires, dtemp, ci.path->len, ci.path->s, ci.flags, ci.cflags, (int) ci.methods); + (int) ci.expires, dtemp, (ci.path)?ci.path->len:0, (ci.path && ci.path->s)?ci.path->s:"", ci.flags, ci.cflags, (int) ci.methods); if ( ret != 9) { rpc->fault(ctx, 500, "Not enough parameters or wrong format"); return;

10 years, 2 months

[tracker] Comment added: coredump when invoking 'kamcmd ul.add ...' with path parameter set to 's:0' and debug level >= 3

by sip-router

THIS IS AN AUTOMATED MESSAGE, DO NOT REPLY. The following task has a new comment added: FS#467 - coredump when invoking 'kamcmd ul.add ...' with path parameter set to 's:0' and debug level >= 3 User who did this - Daniel-Constantin Mierla (miconda) ---------- I assume 'ci.patch' is having a typo and you refer to 'ci.path', right? I am going to apply the patch. ---------- More information can be found at the following URL: http://sip-router.org/tracker/index.php?do=details&task_id=467#comment1620 You are receiving this message because you have requested it from the Flyspray bugtracking system. If you did not expect this message or don't want to receive mails in future, you can change your notification settings at the URL shown above.

10 years, 2 months

[tracker] Comment added: coredump when invoking 'kamcmd ul.add ...' with path parameter set to 's:0' and debug level >= 3 (Attachment added)

by sip-router

THIS IS AN AUTOMATED MESSAGE, DO NOT REPLY. The following task has a new comment added: FS#467 - coredump when invoking 'kamcmd ul.add ...' with path parameter set to 's:0' and debug level >= 3 User who did this - Thomas Arimont (topotomaso) ---------- It is even worser. In the case I've described ci.patch is already NULL. See patch proposal. ---------- One or more files have been attached. More information can be found at the following URL: http://sip-router.org/tracker/index.php?do=details&task_id=467#comment1619 You are receiving this message because you have requested it from the Flyspray bugtracking system. If you did not expect this message or don't want to receive mails in future, you can change your notification settings at the URL shown above.

10 years, 2 months

git:lazedo/kazoo: kazoo : remove dead code and unused var warnings

by Luis Azedo

Module: sip-router Branch: lazedo/kazoo Commit: 0ac16c52d49ef04f4a3054381efae2e83afa4258 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=0ac16c5… Author: lazedo <luis.azedo(a)factorlusitano.com> Committer: lazedo <luis.azedo(a)factorlusitano.com> Date: Fri Sep 12 19:24:47 2014 +0100 kazoo : remove dead code and unused var warnings --- modules/kazoo/kz_amqp.c | 40 +--------------------------------------- 1 files changed, 1 insertions(+), 39 deletions(-) diff --git a/modules/kazoo/kz_amqp.c b/modules/kazoo/kz_amqp.c index 974673a..c13f8a4 100644 --- a/modules/kazoo/kz_amqp.c +++ b/modules/kazoo/kz_amqp.c @@ -856,7 +856,7 @@ int kz_amqp_query_ex(struct sip_msg* msg, char* exchange, char* routing_key, cha return -1; } - char* strjson = json_object_to_json_string(ret); + char* strjson = (char*)json_object_to_json_string(ret); int len = strlen(strjson); char* value = pkg_malloc(len+1); memcpy(value, strjson, len); @@ -1163,43 +1163,6 @@ int get_channel_index() { return get_channel_index(); } -/* -int kz_amqp_unbind_channel(kz_amqp_conn_ptr kz_conn, int idx ) -{ - kz_amqp_bind_ptr reply = channels[idx].targeted; - int ret = 0; - if(reply == NULL) { - LM_ERR("unbinding channel NULL??\n"); - ret = -1; - goto error; - } - - if (amqp_basic_cancel(kz_conn->conn, channels[idx].channel, amqp_empty_bytes) < 0 - || kz_amqp_error("Canceling", amqp_get_rpc_reply(kz_conn->conn))) - { - ret = -RET_AMQP_ERROR; - goto error; - } - - if (amqp_queue_unbind(kz_conn->conn, channels[idx].channel, reply->queue, reply->exchange, reply->routing_key, amqp_empty_table) < 0 - || kz_amqp_error("Unbinding queue", amqp_get_rpc_reply(kz_conn->conn))) - { - ret = -RET_AMQP_ERROR; - goto error; - } - - amqp_queue_delete(kz_conn->conn, channels[idx].channel, reply->queue, 0, 0); - - kz_amqp_free_binding(reply); - channels[idx].targeted = NULL; - channels[idx].state = KZ_AMQP_FREE; - -error: - return ret; -} -*/ - - int kz_amqp_bind_targeted_channel(kz_amqp_conn_ptr kz_conn, int loopcount, int idx ) { kz_amqp_bind_ptr bind = NULL; @@ -1551,7 +1514,6 @@ int consumer = 1; void kz_amqp_send_consumer_event_ex(char* payload, char* event_key, char* event_subkey, amqp_channel_t channel, uint64_t delivery_tag, int nextConsumer) { - int len = 0; kz_amqp_consumer_delivery_ptr ptr = (kz_amqp_consumer_delivery_ptr) shm_malloc(sizeof(kz_amqp_consumer_delivery)); if(ptr == NULL) { LM_ERR("NO MORE SHARED MEMORY!");

10 years, 2 months

← Newer
1
...
14
15
16
17
18
19
20
...
38
Older →

Jump to page:

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev September 2014