Add new function

Author: AtlasHW

README.md

@@ -1 +1,12 @@
 Hello everyone, This is my first github project. It is a virtual oscilloscope to display the wave of hackrf one by hackrf API. It designed by Qt and it didn't use QChart class.
+
+
+![Alt text](./doc/picture/mainview.jpg "mainview")
+
+Next work:
+<1> To adjust time offest and time scale in stop status.
+<2> To add exact time and voltage label.
+<3> To development pre view function.
+<4> To add measure function, vpp, frequncy and others.
+<5> To add drag function.
+

doc/picture/mainview.jpg

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE QtCreatorProject>
-<!-- Written by QtCreator 4.11.1, 2023-02-22T20:07:31. -->
+<!-- Written by QtCreator 4.11.1, 2023-03-09T23:30:47. -->
 <qtcreator>
  <data>
   <variable>EnvironmentId</variable>

hackrf_scope.pro.user

@@ -6,45 +6,59 @@
 #include <QTime>
 #include <cmath>
 
+#include <pthread.h>
+
 //Debug switch
-#define _DEBUG_REC
+//#define _DEBUG_REC
 
 
 #define BUFFER_SIZE 10000000
 static int16_t rx_data_bufferI[BUFFER_SIZE];
 static int16_t rx_data_bufferQ[BUFFER_SIZE];
 static int16_t magnitude[BUFFER_SIZE];
