projects
/
pulseview.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Removed a redundant call to SigSession::set_device
[pulseview.git]
/
pv
/
data
/
decoderstack.cpp
diff --git
a/pv/data/decoderstack.cpp
b/pv/data/decoderstack.cpp
index 323f5cc2cd4b45397cf18e1cd59560dc0ef17f33..9707d8d2cb605ddf61361bd48c648c4b48d65714 100644
(file)
--- a/
pv/data/decoderstack.cpp
+++ b/
pv/data/decoderstack.cpp
@@
-67,8
+67,10
@@
DecoderStack::DecoderStack(const srd_decoder *const dec) :
DecoderStack::~DecoderStack()
{
DecoderStack::~DecoderStack()
{
- _decode_thread.interrupt();
- _decode_thread.join();
+ if (_decode_thread.joinable()) {
+ _decode_thread.interrupt();
+ _decode_thread.join();
+ }
}
const std::list< boost::shared_ptr<decode::Decoder> >&
}
const std::list< boost::shared_ptr<decode::Decoder> >&
@@
-103,7
+105,7
@@
int64_t DecoderStack::samples_decoded() const
return _samples_decoded;
}
return _samples_decoded;
}
-std::vector<Row> DecoderStack::get_rows() const
+std::vector<Row> DecoderStack::get_
visible_
rows() const
{
lock_guard<mutex> lock(_mutex);
{
lock_guard<mutex> lock(_mutex);
@@
-112,6
+114,9
@@
std::vector<Row> DecoderStack::get_rows() const
BOOST_FOREACH (const shared_ptr<decode::Decoder> &dec, _stack)
{
assert(dec);
BOOST_FOREACH (const shared_ptr<decode::Decoder> &dec, _stack)
{
assert(dec);
+ if (!dec->shown())
+ continue;
+
const srd_decoder *const decc = dec->decoder();
assert(dec->decoder());
const srd_decoder *const decc = dec->decoder();
assert(dec->decoder());
@@
-165,8
+170,10
@@
void DecoderStack::begin_decode()
shared_ptr<pv::view::LogicSignal> logic_signal;
shared_ptr<pv::data::Logic> data;
shared_ptr<pv::view::LogicSignal> logic_signal;
shared_ptr<pv::data::Logic> data;
- _decode_thread.interrupt();
- _decode_thread.join();
+ if (_decode_thread.joinable()) {
+ _decode_thread.interrupt();
+ _decode_thread.join();
+ }
clear();
clear();
@@
-243,16
+250,23
@@
void DecoderStack::decode_proc(shared_ptr<data::Logic> data)
assert(data);
assert(data);
+ // Check we have a snapshot of data
const deque< shared_ptr<pv::data::LogicSnapshot> > &snapshots =
data->get_snapshots();
if (snapshots.empty())
return;
const deque< shared_ptr<pv::data::LogicSnapshot> > &snapshots =
data->get_snapshots();
if (snapshots.empty())
return;
+ // Check that all decoders have the required probes
+ BOOST_FOREACH(const shared_ptr<decode::Decoder> &dec, _stack)
+ if (!dec->have_required_probes())
+ return;
+
const shared_ptr<pv::data::LogicSnapshot> &snapshot =
snapshots.front();
const int64_t sample_count = snapshot->get_sample_count();
const shared_ptr<pv::data::LogicSnapshot> &snapshot =
snapshots.front();
const int64_t sample_count = snapshot->get_sample_count();
+ const unsigned int unit_size = snapshot->unit_size();
const unsigned int chunk_sample_count =
const unsigned int chunk_sample_count =
- DecodeChunkLength /
snapshot->unit_size()
;
+ DecodeChunkLength /
unit_size
;
// Create the session
srd_session_new(&session);
// Create the session
srd_session_new(&session);
@@
-261,7
+275,7
@@
void DecoderStack::decode_proc(shared_ptr<data::Logic> data)
// Create the decoders
BOOST_FOREACH(const shared_ptr<decode::Decoder> &dec, _stack)
{
// Create the decoders
BOOST_FOREACH(const shared_ptr<decode::Decoder> &dec, _stack)
{
- srd_decoder_inst *const di = dec->create_decoder_inst(session);
+ srd_decoder_inst *const di = dec->create_decoder_inst(session
, unit_size
);
if (!di)
{
if (!di)
{
@@
-296,8
+310,8
@@
void DecoderStack::decode_proc(shared_ptr<data::Logic> data)
i + chunk_sample_count, sample_count);
snapshot->get_samples(chunk, i, chunk_end);
i + chunk_sample_count, sample_count);
snapshot->get_samples(chunk, i, chunk_end);
- if (srd_session_send(session, i, i + sample_count,
-
chunk, chunk_end - i
) != SRD_OK) {
+ if (srd_session_send(session, i, i + sample_count,
chunk,
+
(chunk_end - i) * unit_size
) != SRD_OK) {
_error_message = tr("Decoder reported an error");
break;
}
_error_message = tr("Decoder reported an error");
break;
}