2  * ff-stream.c - a part of driver for RME Fireface series
9 #include "ff.h"
34 static int keep_resources(struct snd_ff *ff, unsigned int rate)  in keep_resources()  argument
44 	err = amdtp_ff_set_parameters(&ff->tx_stream, rate,  in keep_resources()
45 				      ff->spec->pcm_capture_channels[mode]);  in keep_resources()
48 	ff->tx_resources.channels_mask = 0x00000000000000ffuLL;  in keep_resources()
49 	err = fw_iso_resources_allocate(&ff->tx_resources,  in keep_resources()
50 			amdtp_stream_get_max_payload(&ff->tx_stream),  in keep_resources()
51 			fw_parent_device(ff->unit)->max_speed);  in keep_resources()
56 	err = amdtp_ff_set_parameters(&ff->rx_stream, rate,  in keep_resources()
57 				      ff->spec->pcm_playback_channels[mode]);  in keep_resources()
60 	ff->rx_resources.channels_mask = 0x00000000000000ffuLL;  in keep_resources()
61 	err = fw_iso_resources_allocate(&ff->rx_resources,  in keep_resources()
62 			amdtp_stream_get_max_payload(&ff->rx_stream),  in keep_resources()
63 			fw_parent_device(ff->unit)->max_speed);  in keep_resources()
65 		fw_iso_resources_free(&ff->tx_resources);  in keep_resources()
70 static void release_resources(struct snd_ff *ff)  in release_resources()  argument
72 	fw_iso_resources_free(&ff->tx_resources);  in release_resources()
73 	fw_iso_resources_free(&ff->rx_resources);  in release_resources()
76 static inline void finish_session(struct snd_ff *ff)  in finish_session()  argument
78 	ff->spec->protocol->finish_session(ff);  in finish_session()
79 	ff->spec->protocol->switch_fetching_mode(ff, false);  in finish_session()
82 static int init_stream(struct snd_ff *ff, enum amdtp_stream_direction dir)  in init_stream()  argument
89 		resources = &ff->tx_resources;  in init_stream()
90 		stream = &ff->tx_stream;  in init_stream()
92 		resources = &ff->rx_resources;  in init_stream()
93 		stream = &ff->rx_stream;  in init_stream()
96 	err = fw_iso_resources_init(resources, ff->unit);  in init_stream()
100 	err = amdtp_ff_init(stream, ff->unit, dir);  in init_stream()
107 static void destroy_stream(struct snd_ff *ff, enum amdtp_stream_direction dir)  in destroy_stream()  argument
110 		amdtp_stream_destroy(&ff->tx_stream);  in destroy_stream()
111 		fw_iso_resources_destroy(&ff->tx_resources);  in destroy_stream()
113 		amdtp_stream_destroy(&ff->rx_stream);  in destroy_stream()
114 		fw_iso_resources_destroy(&ff->rx_resources);  in destroy_stream()
118 int snd_ff_stream_init_duplex(struct snd_ff *ff)  in snd_ff_stream_init_duplex()  argument
122 	err = init_stream(ff, AMDTP_OUT_STREAM);  in snd_ff_stream_init_duplex()
126 	err = init_stream(ff, AMDTP_IN_STREAM);  in snd_ff_stream_init_duplex()
128 		destroy_stream(ff, AMDTP_OUT_STREAM);  in snd_ff_stream_init_duplex()
137 void snd_ff_stream_destroy_duplex(struct snd_ff *ff)  in snd_ff_stream_destroy_duplex()  argument
139 	destroy_stream(ff, AMDTP_IN_STREAM);  in snd_ff_stream_destroy_duplex()
140 	destroy_stream(ff, AMDTP_OUT_STREAM);  in snd_ff_stream_destroy_duplex()
143 int snd_ff_stream_start_duplex(struct snd_ff *ff, unsigned int rate)  in snd_ff_stream_start_duplex()  argument
149 	if (ff->substreams_counter == 0)  in snd_ff_stream_start_duplex()
152 	err = ff->spec->protocol->get_clock(ff, &curr_rate, &src);  in snd_ff_stream_start_duplex()
156 	    amdtp_streaming_error(&ff->tx_stream) ||  in snd_ff_stream_start_duplex()
157 	    amdtp_streaming_error(&ff->rx_stream)) {  in snd_ff_stream_start_duplex()
158 		finish_session(ff);  in snd_ff_stream_start_duplex()
160 		amdtp_stream_stop(&ff->tx_stream);  in snd_ff_stream_start_duplex()
161 		amdtp_stream_stop(&ff->rx_stream);  in snd_ff_stream_start_duplex()
163 		release_resources(ff);  in snd_ff_stream_start_duplex()
170 	if (!amdtp_stream_running(&ff->rx_stream)) {  in snd_ff_stream_start_duplex()
171 		err = keep_resources(ff, rate);  in snd_ff_stream_start_duplex()
175 		err = ff->spec->protocol->begin_session(ff, rate);  in snd_ff_stream_start_duplex()
179 		err = amdtp_stream_start(&ff->rx_stream,  in snd_ff_stream_start_duplex()
180 					 ff->rx_resources.channel,  in snd_ff_stream_start_duplex()
181 					 fw_parent_device(ff->unit)->max_speed);  in snd_ff_stream_start_duplex()
185 		if (!amdtp_stream_wait_callback(&ff->rx_stream,  in snd_ff_stream_start_duplex()
191 		err = ff->spec->protocol->switch_fetching_mode(ff, true);  in snd_ff_stream_start_duplex()
196 	if (!amdtp_stream_running(&ff->tx_stream)) {  in snd_ff_stream_start_duplex()
197 		err = amdtp_stream_start(&ff->tx_stream,  in snd_ff_stream_start_duplex()
198 					 ff->tx_resources.channel,  in snd_ff_stream_start_duplex()
199 					 fw_parent_device(ff->unit)->max_speed);  in snd_ff_stream_start_duplex()
203 		if (!amdtp_stream_wait_callback(&ff->tx_stream,  in snd_ff_stream_start_duplex()
212 	amdtp_stream_stop(&ff->tx_stream);  in snd_ff_stream_start_duplex()
213 	amdtp_stream_stop(&ff->rx_stream);  in snd_ff_stream_start_duplex()
215 	finish_session(ff);  in snd_ff_stream_start_duplex()
216 	release_resources(ff);  in snd_ff_stream_start_duplex()
221 void snd_ff_stream_stop_duplex(struct snd_ff *ff)  in snd_ff_stream_stop_duplex()  argument
223 	if (ff->substreams_counter > 0)  in snd_ff_stream_stop_duplex()
226 	amdtp_stream_stop(&ff->tx_stream);  in snd_ff_stream_stop_duplex()
227 	amdtp_stream_stop(&ff->rx_stream);  in snd_ff_stream_stop_duplex()
228 	finish_session(ff);  in snd_ff_stream_stop_duplex()
229 	release_resources(ff);  in snd_ff_stream_stop_duplex()
232 void snd_ff_stream_update_duplex(struct snd_ff *ff)  in snd_ff_stream_update_duplex()  argument
235 	amdtp_stream_pcm_abort(&ff->tx_stream);  in snd_ff_stream_update_duplex()
236 	amdtp_stream_stop(&ff->tx_stream);  in snd_ff_stream_update_duplex()
238 	amdtp_stream_pcm_abort(&ff->rx_stream);  in snd_ff_stream_update_duplex()
239 	amdtp_stream_stop(&ff->rx_stream);  in snd_ff_stream_update_duplex()
241 	fw_iso_resources_update(&ff->tx_resources);  in snd_ff_stream_update_duplex()
242 	fw_iso_resources_update(&ff->rx_resources);  in snd_ff_stream_update_duplex()
245 void snd_ff_stream_lock_changed(struct snd_ff *ff)  in snd_ff_stream_lock_changed()  argument
247 	ff->dev_lock_changed = true;  in snd_ff_stream_lock_changed()
248 	wake_up(&ff->hwdep_wait);  in snd_ff_stream_lock_changed()
251 int snd_ff_stream_lock_try(struct snd_ff *ff)  in snd_ff_stream_lock_try()  argument
255 	spin_lock_irq(&ff->lock);  in snd_ff_stream_lock_try()
258 	if (ff->dev_lock_count < 0) {  in snd_ff_stream_lock_try()
264 	if (ff->dev_lock_count++ == 0)  in snd_ff_stream_lock_try()
265 		snd_ff_stream_lock_changed(ff);  in snd_ff_stream_lock_try()
268 	spin_unlock_irq(&ff->lock);  in snd_ff_stream_lock_try()
272 void snd_ff_stream_lock_release(struct snd_ff *ff)  in snd_ff_stream_lock_release()  argument
274 	spin_lock_irq(&ff->lock);  in snd_ff_stream_lock_release()
276 	if (WARN_ON(ff->dev_lock_count <= 0))  in snd_ff_stream_lock_release()
278 	if (--ff->dev_lock_count == 0)  in snd_ff_stream_lock_release()
279 		snd_ff_stream_lock_changed(ff);  in snd_ff_stream_lock_release()
281 	spin_unlock_irq(&ff->lock);  in snd_ff_stream_lock_release()