// skip 1 byte if requested

    if (bytesAvailable > 0 && skipByteRequested)

    {

        _device->read(1);

        skipByteRequested = false;

        bytesAvailable--;

    }

    // skip 1 sample (channel) if requested

    if (bytesAvailable >= (int) sampleSize && skipSampleRequested)

    {

        _device->read(sampleSize);

        skipSampleRequested = false;

        bytesAvailable--;

    }

    if (bytesAvailable < packageSize) return;

    int numOfPackagesToRead =

        (bytesAvailable - (bytesAvailable % packageSize)) / packageSize;

    if (paused)

    {

        // read and discard data

        _device->read(numOfPackagesToRead*packageSize);

        return;

    }

    double* channelSamples = new double[numOfPackagesToRead*_numOfChannels];

    for (int i = 0; i < numOfPackagesToRead; i++)

    {

        for (unsigned int ci = 0; ci < _numOfChannels; ci++)

        {

            // channelSamples[ci].replace(i, (this->*readSample)());

            channelSamples[ci*numOfPackagesToRead+i] = (this->*readSample)();

        }

    }

    for (unsigned int ci = 0; ci < _numOfChannels; ci++)

    {

        addChannelData(ci,

                       channelSamples + ci*numOfPackagesToRead,

                       numOfPackagesToRead);

    }

    emit dataAdded();

}

template<typename T> double BinaryStreamReader::readSampleAs()

{

    T data;

    _device->read((char*) &data, sizeof(data));

    if (_settingsWidget.endianness() == LittleEndian)

    {

        data = qFromLittleEndian(data);

    }

    else

    {

        data = qFromBigEndian(data);

    }

    return double(data);

}

void BinaryStreamReader::addChannelData(unsigned int channel,

                                        double* data, unsigned size)

{

    _channelMan->addChannelData(channel, data, size);

    sampleCount += size;

}

void BinaryStreamReader::saveSettings(QSettings* settings)

{

    _settingsWidget.saveSettings(settings);

}

void BinaryStreamReader::loadSettings(QSettings* settings)

{

    _settingsWidget.loadSettings(settings);

}

/*

  Copyright © 2015 Hasan Yavuz Özderya

  This file is part of serialplot.

  serialplot is free software: you can redistribute it and/or modify

  it under the terms of the GNU General Public License as published by

  the Free Software Foundation, either version 3 of the License, or

  (at your option) any later version.

  serialplot is distributed in the hope that it will be useful,

  but WITHOUT ANY WARRANTY; without even the implied warranty of

  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

  GNU General Public License for more details.

  You should have received a copy of the GNU General Public License

  along with serialplot.  If not, see <http://www.gnu.org/licenses/>.

*/

#include "framebuffer.h"

FrameBuffer::FrameBuffer(size_t size)

{

    _size = size;

    data = new double[_size]();

    headIndex = 0;

    _boundingRect.setCoords(0, 0, size, 0);

}

FrameBuffer::~FrameBuffer()

{

}

void FrameBuffer::resize(size_t size)

{

    int offset = size - _size;

    if (offset == 0) return;

    double* newData = new double[size];

    // move data to new array

    int fill_start = offset > 0 ? offset : 0;

    for (int i = fill_start; i < int(size); i++)

    {

        newData[i] = sample(i - offset);

    }

    // fill the beginning of the new data

    if (fill_start > 0)

    {

        for (int i = 0; i < fill_start; i++)

        {

            newData[i] = 0;

        }

    }

    // data is ready, clean and re-point

    delete data;

    data = newData;

    headIndex = 0;

    _size = size;

    // update the bounding rectangle

    _boundingRect.setRight(_size);

}

void FrameBuffer::addSamples(double* samples, size_t 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

        {

            for (size_t i = 0; i < shift; i++)

            {

                data[i+headIndex] = samples[i];

{

    // if paused just read and waste data

    if (paused)

    {

        _device->read((checksumEnabled ? frameSize+1 : frameSize));

        return;

    }

    // a package is 1 set of samples for all channels

    unsigned numOfPackagesToRead = frameSize / (_numOfChannels * sampleSize);

    double* channelSamples = new double[numOfPackagesToRead * _numOfChannels];

    for (unsigned i = 0; i < numOfPackagesToRead; i++)

    {

        for (unsigned int ci = 0; ci < _numOfChannels; ci++)

        {

            channelSamples[ci*numOfPackagesToRead+i] = (this->*readSample)();

        }

    }

    // read checksum

    unsigned rChecksum = 0;

    bool checksumPassed = false;

    if (checksumEnabled)

    {

        _device->read((char*) &rChecksum, 1);

        calcChecksum &= 0xFF;

        checksumPassed = (calcChecksum == rChecksum);

    }

    if (!checksumEnabled || checksumPassed)

    {

        // commit data

        for (unsigned int ci = 0; ci < _numOfChannels; ci++)

        {

            _channelMan->addChannelData(

                ci,

                channelSamples + ci*numOfPackagesToRead,

                numOfPackagesToRead);

            sampleCount += numOfPackagesToRead;

        }

        emit dataAdded();

    }

    else

    {

        qCritical() << "Checksum failed! Received:" << rChecksum << "Calculated:" << calcChecksum;

    }

}

template<typename T> double FramedReader::readSampleAs()

{

    T data;

    _device->read((char*) &data, sizeof(data));

    if (checksumEnabled)

    {

        for (unsigned i = 0; i < sizeof(data); i++)

        {

            calcChecksum += ((unsigned char*) &data)[i];

        }

    }

    if (_settingsWidget.endianness() == LittleEndian)

    {

        data = qFromLittleEndian(data);

    }

    else

    {

        data = qFromBigEndian(data);

    }

    return double(data);

}

void FramedReader::saveSettings(QSettings* settings)

{

    _settingsWidget.saveSettings(settings);

}

void FramedReader::loadSettings(QSettings* settings)

{

    _settingsWidget.loadSettings(settings);

}