From 3b31aae2f9e51920b92486338bbea920b7c97a5e Mon Sep 17 00:00:00 2001 From: lazedo Date: Fri, 5 Jun 2020 11:49:24 +0000 Subject: [PATCH] add internal listener socket to dispatcher --- kamailio/dispatcher-role-5.3.cfg | 11 +++++++++-- kamailio/dispatcher-role-5.4.cfg | 11 +++++++++-- 2 files changed, 18 insertions(+), 4 deletions(-) diff --git a/kamailio/dispatcher-role-5.3.cfg b/kamailio/dispatcher-role-5.3.cfg index 41ea4fc..f7d7aab 100644 --- a/kamailio/dispatcher-role-5.3.cfg +++ b/kamailio/dispatcher-role-5.3.cfg @@ -240,8 +240,15 @@ route[DISPATCHER_CHECK_MEDIA_SERVER] if($var(Zone) != "MY_AMQP_ZONE") { $var(SetId) = 2; } + + #!ifdef WITH_INTERNAL_LISTENER + $var(dispatcher_socket) = $_s(socket=PORT_PROTO_INTERNAL_LISTENER;); + #!else + $var(dispatcher_socket) = ""; + #!endif + $var(flags) = KZ_DISPATCHER_ADD_FLAGS; - $var(attrs) = $_s(zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName)); + $var(attrs) = $_s($var(dispatcher_socket)zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName)); route_if_exists("DISPATCHER_CUSTOM_MEDIA_CHECK"); sql_query("exec", "KZQ_CHECK_MEDIA_SERVER_INSERT"); if($sqlrows(exec) > 0) { @@ -253,7 +260,7 @@ route[DISPATCHER_CHECK_MEDIA_SERVER] if($var(MediaIP) != "" && $var(MediaIP) != $(var(MediaUrl){uri.host})) { $var(MediaUrlBack) = $var(MediaUrl); $var(MediaUrl) = $_s($(var(MediaUrlBack){uri.scheme}):$var(MediaIP):$(var(MediaUrlBack){uri.port})); - $var(attrs) = $_s(zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName)); + $var(attrs) = $_s($var(dispatcher_socket)zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName)); $var(SetId) = $sel(cfg_get.kazoo.dispatcher_add_secondary_ip_group); route_if_exists("DISPATCHER_CUSTOM_MEDIA_CHECK"); sql_query("exec", "KZQ_CHECK_MEDIA_SERVER_INSERT"); diff --git a/kamailio/dispatcher-role-5.4.cfg b/kamailio/dispatcher-role-5.4.cfg index 41ea4fc..f7d7aab 100644 --- a/kamailio/dispatcher-role-5.4.cfg +++ b/kamailio/dispatcher-role-5.4.cfg @@ -240,8 +240,15 @@ route[DISPATCHER_CHECK_MEDIA_SERVER] if($var(Zone) != "MY_AMQP_ZONE") { $var(SetId) = 2; } + + #!ifdef WITH_INTERNAL_LISTENER + $var(dispatcher_socket) = $_s(socket=PORT_PROTO_INTERNAL_LISTENER;); + #!else + $var(dispatcher_socket) = ""; + #!endif + $var(flags) = KZ_DISPATCHER_ADD_FLAGS; - $var(attrs) = $_s(zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName)); + $var(attrs) = $_s($var(dispatcher_socket)zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName)); route_if_exists("DISPATCHER_CUSTOM_MEDIA_CHECK"); sql_query("exec", "KZQ_CHECK_MEDIA_SERVER_INSERT"); if($sqlrows(exec) > 0) { @@ -253,7 +260,7 @@ route[DISPATCHER_CHECK_MEDIA_SERVER] if($var(MediaIP) != "" && $var(MediaIP) != $(var(MediaUrl){uri.host})) { $var(MediaUrlBack) = $var(MediaUrl); $var(MediaUrl) = $_s($(var(MediaUrlBack){uri.scheme}):$var(MediaIP):$(var(MediaUrlBack){uri.port})); - $var(attrs) = $_s(zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName)); + $var(attrs) = $_s($var(dispatcher_socket)zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName)); $var(SetId) = $sel(cfg_get.kazoo.dispatcher_add_secondary_ip_group); route_if_exists("DISPATCHER_CUSTOM_MEDIA_CHECK"); sql_query("exec", "KZQ_CHECK_MEDIA_SERVER_INSERT");