Lines Matching refs:rmq
53 AVThreadMessageQueue *rmq;
58 if (!(rmq = av_mallocz(sizeof(*rmq))))
60 if ((ret = pthread_mutex_init(&rmq->lock, NULL))) {
61 av_free(rmq);
64 if ((ret = pthread_cond_init(&rmq->cond, NULL))) {
65 pthread_mutex_destroy(&rmq->lock);
66 av_free(rmq);
69 if (!(rmq->fifo = av_fifo_alloc(elsize * nelem))) {
70 pthread_cond_destroy(&rmq->cond);
71 pthread_mutex_destroy(&rmq->lock);
72 av_free(rmq);
75 rmq->elsize = elsize;
76 *mq = rmq;