Method processInputQueue

src/visual/WaterfallCanvas.cpp:89–126

}

void WaterfallCanvas::processInputQueue() {
    std::lock_guard < std::mutex > lock(tex_update);
    
    gTimer.update();
    
    double targetVis =  1.0 / (double)linesPerSecond;
    lpsIndex += gTimer.lastUpdateSeconds();

    bool updated = false;
    if (linesPerSecond) {
        if (lpsIndex >= targetVis) {
            while (lpsIndex >= targetVis) {
                SpectrumVisualDataPtr vData;

                if (visualDataQueue->try_pop(vData)) {
                    
                    if (vData) {
                        if (vData->spectrum_points.size() == fft_size * 2) {
                            waterfallPanel.setPoints(vData->spectrum_points);
                        }
                        waterfallPanel.step();
                      
                        updated = true;
                    }
                    lpsIndex-=targetVis;
                } else {
                	break;
                }
            }
        }
    }
    if (updated) {
        wxClientDC(this);
        glContext->SetCurrent(*this);
        waterfallPanel.update();
    }
   
}

void WaterfallCanvas::OnPaint(wxPaintEvent& WXUNUSED(event)) {
    std::lock_guard < std::mutex > lock(tex_update);