Fix GSO stat bug

pull/1753/head
winlin 5 years ago
parent 649f2042da
commit dd7b5cf53f

@ -656,7 +656,7 @@ srs_error_t SrsRtcSenderThread::cycle()
// Stat the RAW RTP packets, which maybe group by GSO.
stat->perf_on_rtp_packets(pkts.packets.size());
// Stat the RTP packets going into kernel.
stat->perf_gso_on_packets(pkts.nn_rtp_pkts);
stat->perf_on_gso_packets(pkts.nn_rtp_pkts);
pprint->elapse();
if (pprint->can_print()) {
@ -1836,7 +1836,6 @@ srs_error_t SrsUdpMuxSender::cycle()
mmsghdr* p = &hotspot[0]; mmsghdr* end = p + pos;
for (p = &hotspot[0]; p < end; p++) {
if (!p->msg_len) {
stat->perf_gso_on_packets(1);
continue;
}
@ -1845,7 +1844,6 @@ srs_error_t SrsUdpMuxSender::cycle()
p->msg_len = 0;
gso_pos++; nn_gso_msgs++; nn_gso_iovs += real_iovs; gso_iovs += real_iovs;
stat->perf_gso_on_packets(real_iovs);
}
}

@ -619,7 +619,7 @@ srs_error_t SrsStatistic::dumps_perf_rtp_packets(SrsJsonObject* obj)
return dumps_perf(perf_rtp, obj);
}
void SrsStatistic::perf_gso_on_packets(int nb_packets)
void SrsStatistic::perf_on_gso_packets(int nb_packets)
{
perf_on_packets(perf_gso, nb_packets);
}

@ -248,7 +248,7 @@ public:
public:
// Stat for packets UDP GSO, nb_packets is the merged RTP packets.
// For example, three RTP/audio packets maybe GSO to one msghdr.
virtual void perf_gso_on_packets(int nb_packets);
virtual void perf_on_gso_packets(int nb_packets);
// Dumps the perf statistic data for UDP GSO, for performance analysis.
virtual srs_error_t dumps_perf_gso(SrsJsonObject* obj);
public:

Loading…
Cancel
Save