Module: kamailio Branch: master Commit: 56a946df3f4b6fc2666a5eb7588e6fb986ac3b2a URL: https://github.com/kamailio/kamailio/commit/56a946df3f4b6fc2666a5eb7588e6fb986ac3b2a
Author: Stefan Mititelu <[email protected]> Committer: Daniel-Constantin Mierla <[email protected]> Date: 2026-05-11T21:34:53+02:00 rtpengine: add new modparam dmq_peer_id --- Modified: src/modules/rtpengine/doc/rtpengine_admin.xml Modified: src/modules/rtpengine/rtpengine.c Modified: src/modules/rtpengine/rtpengine_dmq.c --- Diff: https://github.com/kamailio/kamailio/commit/56a946df3f4b6fc2666a5eb7588e6fb986ac3b2a.diff Patch: https://github.com/kamailio/kamailio/commit/56a946df3f4b6fc2666a5eb7588e6fb986ac3b2a.patch --- diff --git a/src/modules/rtpengine/doc/rtpengine_admin.xml b/src/modules/rtpengine/doc/rtpengine_admin.xml index e239adc09f2..bd34a0e6847 100644 --- a/src/modules/rtpengine/doc/rtpengine_admin.xml +++ b/src/modules/rtpengine/doc/rtpengine_admin.xml @@ -2510,6 +2510,28 @@ modparam("rtpengine", "enable_dmq", 1) </para> </section> +<section id="rtpengine.p.dmq_peer_id"> + <title><varname>dmq_peer_id</varname> (string)</title> + <para> + The DMQ peer identifier for rtpengine replication. This allows + customizing the peer name used in DMQ communication, which can be useful + to avoid compatibility conflicts, and for a better partitioning. + </para> + <para> + <emphasis> + Default value is <quote>rtpengine</quote>. + </emphasis> + </para> + <example> + <title>Set <varname>dmq_peer_id</varname> parameter</title> + <programlisting format="linespecific"> +... +modparam("rtpengine", "dmq_peer_id", "rtpengine_6.1.1") +... +</programlisting> + </example> +</section> + <section> <title>Functions</title> <section id="rtpengine.f.set_rtpengine_set"> diff --git a/src/modules/rtpengine/rtpengine.c b/src/modules/rtpengine/rtpengine.c index b10784550b0..88958fbafe4 100644 --- a/src/modules/rtpengine/rtpengine.c +++ b/src/modules/rtpengine/rtpengine.c @@ -426,6 +426,7 @@ int dtmf_event_rt = -1; /* default disabled */ static int rtpengine_ping_mode = 1; static int rtpengine_ping_interval = 60; static int rtpengine_enable_dmq = 0; +str rtpengine_dmq_peer_id = str_init("rtpengine"); /* clang-format off */ typedef struct rtpp_set_link { @@ -700,6 +701,7 @@ static param_export_t params[] = { &side_B_mos_stats.average.samples_param}, {"wsapi", PARAM_STR, &_rtpe_wsapi}, + {"dmq_peer_id", PARAM_STR, &rtpengine_dmq_peer_id}, {0, 0, 0} }; diff --git a/src/modules/rtpengine/rtpengine_dmq.c b/src/modules/rtpengine/rtpengine_dmq.c index af47669f8e3..02f346431ba 100644 --- a/src/modules/rtpengine/rtpengine_dmq.c +++ b/src/modules/rtpengine/rtpengine_dmq.c @@ -31,6 +31,8 @@ static str rtpengine_dmq_500_rpl = str_init("Server Internal Error"); dmq_api_t rtpengine_dmqb; dmq_peer_t *rtpengine_dmq_peer = NULL; +extern str rtpengine_dmq_peer_id; + int rtpengine_dmq_request_sync(dmq_node_t *node); /** @@ -50,10 +52,8 @@ int rtpengine_dmq_init() not_peer.callback = rtpengine_dmq_handle_msg; not_peer.init_callback = rtpengine_dmq_request_sync; - not_peer.description.s = "rtpengine"; - not_peer.description.len = 9; - not_peer.peer_id.s = "rtpengine"; - not_peer.peer_id.len = 9; + not_peer.peer_id = rtpengine_dmq_peer_id; + not_peer.description = rtpengine_dmq_peer_id; rtpengine_dmq_peer = rtpengine_dmqb.register_dmq_peer(¬_peer); if(!rtpengine_dmq_peer) { LM_ERR("error in register_dmq_peer\n"); _______________________________________________ Kamailio - Development Mailing List -- [email protected] To unsubscribe send an email to [email protected] Important: keep the mailing list in the recipients, do not reply only to the sender!
