processing_loop()

void MayaFlux::Core::InputManager::processing_loop ( )

private

Definition at line 306 of file InputManager.cpp.

{
    MF_DEBUG(Journal::Component::Core, Journal::Context::AsyncIO,
        "Processing thread started");
 
    while (true) {
        InputValue value;
 
        while (auto value = m_queue.pop()) {
            dispatch_to_nodes(*value);
            m_events_processed.fetch_add(1);
        }
 
        if (m_stop_requested.load()) {
            break;
        }
 
        m_queue_notify.wait(false);
        m_queue_notify.store(false);
    }
 
    MF_DEBUG(Journal::Component::Core, Journal::Context::AsyncIO,
        "Processing thread exiting");
}

References MayaFlux::Journal::AsyncIO, MayaFlux::Journal::Core, dispatch_to_nodes(), m_events_processed, m_queue, m_queue_notify, m_stop_requested, and MF_DEBUG.

Referenced by start().

Here is the call graph for this function:

Here is the caller graph for this function: