Function ff_decklink_packet_queue_get

libavdevice/decklink_common.cpp:468–490

}

int ff_decklink_packet_queue_get(DecklinkPacketQueue *q, AVPacket *pkt, int block)
{
    int ret;

    pthread_mutex_lock(&q->mutex);

    for (;; ) {
        ret = avpriv_packet_list_get(&q->pkt_list, pkt);
        if (ret == 0) {
            q->nb_packets--;
            q->size -= pkt->size + sizeof(AVPacket);
            ret = 1;
            break;
        } else if (!block) {
            ret = 0;
            break;
        } else {
            pthread_cond_wait(&q->cond, &q->mutex);
        }
    }
    pthread_mutex_unlock(&q->mutex);
    return ret;
}

int64_t ff_decklink_packet_queue_peekpts(DecklinkPacketQueue *q)
{