tex update lock, VisualData"Re"Distributor

src/CubicSDR.cpp

@@ -298,7 +298,7 @@ SpectrumVisualProcessor *CubicSDR::getDemodSpectrumProcessor() {
     return demodVisualThread->getProcessor();
 }
 
-VisualDataDistributor<DemodulatorThreadIQData> *CubicSDR::getSpectrumDistributor() {
+VisualDataReDistributor<DemodulatorThreadIQData> *CubicSDR::getSpectrumDistributor() {
     return &spectrumDistributor;
 }
 

src/CubicSDR.h

@@ -60,7 +60,7 @@ public:
     ScopeVisualProcessor *getScopeProcessor();
     SpectrumVisualProcessor *getSpectrumProcessor();
     SpectrumVisualProcessor *getDemodSpectrumProcessor();
-    VisualDataDistributor<DemodulatorThreadIQData> *getSpectrumDistributor();
+    VisualDataReDistributor<DemodulatorThreadIQData> *getSpectrumDistributor();
     
     DemodulatorThreadOutputQueue* getAudioVisualQueue();
     DemodulatorThreadInputQueue* getIQVisualQueue();
@@ -111,7 +111,7 @@ private:
 
     ScopeVisualProcessor scopeProcessor;
     
-    VisualDataDistributor<DemodulatorThreadIQData> spectrumDistributor;
+    VisualDataReDistributor<DemodulatorThreadIQData> spectrumDistributor;
 
     std::thread *t_SDR;
     std::thread *t_PostSDR;

src/process/VisualProcessor.h

@@ -107,3 +107,25 @@ protected:
     }
 };
 
+
+template<class OutputDataType = ReferenceCounter>
+class VisualDataReDistributor : public VisualProcessor<OutputDataType, OutputDataType> {
+protected:
+    void process() {
+        while (!VisualProcessor<OutputDataType, OutputDataType>::input->empty()) {
+            if (!VisualProcessor<OutputDataType, OutputDataType>::isAnyOutputEmpty()) {
+                return;
+            }
+            OutputDataType *inp;
+            VisualProcessor<OutputDataType, OutputDataType>::input->pop(inp);
+            
+            if (inp) {
+                OutputDataType *outp = buffers.getBuffer();
+                (*outp) = (*inp);
+                inp->decRefCount();
+                VisualProcessor<OutputDataType, OutputDataType>::distribute(outp);
+            }
+        }
+    }
+    ReBuffer<OutputDataType> buffers;
+};

src/visual/WaterfallCanvas.cpp

@@ -99,6 +99,7 @@ void WaterfallCanvas::processInputQueue() {
 
     if (linesPerSecond) {
         if (lpsIndex >= targetVis) {
+            tex_update.lock();
             while (lpsIndex >= targetVis) {
                 SpectrumVisualData *vData;
                 if (!visualDataQueue.empty()) {
@@ -115,6 +116,7 @@ void WaterfallCanvas::processInputQueue() {
                 	break;
                 }
             }
+            tex_update.unlock();
         }
     }
     if (processed) {
@@ -235,7 +237,9 @@ void WaterfallCanvas::OnPaint(wxPaintEvent& WXUNUSED(event)) {
     glContext->BeginDraw(0,0,0);
 
     waterfallPanel.calcTransform(CubicVR::mat4::identity());
+    tex_update.lock();
     waterfallPanel.draw();
+    tex_update.unlock();
 
     std::vector<DemodulatorInstance *> &demods = wxGetApp().getDemodMgr().getDemodulators();
 
@@ -314,7 +318,7 @@ void WaterfallCanvas::OnPaint(wxPaintEvent& WXUNUSED(event)) {
 
     glContext->EndDraw();
 
-    glFlush();
+//    glFlush();
     SwapBuffers();
 }
 

src/visual/WaterfallCanvas.h

@@ -72,6 +72,7 @@ private:
     Timer gTimer, testTimer;
     double lpsIndex;
     bool preBuf;
+    std::mutex tex_update;
     // event table
 wxDECLARE_EVENT_TABLE();
 };