From 1e14d296f5cb0f73317305350512d4b6e2003c48 Mon Sep 17 00:00:00 2001
From: xia-chu <771730766@qq.com>
Date: Sun, 20 Apr 2025 20:27:08 +0800
Subject: [PATCH] =?UTF-8?q?rtp=E7=BA=A7=E8=81=94=E9=80=9F=E5=BA=A6?=
 =?UTF-8?q?=E5=A4=AA=E6=85=A2=E6=97=B6=E4=B8=BB=E5=8A=A8=E9=99=90=E5=88=B6?=
 =?UTF-8?q?=E4=B8=8A=E6=B8=B8=E6=8E=A5=E6=94=B6=E9=80=9F=E5=BA=A6=203?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/Rtp/RtpSender.cpp | 20 ++++++++------------
 1 file changed, 8 insertions(+), 12 deletions(-)

diff --git a/src/Rtp/RtpSender.cpp b/src/Rtp/RtpSender.cpp
index 6db6c3f5..f6234e6f 100644
--- a/src/Rtp/RtpSender.cpp
+++ b/src/Rtp/RtpSender.cpp
@@ -36,19 +36,15 @@ RtpSender::~RtpSender() {
 }
 
 void RtpSender::startSend(const MediaSource &sender, const MediaSourceEvent::SendRtpArgs &args, const function<void(uint16_t local_port, const SockException &ex)> &cb){
-    try {
-        _origin_socket = dynamic_pointer_cast<Socket>(sender.getOriginSock());
-    } catch (...) {
-    }
+    auto origin_socket = sender.getOriginSock();
+    _origin_socket = dynamic_pointer_cast<Socket>(origin_socket);
     if (!_origin_socket) {
-        try {
-            auto process = dynamic_pointer_cast<RtpProcess>(sender.getOriginSock());
-            if (process) {
-                _origin_socket = process->getSock();
-            }
-        } catch (...) {
+        auto process = dynamic_pointer_cast<RtpProcess>(origin_socket);
+        if (process) {
+            _origin_socket = process->getSock();
         }
     }
+
     _args = args;
     if (!_interface) {
         // 重连时不重新创建对象  [AUTO-TRANSLATED:b788cd5d]
@@ -455,8 +451,8 @@ void RtpSender::onFlushRtpList(shared_ptr<List<Buffer::Ptr>> rtp_list) {
                 }
                 default: CHECK(0);
             }
-            if (_socket_rtp->sockType() == toolkit::SockNum::Sock_TCP && _socket_rtp->isSocketBusy()) {
-                _socket_rtp->enableRecv(false);
+            if (_socket_rtp->sockType() == toolkit::SockNum::Sock_TCP && _socket_rtp->isSocketBusy() && _origin_socket) {
+                _origin_socket->enableRecv(false);
             }
         });
     };