CI ONLY

src/audio/buffers/audio_buffer.c

@@ -7,6 +7,7 @@
 #include <stdint.h>
 #include <stddef.h>
 #include <errno.h>
+#include <rtos/panic.h>
 #include <rtos/alloc.h>
 #include <ipc/stream.h>
 #include <sof/audio/audio_buffer.h>
@@ -92,9 +93,8 @@ void audio_buffer_free(struct sof_audio_buffer *buffer)
 	audio_buffer_free(buffer->secondary_buffer_sink);
 	audio_buffer_free(buffer->secondary_buffer_source);
 #endif /* CONFIG_PIPELINE_2_0 */
-	if (buffer->ops->free)
-		buffer->ops->free(buffer);
-	rfree(buffer);
+	/* "virtual destructor": free the buffer internals and buffer memory */
+	buffer->ops->free(buffer);
 }
 
 static
@@ -196,6 +196,7 @@ void audio_buffer_init(struct sof_audio_buffer *buffer, uint32_t buffer_type, bo
 	CORE_CHECK_STRUCT_INIT(&buffer, is_shared);
 	buffer->buffer_type = buffer_type;
 	buffer->ops = audio_buffer_ops;
+	assert(audio_buffer_ops->free);
 	buffer->audio_stream_params = audio_stream_params;
 	buffer->is_shared = is_shared;
 

src/audio/buffers/comp_buffer.c

@@ -158,6 +158,7 @@ static void comp_buffer_free(struct sof_audio_buffer *audio_buffer)
 	notifier_unregister_all(NULL, buffer);
 
 	rfree(buffer->stream.addr);
+	rfree(buffer);
 }
 
 static struct source_ops comp_buffer_source_ops = {

src/audio/buffers/ring_buffer.c

@@ -96,6 +96,7 @@ static void ring_buffer_free(struct sof_audio_buffer *audio_buffer)
 			container_of(audio_buffer, struct ring_buffer, audio_buffer);
 
 	rfree((__sparse_force void *)ring_buffer->_data_buffer);
+	rfree(ring_buffer);
 }
 
 static void ring_buffer_reset(struct sof_audio_buffer *audio_buffer)
@@ -239,6 +240,21 @@ static int ring_buffer_release_data(struct sof_source *source, size_t free_size)
 	return 0;
 }
 
