2  * ff-transaction.c - a part of driver for RME Fireface series
9 #include "ff.h"
11 static void finish_transmit_midi_msg(struct snd_ff *ff, unsigned int port,  in finish_transmit_midi_msg()  argument
15 				READ_ONCE(ff->rx_midi_substreams[port]);  in finish_transmit_midi_msg()
18 		ff->rx_midi_error[port] = true;  in finish_transmit_midi_msg()
24 		ff->next_ktime[port] = 0;  in finish_transmit_midi_msg()
25 		schedule_work(&ff->rx_midi_work[port]);  in finish_transmit_midi_msg()
29 	snd_rawmidi_transmit_ack(substream, ff->rx_bytes[port]);  in finish_transmit_midi_msg()
30 	ff->rx_bytes[port] = 0;  in finish_transmit_midi_msg()
33 		schedule_work(&ff->rx_midi_work[port]);  in finish_transmit_midi_msg()
40 	struct snd_ff *ff =  in finish_transmit_midi0_msg()  local
42 	finish_transmit_midi_msg(ff, 0, rcode);  in finish_transmit_midi0_msg()
49 	struct snd_ff *ff =  in finish_transmit_midi1_msg()  local
51 	finish_transmit_midi_msg(ff, 1, rcode);  in finish_transmit_midi1_msg()
54 static inline void fill_midi_buf(struct snd_ff *ff, unsigned int port,  in fill_midi_buf()  argument
57 	ff->msg_buf[port][index] = cpu_to_le32(byte);  in fill_midi_buf()
60 static void transmit_midi_msg(struct snd_ff *ff, unsigned int port)  in transmit_midi_msg()  argument
63 			READ_ONCE(ff->rx_midi_substreams[port]);  in transmit_midi_msg()
64 	u8 *buf = (u8 *)ff->msg_buf[port];  in transmit_midi_msg()
67 	struct fw_device *fw_dev = fw_parent_device(ff->unit);  in transmit_midi_msg()
75 	if (ff->rx_bytes[port] > 0 || ff->rx_midi_error[port])  in transmit_midi_msg()
79 	if (ktime_after(ff->next_ktime[port], ktime_get())) {  in transmit_midi_msg()
80 		schedule_work(&ff->rx_midi_work[port]);  in transmit_midi_msg()
90 		fill_midi_buf(ff, port, i, buf[i]);  in transmit_midi_msg()
93 		addr = ff->spec->protocol->midi_rx_port_0_reg;  in transmit_midi_msg()
96 		addr = ff->spec->protocol->midi_rx_port_1_reg;  in transmit_midi_msg()
101 	ff->next_ktime[port] = ktime_add_ns(ktime_get(),  in transmit_midi_msg()
103 	ff->rx_bytes[port] = len;  in transmit_midi_msg()
115 	fw_send_request(fw_dev->card, &ff->transactions[port],  in transmit_midi_msg()
118 			addr, &ff->msg_buf[port], len * 4,  in transmit_midi_msg()
119 			callback, &ff->transactions[port]);  in transmit_midi_msg()
124 	struct snd_ff *ff = container_of(work, struct snd_ff, rx_midi_work[0]);  in transmit_midi0_msg()  local
126 	transmit_midi_msg(ff, 0);  in transmit_midi0_msg()
131 	struct snd_ff *ff = container_of(work, struct snd_ff, rx_midi_work[1]);  in transmit_midi1_msg()  local
133 	transmit_midi_msg(ff, 1);  in transmit_midi1_msg()
141 	struct snd_ff *ff = callback_data;  in handle_midi_msg()  local
162 			substream = READ_ONCE(ff->tx_midi_substreams[0]);  in handle_midi_msg()
172 			substream = READ_ONCE(ff->tx_midi_substreams[1]);  in handle_midi_msg()
181 static int allocate_own_address(struct snd_ff *ff, int i)  in allocate_own_address()  argument
186 	ff->async_handler.length = SND_FF_MAXIMIM_MIDI_QUADS * 4;  in allocate_own_address()
187 	ff->async_handler.address_callback = handle_midi_msg;  in allocate_own_address()
188 	ff->async_handler.callback_data = ff;  in allocate_own_address()
191 	midi_msg_region.end = midi_msg_region.start + ff->async_handler.length;  in allocate_own_address()
193 	err = fw_core_add_address_handler(&ff->async_handler, &midi_msg_region);  in allocate_own_address()
196 		if (ff->async_handler.offset & 0x0000ffffffff) {  in allocate_own_address()
197 			fw_core_remove_address_handler(&ff->async_handler);  in allocate_own_address()
237 int snd_ff_transaction_reregister(struct snd_ff *ff)  in snd_ff_transaction_reregister()  argument
239 	struct fw_card *fw_card = fw_parent_device(ff->unit)->card;  in snd_ff_transaction_reregister()
247 	addr = (fw_card->node_id << 16) | (ff->async_handler.offset >> 32);  in snd_ff_transaction_reregister()
249 	return snd_fw_transaction(ff->unit, TCODE_WRITE_QUADLET_REQUEST,  in snd_ff_transaction_reregister()
250 				  ff->spec->protocol->midi_high_addr_reg,  in snd_ff_transaction_reregister()
254 int snd_ff_transaction_register(struct snd_ff *ff)  in snd_ff_transaction_register()  argument
263 		err = allocate_own_address(ff, i);  in snd_ff_transaction_register()
270 	err = snd_ff_transaction_reregister(ff);  in snd_ff_transaction_register()
274 	INIT_WORK(&ff->rx_midi_work[0], transmit_midi0_msg);  in snd_ff_transaction_register()
275 	INIT_WORK(&ff->rx_midi_work[1], transmit_midi1_msg);  in snd_ff_transaction_register()
280 void snd_ff_transaction_unregister(struct snd_ff *ff)  in snd_ff_transaction_unregister()  argument
284 	if (ff->async_handler.callback_data == NULL)  in snd_ff_transaction_unregister()
286 	ff->async_handler.callback_data = NULL;  in snd_ff_transaction_unregister()
290 	snd_fw_transaction(ff->unit, TCODE_WRITE_QUADLET_REQUEST,  in snd_ff_transaction_unregister()
291 			   ff->spec->protocol->midi_high_addr_reg,  in snd_ff_transaction_unregister()
294 	fw_core_remove_address_handler(&ff->async_handler);  in snd_ff_transaction_unregister()