X-Git-Url: http://sigrok.org/gitweb/?a=blobdiff_plain;f=pv%2Fdata%2Fdecoderstack.cpp;h=4b2a90576921178def34ca97dea23c3fe4d68e7c;hb=4c581c790c0e9d378a0074c2b2802a0d7f5c7579;hp=2344804fd1f17d2e2490f83fa6d8df9128084f12;hpb=1c5fb7593d34daeca31148eb48de4ff7a0c6aa05;p=pulseview.git

diff --git a/pv/data/decoderstack.cpp b/pv/data/decoderstack.cpp
index 2344804f..4b2a9057 100644
--- a/pv/data/decoderstack.cpp
+++ b/pv/data/decoderstack.cpp
@@ -58,6 +58,7 @@ namespace data {
 const double DecoderStack::DecodeMargin = 1.0;
 const double DecoderStack::DecodeThreshold = 0.2;
 const int64_t DecoderStack::DecodeChunkLength = 4096;
+const unsigned int DecoderStack::DecodeNotifyPeriod = 65536;
 
 mutex DecoderStack::_global_decode_mutex;
 
@@ -193,6 +194,14 @@ void DecoderStack::begin_decode()
 
 	clear();
 
+	// Check that all decoders have the required probes
+	BOOST_FOREACH(const shared_ptr<decode::Decoder> &dec, _stack)
+		if (!dec->have_required_probes()) {
+			_error_message = tr("One or more required probes "
+				"have not been specified");
+			return;
+		}
+
 	// Add classes
 	BOOST_FOREACH (const shared_ptr<decode::Decoder> &dec, _stack)
 	{
@@ -249,8 +258,7 @@ void DecoderStack::begin_decode()
 	if (_samplerate == 0.0)
 		_samplerate = 1.0;
 
-	_decode_thread = boost::thread(&DecoderStack::decode_proc, this,
-		data);
+	_decode_thread = boost::thread(&DecoderStack::decode_proc, this);
 }
 
 uint64_t DecoderStack::get_max_sample_count() const
@@ -307,12 +315,15 @@ void DecoderStack::decode_data(
 			lock_guard<mutex> lock(_output_mutex);
 			_samples_decoded = chunk_end;
 		}
+
+		if (i % DecodeNotifyPeriod == 0)
+			new_decode_data();
 	}
 
 	new_decode_data();
 }
 
-void DecoderStack::decode_proc(shared_ptr<data::Logic> data)
+void DecoderStack::decode_proc()
 {
 	optional<int64_t> sample_count;
 	srd_session *session;
@@ -321,11 +332,6 @@ void DecoderStack::decode_proc(shared_ptr<data::Logic> data)
 	assert(data);
 	assert(_snapshot);
 
-	// Check that all decoders have the required probes
-	BOOST_FOREACH(const shared_ptr<decode::Decoder> &dec, _stack)
-		if (!dec->have_required_probes())
-			return;
-
 	// Create the session
 	srd_session_new(&session);
 	assert(session);
@@ -425,7 +431,8 @@ void DecoderStack::on_data_received()
 {
 	{
 		unique_lock<mutex> lock(_input_mutex);
-		_sample_count = _snapshot->get_sample_count();
+		if (_snapshot)
+			_sample_count = _snapshot->get_sample_count();
 	}
 	_input_cond.notify_one();
 }
@@ -434,7 +441,8 @@ void DecoderStack::on_frame_ended()
 {
 	{
 		unique_lock<mutex> lock(_input_mutex);
-		_frame_complete = true;
+		if (_snapshot)
+			_frame_complete = true;
 	}
 	_input_cond.notify_one();
 }