amass/ZLMediaKit
1
0
Fork 0
mirror of https://github.com/ZLMediaKit/ZLMediaKit.git synced 2024-11-22 19:00:01 +08:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

优化rtsp性能

Browse Source
This commit is contained in:
xia-chu 2021-02-02 10:33:56 +08:00
parent e4126809a6
commit 1539e4ed60
2 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Rtsp/RtspPusher.cpp
View File

@ -398,8 +398,7 @@ void RtspPusher::sendRtpPacket(const RtspMediaSource::RingDataType &pkt) {
if (++i == size) {
setSendFlushFlag(true);
}
BufferRtp::Ptr buffer(new BufferRtp(rtp));
send(std::move(buffer));
send(rtp);
});
break;
}
@ -416,8 +415,7 @@ void RtspPusher::sendRtpPacket(const RtspMediaSource::RingDataType &pkt) {
return;
}
BufferRtp::Ptr buffer(new BufferRtp(rtp, 4));
pSock->send(std::move(buffer), nullptr, 0, ++i == size);
pSock->send(std::make_shared<BufferRtp>(rtp, RtpPacket::kRtpTcpHeaderSize), nullptr, 0, ++i == size);
});
break;
}

5
src/Rtsp/RtspSession.cpp
View File

@ -1178,9 +1178,8 @@ void RtspSession::sendRtpPacket(const RtspMediaSource::RingDataType &pkt) {
shutdown(SockException(Err_shutdown, "udp sock not opened yet"));
return;
}
BufferRtp::Ptr buffer(new BufferRtp(rtp, 4));
_bytes_usage += buffer->size();
pSock->send(std::move(buffer), nullptr, 0, ++i == size);
_bytes_usage += rtp->size() - RtpPacket::kRtpTcpHeaderSize;
pSock->send(std::make_shared<BufferRtp>(rtp, RtpPacket::kRtpTcpHeaderSize), nullptr, 0, ++i == size);
});
}
break;