cleanup_expired_data()

void MayaFlux::Kriya::BufferPipeline::cleanup_expired_data ( )

private

Definition at line 710 of file BufferPipeline.cpp.

{
    for (size_t i = 0; i < m_data_states.size(); ++i) {
        if (m_data_states[i] == DataState::READY) {
            if (i < m_operations.size() && m_operations[i].get_type() == BufferOperation::OpType::CAPTURE && m_operations[i].m_capture.get_mode() == BufferCapture::CaptureMode::TRANSIENT) {
 
                if (m_operations[i].m_capture.m_data_expired_callback) {
                    auto it = m_operation_data.find(&m_operations[i]);
                    if (it != m_operation_data.end()) {
                        m_operations[i].m_capture.m_data_expired_callback(it->second, m_current_cycle);
                    }
                }
 
                m_data_states[i] = DataState::EXPIRED;
            } else {
                m_data_states[i] = DataState::CONSUMED;
            }
        }
    }
 
    auto it = m_operation_data.begin();
    while (it != m_operation_data.end()) {
        if (m_current_cycle > 2) {
            it = m_operation_data.erase(it);
        } else {
            ++it;
        }
    }
}

References MayaFlux::Kriya::BufferOperation::CAPTURE, CONSUMED, EXPIRED, m_current_cycle, m_data_states, m_operation_data, m_operations, READY, and MayaFlux::Kriya::BufferCapture::TRANSIENT.

Referenced by execute_phased(), and execute_streaming().

Here is the caller graph for this function: