194 static void isoal_rx_framed_update_sdu_release(struct isoal_sink *sink);
413 static isoal_status_t isoal_rx_allocate_sdu(struct isoal_sink *sink,  in isoal_rx_allocate_sdu()  argument
422 	session = &sink->session;  in isoal_rx_allocate_sdu()
423 	sp = &sink->sdu_production;  in isoal_rx_allocate_sdu()
432 			sink,  in isoal_rx_allocate_sdu()
463 static isoal_status_t isoal_rx_buffered_emit_sdu(struct isoal_sink *sink, bool end_of_sdu)  in isoal_rx_buffered_emit_sdu()  argument
474 	session = &sink->session;  in isoal_rx_buffered_emit_sdu()
475 	sp = &sink->sdu_production;  in isoal_rx_buffered_emit_sdu()
545 			err |= session->sdu_emit(sink, &sp->sdu_list.list[i],  in isoal_rx_buffered_emit_sdu()
560 			      sink, sdu_frag.sdu.sn, sdu_frag.sdu.timestamp,  in isoal_rx_buffered_emit_sdu()
562 		err |= session->sdu_emit(sink, &sdu_frag, &sdu_status);  in isoal_rx_buffered_emit_sdu()
577 static isoal_status_t isoal_rx_try_emit_sdu(struct isoal_sink *sink, bool end_of_sdu)  in isoal_rx_try_emit_sdu()  argument
585 	sp = &sink->sdu_production;  in isoal_rx_try_emit_sdu()
586 	session = &sink->session;  in isoal_rx_try_emit_sdu()
621 		err = isoal_rx_buffered_emit_sdu(sink, end_of_sdu);  in isoal_rx_try_emit_sdu()
625 			isoal_rx_framed_update_sdu_release(sink);  in isoal_rx_try_emit_sdu()
631 		sink->sdu_production.sdu_state = next_state;  in isoal_rx_try_emit_sdu()
637 static isoal_status_t isoal_rx_append_to_sdu(struct isoal_sink *sink,  in isoal_rx_append_to_sdu()  argument
671 			err_alloc = isoal_rx_allocate_sdu(sink, pdu_meta);  in isoal_rx_append_to_sdu()
674 		sp = &sink->sdu_production;  in isoal_rx_append_to_sdu()
690 			const struct isoal_sink_session *session = &sink->session;  in isoal_rx_append_to_sdu()
707 			err_emit = isoal_rx_try_emit_sdu(sink, end_of_sdu);  in isoal_rx_append_to_sdu()
727 static isoal_status_t isoal_rx_unframed_consume(struct isoal_sink *sink,  in isoal_rx_unframed_consume()  argument
744 	sp = &sink->sdu_production;  in isoal_rx_unframed_consume()
745 	session = &sink->session;  in isoal_rx_unframed_consume()
950 		err |= isoal_rx_append_to_sdu(sink, pdu_meta, 0,  in isoal_rx_unframed_consume()
1008 static isoal_status_t isoal_rx_framed_release_lost_sdus(struct isoal_sink *sink,  in isoal_rx_framed_release_lost_sdus()  argument
1019 	sp = &sink->sdu_production;  in isoal_rx_framed_release_lost_sdus()
1020 	session = &sink->session;  in isoal_rx_framed_release_lost_sdus()
1041 				       sink, next_sdu_timestamp);  in isoal_rx_framed_release_lost_sdus()
1050 				       sink, next_sdu_timestamp);  in isoal_rx_framed_release_lost_sdus()
1054 		ISOAL_LOG_DBGV("[%p] Releasing %u lost SDUs", sink, lost_sdus);  in isoal_rx_framed_release_lost_sdus()
1059 			err = isoal_rx_append_to_sdu(sink, pdu_meta, 0, 0, true, false);  in isoal_rx_framed_release_lost_sdus()
1070 static void isoal_rx_framed_update_sdu_release(struct isoal_sink *sink)  in isoal_rx_framed_update_sdu_release()  argument
1077 	sp = &sink->sdu_production;  in isoal_rx_framed_update_sdu_release()
1078 	session = &sink->session;  in isoal_rx_framed_update_sdu_release()
1084 		SET_RX_SDU_TIMESTAMP(sink, sdu->timestamp, timestamp);  in isoal_rx_framed_update_sdu_release()
1097 static isoal_status_t isoal_rx_framed_consume(struct isoal_sink *sink,  in isoal_rx_framed_consume()  argument
1118 	sp = &sink->sdu_production;  in isoal_rx_framed_consume()
1119 	session = &sink->session;  in isoal_rx_framed_consume()
1153 		SET_RX_SDU_TIMESTAMP(sink, sdu->timestamp, timestamp);  in isoal_rx_framed_consume()
1158 		ISOAL_LOG_DBGV("[%p] Received padding", sink);  in isoal_rx_framed_consume()
1159 		err |= isoal_rx_framed_release_lost_sdus(sink, pdu_meta, false, timestamp);  in isoal_rx_framed_consume()
1172 		ISOAL_LOG_DBGV("[%p] State %s", sink, FSM_TO_STR(sp->fsm));  in isoal_rx_framed_consume()
1182 				ISOAL_LOG_DBGV("[%p] Segment Start @TS=%ld", sink, timestamp);  in isoal_rx_framed_consume()
1184 				err |= isoal_rx_framed_release_lost_sdus(sink, pdu_meta, true,  in isoal_rx_framed_consume()
1186 				SET_RX_SDU_TIMESTAMP(sink, sdu->timestamp, timestamp);  in isoal_rx_framed_consume()
1192 					ISOAL_LOG_DBGV("[%p] Segment Single", sink);  in isoal_rx_framed_consume()
1214 				ISOAL_LOG_DBGV("[%p] Segment Continue", sink);  in isoal_rx_framed_consume()
1221 				ISOAL_LOG_DBGV("[%p] Segment End", sink);  in isoal_rx_framed_consume()
1239 				ISOAL_LOG_DBGV("[%p] Segment Start @TS=%ld", sink, timestamp);  in isoal_rx_framed_consume()
1241 				err |= isoal_rx_framed_release_lost_sdus(sink, pdu_meta, true,  in isoal_rx_framed_consume()
1243 				SET_RX_SDU_TIMESTAMP(sink, sdu->timestamp, timestamp);  in isoal_rx_framed_consume()
1249 					ISOAL_LOG_DBGV("[%p] Segment Single", sink);  in isoal_rx_framed_consume()
1261 				err |= isoal_rx_framed_release_lost_sdus(sink, pdu_meta, false,  in isoal_rx_framed_consume()
1294 			ISOAL_LOG_DBGV("[%p] Appending %lu bytes", sink, length);  in isoal_rx_framed_consume()
1295 			err |= isoal_rx_append_to_sdu(sink, pdu_meta, offset, length, cmplt, false);  in isoal_rx_framed_consume()
1299 		ISOAL_LOG_DBGV("[%p] FSM Next State %s", sink, FSM_TO_STR(next_state));  in isoal_rx_framed_consume()
1362 			err |= isoal_rx_framed_release_lost_sdus(sink, pdu_meta,  in isoal_rx_framed_consume()
1367 				err |= isoal_rx_append_to_sdu(sink, pdu_meta, 0U, 0U, true, false);  in isoal_rx_framed_consume()
1378 			err |= isoal_rx_append_to_sdu(sink, pdu_meta, 0, 0, true, false);  in isoal_rx_framed_consume()
1379 			err |= isoal_rx_framed_release_lost_sdus(sink, pdu_meta,  in isoal_rx_framed_consume()
1384 			err |= isoal_rx_framed_release_lost_sdus(sink, pdu_meta,  in isoal_rx_framed_consume()
1390 		ISOAL_LOG_DBGV("[%p] FSM Error Next State %s", sink, FSM_TO_STR(next_state));  in isoal_rx_framed_consume()
1411 	struct isoal_sink *sink = &isoal_global.sink_state[sink_hdl];  in isoal_rx_pdu_recombine()  local
1414 	if (sink && sink->sdu_production.mode != ISOAL_PRODUCTION_MODE_DISABLED) {  in isoal_rx_pdu_recombine()
1415 		if (sink->session.framed) {  in isoal_rx_pdu_recombine()
1416 			err = isoal_rx_framed_consume(sink, pdu_meta);  in isoal_rx_pdu_recombine()
1418 			err = isoal_rx_unframed_consume(sink, pdu_meta);  in isoal_rx_pdu_recombine()