Files
        @ a30d48dab8b8
    
        
              Branch filter: 
        
    Location: tempo-plotter/src/chunkedbuffer.cpp
        
            
            a30d48dab8b8
            2.4 KiB
            text/x-c++hdr
        
        
    
    Merge with default
    1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111  | /*
  Copyright © 2017 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 "chunkedbuffer.h"
ChunkedBuffer::ChunkedBuffer()
{
    numChunks = 0;
    _size = 0;
    // create first chunk
    addNewChunk();
}
ChunkedBuffer::~ChunkedBuffer()
{
    for (auto chunk : chunks)
    {
        delete chunk;
    }
}
void ChunkedBuffer::addSamples(double* samples, size_t size)
{
    size_t i = 0;
    while (i < size)
    {
        // select chunk to add data
        auto chunk = chunks.last();
        if (chunk->isFull())
        {
            chunk = addNewChunk(); // create a new chunk
        }
        // add data to chunk
        size_t c = std::min(chunk->left(), (size - i));
        chunk->addSamples(&samples[i], c);
        i += c;
    }
    _size += size;
}
void ChunkedBuffer::clear()
{
    // delete all chunks
    for (auto chunk : chunks)
    {
        delete chunk;
    }
    chunks.clear();
    numChunks = 0;
    _size = 0;
    // create first chunk
    addNewChunk();
}
DataChunk* ChunkedBuffer::addNewChunk()
{
    auto chunk = new DataChunk(_size, CHUNK_SIZE);
    chunks.append(chunk);
    return chunk;
}
size_t ChunkedBuffer::size() const
{
    return _size;
}
QRectF ChunkedBuffer::boundingRect() const
{
    // TODO: it should be possible to cache boundingRect and only
    // update on 'addSamples' and when dropping chunks
    // find ymin and ymax
    double ymin = chunks.first()->min();
    double ymax = chunks.first()->max();
    for (auto c : chunks)
    {
        ymin = std::min(ymin, c->min());
        ymax = std::max(ymax, c->max());
    }
    return QRectF(0, ymax, _size, (ymax-ymin));
}
double ChunkedBuffer::sample(size_t i) const
{
    int chunk_index = i / CHUNK_SIZE;
    int chunk_offset = i % CHUNK_SIZE;
    return chunks[chunk_index]->sample(chunk_offset);
}
 |