decode_thread_func()

void MayaFlux::IO::VideoFileReader::decode_thread_func ( )

private

Definition at line 517 of file VideoFileReader.cpp.

{
    auto vc = m_container_ref.lock();
    if (!vc) {
        MF_WARN(Journal::Component::IO, Journal::Context::FileIO,
            "VideoFileReader: decode thread — container expired");
        m_decode_active.store(false);
        return;
    }
 
    const uint64_t total = vc->get_total_source_frames();
    const uint32_t ring_cap = vc->get_ring_capacity();
    const uint32_t threshold = (m_refill_threshold > 0)
        ? m_refill_threshold
        : ring_cap / 4;
 
    while (!m_decode_stop.load()) {
        uint64_t head = m_decode_head.load();
        const uint64_t read_pos = vc->get_read_position()[0];
 
        if (head >= total)
            break;
 
        const uint64_t buffered = (head > read_pos) ? (head - read_pos) : 0;
 
        if (buffered >= static_cast<uint64_t>(ring_cap)) {
            std::unique_lock lock(m_decode_mutex);
            m_decode_cv.wait_for(lock, std::chrono::milliseconds(50), [&] {
                if (m_decode_stop.load())
                    return true;
                const uint64_t h = m_decode_head.load(std::memory_order_acquire);
                const uint64_t rp = vc->get_read_position()[0];
                const uint64_t ahead = (h > rp) ? (h - rp) : 0;
                return ahead <= static_cast<uint64_t>(ring_cap - threshold);
            });
            continue;
        }
 
        const uint64_t want = static_cast<uint64_t>(ring_cap) - buffered;
        const uint64_t capped = std::min(want, total - head);
        const uint64_t batch = std::min(capped,
            static_cast<uint64_t>(m_decode_batch_size));
 
        uint64_t decoded = decode_batch(*vc, batch);
 
        if (decoded == 0)
            break;
    }
 
    m_decode_active.store(false);
}

References decode_batch(), MayaFlux::Journal::FileIO, h, MayaFlux::Journal::IO, m_container_ref, m_decode_active, m_decode_batch_size, m_decode_cv, m_decode_head, m_decode_mutex, m_decode_stop, m_refill_threshold, MF_WARN, and threshold.

Referenced by start_decode_thread().

Here is the call graph for this function:

Here is the caller graph for this function: