1
2
3
4
5
6
7
8
9#include "tascam.h"
10
11
12
13
14
15
16static inline int calculate_message_bytes(u8 status)
17{
18 switch (status) {
19 case 0xf6:
20 case 0xf8:
21 case 0xfa:
22 case 0xfb:
23 case 0xfc:
24 case 0xfe:
25 case 0xff:
26 return 1;
27 case 0xf1:
28 case 0xf3:
29 return 2;
30 case 0xf2:
31 return 3;
32 case 0xf0:
33 return 0;
34 case 0xf7:
35 break;
36 case 0xf4:
37 case 0xf5:
38 case 0xf9:
39 case 0xfd:
40 break;
41 default:
42 switch (status & 0xf0) {
43 case 0x80:
44 case 0x90:
45 case 0xa0:
46 case 0xb0:
47 case 0xe0:
48 return 3;
49 case 0xc0:
50 case 0xd0:
51 return 2;
52 default:
53 break;
54 }
55 break;
56 }
57
58 return -EINVAL;
59}
60
61static int fill_message(struct snd_rawmidi_substream *substream, u8 *buf)
62{
63 struct snd_tscm *tscm = substream->rmidi->private_data;
64 unsigned int port = substream->number;
65 int i, len, consume;
66 u8 *label, *msg;
67 u8 status;
68
69
70 label = buf;
71 msg = buf + 1;
72
73 consume = snd_rawmidi_transmit_peek(substream, msg, 3);
74 if (consume == 0)
75 return 0;
76
77
78 if (tscm->on_sysex[port]) {
79
80 for (i = 0; i < consume; ++i) {
81 if (msg[i] == 0xf7) {
82 tscm->on_sysex[port] = false;
83 break;
84 }
85 }
86
87
88 if (!tscm->on_sysex[port]) {
89 consume = i + 1;
90 *label = (port << 4) | 0x07;
91
92 } else if (consume == 3) {
93 *label = (port << 4) | 0x04;
94
95 } else {
96 return 0;
97 }
98
99 len = consume;
100 } else {
101
102 if (msg[0] == 0xf0) {
103
104 tscm->on_sysex[port] = true;
105 return 0;
106 } else {
107
108 if ((msg[0] & 0x80) != 0x80)
109 status = tscm->running_status[port];
110 else
111 status = msg[0];
112
113
114 len = calculate_message_bytes(status);
115 if (len <= 0)
116 return 0;
117
118
119 if ((msg[0] & 0x80) != 0x80) {
120
121 if (consume < len - 1)
122 return 0;
123 consume = len - 1;
124
125 msg[2] = msg[1];
126 msg[1] = msg[0];
127 msg[0] = tscm->running_status[port];
128 } else {
129
130 if (consume < len)
131 return 0;
132 consume = len;
133
134 tscm->running_status[port] = msg[0];
135 }
136 }
137
138 *label = (port << 4) | (msg[0] >> 4);
139 }
140
141 if (len > 0 && len < 3)
142 memset(msg + len, 0, 3 - len);
143
144 return consume;
145}
146
147static void handle_midi_tx(struct fw_card *card, struct fw_request *request,
148 int tcode, int destination, int source,
149 int generation, unsigned long long offset,
150 void *data, size_t length, void *callback_data)
151{
152 struct snd_tscm *tscm = callback_data;
153 u32 *buf = (u32 *)data;
154 unsigned int messages;
155 unsigned int i;
156 unsigned int port;
157 struct snd_rawmidi_substream *substream;
158 u8 *b;
159 int bytes;
160
161 if (offset != tscm->async_handler.offset)
162 goto end;
163
164 messages = length / 8;
165 for (i = 0; i < messages; i++) {
166 b = (u8 *)(buf + i * 2);
167
168 port = b[0] >> 4;
169
170 if (port >= tscm->spec->midi_capture_ports)
171 goto end;
172
173
174 bytes = calculate_message_bytes(b[1]);
175
176 if (bytes <= 0) {
177
178 for (bytes = 1; bytes < 4; bytes++) {
179 if (b[bytes] == 0xf7)
180 break;
181 }
182 if (bytes == 4)
183 bytes = 3;
184 }
185
186 substream = ACCESS_ONCE(tscm->tx_midi_substreams[port]);
187 if (substream != NULL)
188 snd_rawmidi_receive(substream, b + 1, bytes);
189 }
190end:
191 fw_send_response(card, request, RCODE_COMPLETE);
192}
193
194int snd_tscm_transaction_register(struct snd_tscm *tscm)
195{
196 static const struct fw_address_region resp_register_region = {
197 .start = 0xffffe0000000ull,
198 .end = 0xffffe000ffffull,
199 };
200 unsigned int i;
201 int err;
202
203
204
205
206
207
208 tscm->async_handler.length = 8 * 8;
209 tscm->async_handler.address_callback = handle_midi_tx;
210 tscm->async_handler.callback_data = tscm;
211
212 err = fw_core_add_address_handler(&tscm->async_handler,
213 &resp_register_region);
214 if (err < 0)
215 return err;
216
217 err = snd_tscm_transaction_reregister(tscm);
218 if (err < 0)
219 goto error;
220
221 for (i = 0; i < TSCM_MIDI_OUT_PORT_MAX; i++) {
222 err = snd_fw_async_midi_port_init(
223 &tscm->out_ports[i], tscm->unit,
224 TSCM_ADDR_BASE + TSCM_OFFSET_MIDI_RX_QUAD,
225 4, fill_message);
226 if (err < 0)
227 goto error;
228 }
229
230 return err;
231error:
232 fw_core_remove_address_handler(&tscm->async_handler);
233 tscm->async_handler.callback_data = NULL;
234 return err;
235}
236
237
238int snd_tscm_transaction_reregister(struct snd_tscm *tscm)
239{
240 struct fw_device *device = fw_parent_device(tscm->unit);
241 __be32 reg;
242 int err;
243
244
245 reg = cpu_to_be32((device->card->node_id << 16) |
246 (tscm->async_handler.offset >> 32));
247 err = snd_fw_transaction(tscm->unit, TCODE_WRITE_QUADLET_REQUEST,
248 TSCM_ADDR_BASE + TSCM_OFFSET_MIDI_TX_ADDR_HI,
249 ®, sizeof(reg), 0);
250 if (err < 0)
251 return err;
252
253 reg = cpu_to_be32(tscm->async_handler.offset);
254 err = snd_fw_transaction(tscm->unit, TCODE_WRITE_QUADLET_REQUEST,
255 TSCM_ADDR_BASE + TSCM_OFFSET_MIDI_TX_ADDR_LO,
256 ®, sizeof(reg), 0);
257 if (err < 0)
258 return err;
259
260
261 reg = cpu_to_be32(0x00000001);
262 err = snd_fw_transaction(tscm->unit, TCODE_WRITE_QUADLET_REQUEST,
263 TSCM_ADDR_BASE + TSCM_OFFSET_MIDI_TX_ON,
264 ®, sizeof(reg), 0);
265 if (err < 0)
266 return err;
267
268
269 reg = cpu_to_be32(0x0001008e);
270 return snd_fw_transaction(tscm->unit, TCODE_WRITE_QUADLET_REQUEST,
271 TSCM_ADDR_BASE + TSCM_OFFSET_LED_POWER,
272 ®, sizeof(reg), 0);
273}
274
275void snd_tscm_transaction_unregister(struct snd_tscm *tscm)
276{
277 __be32 reg;
278 unsigned int i;
279
280 if (tscm->async_handler.callback_data == NULL)
281 return;
282
283
284 reg = cpu_to_be32(0x0000008e);
285 snd_fw_transaction(tscm->unit, TCODE_WRITE_QUADLET_REQUEST,
286 TSCM_ADDR_BASE + TSCM_OFFSET_LED_POWER,
287 ®, sizeof(reg), 0);
288
289
290 reg = cpu_to_be32(0x00000000);
291 snd_fw_transaction(tscm->unit, TCODE_WRITE_QUADLET_REQUEST,
292 TSCM_ADDR_BASE + TSCM_OFFSET_MIDI_TX_ON,
293 ®, sizeof(reg), 0);
294
295
296 snd_fw_transaction(tscm->unit, TCODE_WRITE_QUADLET_REQUEST,
297 TSCM_ADDR_BASE + TSCM_OFFSET_MIDI_TX_ADDR_HI,
298 ®, sizeof(reg), 0);
299 snd_fw_transaction(tscm->unit, TCODE_WRITE_QUADLET_REQUEST,
300 TSCM_ADDR_BASE + TSCM_OFFSET_MIDI_TX_ADDR_LO,
301 ®, sizeof(reg), 0);
302
303 fw_core_remove_address_handler(&tscm->async_handler);
304 tscm->async_handler.callback_data = NULL;
305
306 for (i = 0; i < TSCM_MIDI_OUT_PORT_MAX; i++)
307 snd_fw_async_midi_port_destroy(&tscm->out_ports[i]);
308}
309