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
21 #include "storesession.h"
23 #include <pv/sigsession.h>
24 #include <pv/data/logic.h>
25 #include <pv/data/logicsnapshot.h>
26 #include <pv/view/signal.h>
29 using std::dynamic_pointer_cast;
30 using std::lock_guard;
36 using std::shared_ptr;
43 const size_t StoreSession::BlockSize = 1024 * 1024;
45 StoreSession::StoreSession(const std::string &file_name,
46 const SigSession &session) :
47 _file_name(file_name),
55 StoreSession::~StoreSession()
60 pair<uint64_t, uint64_t> StoreSession::progress() const
62 lock_guard<mutex> lock(_mutex);
63 return make_pair(_units_stored, _unit_count);
66 const QString& StoreSession::error() const
68 lock_guard<mutex> lock(_mutex);
72 bool StoreSession::start()
74 set< shared_ptr<data::SignalData> > data_set =
76 const vector< shared_ptr<view::Signal> > sigs =
77 _session.get_signals();
79 // Check we have logic data
80 if (data_set.empty() || sigs.empty()) {
81 _error = tr("No data to save.");
85 if (data_set.size() > 1) {
86 _error = tr("PulseView currently only has support for "
87 "storing a single data stream.");
92 //shared_ptr<data::SignalData
93 shared_ptr<data::Logic> data;
94 if (!(data = dynamic_pointer_cast<data::Logic>(*data_set.begin()))) {
95 _error = tr("PulseView currently only has support for "
96 "storing a logic data.");
101 const deque< shared_ptr<data::LogicSnapshot> > &snapshots =
102 data->get_snapshots();
104 if (snapshots.empty()) {
105 _error = tr("No snapshots to save.");
109 const shared_ptr<data::LogicSnapshot> snapshot(snapshots.front());
112 // Make a list of probes
113 char **const probes = new char*[sigs.size() + 1];
114 for (size_t i = 0; i < sigs.size(); i++) {
115 shared_ptr<view::Signal> sig(sigs[i]);
117 probes[i] = strdup(sig->get_name().toUtf8().constData());
119 probes[sigs.size()] = NULL;
122 if (sr_session_save_init(_file_name.c_str(),
123 data->samplerate(), probes) != SR_OK) {
124 _error = tr("Error while saving.");
128 // Delete the probes array
129 for (size_t i = 0; i <= sigs.size(); i++)
133 _thread = std::thread(&StoreSession::store_proc, this, snapshot);
137 void StoreSession::wait()
139 if (_thread.joinable())
143 void StoreSession::cancel()
148 void StoreSession::store_proc(shared_ptr<data::LogicSnapshot> snapshot)
152 uint64_t start_sample = 0;
154 /// TODO: Wrap this in a std::unique_ptr when we transition to C++11
155 uint8_t *const data = new uint8_t[BlockSize];
158 const int unit_size = snapshot->unit_size();
159 assert(unit_size != 0);
162 lock_guard<mutex> lock(_mutex);
163 _unit_count = snapshot->get_sample_count();
166 const unsigned int samples_per_block = BlockSize / unit_size;
168 while (!_interrupt && start_sample < _unit_count)
172 const uint64_t end_sample = min(
173 start_sample + samples_per_block, _unit_count);
174 snapshot->get_samples(data, start_sample, end_sample);
176 if(sr_session_append(_file_name.c_str(), data, unit_size,
177 end_sample - start_sample) != SR_OK)
179 _error = tr("Error while saving.");
183 start_sample = end_sample;
186 lock_guard<mutex> lock(_mutex);
187 _units_stored = start_sample;