msg.frame->format = AV_PIX_FMT_RGBA;
msg.frame->width = 320;
msg.frame->height = 240;
- ret = av_frame_get_buffer(msg.frame, 32);
+ ret = av_frame_get_buffer(msg.frame, 0);
if (ret < 0) {
av_frame_free(&msg.frame);
break;
for (i = 0; i < rd->workload; i++) {
if (rand() % rd->workload < rd->workload / 10) {
- av_log(NULL, AV_LOG_INFO, "receiver #%d: flushing the queue\n", rd->id);
+ av_log(NULL, AV_LOG_INFO, "receiver #%d: flushing the queue, "
+ "discarding %d message(s)\n", rd->id,
+ av_thread_message_queue_nb_elems(rd->queue));
av_thread_message_flush(rd->queue);
} else {
struct message msg;