For #307, refine gperf api

trunk/scripts/perf_gso.py

@@ -35,16 +35,25 @@ f.close()
 print "Repsonse %s"%(s)
 
 obj = json.loads(s)
-keys = [1, 3, 5, 9, 16, 32, 64, 256, 1000]
+
+# 2, 3, 5, 9, 16, 32, 64, 128, 256
+keys = ['lt_2', 'lt_3', 'lt_5', 'lt_9', 'lt_16', 'lt_32', 'lt_64', 'lt_128', 'lt_256', 'gt_256']
 
 print ""
 print("AV---Frames"),
 for k in keys:
-    k2 = 'lt_%s'%(k)
+    k2 = '%s'%(k)
-    if 'frames' in obj['data']:
+    p = obj['data']['avframes']
-        p = obj['data']['frames']['msgs']
+    if k2 in p:
+        print(p[k2]),
     else:
-        p = obj['data']['writev']['msgs']
+        print(0),
+
+print ""
+print("RTC--Frames"),
+for k in keys:
+    k2 = '%s'%(k)
+    p = obj['data']['rtc']
     if k2 in p:
         print(p[k2]),
     else:
@@ -53,11 +62,18 @@ for k in keys:
 print ""
 print("RTP-Packets"),
 for k in keys:
-    k2 = 'lt_%s'%(k)
+    k2 = '%s'%(k)
-    if 'frames' in obj['data']:
+    p = obj['data']['rtp']
-        p = obj['data']['frames']['iovs']
+    if k2 in p:
-    else:
+        print(p[k2]),
-        p = obj['data']['writev']['iovs']
+    else:
+        print(0),
+
+print ""
+print("GSO-Packets"),
+for k in keys:
+    k2 = '%s'%(k)
+    p = obj['data']['gso']
     if k2 in p:
         print(p[k2]),
     else:

trunk/src/app/srs_app_http_api.cpp

@@ -1622,13 +1622,40 @@ srs_error_t SrsGoApiPerf::serve_http(ISrsHttpResponseWriter* w, ISrsHttpMessage*
         data->set("query", p);
 
         p->set("target", SrsJsonAny::str(target.c_str()));
-        p->set("help", SrsJsonAny::str("?target=frames|sendmmsg|gso"));
+        p->set("help", SrsJsonAny::str("?target=avframes|rtc|rtp|gso|writev_iovs|sendmmsg"));
     }
 
