Fixed slow waterfall with low sample rates

src/dsp/resampling.h

@@ -148,9 +148,6 @@ namespace dsp {
             if (running) {
                 return;
             }
-            if (blockSize < 1 ) {
-                return;
-            }
             _blockSize = blockSize;
             output.setMaxLatency(blockSize * 2);
         }
@@ -159,9 +156,6 @@ namespace dsp {
             if (running) {
                 return;
             }
-            if (skip < 0 ) {
-                skip = 0;
-            }
             _skip = skip;
         }
 
@@ -170,9 +164,20 @@ namespace dsp {
     private:
         static void _worker(BlockDecimator* _this) {
             complex_t* buf = new complex_t[_this->_blockSize];
+            bool delay = _this->_skip < 0;
+
+            int readCount = std::min<int>(_this->_blockSize + _this->_skip, _this->_blockSize);
+            int skip = std::max<int>(_this->_skip, 0);
+            int delaySize = (-_this->_skip) * sizeof(complex_t);
+
+            complex_t* start = &buf[std::max<int>(-_this->_skip, 0)];
+            complex_t* delayStart = &buf[_this->_blockSize + _this->_skip];
+
             while (true) {
-                int read = _this->_input->readAndSkip(buf, _this->_blockSize, _this->_skip);
-                if (read < 0) { break; };
+                if (delay) {
+                    memmove(buf, delayStart, delaySize);
+                }
+                if (_this->_input->readAndSkip(start, readCount, skip) < 0) { break; };
                 if (_this->output.write(buf, _this->_blockSize) < 0) { break; };
             }
             delete[] buf;

src/dsp/source.h

@@ -73,8 +73,8 @@ namespace dsp {
                     _this->_phase += _this->_phasorSpeed;
                     outBuf[i].i = sin(_this->_phase);
                     outBuf[i].q = cos(_this->_phase);
+                    _this->_phase = fmodf(_this->_phase, 2.0f * 3.1415926535); // TODO: Get a more efficient generator
                 }
-                _this->_phase = fmodf(_this->_phase, 2.0f * 3.1415926535);
                 if (_this->output.write(outBuf, _this->_blockSize) < 0) { break; };
             }
             delete[] outBuf;

src/main_window.cpp

@@ -302,7 +302,7 @@ void drawWindow() {
             ImGui::Combo("##_1_", &srId, soapy.txtSampleRateList.c_str());
         }
         else {
-            ImGui::Text("%s Samples/s", soapy.txtSampleRateList.c_str());
+            ImGui::Text("%.0f Samples/s", soapy.sampleRates[srId]);
         }
 
         ImGui::SameLine();

src/signal_path.cpp

@@ -46,7 +46,8 @@ void SignalPath::setSampleRate(float sampleRate) {
 
     dcBiasRemover.setBlockSize(inputBlockSize);
     split.setBlockSize(inputBlockSize);
-    fftBlockDec.setSkip((sampleRate / fftRate) - fftSize);
+    int skip = (sampleRate / fftRate) - fftSize;
+    fftBlockDec.setSkip(skip);
     mainVFO.setInputSampleRate(sampleRate, inputBlockSize);
 
     // // Reset the modulator and audio systems

src/version.h

@@ -1,3 +1,3 @@
 #pragma once
 
-#define VERSION_STR "0.2.1_alpha"
+#define VERSION_STR "0.2.2_alpha"