diff --git a/src/Rtp/RtpServer.cpp b/src/Rtp/RtpServer.cpp index d2356a86..53dd5b30 100644 --- a/src/Rtp/RtpServer.cpp +++ b/src/Rtp/RtpServer.cpp @@ -125,8 +125,8 @@ void RtpServer::start(uint16_t local_port, const string &stream_id, bool enable RtcpHelper::Ptr helper = std::make_shared(std::move(rtcp_socket), 90000); helper->startRtcp(); rtp_socket->setOnRead([rtp_socket, process, helper](const Buffer::Ptr &buf, struct sockaddr *addr, int addr_len) { - helper->onRecvRtp(buf, addr, addr_len); process->inputRtp(true, rtp_socket, buf->data(), buf->size(), addr); + helper->onRecvRtp(buf, addr, addr_len); }); } else { #if 1