rtpproxy/rtpengine: update sockets when a node is forced

OpenSIPS · Jan 21, 2022 · 8b4f8d1 · 8b4f8d1
1 parent d28805f
commit 8b4f8d1
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/modules/rtpengine/rtpengine.c b/modules/rtpengine/rtpengine.c
@@ -2002,6 +2002,12 @@ static struct rtpe_node *get_rtpe_node(str *node, struct rtpe_set *set)
 {
 	struct rtpe_node *rnode;
 
+	/* check last list version */
+	if (my_version != *list_version && update_rtpengines() < 0) {
+		LM_ERR("cannot update rtpengines list\n");
+		return NULL;
+	}
+
 	for (rnode = set->rn_first; rnode; rnode = rnode->rn_next)
 		if (node->len == rnode->rn_url.len &&
 				!memcmp(node->s, rnode->rn_url.s, node->len)) {

diff --git a/modules/rtpproxy/rtpproxy.c b/modules/rtpproxy/rtpproxy.c
@@ -2342,6 +2342,12 @@ struct rtpp_node *get_rtpp_node(str *node)
 	struct rtpp_set *set;
 	struct rtpp_node *rnode;
 
+	/* check last list version */
+	if (my_version != *list_version && update_rtpp_proxies() < 0) {
+		LM_ERR("cannot update rtpp proxies list\n");
+		return 0;
+	}
+
 	/* if chosen a specific node, use it! */
 	for (set = (*rtpp_set_list)->rset_first; set; set = set->rset_next) {
 		if ((rnode = get_rtpp_node_from_set(node, set, 1)) != NULL)