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>
31 using std::dynamic_pointer_cast;
32 using std::lock_guard;
38 using std::shared_ptr;
45 const size_t StoreSession::BlockSize = 1024 * 1024;
47 StoreSession::StoreSession(const std::string &file_name,
48 const SigSession &session) :
49 _file_name(file_name),
57 StoreSession::~StoreSession()
62 pair<uint64_t, uint64_t> StoreSession::progress() const
64 return make_pair(_units_stored.load(), _unit_count.load());
67 const QString& StoreSession::error() const
69 lock_guard<mutex> lock(_mutex);
73 bool StoreSession::start()
75 set< shared_ptr<data::SignalData> > data_set =
77 const vector< shared_ptr<view::Signal> > sigs =
78 _session.get_signals();
80 // Check we have logic data
81 if (data_set.empty() || sigs.empty()) {
82 _error = tr("No data to save.");
86 if (data_set.size() > 1) {
87 _error = tr("PulseView currently only has support for "
88 "storing a single data stream.");
93 //shared_ptr<data::SignalData
94 shared_ptr<data::Logic> data;
95 if (!(data = dynamic_pointer_cast<data::Logic>(*data_set.begin()))) {
96 _error = tr("PulseView currently only has support for "
97 "storing a logic data.");
102 const deque< shared_ptr<data::LogicSnapshot> > &snapshots =
103 data->get_snapshots();
105 if (snapshots.empty()) {
106 _error = tr("No snapshots to save.");
110 const shared_ptr<data::LogicSnapshot> snapshot(snapshots.front());
113 // Make a list of probes
114 char **const probes = new char*[sigs.size() + 1];
115 for (size_t i = 0; i < sigs.size(); i++) {
116 shared_ptr<view::Signal> sig(sigs[i]);
118 probes[i] = strdup(sig->get_name().toUtf8().constData());
120 probes[sigs.size()] = NULL;
123 if (sr_session_save_init(_file_name.c_str(),
124 data->samplerate(), probes) != SR_OK) {
125 _error = tr("Error while saving.");
129 // Delete the probes array
130 for (size_t i = 0; i <= sigs.size(); i++)
134 _thread = std::thread(&StoreSession::store_proc, this, snapshot);
138 void StoreSession::wait()
140 if (_thread.joinable())
144 void StoreSession::cancel()
149 void StoreSession::store_proc(shared_ptr<data::LogicSnapshot> snapshot)
153 uint64_t start_sample = 0;
155 /// TODO: Wrap this in a std::unique_ptr when we transition to C++11
156 uint8_t *const data = new uint8_t[BlockSize];
159 const int unit_size = snapshot->unit_size();
160 assert(unit_size != 0);
162 _unit_count = snapshot->get_sample_count();
164 const unsigned int samples_per_block = BlockSize / unit_size;
166 while (!_interrupt && start_sample < _unit_count)
170 const uint64_t end_sample = min(
171 start_sample + samples_per_block, _unit_count.load());
172 snapshot->get_samples(data, start_sample, end_sample);
174 if(sr_session_append(_file_name.c_str(), data, unit_size,
175 end_sample - start_sample) != SR_OK)
177 _error = tr("Error while saving.");
181 start_sample = end_sample;
182 _units_stored = start_sample;