-    if (target.empty() || target == "frames") {
+    if (target.empty() || target == "avframes") {
         SrsJsonObject* p = SrsJsonAny::object();
-        data->set("frames", p);
+        data->set("avframes", p);
-        if ((err = stat->dumps_perf_writev(p)) != srs_success) {
+        if ((err = stat->dumps_perf_msgs(p)) != srs_success) {
+            int code = srs_error_code(err); srs_error_reset(err);
+            return srs_api_response_code(w, r, code);
+        }
+    }
+
+    if (target.empty() || target == "rtc") {
+        SrsJsonObject* p = SrsJsonAny::object();
+        data->set("rtc", p);
+        if ((err = stat->dumps_perf_rtc_packets(p)) != srs_success) {
+            int code = srs_error_code(err); srs_error_reset(err);
+            return srs_api_response_code(w, r, code);
+        }
+    }
+
+    if (target.empty() || target == "rtp") {
+        SrsJsonObject* p = SrsJsonAny::object();
+        data->set("rtp", p);
+        if ((err = stat->dumps_perf_rtp_packets(p)) != srs_success) {
+            int code = srs_error_code(err); srs_error_reset(err);
+            return srs_api_response_code(w, r, code);
+        }
+    }
+
+    if (target.empty() || target == "gso") {
+        SrsJsonObject* p = SrsJsonAny::object();
+        data->set("gso", p);
+        if ((err = stat->dumps_perf_gso(p)) != srs_success) {
             int code = srs_error_code(err); srs_error_reset(err);
             return srs_api_response_code(w, r, code);
         }
@@ -1643,10 +1670,10 @@ srs_error_t SrsGoApiPerf::serve_http(ISrsHttpResponseWriter* w, ISrsHttpMessage*
         }
     }
 
-    if (target.empty() || target == "gso") {
+    if (target.empty() || target == "writev_iovs") {
         SrsJsonObject* p = SrsJsonAny::object();
-        data->set("gso", p);
+        data->set("writev_iovs", p);
-        if ((err = stat->dumps_perf_gso(p)) != srs_success) {
+        if ((err = stat->dumps_perf_writev_iovs(p)) != srs_success) {
             int code = srs_error_code(err); srs_error_reset(err);
             return srs_api_response_code(w, r, code);
         }

trunk/src/app/srs_app_rtc_conn.cpp

@@ -649,7 +649,14 @@ srs_error_t SrsRtcSenderThread::cycle()
             srs_freep(msg);
         }
 
-        stat->perf_mw_on_msgs(msg_count, pkts.nn_bytes, pkts.nn_rtp_pkts);
+        // Stat the original RAW AV frame, maybe h264+aac.
+        stat->perf_on_msgs(msg_count);
+        // Stat the RTC packets, RAW AV frame, maybe h.264+opus.
+        stat->perf_on_rtc_packets(srs_max(pkts.nn_audios, pkts.nn_extras) + pkts.nn_videos);
+        // 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);
 
         pprint->elapse();
         if (pprint->can_print()) {
@@ -957,6 +964,9 @@ srs_error_t SrsRtcSenderThread::send_packets_gso(SrsUdpMuxSocket* skt, SrsRtcPac
         if (do_send) {
             for (int j = 0; j < (int)mhdr->msg_hdr.msg_iovlen; j++) {
                 iovec* iov = mhdr->msg_hdr.msg_iov + j;
+                if (iov->iov_len <= 0) {
+                    break;
+                }
                 srs_trace("%s #%d/%d/%d, %d bytes, size %d/%d", (use_gso? "GSO":"RAW"), j, gso_cursor + 1,
                     mhdr->msg_hdr.msg_iovlen, iov->iov_len, gso_size, gso_encrypt);
             }
@@ -1004,7 +1014,7 @@ srs_error_t SrsRtcSenderThread::send_packets_gso(SrsUdpMuxSocket* skt, SrsRtcPac
     }
 
 #if defined(SRS_DEBUG)
-    srs_trace("GSO packets, rtp %d/%d, videos %d/%d", packets.packets.size(),
+    srs_trace("Summary packets, rtp %d/%d, videos %d/%d, audios %d/%d", packets.packets.size(),
         packets.nn_rtp_pkts, packets.nn_videos, packets.nn_samples, packets.nn_audios, packets.nn_extras);
 #endif
 

trunk/src/app/srs_app_statistic.cpp

@@ -267,6 +267,8 @@ SrsStatistic::SrsStatistic()
     perf_msgs = new SrsStatisticCategory();
     perf_sendmmsg = new SrsStatisticCategory();
     perf_gso = new SrsStatisticCategory();
+    perf_rtp = new SrsStatisticCategory();
+    perf_rtc = new SrsStatisticCategory();
 }
 
 SrsStatistic::~SrsStatistic()
@@ -305,6 +307,8 @@ SrsStatistic::~SrsStatistic()
     srs_freep(perf_msgs);
     srs_freep(perf_sendmmsg);
     srs_freep(perf_gso);
+    srs_freep(perf_rtp);
+    srs_freep(perf_rtc);
 }
 
 SrsStatistic* SrsStatistic::instance()
@@ -585,272 +589,131 @@ srs_error_t SrsStatistic::dumps_clients(SrsJsonArray* arr, int start, int count)
     return err;
 }
 
-void SrsStatistic::perf_mw_on_msgs(int nb_msgs, int bytes_msgs, int nb_iovs)
+void SrsStatistic::perf_on_msgs(int nb_msgs)
 {
-    // For perf msgs, the nb_msgs stat.
+    perf_on_packets(perf_msgs, nb_msgs);
-    //      a: <3
-    //      b: <5
-    //      c: <9
-    //      d: <16
-    //      e: <32
-    //      f: <64
-    //      g: <128
-    //      h: <256
-    //      i: <1000
-    //      j: >=1000
-    if (nb_msgs < 3) {
-        perf_msgs->a++;
-    } else if (nb_msgs < 5) {
-        perf_msgs->b++;
-    } else if (nb_msgs < 9) {
-        perf_msgs->c++;
-    } else if (nb_msgs < 16) {
-        perf_msgs->d++;
-    } else if (nb_msgs < 32) {
-        perf_msgs->e++;
-    } else if (nb_msgs < 64) {
-        perf_msgs->f++;
-    } else if (nb_msgs < 128) {
-        perf_msgs->g++;
-    } else if (nb_msgs < 256) {
-        perf_msgs->h++;
-    } else if (nb_msgs < 1000) {
-        perf_msgs->i++;
-    } else {
-        perf_msgs->j++;
 }
 
-    // For perf iovs, the nb_iovs stat.
+srs_error_t SrsStatistic::dumps_perf_msgs(SrsJsonObject* obj)
-    //      a: <3
-    //      b: <5
-    //      c: <9
-    //      d: <16
-    //      e: <32
-    //      f: <64
-    //      g: <128
-    //      h: <256
-    //      i: <1000
-    //      j: >=1000
-    if (nb_iovs < 3) {
-        perf_iovs->a++;
-    } else if (nb_iovs < 5) {
-        perf_iovs->b++;
-    } else if (nb_iovs < 9) {
-        perf_iovs->c++;
-    } else if (nb_iovs < 16) {
-        perf_iovs->d++;
-    } else if (nb_iovs < 32) {
-        perf_iovs->e++;
-    } else if (nb_iovs < 64) {
-        perf_iovs->f++;
-    } else if (nb_iovs < 128) {
-        perf_iovs->g++;
-    } else if (nb_iovs < 256) {
-        perf_iovs->h++;
-    } else if (nb_iovs < 1000) {
-        perf_iovs->i++;
-    } else {
-        perf_iovs->j++;
-    }
-}
-
-srs_error_t SrsStatistic::dumps_perf_writev(SrsJsonObject* obj)
 {
-    srs_error_t err = srs_success;
+    return dumps_perf(perf_msgs, obj);
-
-    if (true) {
-        SrsJsonObject* p = SrsJsonAny::object();
-        obj->set("msgs", p);
-
-        // For perf msgs, the nb_msgs stat.
-        //      a: <3
-        //      b: <5
-        //      c: <9
-        //      d: <16
-        //      e: <32
-        //      f: <64
-        //      g: <128
-        //      h: <256
-        //      i: <1000
-        //      j: >=1000
-        if (perf_msgs->a) p->set("lt_3",        SrsJsonAny::integer(perf_msgs->a));
-        if (perf_msgs->b) p->set("lt_5",        SrsJsonAny::integer(perf_msgs->b));
-        if (perf_msgs->c) p->set("lt_9",        SrsJsonAny::integer(perf_msgs->c));
-        if (perf_msgs->d) p->set("lt_16",       SrsJsonAny::integer(perf_msgs->d));
-        if (perf_msgs->e) p->set("lt_32",       SrsJsonAny::integer(perf_msgs->e));
-        if (perf_msgs->f) p->set("lt_64",       SrsJsonAny::integer(perf_msgs->f));
-        if (perf_msgs->g) p->set("lt_128",      SrsJsonAny::integer(perf_msgs->g));
-        if (perf_msgs->h) p->set("lt_256",      SrsJsonAny::integer(perf_msgs->h));
-        if (perf_msgs->i) p->set("lt_1000",     SrsJsonAny::integer(perf_msgs->i));
-        if (perf_msgs->j) p->set("gt_1000",     SrsJsonAny::integer(perf_msgs->j));
 }
 
-    if (true) {
+void SrsStatistic::perf_on_rtc_packets(int nb_packets)
-        SrsJsonObject* p = SrsJsonAny::object();
-        obj->set("iovs", p);
-
-        // For perf iovs, the nb_iovs stat.
-        //      a: <3
-        //      b: <5
-        //      c: <9
-        //      d: <16
-        //      e: <32
-        //      f: <64
-        //      g: <128
-        //      h: <256
-        //      i: <1000
-        //      j: >=1000
-        if (perf_iovs->a) p->set("lt_3",        SrsJsonAny::integer(perf_iovs->a));
-        if (perf_iovs->b) p->set("lt_5",        SrsJsonAny::integer(perf_iovs->b));
-        if (perf_iovs->c) p->set("lt_9",        SrsJsonAny::integer(perf_iovs->c));
-        if (perf_iovs->d) p->set("lt_16",       SrsJsonAny::integer(perf_iovs->d));
-        if (perf_iovs->e) p->set("lt_32",       SrsJsonAny::integer(perf_iovs->e));
-        if (perf_iovs->f) p->set("lt_64",       SrsJsonAny::integer(perf_iovs->f));
-        if (perf_iovs->g) p->set("lt_128",      SrsJsonAny::integer(perf_iovs->g));
-        if (perf_iovs->h) p->set("lt_256",      SrsJsonAny::integer(perf_iovs->h));
-        if (perf_iovs->i) p->set("lt_1000",     SrsJsonAny::integer(perf_iovs->i));
-        if (perf_iovs->j) p->set("gt_1000",     SrsJsonAny::integer(perf_iovs->j));
-    }
-
-    return err;
-}
-
-void SrsStatistic::perf_sendmmsg_on_packets(int nb_msgs)
 {
-    // For perf msgs, the nb_msgs stat.
+    perf_on_packets(perf_rtc, nb_packets);
-    //      a: =1
-    //      b: <10
-    //      c: <100
-    //      d: <200
-    //      e: <300
-    //      f: <400
-    //      g: <500
-    //      h: <600
-    //      i: <1000
-    //      j: >=1000
-    if (nb_msgs == 1) {
-        perf_sendmmsg->a++;
-    } else if (nb_msgs < 10) {
-        perf_sendmmsg->b++;
-    } else if (nb_msgs < 100) {
-        perf_sendmmsg->c++;
-    } else if (nb_msgs < 200) {
-        perf_sendmmsg->d++;
-    } else if (nb_msgs < 300) {
-        perf_sendmmsg->e++;
-    } else if (nb_msgs < 400) {
-        perf_sendmmsg->f++;
-    } else if (nb_msgs < 500) {
-        perf_sendmmsg->g++;
-    } else if (nb_msgs < 600) {
-        perf_sendmmsg->h++;
-    } else if (nb_msgs < 1000) {
-        perf_sendmmsg->i++;
-    } else {
-        perf_sendmmsg->j++;
-    }
 }
 
-srs_error_t SrsStatistic::dumps_perf_sendmmsg(SrsJsonObject* obj)
+srs_error_t SrsStatistic::dumps_perf_rtc_packets(SrsJsonObject* obj)
 {
-    srs_error_t err = srs_success;
+    return dumps_perf(perf_rtc, obj);
-
-    if (true) {
-        SrsJsonObject* p = SrsJsonAny::object();
-        obj->set("msgs", p);
-
-        // For perf msgs, the nb_msgs stat.
-        //      a: =1
-        //      b: <10
-        //      c: <100
-        //      d: <200
-        //      e: <300
-        //      f: <400
-        //      g: <500
-        //      h: <600
-        //      i: <1000
-        //      j: >=1000
-        if (perf_sendmmsg->a) p->set("lt_2",      SrsJsonAny::integer(perf_sendmmsg->a));
-        if (perf_sendmmsg->b) p->set("lt_10",     SrsJsonAny::integer(perf_sendmmsg->b));
-        if (perf_sendmmsg->c) p->set("lt_100",    SrsJsonAny::integer(perf_sendmmsg->c));
-        if (perf_sendmmsg->d) p->set("lt_200",    SrsJsonAny::integer(perf_sendmmsg->d));
-        if (perf_sendmmsg->e) p->set("lt_300",    SrsJsonAny::integer(perf_sendmmsg->e));
-        if (perf_sendmmsg->f) p->set("lt_400",    SrsJsonAny::integer(perf_sendmmsg->f));
-        if (perf_sendmmsg->g) p->set("lt_500",    SrsJsonAny::integer(perf_sendmmsg->g));
-        if (perf_sendmmsg->h) p->set("lt_600",    SrsJsonAny::integer(perf_sendmmsg->h));
-        if (perf_sendmmsg->i) p->set("lt_1000",   SrsJsonAny::integer(perf_sendmmsg->i));
-        if (perf_sendmmsg->j) p->set("gt_1000",   SrsJsonAny::integer(perf_sendmmsg->j));
 }
 
-    return err;
+void SrsStatistic::perf_on_rtp_packets(int nb_packets)
-}
-
-void SrsStatistic::perf_gso_on_packets(int nb_msgs)
 {
-    // For perf msgs, the nb_msgs stat.
+    perf_on_packets(perf_rtp, nb_packets);
-    //      a: =1
-    //      b: <3
-    //      c: <6
-    //      d: <9
-    //      e: <16
-    //      f: <32
-    //      g: <64
-    //      h: <128
-    //      i: <512
-    //      j: >=512
-    if (nb_msgs == 1) {
-        perf_gso->a++;
-    } else if (nb_msgs < 3) {
-        perf_gso->b++;
-    } else if (nb_msgs < 6) {
-        perf_gso->c++;
-    } else if (nb_msgs < 9) {
-        perf_gso->d++;
-    } else if (nb_msgs < 16) {
-        perf_gso->e++;
-    } else if (nb_msgs < 32) {
-        perf_gso->f++;
-    } else if (nb_msgs < 64) {
-        perf_gso->g++;
-    } else if (nb_msgs < 128) {
-        perf_gso->h++;
-    } else if (nb_msgs < 512) {
-        perf_gso->i++;
-    } else {
-        perf_gso->j++;
 }
+
+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)
+{
+    perf_on_packets(perf_gso, nb_packets);
 }
 
 srs_error_t SrsStatistic::dumps_perf_gso(SrsJsonObject* obj)
 {
-    srs_error_t err = srs_success;
+    return dumps_perf(perf_gso, obj);
+}
 
-    if (true) {
+void SrsStatistic::perf_on_writev_iovs(int nb_iovs)
-        SrsJsonObject* p = SrsJsonAny::object();
+{
-        obj->set("msgs", p);
+    perf_on_packets(perf_iovs, nb_iovs);
+}
 
-        // For perf msgs, the nb_msgs stat.
+srs_error_t SrsStatistic::dumps_perf_writev_iovs(SrsJsonObject* obj)
-        //      a: =1
+{
+    return dumps_perf(perf_iovs, obj);
+}
+
+void SrsStatistic::perf_sendmmsg_on_packets(int nb_packets)
+{
+    perf_on_packets(perf_sendmmsg, nb_packets);
+}
+
+srs_error_t SrsStatistic::dumps_perf_sendmmsg(SrsJsonObject* obj)
+{
+    return dumps_perf(perf_sendmmsg, obj);
+}
+
+void SrsStatistic::perf_on_packets(SrsStatisticCategory* p, int nb_msgs)
+{
+    // The range for stat:
+    //      2, 3, 5, 9, 16, 32, 64, 128, 256
+    // that is:
+    //      a: <2
     //      b: <3
-        //      c: <6
+    //      c: <5
     //      d: <9
     //      e: <16
     //      f: <32
     //      g: <64
     //      h: <128
-        //      i: <512
+    //      i: <256
-        //      j: >=512
+    //      j: >=256
-        if (perf_gso->a) p->set("lt_2",     SrsJsonAny::integer(perf_gso->a));
+    if (nb_msgs < 2) {
-        if (perf_gso->b) p->set("lt_3",     SrsJsonAny::integer(perf_gso->b));
+        p->a++;
-        if (perf_gso->c) p->set("lt_6",     SrsJsonAny::integer(perf_gso->c));
+    } else if (nb_msgs < 3) {
-        if (perf_gso->d) p->set("lt_9",     SrsJsonAny::integer(perf_gso->d));
+        p->b++;
-        if (perf_gso->e) p->set("lt_16",    SrsJsonAny::integer(perf_gso->e));
+    } else if (nb_msgs < 5) {
-        if (perf_gso->f) p->set("lt_32",    SrsJsonAny::integer(perf_gso->f));
+        p->c++;
-        if (perf_gso->g) p->set("lt_64",    SrsJsonAny::integer(perf_gso->g));
+    } else if (nb_msgs < 9) {
-        if (perf_gso->h) p->set("lt_128",   SrsJsonAny::integer(perf_gso->h));
+        p->d++;
-        if (perf_gso->i) p->set("lt_512",   SrsJsonAny::integer(perf_gso->i));
+    } else if (nb_msgs < 16) {
-        if (perf_gso->j) p->set("gt_512",   SrsJsonAny::integer(perf_gso->j));
+        p->e++;
+    } else if (nb_msgs < 32) {
+        p->f++;
+    } else if (nb_msgs < 64) {
+        p->g++;
+    } else if (nb_msgs < 128) {
+        p->h++;
+    } else if (nb_msgs < 256) {
+        p->i++;
+    } else {
+        p->j++;
     }
+}
+
+srs_error_t SrsStatistic::dumps_perf(SrsStatisticCategory* p, SrsJsonObject* obj)
+{
+    srs_error_t err = srs_success;
+
+    // The range for stat:
+    //      2, 3, 5, 9, 16, 32, 64, 128, 256
+    // that is:
+    //      a: <2
+    //      b: <3
+    //      c: <5
+    //      d: <9
+    //      e: <16
+    //      f: <32
+    //      g: <64
+    //      h: <128
+    //      i: <256
+    //      j: >=256
+    if (p->a) obj->set("lt_2",    SrsJsonAny::integer(p->a));
+    if (p->b) obj->set("lt_3",    SrsJsonAny::integer(p->b));
+    if (p->c) obj->set("lt_5",    SrsJsonAny::integer(p->c));
+    if (p->d) obj->set("lt_9",    SrsJsonAny::integer(p->d));
+    if (p->e) obj->set("lt_16",   SrsJsonAny::integer(p->e));
+    if (p->f) obj->set("lt_32",   SrsJsonAny::integer(p->f));
+    if (p->g) obj->set("lt_64",   SrsJsonAny::integer(p->g));
+    if (p->h) obj->set("lt_128",  SrsJsonAny::integer(p->h));
+    if (p->i) obj->set("lt_256",  SrsJsonAny::integer(p->i));
+    if (p->j) obj->set("gt_256",  SrsJsonAny::integer(p->j));
 
     return err;
 }

trunk/src/app/srs_app_statistic.hpp

@@ -170,6 +170,8 @@ private:
     SrsStatisticCategory* perf_msgs;
     SrsStatisticCategory* perf_sendmmsg;
     SrsStatisticCategory* perf_gso;
+    SrsStatisticCategory* perf_rtp;
+    SrsStatisticCategory* perf_rtc;
 private:
     SrsStatistic();
     virtual ~SrsStatistic();
@@ -228,21 +230,39 @@ public:
     // @param count the max count of clients to dump.
     virtual srs_error_t dumps_clients(SrsJsonArray* arr, int start, int count);
 public:
-    // Stat for packets merged written, nb_msgs is the number of RTMP messages,
+    // Stat for packets merged written, nb_msgs is the number of RTMP messages.
-    // bytes_msgs is the total bytes of RTMP messages, nb_iovs is the total number of iovec.
+    // For example, publish by FFMPEG, Audio and Video frames.
-    virtual void perf_mw_on_msgs(int nb_msgs, int bytes_msgs, int nb_iovs);
+    virtual void perf_on_msgs(int nb_msgs);
-    // Dumps the perf statistic data for TCP writev, for performance analysis.
+    virtual srs_error_t dumps_perf_msgs(SrsJsonObject* obj);
-    virtual srs_error_t dumps_perf_writev(SrsJsonObject* obj);
 public:
-    // Stat for packets UDP sendmmsg, nb_msgs is the vlen for sendmmsg.
+    // Stat for packets merged written, nb_packets is the number of RTC packets.
-    virtual void perf_sendmmsg_on_packets(int nb_msgs);
+    // For example, a RTMP/AAC audio packet maybe transcoded to two RTC/opus packets.
-    // Dumps the perf statistic data for UDP sendmmsg, for performance analysis.
+    virtual void perf_on_rtc_packets(int nb_packets);
-    virtual srs_error_t dumps_perf_sendmmsg(SrsJsonObject* obj);
+    virtual srs_error_t dumps_perf_rtc_packets(SrsJsonObject* obj);
 public:
-    // Stat for packets UDP GSO, nb_msgs is the vlen for sendmmsg.
+    // Stat for packets merged written, nb_packets is the number of RTP packets.
-    virtual void perf_gso_on_packets(int nb_msgs);
+    // For example, a RTC/opus packet maybe package to three RTP packets.
+    virtual void perf_on_rtp_packets(int nb_packets);
+    // Dumps the perf statistic data for RTP packets, for performance analysis.
+    virtual srs_error_t dumps_perf_rtp_packets(SrsJsonObject* obj);
+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);
     // Dumps the perf statistic data for UDP GSO, for performance analysis.
     virtual srs_error_t dumps_perf_gso(SrsJsonObject* obj);
+public:
+    // Stat for TCP writev, nb_iovs is the total number of iovec.
+    virtual void perf_on_writev_iovs(int nb_iovs);
+    virtual srs_error_t dumps_perf_writev_iovs(SrsJsonObject* obj);
+public:
+    // Stat for packets UDP sendmmsg, nb_packets is the vlen for sendmmsg.
+    virtual void perf_sendmmsg_on_packets(int nb_packets);
+    // Dumps the perf statistic data for UDP sendmmsg, for performance analysis.
+    virtual srs_error_t dumps_perf_sendmmsg(SrsJsonObject* obj);
+private:
+    virtual void perf_on_packets(SrsStatisticCategory* p, int nb_msgs);
+    virtual srs_error_t dumps_perf(SrsStatisticCategory* p, SrsJsonObject* obj);
 private:
     virtual SrsStatisticVhost* create_vhost(SrsRequest* req);
     virtual SrsStatisticStream* create_stream(SrsStatisticVhost* vhost, SrsRequest* req);

trunk/src/protocol/srs_rtmp_stack.cpp

@@ -548,7 +548,8 @@ srs_error_t SrsProtocol::do_send_messages(SrsSharedPtrMessage** msgs, int nb_msg
 
                 // Notify about perf stat.
                 if (perf) {
-                    perf->perf_mw_on_msgs(nb_msgs_merged_written, bytes_msgs_merged_written, iov_index);
+                    perf->perf_on_msgs(nb_msgs_merged_written);
+                    perf->perf_on_writev_iovs(iov_index);
                     nb_msgs_merged_written = 0; bytes_msgs_merged_written = 0;
                 }
                 
@@ -576,7 +577,8 @@ srs_error_t SrsProtocol::do_send_messages(SrsSharedPtrMessage** msgs, int nb_msg
 
     // Notify about perf stat.
     if (perf) {
-        perf->perf_mw_on_msgs(nb_msgs_merged_written, bytes_msgs_merged_written, iov_index);
+        perf->perf_on_msgs(nb_msgs_merged_written);
+        perf->perf_on_writev_iovs(iov_index);
         nb_msgs_merged_written = 0; bytes_msgs_merged_written = 0;
     }
 

trunk/src/protocol/srs_rtmp_stack.hpp

@@ -155,8 +155,9 @@ public:
     virtual ~ISrsProtocolPerf();
 public:
     // Stat for packets merged written, nb_msgs is the number of RTMP messages,
-    // bytes_msgs is the total bytes of RTMP messages, nb_iovs is the total number of iovec.
+    virtual void perf_on_msgs(int nb_msgs) = 0;
-    virtual void perf_mw_on_msgs(int nb_msgs, int bytes_msgs, int nb_iovs) = 0;
+    // Stat for TCP writev, nb_iovs is the total number of iovec.
+    virtual void perf_on_writev_iovs(int nb_iovs) = 0;
 };
 
 // The protocol provides the rtmp-message-protocol services,