diff --git a/webrtc/WebRtcTransport.cpp b/webrtc/WebRtcTransport.cpp index fc3e5c9e..2f396374 100644 --- a/webrtc/WebRtcTransport.cpp +++ b/webrtc/WebRtcTransport.cpp @@ -313,6 +313,7 @@ void WebRtcTransportImp::onCreate(){ WebRtcTransportImp::WebRtcTransportImp(const EventPoller::Ptr &poller) : WebRtcTransport(poller) { InfoL << getIdentifier(); + _packet_pool.setSize(64); } WebRtcTransportImp::~WebRtcTransportImp() { @@ -329,7 +330,7 @@ void WebRtcTransportImp::onSendSockData(const char *buf, size_t len, struct sock WarnL << "send data failed:" << len; return; } - auto ptr = BufferRaw::create(); + auto ptr = _packet_pool.obtain(); ptr->assign(buf, len); //一次性发送一帧的rtp数据,提高网络io性能 _session->setSendFlushFlag(flush); diff --git a/webrtc/WebRtcTransport.h b/webrtc/WebRtcTransport.h index 45fd2e72..2879944a 100644 --- a/webrtc/WebRtcTransport.h +++ b/webrtc/WebRtcTransport.h @@ -214,8 +214,6 @@ struct WrappedRtpTrack : public WrappedMediaTrack { void inputRtp(const char *buf, size_t len, uint64_t stamp_ms, RtpHeader *rtp) override; }; - - class WebRtcTransportImp : public WebRtcTransport { public: using Ptr = std::shared_ptr; @@ -281,6 +279,8 @@ private: unordered_map _ssrc_to_track; //根据接收rtp的pt获取相关信息 unordered_map> _pt_to_track; + //循环池 + ResourcePool _packet_pool; }; class WebRtcTransportManager {