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: Refine stat for total pkts.

Browse source
This commit is contained in:
winlin 2020-08-06 14:12:31 +08:00
parent b070e5aa05
commit a98187580f
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
trunk/src/app/srs_app_rtc_conn.cpp
View file

@ -366,6 +366,7 @@ srs_error_t SrsRtcPlayStream::cycle()
// TODO: FIXME: Use cache for performance? // TODO: FIXME: Use cache for performance?
vector<SrsRtpPacket2*> pkts; vector<SrsRtpPacket2*> pkts;
uint64_t total_pkts = 0;
if (_srs_rtc_hijacker) { if (_srs_rtc_hijacker) {
if ((err = _srs_rtc_hijacker->on_start_consume(session_, this, req_, consumer)) != srs_success) { if ((err = _srs_rtc_hijacker->on_start_consume(session_, this, req_, consumer)) != srs_success) {
@ -391,6 +392,7 @@ srs_error_t SrsRtcPlayStream::cycle()
// Update stats for session. // Update stats for session.
session_->stat_->nn_out_rtp += msg_count; session_->stat_->nn_out_rtp += msg_count;
total_pkts += msg_count;
// Send-out all RTP packets and do cleanup. // Send-out all RTP packets and do cleanup.
// TODO: FIXME: Handle error. // TODO: FIXME: Handle error.
@ -421,7 +423,7 @@ srs_error_t SrsRtcPlayStream::cycle()
if (pprint->can_print()) { if (pprint->can_print()) {
// TODO: FIXME: Print stat like frame/s, packet/s, loss_packets. // TODO: FIXME: Print stat like frame/s, packet/s, loss_packets.
srs_trace("-> RTC PLAY %d msgs, %d/%d packets, %d audios, %d extras, %d videos, %d samples, %d/%d/%d bytes, %d pad, %d/%d cache", srs_trace("-> RTC PLAY %d msgs, %d/%d packets, %d audios, %d extras, %d videos, %d samples, %d/%d/%d bytes, %d pad, %d/%d cache",
msg_count, msg_count, info.nn_rtp_pkts, info.nn_audios, info.nn_extras, info.nn_videos, info.nn_samples, info.nn_bytes, total_pkts, msg_count, info.nn_rtp_pkts, info.nn_audios, info.nn_extras, info.nn_videos, info.nn_samples, info.nn_bytes,
info.nn_rtp_bytes, info.nn_padding_bytes, info.nn_paddings, msg_count, msg_count); info.nn_rtp_bytes, info.nn_padding_bytes, info.nn_paddings, msg_count, msg_count);
} }
} }