lavf: set internal thread names

3 files changed, 8 insertions, 0 deletions

diff --git a/libavformat/async.c b/libavformat/async.c
index 3c6f89cab9..e096b0bc6f 100644
--- a/libavformat/async.c
+++ b/libavformat/async.c
@@ -189,6 +189,8 @@ static void *async_buffer_task(void *arg)
     int           ret  = 0;
     int64_t       seek_ret;
 
+    ff_thread_setname("async");
+
     while (1) {
         int fifo_space, to_copy;
 
diff --git a/libavformat/fifo.c b/libavformat/fifo.c
index 692c854be2..7b35c9bf02 100644
--- a/libavformat/fifo.c
+++ b/libavformat/fifo.c
@@ -432,6 +432,8 @@ static void *fifo_consumer_thread(void *data)
     fifo_thread_ctx.avf = avf;
     fifo_thread_ctx.last_received_dts = AV_NOPTS_VALUE;
 
+    ff_thread_setname("fifo-consumer");
+
     while (1) {
         uint8_t just_flushed = 0;
 
diff --git a/libavformat/udp.c b/libavformat/udp.c
index 3b36a4a094..e8980b29d8 100644
--- a/libavformat/udp.c
+++ b/libavformat/udp.c
@@ -487,6 +487,8 @@ static void *circular_buffer_task_rx( void *_URLContext)
     UDPContext *s = h->priv_data;
     int old_cancelstate;
 
+    ff_thread_setname("udp-rx");
+
     pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &old_cancelstate);
     pthread_mutex_lock(&s->mutex);
     if (ff_socket_nonblock(s->udp_fd, 0) < 0) {
@@ -552,6 +554,8 @@ static void *circular_buffer_task_tx( void *_URLContext)
     int64_t burst_interval = s->bitrate ? (s->burst_bits * 1000000 / s->bitrate) : 0;
     int64_t max_delay = s->bitrate ?  ((int64_t)h->max_packet_size * 8 * 1000000 / s->bitrate + 1) : 0;
 
+    ff_thread_setname("udp-tx");
+
     pthread_mutex_lock(&s->mutex);
 
     if (ff_socket_nonblock(s->udp_fd, 0) < 0) {