| 108 | } |
| 109 | |
| 110 | int av_thread_message_queue_nb_elems(AVThreadMessageQueue *mq) |
| 111 | { |
| 112 | #if HAVE_THREADS |
| 113 | int ret; |
| 114 | pthread_mutex_lock(&mq->lock); |
| 115 | ret = av_fifo_can_read(mq->fifo); |
| 116 | pthread_mutex_unlock(&mq->lock); |
| 117 | return ret; |
| 118 | #else |
| 119 | return AVERROR(ENOSYS); |
| 120 | #endif |
| 121 | } |
| 122 | |
| 123 | #if HAVE_THREADS |
| 124 |