module: cadence: Implement complete process flow with INPUT_OVER+QUERY_DONE

The full processing command flow should start with the INPUT_OVER command
when EOS is expected and after the DO_EXECUTE the DONE needs to be checked
to see if the decoding has completed.

Signed-off-by: Peter Ujfalusi <peter.ujfalusi@linux.intel.com>

Author: ujfalusi

src/audio/module_adapter/module/cadence.c

@@ -476,6 +476,7 @@ int cadence_codec_process_data(struct processing_module *mod)
 	struct cadence_codec_data *cd = module_get_private_data(mod);
 	struct module_data *codec = &mod->priv;
 	struct comp_dev *dev = mod->dev;
+	uint32_t done = 0;
 	int ret;
 
 	if (codec->mpd.eos_reached) {
@@ -485,6 +486,18 @@ int cadence_codec_process_data(struct processing_module *mod)
 		return 0;
 	}
 
+	if (dev->pipeline->expect_eos) {
+		/* Signal that the stream is expected to end anytime soon */
+		API_CALL(cd, XA_API_CMD_INPUT_OVER, 0, NULL, ret);
+		if (ret != LIB_NO_ERROR) {
+			if (LIB_IS_FATAL_ERROR(ret)) {
+				comp_err(dev, "input_over failed with error: %x", ret);
+				return ret;
+			}
+			comp_warn(dev, "input_over failed with nonfatal error: %x", ret);
+		}
+	}
+
 	API_CALL(cd, XA_API_CMD_SET_INPUT_BYTES, 0, &codec->mpd.avail, ret);
 	if (ret != LIB_NO_ERROR) {
 		comp_err(dev, "failed to set size of input data with error: %x:", ret);
@@ -500,6 +513,15 @@ int cadence_codec_process_data(struct processing_module *mod)
 		comp_warn(dev, "processing failed with nonfatal error: %x", ret);
 	}
 
+	API_CALL(cd, XA_API_CMD_EXECUTE, XA_CMD_TYPE_DONE_QUERY, &done, ret);
+	if (ret != LIB_NO_ERROR) {
+		if (LIB_IS_FATAL_ERROR(ret)) {
+			comp_err(dev, "done query failed with error: %x", ret);
+			return ret;
+		}
+		comp_warn(dev, "done query failed with nonfatal error: %x", ret);
+	}
+
 	API_CALL(cd, XA_API_CMD_GET_OUTPUT_BYTES, 0, &codec->mpd.produced, ret);
 	if (ret != LIB_NO_ERROR) {
 		comp_err(dev, "could not get produced bytes, error %x:",
@@ -513,7 +535,7 @@ int cadence_codec_process_data(struct processing_module *mod)
 		return ret;
 	}
 
-	if (!codec->mpd.produced && dev->pipeline->expect_eos)
+	if (dev->pipeline->expect_eos && done)
 		codec->mpd.eos_reached = true;
 
 	return 0;