decoder: terminate .wait() and .decode(), join threads for v3 instances

Add support to terminate blocking .wait() and .decode() method calls of
v3 decoder instances. This terminates the decoder thread's main routine
and allows to release associated resources. Cope with requested as well
as unexpected termination of decode() calls. Add debug messages to
thread related code paths.

Make sure to unblock the main thread which feeds the decoder thread.
This unbreaks situations where decoders e.g. throw "need samplerate to
decode" exceptions.

Drain Python errors which might remain from the most recent .decode()
execution, to not affect other code paths. This avoids an issue where
the creation of a new decoder instance fails in the presence of errors
from a previous run.

This fixes bug #902.

1 files changed, 3 insertions, 0 deletions

diff --git a/libsigrokdecode.h b/libsigrokdecode.h
index 8d1d5ae..549bd25 100644
--- a/libsigrokdecode.h
+++ b/libsigrokdecode.h
@@ -261,6 +261,9 @@ struct srd_decoder_inst {
 	/** Indicates whether the worker thread has handled all samples. */
 	gboolean handled_all_samples;
 
+	/** Requests termination of wait() and decode(). */
+	gboolean want_wait_terminate;
+
 	GCond got_new_samples_cond;
 	GCond handled_all_samples_cond;
 	GMutex data_mutex;