Add experimental ring buffer based RAW recording

src/input/raw_file.cpp

@@ -283,6 +283,7 @@ void CRAWFile::run(void)
         }
         SampleBuffer.putDataIntoBuffer(bi.data(), t);
         SpectrumSampleBuffer.putDataIntoBuffer(bi.data(), t);
+        putIntoRecordBuffer(*bi.data(), t);
         int64_t t_to_wait = nextStop - getMyTime();
         if (throttle and t_to_wait > 0)
             std::this_thread::sleep_for(std::chrono::microseconds(t_to_wait));

src/input/rtl_sdr.cpp

@@ -343,6 +343,7 @@ void CRTL_SDR::RTLSDRCallBack(uint8_t* buf, uint32_t len, void* ctx)
             rtlsdr->sampleCounter += len - tmp;
 
         rtlsdr->spectrumSampleBuffer.putDataIntoBuffer(buf, len);
+        rtlsdr->putIntoRecordBuffer(*buf, len);
 
         // Check if device is overloaded
         rtlsdr->minAmplitude = 255;

src/input/virtual_input.h

@@ -30,16 +30,62 @@
 #ifndef __VIRTUAL_INPUT
 #define __VIRTUAL_INPUT
 
+#include <memory>
+#include <fstream>
+#include <iostream>
+
 #include "dab-constants.h"
 #include "radio-controller.h"
+#include "ringbuffer.h"
 
 enum class CDeviceID {
     UNKNOWN, NULLDEVICE, AIRSPY, RAWFILE, RTL_SDR, RTL_TCP, SOAPYSDR};
 
 class CVirtualInput : public InputInterface {
-    public:
-        virtual ~CVirtualInput() {}
-        virtual CDeviceID getID(void) = 0;
+public:
+    virtual ~CVirtualInput() {}
+    virtual CDeviceID getID(void) = 0;
+
+    void writeRecordBufferToFile(std::string &fileanme) {
+        if(!recordBuffer)
+            return;
+
+        std::ofstream rawStream(fileanme, std::ios::binary);
+        int test = recordBuffer->GetRingBufferReadAvailable();
+
+        while(recordBuffer->GetRingBufferReadAvailable() > 0) {
+            size_t data_tmpSize = 0;
+            if(recordBuffer->GetRingBufferReadAvailable() > 1024)
+                data_tmpSize = 1024;
+            else
+                data_tmpSize = static_cast<size_t>(recordBuffer->GetRingBufferReadAvailable());
+
+            uint8_t data_tmp[data_tmpSize];
+            recordBuffer->getDataFromBuffer(data_tmp, data_tmpSize);
+            rawStream.write((char *) data_tmp, data_tmpSize);
+        }
+        rawStream.close();
+    }
+
+    void initRecordBuffer(uint32_t size) {
+        // The ring buffer size has to be power of 2
+        uint32_t bitCount = ceil(log2(size));
+        uint32_t bufferSize = pow(2, bitCount);
+
+        recordBuffer.reset(new RingBuffer<uint8_t>(bufferSize));
+    }
+
+protected:
+    void putIntoRecordBuffer(uint8_t &data, uint32_t size) {
+        if(!recordBuffer)
+            return;
+
+        recordBuffer->putDataIntoBuffer(&data, static_cast<int>(size));
+        std::clog << "CVirtualInput: GetRingBufferReadAvailable() " << recordBuffer->GetRingBufferReadAvailable() << std::endl;
+    }
+
+private:
+    std::unique_ptr<RingBuffer<uint8_t>> recordBuffer;
 };
 
 #endif

src/welle-gui/QML/MainView.qml

@@ -417,6 +417,12 @@ ApplicationWindow {
                 font.pixelSize: TextStyle.textStandartSize
                 onTriggered: generalView.addComponent("qrc:/QML/expertviews/TextOutputView.qml")
             }