+int ring_buffer_module_unbind(struct sof_sink *sink)
+{
+	struct ring_buffer *ring_buffer = ring_buffer_from_sink(sink);
+
+	CORE_CHECK_STRUCT(&ring_buffer->audio_buffer);
+
+	/* in case of disconnection, invalidate all cache. This method is guaranteed be called on
+	 * core that have been using sink API
+	 */
+	ring_buffer_invalidate_shared(ring_buffer, ring_buffer->_data_buffer,
+				      ring_buffer->data_buffer_size);
+
+	return 0;
+}
+
 static struct source_ops ring_buffer_source_ops = {
 	.get_data_available = ring_buffer_get_data_available,
 	.get_data = ring_buffer_get_data,
@@ -249,6 +265,7 @@ static struct sink_ops ring_buffer_sink_ops = {
 	.get_free_size = ring_buffer_get_free_size,
 	.get_buffer = ring_buffer_get_buffer,
 	.commit_buffer = ring_buffer_commit_buffer,
+	.on_unbind = ring_buffer_module_unbind,
 };
 
 static const struct audio_buffer_ops audio_buffer_ops = {

src/audio/copier/copier.c

@@ -1173,9 +1173,9 @@ __cold static int copier_get_hw_params(struct comp_dev *dev, struct sof_ipc_stre
 	return dai_common_get_hw_params(dd, dev, params, dir);
 }
 
-__cold static int copier_bind(struct processing_module *mod, void *data)
+__cold static int copier_bind(struct processing_module *mod, struct bind_info *bind_data)
 {
-	const struct ipc4_module_bind_unbind *const bu = (struct ipc4_module_bind_unbind *)data;
+	const struct ipc4_module_bind_unbind *const bu = bind_data->ipc4_data;
 	const uint32_t src_id = IPC4_COMP_ID(bu->primary.r.module_id, bu->primary.r.instance_id);
 	const uint32_t src_queue_id = bu->extension.r.src_queue;
 	struct copier_data *cd = module_get_private_data(mod);
@@ -1202,7 +1202,7 @@ __cold static int copier_bind(struct processing_module *mod, void *data)
 	return -ENODEV;
 }
 
-__cold static int copier_unbind(struct processing_module *mod, void *data)
+__cold static int copier_unbind(struct processing_module *mod, struct bind_info *unbind_data)
 {
 	struct copier_data *cd = module_get_private_data(mod);
 	struct comp_dev *dev = mod->dev;
@@ -1212,7 +1212,7 @@ __cold static int copier_unbind(struct processing_module *mod, void *data)
 	if (dev->ipc_config.type == SOF_COMP_DAI) {
 		struct dai_data *dd = cd->dd[0];
 
-		return dai_zephyr_unbind(dd, dev, data);
+		return dai_zephyr_unbind(dd, dev, unbind_data);
 	}
 
 	return 0;

src/audio/copier/dai_copier.h

@@ -69,7 +69,7 @@ static inline int dai_zephyr_unbind(struct dai_data *dd, struct comp_dev *dev, v
 int dai_zephyr_multi_endpoint_copy(struct dai_data **dd, struct comp_dev *dev,
 				   struct comp_buffer *multi_endpoint_buffer,
 				   int num_endpoints);
-int dai_zephyr_unbind(struct dai_data *dd, struct comp_dev *dev, void *data);
+int dai_zephyr_unbind(struct dai_data *dd, struct comp_dev *dev, struct bind_info *unbind_data);
 #endif
 
 

src/audio/dai-zephyr.c

@@ -1961,14 +1961,15 @@ static uint64_t dai_get_processed_data(struct comp_dev *dev, uint32_t stream_no,
 }
 
 #ifdef CONFIG_IPC_MAJOR_4
-__cold int dai_zephyr_unbind(struct dai_data *dd, struct comp_dev *dev, void *data)
+__cold
+int dai_zephyr_unbind(struct dai_data *dd, struct comp_dev *dev, struct bind_info *unbind_data)
 {
 	struct ipc4_module_bind_unbind *bu;
 	int buf_id;
 
 	assert_can_be_cold();
 
-	bu = (struct ipc4_module_bind_unbind *)data;
+	bu = unbind_data->ipc4_data;
 	buf_id = IPC4_COMP_ID(bu->extension.r.src_queue, bu->extension.r.dst_queue);
 
 	if (dd && dd->local_buffer) {

src/audio/kpb.c

@@ -333,10 +333,10 @@ static int kpb_get_attribute(struct comp_dev *dev,
 /**
  * \brief Initialize KPB sinks when binding.
  * \param[in] dev - component device pointer.
- * \param[in] data - ipc4 bind/unbind data.
+ * \param[in] bind_data - bind/unbind data.
  * \return: none.
  */
-static int kpb_bind(struct comp_dev *dev, void *data)
+static int kpb_bind(struct comp_dev *dev, struct bind_info *bind_data)
 {
 	struct comp_data *kpb = comp_get_drvdata(dev);
 	struct ipc4_module_bind_unbind *bu;
@@ -345,7 +345,7 @@ static int kpb_bind(struct comp_dev *dev, void *data)
 
 	comp_dbg(dev, "kpb_bind()");
 
-	bu = (struct ipc4_module_bind_unbind *)data;
+	bu = bind_data->ipc4_data;
 	buf_id = IPC4_COMP_ID(bu->extension.r.src_queue, bu->extension.r.dst_queue);
 
 	/* We're assuming here that KPB Real Time sink (kpb->sel_sink) is
@@ -383,15 +383,15 @@ static int kpb_bind(struct comp_dev *dev, void *data)
  * \param[in] data - ipc4 bind/unbind data.
  * \return: none.
  */
-static int kpb_unbind(struct comp_dev *dev, void *data)
+static int kpb_unbind(struct comp_dev *dev, struct bind_info *unbind_data)
 {
 	struct comp_data *kpb = comp_get_drvdata(dev);
 	struct ipc4_module_bind_unbind *bu;
 	int buf_id;
 
 	comp_dbg(dev, "kpb_bind()");
 
-	bu = (struct ipc4_module_bind_unbind *)data;
+	bu = unbind_data->ipc4_data;
 	buf_id = IPC4_COMP_ID(bu->extension.r.src_queue, bu->extension.r.dst_queue);
 
 	/* Reset sinks when unbinding */

src/audio/mixin_mixout/mixin_mixout.c

@@ -784,17 +784,15 @@ static int mixout_prepare(struct processing_module *mod,
 	return 0;
 }
 
-static int mixout_bind(struct processing_module *mod, void *data)
+static int mixout_bind(struct processing_module *mod, struct bind_info *bind_data)
 {
 	struct ipc4_module_bind_unbind *bu;
 	struct comp_dev *mixin;
 	struct pending_frames *pending_frames;
 	int src_id;
 	struct mixout_data *mixout_data;
 
-	comp_dbg(mod->dev, "mixout_bind() %p", data);
-
-	bu = (struct ipc4_module_bind_unbind *)data;
+	bu = bind_data->ipc4_data;
 	src_id = IPC4_COMP_ID(bu->primary.r.module_id, bu->primary.r.instance_id);
 
 	/* we are only interested in bind for mixin -> mixout pair */
@@ -833,7 +831,7 @@ static int mixout_bind(struct processing_module *mod, void *data)
 	return 0;
 }
 
-static int mixout_unbind(struct processing_module *mod, void *data)
+static int mixout_unbind(struct processing_module *mod, struct bind_info *unbind_data)
 {
 	struct ipc4_module_bind_unbind *bu;
 	struct comp_dev *mixin;
@@ -843,7 +841,7 @@ static int mixout_unbind(struct processing_module *mod, void *data)
 
 	comp_dbg(mod->dev, "mixout_unbind()");
 
-	bu = (struct ipc4_module_bind_unbind *)data;
+	bu = unbind_data->ipc4_data;
 	src_id = IPC4_COMP_ID(bu->primary.r.module_id, bu->primary.r.instance_id);
 
 	/* we are only interested in unbind for mixin -> mixout pair */

src/audio/module_adapter/module/generic.c

@@ -493,22 +493,52 @@ int module_set_configuration(struct processing_module *mod,
 }
 EXPORT_SYMBOL(module_set_configuration);
 
-int module_bind(struct processing_module *mod, void *data)
+int module_bind(struct processing_module *mod, struct bind_info *bind_data)
 {
+	int ret;
 	const struct module_interface *const ops = mod->dev->drv->adapter_ops;
 
+	switch (bind_data->bind_type) {
+	case COMP_BIND_TYPE_SINK:
+		ret = sink_bind(bind_data->sink, mod);
+		break;
+	case COMP_BIND_TYPE_SOURCE:
+		ret = source_bind(bind_data->source, mod);
+		break;
+	default:
+		ret = -EINVAL;
+	}
+	if (ret)
+		return ret;
+
 	if (ops->bind)
-		return ops->bind(mod, data);
-	return 0;
+		ret = ops->bind(mod, bind_data);
+
+	return ret;
 }
 
-int module_unbind(struct processing_module *mod, void *data)
+int module_unbind(struct processing_module *mod, struct bind_info *unbind_data)
 {
+	int ret;
 	const struct module_interface *const ops = mod->dev->drv->adapter_ops;
 
-	if (ops->unbind)
-		return ops->unbind(mod, data);
-	return 0;
+	switch (unbind_data->bind_type) {
+	case COMP_BIND_TYPE_SINK:
+		ret = sink_unbind(unbind_data->sink);
+		break;
+	case COMP_BIND_TYPE_SOURCE:
+		ret = source_unbind(unbind_data->source);
+		break;
+	default:
+		ret = -EINVAL;
+	}
+	if (ret)
+		return ret;
+
+	if (ops->bind)
+		ret = ops->unbind(mod, unbind_data);
+
+	return ret;
 }
 
 void module_update_buffer_position(struct input_stream_buffer *input_buffers,

src/audio/module_adapter/module_adapter_ipc4.c

@@ -242,12 +242,12 @@ static bool module_adapter_multi_sink_source_prepare(struct comp_dev *dev)
 	return false;
 }
 
-int module_adapter_bind(struct comp_dev *dev, void *data)
+int module_adapter_bind(struct comp_dev *dev, struct bind_info *bind_data)
 {
 	struct processing_module *mod = comp_mod(dev);
 	int ret;
 
-	ret = module_bind(mod, data);
+	ret = module_bind(mod, bind_data);
 	if (ret < 0)
 		return ret;
 
@@ -257,12 +257,12 @@ int module_adapter_bind(struct comp_dev *dev, void *data)
 }
 EXPORT_SYMBOL(module_adapter_bind);
 
-int module_adapter_unbind(struct comp_dev *dev, void *data)
+int module_adapter_unbind(struct comp_dev *dev, struct bind_info *unbind_data)
 {
 	struct processing_module *mod = comp_mod(dev);
 	int ret;
 
-	ret = module_unbind(mod, data);
+	ret = module_unbind(mod, unbind_data);
 	if (ret < 0)
 		return ret;
 

src/debug/tester/tester.c

@@ -188,24 +188,24 @@ static int tester_free(struct processing_module *mod)
 	return ret;
 }
 
-static int tester_bind(struct processing_module *mod, void *data)
+static int tester_bind(struct processing_module *mod, struct bind_info *bind_data)
 {
 	struct tester_module_data *cd = module_get_private_data(mod);
 	int ret = 0;
 
 	if (cd->tester_case_interface->bind)
-		ret = cd->tester_case_interface->bind(cd->test_case_ctx, mod, data);
+		ret = cd->tester_case_interface->bind(cd->test_case_ctx, mod, bind_data);
 
 	return ret;
 }
 
-static int tester_unbind(struct processing_module *mod, void *data)
+static int tester_unbind(struct processing_module *mod, struct bind_info *unbind_data)
 {
 	struct tester_module_data *cd = module_get_private_data(mod);
 	int ret = 0;
 
 	if (cd->tester_case_interface->unbind)
-		ret = cd->tester_case_interface->unbind(cd->test_case_ctx, mod, data);
+		ret = cd->tester_case_interface->unbind(cd->test_case_ctx, mod, unbind_data);
 
 	return ret;
 }

src/debug/tester/tester.h

@@ -75,12 +75,12 @@ struct tester_test_case_interface {
 	/**
 	 * copy of module bind method, with additional ctx param
 	 */
-	int (*bind)(void *ctx, struct processing_module *mod, void *data);
+	int (*bind)(void *ctx, struct processing_module *mod, struct bind_info *bind_data);
 
 	/**
 	 * copy of module unbind method, with additional ctx param
 	 */
-	int (*unbind)(void *ctx, struct processing_module *mod, void *data);
+	int (*unbind)(void *ctx, struct processing_module *mod, struct bind_info *unbind_data);
 
 	/**
 	 * copy of module trigger method, with additional ctx param

src/idc/idc.c

@@ -86,14 +86,14 @@ static int idc_ipc4_bind(uint32_t comp_id)
 {
 	struct ipc_comp_dev *ipc_dev;
 	struct idc_payload *payload;
-	struct ipc4_module_bind_unbind *bu;
+	struct bind_info *bu;
 
 	ipc_dev = ipc_get_comp_by_id(ipc_get(), comp_id);
 	if (!ipc_dev)
 		return -ENODEV;
 
 	payload = idc_payload_get(*idc_get(), cpu_get_id());
-	bu = (struct ipc4_module_bind_unbind *)payload;
+	bu = (struct bind_info *)payload;
 
 	return comp_bind(ipc_dev->cd, bu);
 }
@@ -102,14 +102,14 @@ static int idc_ipc4_unbind(uint32_t comp_id)
 {
 	struct ipc_comp_dev *ipc_dev;
 	struct idc_payload *payload;
-	struct ipc4_module_bind_unbind *bu;
+	struct bind_info *bu;
 
 	ipc_dev = ipc_get_comp_by_id(ipc_get(), comp_id);
 	if (!ipc_dev)
 		return -ENODEV;
 
 	payload = idc_payload_get(*idc_get(), cpu_get_id());
-	bu = (struct ipc4_module_bind_unbind *)payload;
+	bu = (struct bind_info *)payload;
 
 	return comp_unbind(ipc_dev->cd, bu);
 }