external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

RTC: Stat the large buffer allocation

Browse source
This commit is contained in:
winlin 2021-02-26 18:32:29 +08:00
parent 439a7fa655
commit 65ba88de3f
2 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
trunk/src/app/srs_app_rtc_server.cpp
View file

@ -78,6 +78,7 @@ extern SrsPps* _srs_pps_rmnack;
extern SrsPps* _srs_pps_objs_rtps; extern SrsPps* _srs_pps_objs_rtps;
extern SrsPps* _srs_pps_objs_rraw; extern SrsPps* _srs_pps_objs_rraw;
extern SrsPps* _srs_pps_objs_rfua; extern SrsPps* _srs_pps_objs_rfua;
extern SrsPps* _srs_pps_objs_rbuf;
SrsRtcBlackhole::SrsRtcBlackhole() SrsRtcBlackhole::SrsRtcBlackhole()
{ {
@ -684,9 +685,9 @@ srs_error_t SrsRtcServer::notify(int type, srs_utime_t interval, srs_utime_t tic
static char buf[128]; static char buf[128];
string objs_desc; string objs_desc;
_srs_pps_objs_rtps->update(); _srs_pps_objs_rraw->update(); _srs_pps_objs_rfua->update(); _srs_pps_objs_rtps->update(); _srs_pps_objs_rraw->update(); _srs_pps_objs_rfua->update(); _srs_pps_objs_rbuf->update();
if (_srs_pps_objs_rtps->r10s() || _srs_pps_objs_rraw->r10s() || _srs_pps_objs_rfua->r10s()) { if (_srs_pps_objs_rtps->r10s() || _srs_pps_objs_rraw->r10s() || _srs_pps_objs_rfua->r10s() || _srs_pps_objs_rbuf->r10s()) {
snprintf(buf, sizeof(buf), ", objs=%d,%d,%d", _srs_pps_objs_rtps->r10s(), _srs_pps_objs_rraw->r10s(), _srs_pps_objs_rfua->r10s()); snprintf(buf, sizeof(buf), ", objs=%d,%d,%d,%d", _srs_pps_objs_rtps->r10s(), _srs_pps_objs_rraw->r10s(), _srs_pps_objs_rfua->r10s(), _srs_pps_objs_rbuf->r10s());
objs_desc = buf; objs_desc = buf;
} }

3
trunk/src/kernel/srs_kernel_rtc_rtp.cpp
View file

@ -39,6 +39,7 @@ using namespace std;
SrsPps* _srs_pps_objs_rtps = new SrsPps(); SrsPps* _srs_pps_objs_rtps = new SrsPps();
SrsPps* _srs_pps_objs_rraw = new SrsPps(); SrsPps* _srs_pps_objs_rraw = new SrsPps();
SrsPps* _srs_pps_objs_rfua = new SrsPps(); SrsPps* _srs_pps_objs_rfua = new SrsPps();
SrsPps* _srs_pps_objs_rbuf = new SrsPps();
/* @see https://tools.ietf.org/html/rfc1889#section-5.1 /* @see https://tools.ietf.org/html/rfc1889#section-5.1
0 1 2 3 0 1 2 3
@ -867,6 +868,8 @@ char* SrsRtpPacket2::wrap(int size)
srs_freep(cache_buffer_); srs_freep(cache_buffer_);
cache_buffer_ = new SrsBuffer(buf, size); cache_buffer_ = new SrsBuffer(buf, size);
++_srs_pps_objs_rbuf->sugar;
return buf; return buf;
} }