Threads: Set the threads name display in top.

winlinvip · winlinvip · commit fa4c9f9bfbcc · 2021-04-26T08:13:30.000+08:00
diff --git a/trunk/src/app/srs_app_rtc_server.cpp b/trunk/src/app/srs_app_rtc_server.cpp
@@ -699,6 +699,7 @@ srs_error_t SrsRtcServer::on_timer(srs_utime_t interval, srs_utime_t tick)
         rnk_desc = buf;
     }
 
+    // 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());
diff --git a/trunk/src/app/srs_app_threads.cpp b/trunk/src/app/srs_app_threads.cpp
@@ -110,6 +110,11 @@ SrsThreadPool::SrsThreadPool()
     entry->start = NULL;
     entry->arg = NULL;
     entry->num = 1;
+    entry->trd = pthread_self();
+
+    char buf[256];
+    snprintf(buf, sizeof(buf), "srs-master-%d", entry->num);
+    entry->name = buf;
 }
 
 // TODO: FIMXE: If free the pool, we should stop all threads.
@@ -129,8 +134,8 @@ srs_error_t SrsThreadPool::initialize()
 
     interval_ = _srs_config->get_threads_interval();
     bool async_srtp = _srs_config->get_threads_async_srtp();
-    srs_trace("Thread #%d(%s): init interval=%dms, async_srtp=%d",
-        entry_->num, entry_->label.c_str(), srsu2msi(interval_), async_srtp);
+    srs_trace("Thread #%d(%s): init name=%s, interval=%dms, async_srtp=%d",
+        entry_->num, entry_->label.c_str(), entry_->name.c_str(), srsu2msi(interval_), async_srtp);
 
     return err;
 }
@@ -158,6 +163,10 @@ srs_error_t SrsThreadPool::execute(string label, srs_error_t (*start)(void* arg)
     static int num = entry_->num + 1;
     entry->num = num++;
 
+    char buf[256];
+    snprintf(buf, sizeof(buf), "srs-%s-%d", entry->label.c_str(), entry->num);
+    entry->name = buf;
+
     // https://man7.org/linux/man-pages/man3/pthread_create.3.html
     pthread_t trd;
     int r0 = pthread_create(&trd, NULL, SrsThreadPool::start, entry);
@@ -205,7 +214,7 @@ srs_error_t SrsThreadPool::run()
             sync_desc = buf;
         }
 
-        srs_trace("Thread: cycle threads=%d%s%s", (int)threads_.size(),
+        srs_trace("Thread: %s cycle threads=%d%s%s", entry_->name.c_str(), (int)threads_.size(),
             async_logs.c_str(), sync_desc.c_str());
     }
 
@@ -222,7 +231,14 @@ void* SrsThreadPool::start(void* arg)
     srs_error_t err = srs_success;
 
     SrsThreadEntry* entry = (SrsThreadEntry*)arg;
-    srs_trace("Thread #%d(%s): run", entry->num, entry->label.c_str());
+
+#ifndef SRS_OSX
+    // https://man7.org/linux/man-pages/man3/pthread_setname_np.3.html
+    pthread_setname_np(entry->trd, entry->name.c_str());
+#endif
+
+    srs_trace("Thread #%d: run with label=%s, name=%s", entry->num,
+        entry->label.c_str(), entry->name.c_str());
 
     if ((err = entry->start(entry->arg)) != srs_success) {
         entry->err = err;
diff --git a/trunk/src/app/srs_app_threads.hpp b/trunk/src/app/srs_app_threads.hpp
@@ -80,6 +80,7 @@ class SrsThreadEntry
 public:
     SrsThreadPool* pool;
     std::string label;
+    std::string name;
     srs_error_t (*start)(void* arg);
     void* arg;
     int num;

Original file line number	Diff line number	Diff line change
`@@ -699,6 +699,7 @@ srs_error_t SrsRtcServer::on_timer(srs_utime_t interval, srs_utime_t tick)`
`699`	`699`	`rnk_desc = buf;`
`700`	`700`	`}`
`701`	`701`
	`702`	`+ // TODO: FIXME: Should move to Hybrid server stat.`
`702`	`703`	`string loss_desc;`
`703`	`704`	`if (_srs_pps_rloss->r10s() \|\| _srs_pps_sloss->r10s()) {`
`704`	`705`	`snprintf(buf, sizeof(buf), ", loss=(r:%d,s:%d)", _srs_pps_rloss->r10s(), _srs_pps_sloss->r10s());`