X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fdata%2Fsegment.hpp;h=db75ef710a285ceb75f795667a0826d34f4b8e1b;hp=5d0a242aaf00f0634339eb25eb9f48644381f3e5;hb=ba5f21864c459a24f71ce3b0045805813c032134;hpb=60d9b99a32e551cffd2b537d3e157d578a761c9b diff --git a/pv/data/segment.hpp b/pv/data/segment.hpp index 5d0a242a..db75ef71 100644 --- a/pv/data/segment.hpp +++ b/pv/data/segment.hpp @@ -1,6 +1,7 @@ /* * This file is part of the PulseView project. * + * Copyright (C) 2017 Soeren Apel * Copyright (C) 2012 Joel Holdsworth * * This program is free software; you can redistribute it and/or modify @@ -14,8 +15,7 @@ * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA + * along with this program; if not, see . */ #ifndef PULSEVIEW_PV_DATA_SEGMENT_HPP @@ -23,15 +23,40 @@ #include "pv/util.hpp" -#include #include +#include #include +using std::recursive_mutex; +using std::vector; + +namespace SegmentTest { +struct SmallSize8Single; +struct MediumSize8Single; +struct MaxSize8Single; +struct MediumSize24Single; +struct MediumSize32Single; +struct MaxSize32Single; +struct MediumSize32Multi; +struct MaxSize32Multi; +struct MaxSize32MultiAtOnce; +struct MaxSize32MultiIterated; +} // namespace SegmentTest + namespace pv { namespace data { +typedef struct { + uint64_t sample_index, chunk_num, chunk_offs; + uint8_t* chunk; + uint8_t* value; +} SegmentRawDataIterator; + class Segment { +private: + static const uint64_t MaxChunkSize; + public: Segment(uint64_t samplerate, unsigned int unit_size); @@ -46,44 +71,39 @@ public: unsigned int unit_size() const; - /** - * @brief Increase the capacity of the segment. - * - * Increasing the capacity allows samples to be appended without needing - * to reallocate memory. - * - * For the best efficiency @c set_capacity() should be called once before - * @c append_data() is called to set up the segment with the expected number - * of samples that will be appended in total. - * - * @note The capacity will automatically be increased when @c append_data() - * is called if there is not enough capacity in the buffer to store the samples. - * - * @param[in] new_capacity The new capacity of the segment. If this value is - * smaller or equal than the current capacity then the method has no effect. - */ - void set_capacity(uint64_t new_capacity); - - /** - * @brief Get the current capacity of the segment. - * - * The capacity can be increased by calling @c set_capacity(). - * - * @return The current capacity of the segment. - */ - uint64_t capacity() const; - -protected: - void append_data(void *data, uint64_t samples); + void free_unused_memory(); protected: - mutable std::recursive_mutex mutex_; - std::vector data_; + void append_single_sample(void *data); + void append_samples(void *data, uint64_t samples); + void get_raw_samples(uint64_t start, uint64_t count, uint8_t *dest) const; + + SegmentRawDataIterator* begin_raw_sample_iteration(uint64_t start); + void continue_raw_sample_iteration(SegmentRawDataIterator* it, uint64_t increase); + void end_raw_sample_iteration(SegmentRawDataIterator* it); + + mutable recursive_mutex mutex_; + vector data_chunks_; + uint8_t* current_chunk_; + uint64_t used_samples_, unused_samples_; uint64_t sample_count_; pv::util::Timestamp start_time_; double samplerate_; - uint64_t capacity_; + uint64_t chunk_size_; unsigned int unit_size_; + int iterator_count_; + bool mem_optimization_requested_; + + friend struct SegmentTest::SmallSize8Single; + friend struct SegmentTest::MediumSize8Single; + friend struct SegmentTest::MaxSize8Single; + friend struct SegmentTest::MediumSize24Single; + friend struct SegmentTest::MediumSize32Single; + friend struct SegmentTest::MaxSize32Single; + friend struct SegmentTest::MediumSize32Multi; + friend struct SegmentTest::MaxSize32Multi; + friend struct SegmentTest::MaxSize32MultiAtOnce; + friend struct SegmentTest::MaxSize32MultiIterated; }; } // namespace data