58 static inline struct cras_iodev *get_main_dev(const struct dev_stream *stream)  in get_main_dev()
73 	struct dev_stream *dev_stream;  in update_estimated_rate()  local
103 	DL_FOREACH (dev->streams, dev_stream) {  in update_estimated_rate()
104 		main_dev = get_main_dev(dev_stream);  in update_estimated_rate()
120 		dev_stream_set_dev_rate(dev_stream, dev->format->frame_rate,  in update_estimated_rate()
156 static bool is_time_to_fetch(const struct dev_stream *dev_stream,  in is_time_to_fetch()  argument
160 	next_cb_ts = dev_stream_next_cb_ts(dev_stream);  in is_time_to_fetch()
197 	struct dev_stream *dev_stream;  in fetch_streams()  local
206 	DL_FOREACH (adev->dev->streams, dev_stream) {  in fetch_streams()
207 		struct cras_rstream *rstream = dev_stream->stream;  in fetch_streams()
213 		if (dev_stream_is_pending_reply(dev_stream)) {  in fetch_streams()
214 			dev_stream_flush_old_audio_messages(dev_stream);  in fetch_streams()
215 			cras_rstream_record_fetch_interval(dev_stream->stream,  in fetch_streams()
219 		if (!dev_stream_is_running(dev_stream))  in fetch_streams()
222 		if (!is_time_to_fetch(dev_stream, now))  in fetch_streams()
228 		if (cras_rstream_get_is_draining(dev_stream->stream))  in fetch_streams()
248 			dev_stream_update_next_wake_time(dev_stream);  in fetch_streams()
249 			cras_server_metrics_missed_cb_event(dev_stream->stream);  in fetch_streams()
253 		dev_stream_set_delay(dev_stream, delay);  in fetch_streams()
259 		rc = dev_stream_request_playback_samples(dev_stream, &now);  in fetch_streams()
295 	struct dev_stream *stream;  in set_stream_delay()
322 				     struct dev_stream **limit_stream)  in get_stream_limit()
326 	struct dev_stream *stream;  in get_stream_limit()
430 	struct dev_stream *stream;  in set_input_dev_wake_ts()
431 	struct dev_stream *cap_limit_stream;  in set_input_dev_wake_ts()
519 	struct dev_stream *cap_limit_stream;  in capture_to_streams()
520 	struct dev_stream *stream;  in capture_to_streams()
652 	struct dev_stream *curr;  in write_streams()
971 		struct dev_stream *stream;  in dev_io_send_captured_samples()
1046 	struct dev_stream *dev_stream;  in dev_io_check_dev_stream_start()  local
1050 	DL_FOREACH (adev->dev->streams, dev_stream) {  in dev_io_check_dev_stream_start()
1051 		if (!is_time_to_fetch(dev_stream, now))  in dev_io_check_dev_stream_start()
1053 		if (!dev_stream_is_running(dev_stream))  in dev_io_check_dev_stream_start()
1054 			cras_iodev_start_stream(adev->dev, dev_stream);  in dev_io_check_dev_stream_start()
1080 	struct dev_stream *curr;  in dev_io_playback_write()
1141 		struct dev_stream *stream;  in dev_io_playback_write()
1225 static int get_next_stream_wake_from_list(struct dev_stream *streams,  in get_next_stream_wake_from_list()
1228 	struct dev_stream *dev_stream;  in get_next_stream_wake_from_list()  local
1231 	DL_FOREACH (streams, dev_stream) {  in get_next_stream_wake_from_list()
1234 		if (cras_rstream_get_is_draining(dev_stream->stream))  in get_next_stream_wake_from_list()
1237 		if (cras_rstream_is_pending_reply(dev_stream->stream))  in get_next_stream_wake_from_list()
1240 		next_cb_ts = dev_stream_next_cb_ts(dev_stream);  in get_next_stream_wake_from_list()
1245 		      dev_stream->stream->stream_id, next_cb_ts->tv_sec,  in get_next_stream_wake_from_list()
1289 	struct dev_stream *dev_stream;  in dev_io_rm_open_dev()  local
1318 	DL_FOREACH (dev_to_rm->dev->streams, dev_stream) {  in dev_io_rm_open_dev()
1319 		cras_iodev_rm_stream(dev_to_rm->dev, dev_stream->stream);  in dev_io_rm_open_dev()
1320 		dev_stream_destroy(dev_stream);  in dev_io_rm_open_dev()
1333 	struct dev_stream *out;  in delete_stream_from_dev()
1347 static struct dev_stream *
1352 	struct dev_stream *dev_stream;  in find_matched_input_stream()  local
1357 		DL_FOREACH (odev->dev->streams, dev_stream) {  in find_matched_input_stream()
1358 			if (dev_stream->stream->format.frame_rate != out_rate)  in find_matched_input_stream()
1360 			if (cras_rstream_get_cb_threshold(dev_stream->stream) !=  in find_matched_input_stream()
1363 			return dev_stream;  in find_matched_input_stream()
1375 	struct dev_stream *dev_stream =  in find_matched_input_stream_next_cb_ts()  local
1377 	if (dev_stream) {  in find_matched_input_stream_next_cb_ts()
1378 		*next_cb_ts = dev_stream_next_cb_ts(dev_stream);  in find_matched_input_stream_next_cb_ts()
1379 		*sleep_interval_ts = dev_stream_sleep_interval_ts(dev_stream);  in find_matched_input_stream_next_cb_ts()
1392 	struct dev_stream *out;  in dev_io_append_stream()