+
+            MenuItem {
+                text: qsTr("RAW Recorder")
+                font.pixelSize: TextStyle.textStandartSize
+                onTriggered: generalView.addComponent("qrc:/QML/expertviews/RawRecorder.qml")
+            }
         }
     }
 

src/welle-gui/QML/expertviews/RawRecorder.qml

@@ -0,0 +1,47 @@
+import QtQuick 2.0
+import QtQuick.Controls 2.3
+import QtQuick.Layouts 1.1
+
+
+// Import custom styles
+import "../texts"
+import "../components"
+
+ViewBaseFrame {
+    labelText: qsTr("I/Q RAW Recorder (experimental)")
+
+    property bool isStart: false
+    property int ringeBufferSize: 0
+
+    content:  ColumnLayout {
+        RowLayout {
+            TextStandart {
+                text: qsTr("Ring buffer length [s]")
+            }
+
+            WTumbler {
+                id: ringeBufferSetting
+                model: [5, 10, 60, 120, 240]
+            }
+
+            WButton {
+                text: isStart ? qsTr("Save ringe buffer") : qsTr("Init")
+
+                onPressed: {
+                    ringeBufferSize = parseInt(ringeBufferSetting.currentItem.text) * 2048 * 1024
+
+                    if(!isStart)
+                        radioController.initRecorder(ringeBufferSize)
+                    else
+                        radioController.triggerRecorder("")
+
+                    isStart = !isStart
+                }
+            }
+        }
+
+        TextStandart {
+            text: "Ringe buffer size [MB]: " + (ringeBufferSize / 1000000)
+        }
+    }
+}

src/welle-gui/radio_controller.cpp

@@ -32,6 +32,7 @@
 
 #include <QDebug>
 #include <QSettings>
+#include <QStandardPaths>
 #include <stdexcept>
 
 #include "radio_controller.h"
@@ -395,7 +396,20 @@ void CRadioController::setGain(int Gain)
             gainCount = gainCount_tmp;
             emit gainCountChanged(gainCount);
         }
-    }  
+    }
+}
+
+void CRadioController::initRecorder(int size)
+{
+    device->initRecordBuffer(size);
+}
+
+void CRadioController::triggerRecorder(QString filename)
+{
+    // TODO just for testing
+    filename = QStandardPaths::writableLocation(QStandardPaths::DesktopLocation) + "/welle-io-record.iq";
+    std::string filename_tmp = filename.toStdString();
+    device->writeRecordBufferToFile(filename_tmp);
 }
 
 DABParams& CRadioController::getDABParams()

src/welle-gui/radio_controller.h

@@ -122,6 +122,8 @@ class CRadioController :
     Q_INVOKABLE void enableOldFFTWindowPlacement(bool old);
     Q_INVOKABLE void setFreqSyncMethod(int fsm_ix);
     Q_INVOKABLE void setGain(int gain);
+    Q_INVOKABLE void initRecorder(int size);
+    Q_INVOKABLE void triggerRecorder(QString filename);
     DABParams& getDABParams(void);
     int getCurrentFrequency();
 

src/welle-gui/resources.qrc

@@ -92,6 +92,7 @@
         <file>QML/expertviews/NullSymbolGraph.qml</file>
         <file>QML/expertviews/SpectrumGraph.qml</file>
         <file>QML/expertviews/TextOutputView.qml</file>
+        <file>QML/expertviews/RawRecorder.qml</file>
         <file>QML/components/ViewBaseFrame.qml</file>
         <file>QML/MotView.qml</file>
         <file>QML/GeneralView.qml</file>

src/welle-gui/welle-gui.pro

@@ -46,6 +46,7 @@ DISTFILES +=    \
     QML/expertviews/NullSymbolGraph.qml \
     QML/expertviews/SpectrumGraph.qml \
     QML/expertviews/TextOutputView.qml \
+    QML/expertviews/RawRecorder.qml \
     QML/components/StationListModel.qml \
     QML/MotView.qml \
     QML/components/ViewBaseFrame.qml \