From 6ccbd3aafb4c418c28d26e2830e475cbbca90f64 Mon Sep 17 00:00:00 2001 From: sbkyy <135107730+sbkyy@users.noreply.github.com> Date: Sat, 26 Jul 2025 15:44:29 +0800 Subject: [PATCH] =?UTF-8?q?rtp=E7=BA=A7=E8=81=94=E7=BD=91=E7=BB=9C?= =?UTF-8?q?=E6=85=A2=E6=97=B6=E9=BB=98=E8=AE=A4=E4=B8=8D=E9=99=90=E5=88=B6?= =?UTF-8?q?=E6=BA=90=E7=AB=AF=E6=8E=A5=E6=94=B6=E7=BD=91=E9=80=9F=20(#4359?= =?UTF-8?q?)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/Common/MediaSource.h | 3 +++ src/Rtp/RtpSender.cpp | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/Common/MediaSource.h b/src/Common/MediaSource.h index 8b45a87f..8b2655b0 100644 --- a/src/Common/MediaSource.h +++ b/src/Common/MediaSource.h @@ -175,6 +175,9 @@ public: std::string recv_stream_app; std::string recv_stream_vhost; + + // rtp tcp模式发送时busy时, origin 接收限流, 默认不启用 + bool enable_origin_recv_limit = false; }; // 开始发送ps-rtp [AUTO-TRANSLATED:a51796fa] diff --git a/src/Rtp/RtpSender.cpp b/src/Rtp/RtpSender.cpp index be9adbf6..93a205de 100644 --- a/src/Rtp/RtpSender.cpp +++ b/src/Rtp/RtpSender.cpp @@ -451,7 +451,7 @@ void RtpSender::onFlushRtpList(shared_ptr> rtp_list) { } default: CHECK(0); } - if (_socket_rtp->sockType() == toolkit::SockNum::Sock_TCP && _socket_rtp->isSocketBusy() && _origin_socket) { + if (_args.enable_origin_recv_limit && _socket_rtp->sockType() == toolkit::SockNum::Sock_TCP && _socket_rtp->isSocketBusy() && _origin_socket) { _origin_socket->enableRecv(false); } });