From ce4123f250faf06fc429db92889e5101daf2e074 Mon Sep 17 00:00:00 2001
From: "Alex.CR" <shi.weibd@hotmail.com>
Date: Thu, 13 Feb 2020 03:02:54 -0600
Subject: [PATCH] rtmp tcp listen port bugs in srt2rtmp  (#1602)

* update srt2rtmp about rtmp listen tcp port

* update srt2rtmp about rtmp listen tcp port
---
 trunk/src/srt/srt_to_rtmp.cpp | 16 ++++++++++++++--
 1 file changed, 14 insertions(+), 2 deletions(-)

diff --git a/trunk/src/srt/srt_to_rtmp.cpp b/trunk/src/srt/srt_to_rtmp.cpp
index 729e3e970..13e83056d 100644
--- a/trunk/src/srt/srt_to_rtmp.cpp
+++ b/trunk/src/srt/srt_to_rtmp.cpp
@@ -4,6 +4,7 @@
 #include <srs_kernel_log.hpp>
 #include <srs_kernel_error.hpp>
 #include <srs_kernel_buffer.hpp>
+#include <srs_kernel_utility.hpp>
 #include <srs_app_rtmp_conn.hpp>
 #include <srs_app_config.hpp>
 #include <srs_kernel_stream.hpp>
@@ -207,11 +208,22 @@ rtmp_client::rtmp_client(std::string key_path):_key_path(key_path)
     }
     char url_sz[128];
     
+    std::vector<std::string> ip_ports = _srs_config->get_listens();
+    int port = 0;
+    std::string ip;
+
+    for (auto item : ip_ports) {
+        srs_parse_endpoint(item, ip, port);
+        if (port != 0) {
+            break;
+        }
+    }
+    port = (port == 0) ? 1935 : port;
     if (_vhost == DEF_VHOST) {
-        sprintf(url_sz, "rtmp://127.0.0.1/%s/%s",
+        sprintf(url_sz, "rtmp://127.0.0.1:%d/%s/%s", port,
             _appname.c_str(), _streamname.c_str());
     } else {
-        sprintf(url_sz, "rtmp://127.0.0.1/%s?vhost=%s/%s",
+        sprintf(url_sz, "rtmp://127.0.0.1:%d/%s?vhost=%s/%s", port,
             _appname.c_str(), _vhost.c_str(), _streamname.c_str());
     }