Threads-RECV: Show the dropped packets pps.

ossrs · Apr 26, 2021 · 185359f · 185359f
1 parent 6fca411
commit 185359f
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 2 deletions.
diff --git a/trunk/src/app/srs_app_rtc_server.cpp b/trunk/src/app/srs_app_rtc_server.cpp
@@ -77,6 +77,7 @@ extern SrsPps* _srs_pps_rmnack;
 
 extern SrsPps* _srs_pps_rloss;
 extern SrsPps* _srs_pps_sloss;
+extern SrsPps* _srs_pps_aloss;
 
 SrsRtcBlackhole::SrsRtcBlackhole()
 {
@@ -701,8 +702,9 @@ srs_error_t SrsRtcServer::on_timer(srs_utime_t interval, srs_utime_t tick)
 
     // TODO: FIXME: Should move to Hybrid server stat.
     string loss_desc;
-    if (_srs_pps_rloss->r10s() || _srs_pps_sloss->r10s()) {
-        snprintf(buf, sizeof(buf), ", loss=(r:%d,s:%d)", _srs_pps_rloss->r10s(), _srs_pps_sloss->r10s());
+    _srs_pps_aloss->update();
+    if (_srs_pps_rloss->r10s() || _srs_pps_sloss->r10s() || _srs_pps_aloss->r10s()) {
+        snprintf(buf, sizeof(buf), ", loss=(r:%d,s:%d,a:%d)", _srs_pps_rloss->r10s(), _srs_pps_sloss->r10s(), _srs_pps_aloss->r10s());
         loss_desc = buf;
     }
 

diff --git a/trunk/src/app/srs_app_threads.cpp b/trunk/src/app/srs_app_threads.cpp
@@ -40,6 +40,8 @@ SrsPps* _srs_thread_sync_100us = new SrsPps();
 SrsPps* _srs_thread_sync_1000us = new SrsPps();
 SrsPps* _srs_thread_sync_plus = new SrsPps();
 
+extern SrsPps* _srs_pps_aloss;
+
 uint64_t srs_covert_cpuset(cpu_set_t v)
 {
 #ifdef SRS_OSX
@@ -897,6 +899,7 @@ srs_error_t SrsAsyncRecvManager::do_start()
 
             // Drop packet if exceed max recv queue size.
             if ((int)packets_->size() >= max_recv_queue_) {
+                ++_srs_pps_aloss->sugar;
                 continue;
             }
 

diff --git a/trunk/src/app/srs_app_utility.cpp b/trunk/src/app/srs_app_utility.cpp
@@ -54,6 +54,7 @@ using namespace std;
 
 SrsPps* _srs_pps_rloss = new SrsPps();
 SrsPps* _srs_pps_sloss = new SrsPps();
+SrsPps* _srs_pps_aloss = new SrsPps();
 
 // the longest time to wait for a process to quit.
 #define SRS_PROCESS_QUIT_TIMEOUT_MS 1000