pipeline: Add data process error notification

Add functionality to send notifications when a data processing function
in a module reports an error. Add notifications for both ll and dp modules.

Signed-off-by: Adrian Warecki <adrian.warecki@intel.com>

Author: softwarecki

src/audio/pipeline/pipeline-schedule.c

@@ -372,8 +372,10 @@ static enum task_state dp_task_run(void *data)
 {
 	struct processing_module *mod = data;
 
-	module_process_sink_src(mod, mod->sources, mod->num_of_sources,
-				mod->sinks, mod->num_of_sinks);
+	int ret = module_process_sink_src(mod, mod->sources, mod->num_of_sources,
+					  mod->sinks, mod->num_of_sinks);
+	if (ret)
+		pipeline_comp_copy_error_notify(mod->dev, ret);
 
 	return SOF_TASK_STATE_RESCHEDULE;
 }

src/audio/pipeline/pipeline-stream.c

@@ -21,6 +21,11 @@
 #include <rtos/kernel.h>
 #include <sof/audio/module_adapter/module/generic.h>
 #include <sof/lib/cpu-clk-manager.h>
+#include <sof/ipc/notification_pool.h>
+
+#ifdef CONFIG_IPC_MAJOR_4
+#include <ipc4/notification.h>
+#endif
 
 #include <errno.h>
 #include <stdbool.h>
@@ -88,6 +93,20 @@ pipeline_should_report_enodata_on_trigger(struct comp_dev *rsrc,
 	return false;
 }
 
+void pipeline_comp_copy_error_notify(const struct comp_dev *component, int err)
+{
+#ifdef CONFIG_IPC_MAJOR_4
+	struct ipc_msg *notify;
+
+	notify = ipc_notification_pool_get(IPC4_RESOURCE_EVENT_SIZE);
+	if (!notify)
+		return;
+
+	process_data_error_notif_msg_init(notify, component->ipc_config.id, err);
+	ipc_msg_send(notify, notify->tx_data, false);
+#endif
+}
+
 static int pipeline_comp_copy(struct comp_dev *current,
 			      struct comp_buffer *calling_buf,
 			      struct pipeline_walk_context *ctx, int dir)
@@ -113,16 +132,23 @@ static int pipeline_comp_copy(struct comp_dev *current,
 	/* copy to downstream immediately */
 	if (dir == PPL_DIR_DOWNSTREAM) {
 		err = comp_copy(current);
-		if (err < 0 || err == PPL_STATUS_PATH_STOP)
+		if (err < 0) {
+			pipeline_comp_copy_error_notify(current, err);
+			return err;
+		}
+		if (err == PPL_STATUS_PATH_STOP)
 			return err;
 	}
 
 	err = pipeline_for_each_comp(current, ctx, dir);
 	if (err < 0 || err == PPL_STATUS_PATH_STOP)
 		return err;
 
-	if (dir == PPL_DIR_UPSTREAM)
+	if (dir == PPL_DIR_UPSTREAM) {
 		err = comp_copy(current);
+		if (err < 0)
+			pipeline_comp_copy_error_notify(current, err);
+	}
 
 	return err;
 }

src/include/sof/audio/pipeline.h

@@ -431,4 +431,11 @@ void pipeline_xrun(struct pipeline *p, struct comp_dev *dev, int32_t bytes);
  */
 int pipeline_xrun_set_limit(struct pipeline *p, uint32_t xrun_limit_usecs);
 
+/**
+ * \brief Sends an ipc notification that an error occurred in the module's processing function.
+ * \param[in] component The component in which the error occurred.
+ * \param[in] error_code Error code.
+ */
+void pipeline_comp_copy_error_notify(const struct comp_dev *component, int error_code);
+
 #endif /* __SOF_AUDIO_PIPELINE_H__ */