-size_t datalength=0;
-scope_ch_data_t ch_data={
-    .ch_count=3,
-    .ch1_data=rx_data_bufferI,
-    .ch2_data=rx_data_bufferQ,
-    .ch3_data=magnitude,
-    .ch4_data=NULL,
-    .buffer_size=BUFFER_SIZE,
-    .update_index=0,
-    .pre_index=0,
-    .update_count=0
+
+scope_ch_data_t ch_data = {
+    .ch_mask = CH1_MASK | CH2_MASK | CH3_MASK,
+    .ch1_data = rx_data_bufferI,
+    .ch2_data = rx_data_bufferQ,
+    .ch3_data = magnitude,
+    .ch4_data = NULL,
+    .buffer_size = BUFFER_SIZE,
+    .head = 0,
+    .tail = 0,
+    .valid_length = 0,
+    .overflow_flag = false
 };
 
+pthread_mutex_t mutex_lock;
+
 static int rx_callback(hackrf_transfer* transfer) {
-#ifdef _DEBUG_REC
-    qDebug()<<QTime::currentTime().msecsSinceStartOfDay()<<transfer->valid_length;
-#endif
+    if(ch_data.overflow_flag)
+        return -1;
+
     if(transfer->valid_length)
     {
-        ch_data.pre_index = ch_data.update_index;
+        pthread_mutex_lock(&mutex_lock);
+        int16_t I,Q;
         for(int i = 0; i < transfer->valid_length; i += 2){
-            *(rx_data_bufferI + ch_data.update_index) = (int) *((int8_t*)transfer->buffer + i);
-            *(rx_data_bufferQ + ch_data.update_index) = (int) *((int8_t*)transfer->buffer + i + 1);
-            *(magnitude + ch_data.update_index) = sqrt(pow(*(rx_data_bufferI + ch_data.update_index), 2)
-                                                       + pow(*(rx_data_bufferQ + ch_data.update_index), 2));
-            ch_data.update_index++;
-            if(ch_data.update_index == ch_data.buffer_size)
-                ch_data.update_index = 0;
+            I = *((int8_t*)transfer->buffer + i);
+            Q = *((int8_t*)transfer->buffer + i + 1);
+            *(rx_data_bufferI + ch_data.tail) = I;
+            *(rx_data_bufferQ + ch_data.tail) = Q;
+            *(magnitude + ch_data.tail) = sqrt(pow(I, 2) + pow(Q, 2));
+            ch_data.tail++;
+            if(ch_data.tail == ch_data.buffer_size)
+                ch_data.tail = 0;
+            if(ch_data.tail == ch_data.head) //Receive overflow
+            {
+                ch_data.overflow_flag = true;
+                qDebug() << "Receive data flow!";
+            }
         }
-        datalength+=transfer->valid_length;
-        ch_data.update_count += (transfer->valid_length / 2);
+        ch_data.valid_length = ch_data.tail > ch_data.head ?
+                               ch_data.tail - ch_data.head:
+                               ch_data.tail + ch_data.buffer_size - ch_data.head;
+        pthread_mutex_unlock(&mutex_lock);
     }
     return 0;
 }
@@ -60,36 +74,47 @@ MainWindow::MainWindow(QWidget *parent) :
     int result = HACKRF_SUCCESS;
     result = hackrf_init_t();
     if (result != HACKRF_SUCCESS) {
+        device_run = false;
         QMessageBox::warning(this,tr("ERROR"),tr("Error:%1 Code:%2").arg(hackrf_error_name((hackrf_error)result)).arg(result));
     }
+    else
+    {
+        device_run = true;
+    }
 
     for(int i = 0; i <= 40; i += 8)
     {
         ui->LNA_CB->addItem(tr("%1").arg(i));
     }
+    ui->LNA_CB->setCurrentIndex(1);
 
     for(int i = 0; i <= 62; i += 2)
     {
         ui->VGA_CB->addItem(tr("%1").arg(i));
     }
+    ui->VGA_CB->setCurrentIndex(10);
 
     datarx_timer=new QTimer(this);
     connect(datarx_timer,&QTimer::timeout,this,&MainWindow::datarx_slot);
     datarx_timer->start(33);
+
+    pthread_mutex_init(&mutex_lock, NULL);
 }
 
 MainWindow::~MainWindow()
 {
     hackrf_close_t();
     delete ui;
+    pthread_mutex_destroy(&mutex_lock);
 }
 
 void MainWindow::datarx_slot()
 {
-    if(datalength){
+    if(ch_data.valid_length){
+        pthread_mutex_lock(&mutex_lock);
         emit rx_data_update(&ch_data);
-        qDebug()<<QTime::currentTime().msecsSinceStartOfDay()<<datalength;
-        datalength=0;
+        clear_rxch_buff(&ch_data);
+        pthread_mutex_unlock(&mutex_lock);
     }
 }
 
@@ -158,7 +183,7 @@ int MainWindow::hackrf_init_t()
 
 int MainWindow::hackrf_close_t()
 {
-    if(device == NULL)
+    if(device_run == false)
     {
         qDebug()<<"No device, exit!";
         hackrf_exit();
@@ -180,25 +205,44 @@ int MainWindow::hackrf_close_t()
     }
     hackrf_exit();
             fprintf(stderr, "hackrf_exit() done\n");
-    return HACKRF_SUCCESS;
+            return HACKRF_SUCCESS;
+}
+
+int MainWindow::clear_rxch_buff(scope_ch_data_t *ch_buffer)
+{
+    if(ch_buffer->overflow_flag)
+    {
+        ch_buffer->overflow_flag = false;
+        ch_buffer->head = 0;
+        ch_buffer->tail = 0;
+        ch_buffer->valid_length = 0;
+        return 1;
+    }
+    else if(ch_buffer->valid_length > 0)
+    {
+        ch_buffer->head = ch_buffer->tail;
+        ch_buffer->valid_length = 0;
+        return 0;
+    }
+    return -1;
 }
 
 void MainWindow::on_doubleSpinBox_valueChanged(double arg1)
 {
-    if(device != NULL)
+    if(device_run)
         hackrf_set_freq(device, static_cast<long long>(arg1*1000000));
 }
 
 void MainWindow::on_LNA_CB_currentTextChanged(const QString &arg1)
 {
     int lna = arg1.toInt();
-    if(device != NULL)
+    if(device_run)
         hackrf_set_lna_gain(device, lna);
 }
 
 void MainWindow::on_VGA_CB_currentTextChanged(const QString &arg1)
 {
     int vga = arg1.toInt();
-    if(device != NULL)
+    if(device_run)
         hackrf_set_vga_gain(device, vga);
 }

mainwindow.cpp

@@ -33,6 +33,8 @@ private slots:
     int hackrf_init_t();
     int hackrf_close_t();
 
+    int clear_rxch_buff(scope_ch_data_t *ch_data);
+
 private:
     Ui::MainWindow *ui;
 
@@ -42,6 +44,8 @@ private slots:
 
     QTimer *datarx_timer;
 
+    bool device_run;
+
 signals:
     void rx_data_update(scope_ch_data_t*);
 };