Function submit_packet

libavcodec/pthread_frame.c:499–561

}

static int submit_packet(PerThreadContext *p, AVCodecContext *user_avctx,
                         AVPacket *in_pkt)
{
    FrameThreadContext *fctx = p->parent;
    PerThreadContext *prev_thread = fctx->prev_thread;
    const AVCodec *codec = p->avctx->codec;
    int ret;

    pthread_mutex_lock(&p->mutex);

    av_packet_unref(p->avpkt);
    av_packet_move_ref(p->avpkt, in_pkt);

    if (AVPACKET_IS_EMPTY(p->avpkt))
        p->avctx->internal->draining = 1;

    ret = update_context_from_user(p->avctx, user_avctx);
    if (ret) {
        pthread_mutex_unlock(&p->mutex);
        return ret;
    }
    atomic_store_explicit(&p->debug_threads,
                          (p->avctx->debug & FF_DEBUG_THREADS) != 0,
                          memory_order_relaxed);

    if (prev_thread) {
        if (atomic_load(&prev_thread->state) == STATE_SETTING_UP) {
            pthread_mutex_lock(&prev_thread->progress_mutex);
            while (atomic_load(&prev_thread->state) == STATE_SETTING_UP)
                pthread_cond_wait(&prev_thread->progress_cond, &prev_thread->progress_mutex);
            pthread_mutex_unlock(&prev_thread->progress_mutex);
        }

        /* codecs without delay might not be prepared to be called repeatedly here during
         * flushing (vp3/theora), and also don't need to be, since from this point on, they
         * will always return EOF anyway */
        if (!p->avctx->internal->draining ||
            (codec->capabilities & AV_CODEC_CAP_DELAY)) {
            ret = update_context_from_thread(p->avctx, prev_thread->avctx, 0);
            if (ret) {
                pthread_mutex_unlock(&p->mutex);
                return ret;
            }
        }
    }

    /* transfer the stashed hwaccel state, if any */
    av_assert0(!p->avctx->hwaccel || p->hwaccel_threadsafe);
    if (!p->hwaccel_threadsafe) {
        FFSWAP(const AVHWAccel*, p->avctx->hwaccel,                     fctx->stash_hwaccel);
        FFSWAP(void*,            p->avctx->hwaccel_context,             fctx->stash_hwaccel_context);
        FFSWAP(void*,            p->avctx->internal->hwaccel_priv_data, fctx->stash_hwaccel_priv);
    }

    atomic_store(&p->state, STATE_SETTING_UP);
    pthread_cond_signal(&p->input_cond);
    pthread_mutex_unlock(&p->mutex);