| 94 | } |
| 95 | |
| 96 | void av_thread_message_queue_free(AVThreadMessageQueue **mq) |
| 97 | { |
| 98 | #if HAVE_THREADS |
| 99 | if (*mq) { |
| 100 | av_thread_message_flush(*mq); |
| 101 | av_fifo_freep2(&(*mq)->fifo); |
| 102 | pthread_cond_destroy(&(*mq)->cond_send); |
| 103 | pthread_cond_destroy(&(*mq)->cond_recv); |
| 104 | pthread_mutex_destroy(&(*mq)->lock); |
| 105 | av_freep(mq); |
| 106 | } |
| 107 | #endif |
| 108 | } |
| 109 | |
| 110 | int av_thread_message_queue_nb_elems(AVThreadMessageQueue *mq) |
| 111 | { |