ipc4: handler: pipeline: Add support for eos state

Add support for setting the pipeline in the EOS state. Setting this state
sets the except_eos flag in the pipeline, indicating that the end of data
to be processed is expected.

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

Author: softwarecki

src/include/sof/audio/pipeline.h

@@ -68,6 +68,7 @@ struct pipeline {
 	int32_t xrun_bytes;		/* last xrun length */
 	uint32_t status;		/* pipeline status */
 	struct tr_ctx tctx;		/* trace settings */
+	bool expect_eos;		/* pipeline is expecting end of stream */
 
 	/* scheduling */
 	struct task *pipe_task;		/* pipeline processing task */

src/ipc/ipc4/handler.c

@@ -287,6 +287,12 @@ int ipc4_pipeline_prepare(struct ipc_comp_dev *ppl_icd, uint32_t cmd)
 
 	switch (cmd) {
 	case SOF_IPC4_PIPELINE_STATE_RUNNING:
+		if (ppl_icd->pipeline->expect_eos) {
+			ipc_cmd_err(&ipc_tr, "pipeline %d: Can't transition from EOS to RUNNING",
+				    ppl_icd->id);
+			return IPC4_INVALID_REQUEST;
+		}
+
 		/* init params when pipeline is complete or reset */
 		switch (status) {
 		case COMP_STATE_ACTIVE:
@@ -339,11 +345,15 @@ int ipc4_pipeline_prepare(struct ipc_comp_dev *ppl_icd, uint32_t cmd)
 		}
 
 		break;
-	/* special case- TODO */
 	case SOF_IPC4_PIPELINE_STATE_EOS:
-		if (status != COMP_STATE_ACTIVE)
+		if (status != COMP_STATE_ACTIVE) {
+			ipc_cmd_err(&ipc_tr, "pipeline %d: Invalid state for EOS: %d",
+				    ppl_icd->id, status);
 			return IPC4_INVALID_REQUEST;
-		COMPILER_FALLTHROUGH;
+		}
+		ppl_icd->pipeline->expect_eos = true;
+		return 0; /* Must return here. Any other transition clears expect_eos. */
+	/* special case - TODO */
 	case SOF_IPC4_PIPELINE_STATE_SAVED:
 	case SOF_IPC4_PIPELINE_STATE_ERROR_STOP:
 	default:
@@ -354,6 +364,9 @@ int ipc4_pipeline_prepare(struct ipc_comp_dev *ppl_icd, uint32_t cmd)
 
 	if (ret < 0)
 		return IPC4_INVALID_REQUEST;
+
+	ppl_icd->pipeline->expect_eos = false;
+
 	return ret;
 }
 
@@ -417,6 +430,9 @@ int ipc4_pipeline_trigger(struct ipc_comp_dev *ppl_icd, uint32_t cmd, bool *dela
 		}
 
 		break;
+	case SOF_IPC4_PIPELINE_STATE_EOS:
+		/* EOS handled in ipc4_pipeline_prepare */
+		return 0;
 	default:
 		ipc_cmd_err(&ipc_tr, "pipeline %d: unsupported trigger cmd: %d",
 			    ppl_icd->id, cmd);