65     struct sender_data *wd = arg;  in sender_thread()  local
67     av_log(NULL, AV_LOG_INFO, "sender #%d: workload=%d\n", wd->id, wd->workload);  in sender_thread()
68     for (i = 0; i < wd->workload; i++) {  in sender_thread()
69         if (rand() % wd->workload < wd->workload / 10) {  in sender_thread()
70             av_log(NULL, AV_LOG_INFO, "sender #%d: flushing the queue\n", wd->id);  in sender_thread()
71             av_thread_message_flush(wd->queue);  in sender_thread()
87                               i + 1, wd->workload, wd->id);  in sender_thread()
112                    wd->id, i + 1, wd->workload, msg.frame);  in sender_thread()
113             ret = av_thread_message_queue_send(wd->queue, &msg, 0);  in sender_thread()
121            wd->id, av_err2str(ret));  in sender_thread()
122     av_thread_message_queue_set_err_recv(wd->queue, ret < 0 ? ret : AVERROR_EOF);  in sender_thread()