tempo-plotter Changeset - 8bc730cfda45 · protofusion repositories

Changeset - 8bc730cfda45

Parent rev.

Child rev.

[Not reviewed]

default

0 4 0

Hasan Yavuz ÖZDERYA - 10 years ago 2015-08-15 13:17:08
hy@ozderya.net

use simple double array instead of QVector for FrameBuffer interface

4 files changed with 17 insertions and 18 deletions:

framebuffer.cpp

framebuffer.h

mainwindow.cpp

mainwindow.h

0 comments (0 inline, 0 general)

framebuffer.cpp

➞

Show inline comments

@@ @@ -59,15 +59,15 @@ void FrameBuffer::resize(size_t size) @@
     delete data;
     data = newData;
     headIndex = 0;
     _size = size;
+}
-void FrameBuffer::addSamples(QVector<double> samples)
+void FrameBuffer::addSamples(double* samples, size_t size)
+{
-    unsigned shift = samples.size();
     unsigned shift = size;
     if (shift < _size)
+    {
         unsigned x = _size - headIndex; // distance of `head` to end
         if (shift <= x) // there is enough room at the end of array
+        {

framebuffer.h

➞

Show inline comments

@@ @@ -28,13 +28,13 @@ class FrameBuffer : public QwtSeriesData @@
+{
 public:
     FrameBuffer(size_t size);
     ~FrameBuffer();
     void resize(size_t size);
-    void addSamples(QVector<double> samples);
+    void addSamples(double* samples, size_t size);
     void clear(); // fill 0
     // QwtSeriesData implementations
     size_t size() const;
     QPointF sample(size_t i) const;
     QRectF boundingRect() const;

mainwindow.cpp

➞

Show inline comments

@@ @@ -252,32 +252,33 @@ void MainWindow::onDataReady() @@
+    }
     if (bytesAvailable < packageSize) return;
     int numOfPackagesToRead =
         (bytesAvailable - (bytesAvailable % packageSize)) / packageSize;
     QVector<DataArray> channelSamples(numOfChannels);
     for (unsigned int ci = 0; ci < numOfChannels; ci++)
+    {
         channelSamples[ci].resize(numOfPackagesToRead);
+    }
     double* channelSamples = new double[numOfPackagesToRead*numOfChannels];
     int i = 0;
     while(i < numOfPackagesToRead)
+    {
         for (unsigned int ci = 0; ci < numOfChannels; ci++)
+        {
             channelSamples[ci].replace(i, (this->*readSample)());
             // channelSamples[ci].replace(i, (this->*readSample)());
             channelSamples[ci*numOfPackagesToRead+i] = (this->*readSample)();
+        }
         i++;
+    }
     for (unsigned int ci = 0; ci < numOfChannels; ci++)
+    {
         addChannelData(ci, channelSamples[ci]);
         addChannelData(ci,
                        channelSamples + ci*numOfPackagesToRead,
                        numOfPackagesToRead);
+    }
     delete channelSamples;
+}
 void MainWindow::onDataReadyASCII()
+{
     while(serialPort.canReadLine())
+    {
@@ @@ -307,13 +308,13 @@ void MainWindow::onDataReadyASCII() @@
         for (int ci = 0; ci < numReadChannels; ci++)
+        {
             bool ok;
             double channelSample = separatedValues[ci].toDouble(&ok);
             if (ok)
+            {
-                addChannelData(ci, DataArray({channelSample}));
+                addChannelData(ci, &channelSample, 1);
+            }
             else
+            {
                 qWarning() << "Data parsing error for channel: " << ci;
+            }
+        }
@@ @@ -380,17 +381,17 @@ required privileges or device is already @@
 void MainWindow::skipByte()
+{
     skipByteRequested = true;
+}
-void MainWindow::addChannelData(unsigned int channel, DataArray data)
+void MainWindow::addChannelData(unsigned int channel, double* data, unsigned size)
+{
     channelBuffers[channel]->addSamples(data);
+    channelBuffers[channel]->addSamples(data, size);
     ui->plot->replot(); // TODO: replot after all channel data updated
-    sampleCount += data.size();
     sampleCount += size;
+}
 void MainWindow::clearPlot()
+{
     for (unsigned int ci = 0; ci < numOfChannels; ci++)
+    {
@@ @@ -562,17 +563,15 @@ void MainWindow::demoTimerTimeout() @@
     if (demoCount > 100) demoCount = 0;
     if (!ui->actionPause->isChecked())
+    {
         for (unsigned int ci = 0; ci < numOfChannels; ci++)
+        {
             DataArray data(1);
             // we are calculating the fourier components of square wave
             double value = 4*sin(2*M_PI*double((ci+1)*demoCount)/period)/((2*(ci+1))*M_PI);
             data.replace(0, value);
             addChannelData(ci, data);
             addChannelData(ci, &value, 1);
+        }
+    }
+}
 void MainWindow::enableDemo(bool enabled)
+{

mainwindow.h

➞

Show inline comments

@@ @@ -81,13 +81,13 @@ private: @@
     QList<QwtPlotCurve*> curves;
     typedef QVector<double> DataArray;
     // Note: FrameBuffer s are owned by their respective QwtPlotCurve s.
     QList<FrameBuffer*> channelBuffers;
     // `data` contains i th channels data
-    void addChannelData(unsigned int channel, DataArray data);
+    void addChannelData(unsigned int channel, double* data, unsigned size);
     NumberFormat numberFormat;
     unsigned int sampleSize; // number of bytes in the selected number format
     double (MainWindow::*readSample)();
     // note that serialPort should already have enough bytes present

0 comments (0 inline, 0 general)