Skip to content

Commit 86fccbf

Browse files
committed
rtpengine: Update fd when node reconnects
1 parent cc6c368 commit 86fccbf

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

modules/rtpengine/rtpengine.c

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3130,9 +3130,12 @@ send_rtpe_command(struct rtpe_node *node, bencode_item_t *dict, int *outlen)
31303130
v[0].iov_base = gencookie();
31313131
v[0].iov_len = strlen(v[0].iov_base);
31323132
for (i = 0; i < rtpengine_retr; i++) {
3133-
if (rtpe_socks[node->idx] == -1 && !rtpengine_connect_node(node)) {
3134-
LM_ERR("cannot reconnect RTP engine socket!\n");
3135-
goto badproxy;
3133+
if (rtpe_socks[node->idx] == -1) {
3134+
if (!rtpengine_connect_node(node)) {
3135+
LM_ERR("cannot reconnect RTP engine socket!\n");
3136+
goto badproxy;
3137+
}
3138+
fds[0].fd = rtpe_socks[node->idx];
31363139
}
31373140
do {
31383141
len = writev(rtpe_socks[node->idx], v, vcnt);

0 commit comments

Comments
 (0)