Function di_thread

libsigrokdecode4DSL/instance.c:1064–1151

* Worker thread (per PD-stack). * * @param data Pointer to the lowest-level PD's device instance. * Must not be NULL. * * @return NULL if there was an error. */

 * @return NULL if there was an error.
 */
static gpointer di_thread(gpointer data)
{
	PyObject *py_res;
	struct srd_decoder_inst *di;
	int wanted_term = 0;
	PyGILState_STATE gstate;
	int is_task_stop_signal = FALSE;

	assert(data);

	di = data; 

	srd_dbg("%s: Starting thread routine for decoder.", di->inst_id);

	gstate = PyGILState_Ensure();

	/*
	 * Call self.decode(). Only returns if the PD throws an exception.
	 * "Regular" termination of the decode() method is not expected.
	 */
	srd_dbg("%s: Calling decode().", di->inst_id);
	py_res = PyObject_CallMethod(di->py_inst, "decode", NULL);
	srd_dbg("%s: decode() terminated.", di->inst_id);

	is_task_stop_signal = di->is_task_stop_signal;
	//srd_err("get flag:%d", is_task_stop_signal);

	/**
	 * decode() returns a error!
	 * before the send thread exits, write the error
	 * 
	*/
	if (py_res){
		
		di->decoder_state = SRD_ERR;

		if (PyUnicode_Check(py_res))
		{
			PyObject *py_bytes = PyUnicode_AsUTF8String(py_res);
			char *err_str = PyBytes_AsString(py_bytes);
			srd_err("python method decode() returns an error:\n %s", err_str);
			di->python_proc_error = g_strdup(err_str);
		}
		else{
			di->python_proc_error = g_strdup("python method decode() returns an unknown type error!");
		}

		Py_DecRef(py_res);
	}
	
	/**
	 * decode() throw an except!
	 * before the send thread exits, write the error
	 * 
	*/
	if (!py_res && !is_task_stop_signal)
	{
		srd_exception_catch(&di->python_proc_error, "Protocol decoder instance %s: ", di->inst_id);