From d6c01178707ec3c16b70a0326ca9008b4a3639cc Mon Sep 17 00:00:00 2001
From: winlin <winlin@vip.126.com>
Date: Fri, 26 Feb 2021 20:38:50 +0800
Subject: [PATCH] Perf: Stat the shared messages.

---
 trunk/src/app/srs_app_rtc_server.cpp | 7 ++++---
 trunk/src/kernel/srs_kernel_flv.cpp  | 6 ++++++
 2 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/trunk/src/app/srs_app_rtc_server.cpp b/trunk/src/app/srs_app_rtc_server.cpp
index e1b601478..45be1e6ba 100644
--- a/trunk/src/app/srs_app_rtc_server.cpp
+++ b/trunk/src/app/srs_app_rtc_server.cpp
@@ -79,6 +79,7 @@ extern SrsPps* _srs_pps_objs_rtps;
 extern SrsPps* _srs_pps_objs_rraw;
 extern SrsPps* _srs_pps_objs_rfua;
 extern SrsPps* _srs_pps_objs_rbuf;
+extern SrsPps* _srs_pps_objs_msgs;
 
 SrsRtcBlackhole::SrsRtcBlackhole()
 {
@@ -690,9 +691,9 @@ srs_error_t SrsRtcServer::notify(int type, srs_utime_t interval, srs_utime_t tic
     static char buf[128];
 
     string objs_desc;
-    _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() || _srs_pps_objs_rbuf->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());
+    _srs_pps_objs_rtps->update(); _srs_pps_objs_rraw->update(); _srs_pps_objs_rfua->update(); _srs_pps_objs_rbuf->update(); _srs_pps_objs_msgs->update();
+    if (_srs_pps_objs_rtps->r10s() || _srs_pps_objs_rraw->r10s() || _srs_pps_objs_rfua->r10s() || _srs_pps_objs_rbuf->r10s() || _srs_pps_objs_msgs->r10s()) {
+        snprintf(buf, sizeof(buf), ", objs=%d,%d,%d,%d,%d", _srs_pps_objs_rtps->r10s(), _srs_pps_objs_rraw->r10s(), _srs_pps_objs_rfua->r10s(), _srs_pps_objs_rbuf->r10s(), _srs_pps_objs_msgs->r10s());
         objs_desc = buf;
     }
 
diff --git a/trunk/src/kernel/srs_kernel_flv.cpp b/trunk/src/kernel/srs_kernel_flv.cpp
index ff41f6f4c..e5c27b673 100644
--- a/trunk/src/kernel/srs_kernel_flv.cpp
+++ b/trunk/src/kernel/srs_kernel_flv.cpp
@@ -40,6 +40,10 @@ using namespace std;
 #include <srs_kernel_utility.hpp>
 #include <srs_core_autofree.hpp>
 
+#include <srs_kernel_kbps.hpp>
+
+SrsPps* _srs_pps_objs_msgs = new SrsPps();
+
 SrsMessageHeader::SrsMessageHeader()
 {
     message_type = 0;
@@ -209,6 +213,8 @@ SrsSharedPtrMessage::SrsSharedPtrPayload::~SrsSharedPtrPayload()
 SrsSharedPtrMessage::SrsSharedPtrMessage() : timestamp(0), stream_id(0), size(0), payload(NULL)
 {
     ptr = NULL;
+
+    ++ _srs_pps_objs_msgs->sugar;
 }
 
 SrsSharedPtrMessage::~SrsSharedPtrMessage()