Function syncVideoWork

libhb/sync.c:2933–2983

* syncVideoWork *********************************************************************** * **********************************************************************/

 *
 **********************************************************************/
static int syncVideoWork( hb_work_object_t * w, hb_buffer_t ** buf_in,
                          hb_buffer_t ** buf_out )
{
    hb_work_private_t * pv = w->private_data;
    hb_buffer_t * in = *buf_in;

#if HB_PROJECT_FEATURE_QSV
    // Fix of LA case allowing use of LA up to 40 in full encode path,
    // as currently for such support we cannot allocate >64 slices per texture
    // due to MSFT limitation, not impacting other cases
    hb_job_t *job = pv->common->job;
    if (job->hw_pix_fmt == AV_PIX_FMT_QSV &&
        job->qsv_ctx->la_is_enabled == 1)
    {
        pv->stream->max_len = SYNC_MIN_VIDEO_QUEUE_LEN;
        pv->common->job->qsv_ctx->la_is_enabled++;
    }
#endif

    if (pv->stream->done)
    {
        flushStreamsLock(pv->common);
        return HB_WORK_DONE;
    }
    if (in->s.flags & HB_BUF_FLAG_EOF)
    {
        pv->stream->flush = 1;
        flushStreamsLock(pv->common);
        // Ideally, we would only do this subtitle scan check in
        // syncSubtitleWork, but someone might try to do a subtitle
        // scan on a source that has no subtitles :-(
        if (pv->common->job->indepth_scan)
        {
            // When doing subtitle indepth scan, the pipeline ends at sync.
            // Terminate job when EOF reached.
            *w->done = 1;
        }
        return HB_WORK_DONE;
    }

    *buf_in = NULL;
    QueueBuffer(pv->stream, in);
    Synchronize(pv->stream);

    if (pv->stream->done)
    {
        flushStreamsLock(pv->common);
        return HB_WORK_DONE;
    }
    return HB_WORK_OK;
}

hb_work_object_t hb_sync_video =
{