2 * This file is part of the PulseView project.
4 * Copyright (C) 2014 Joel Holdsworth <joel@airwebreathe.org.uk>
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
23 #include "storesession.h"
25 #include <pv/sigsession.h>
26 #include <pv/data/logic.h>
27 #include <pv/data/logicsnapshot.h>
28 #include <pv/view/signal.h>
30 #include <libsigrok/libsigrok.hpp>
33 using std::dynamic_pointer_cast;
34 using std::lock_guard;
40 using std::shared_ptr;
49 const size_t StoreSession::BlockSize = 1024 * 1024;
51 StoreSession::StoreSession(const std::string &file_name,
52 const SigSession &session) :
53 _file_name(file_name),
61 StoreSession::~StoreSession()
66 pair<int, int> StoreSession::progress() const
68 return make_pair(_units_stored.load(), _unit_count.load());
71 const QString& StoreSession::error() const
73 lock_guard<mutex> lock(_mutex);
77 bool StoreSession::start()
79 set< shared_ptr<data::SignalData> > data_set =
81 const vector< shared_ptr<view::Signal> > sigs =
82 _session.get_signals();
84 // Check we have logic data
85 if (data_set.empty() || sigs.empty()) {
86 _error = tr("No data to save.");
90 if (data_set.size() > 1) {
91 _error = tr("PulseView currently only has support for "
92 "storing a single data stream.");
97 //shared_ptr<data::SignalData
98 shared_ptr<data::Logic> data;
99 if (!(data = dynamic_pointer_cast<data::Logic>(*data_set.begin()))) {
100 _error = tr("PulseView currently only has support for "
101 "storing a logic data.");
106 const deque< shared_ptr<data::LogicSnapshot> > &snapshots =
107 data->get_snapshots();
109 if (snapshots.empty()) {
110 _error = tr("No snapshots to save.");
114 const shared_ptr<data::LogicSnapshot> snapshot(snapshots.front());
117 // Make a list of channels
118 char **const channels = new char*[sigs.size() + 1];
119 for (size_t i = 0; i < sigs.size(); i++) {
120 shared_ptr<view::Signal> sig(sigs[i]);
122 channels[i] = strdup(sig->get_name().toUtf8().constData());
124 channels[sigs.size()] = NULL;
128 SigSession::_sr_session->begin_save(_file_name);
129 } catch (Error error) {
130 _error = tr("Error while saving.");
134 // Delete the channels array
135 for (size_t i = 0; i <= sigs.size(); i++)
139 _thread = std::thread(&StoreSession::store_proc, this, snapshot);
143 void StoreSession::wait()
145 if (_thread.joinable())
149 void StoreSession::cancel()
154 void StoreSession::store_proc(shared_ptr<data::LogicSnapshot> snapshot)
158 uint64_t start_sample = 0, sample_count;
159 unsigned progress_scale = 0;
161 /// TODO: Wrap this in a std::unique_ptr when we transition to C++11
162 uint8_t *const data = new uint8_t[BlockSize];
165 const int unit_size = snapshot->unit_size();
166 assert(unit_size != 0);
168 sample_count = snapshot->get_sample_count();
170 // Qt needs the progress values to fit inside an int. If they would
171 // not, scale the current and max values down until they do.
172 while ((sample_count >> progress_scale) > INT_MAX)
175 _unit_count = sample_count >> progress_scale;
177 const unsigned int samples_per_block = BlockSize / unit_size;
179 while (!_interrupt && start_sample < sample_count)
183 const uint64_t end_sample = min(
184 start_sample + samples_per_block, sample_count);
185 snapshot->get_samples(data, start_sample, end_sample);
187 size_t length = end_sample - start_sample;
190 SigSession::_sr_session->append(data, length, unit_size);
191 } catch (Error error) {
192 _error = tr("Error while saving.");
196 start_sample = end_sample;
197 _units_stored = start_sample >> progress_scale;