diff options
Diffstat (limited to 'drivers/media/dvb/bt8xx/dst_ca.c')
-rw-r--r-- | drivers/media/dvb/bt8xx/dst_ca.c | 861 |
1 files changed, 861 insertions, 0 deletions
diff --git a/drivers/media/dvb/bt8xx/dst_ca.c b/drivers/media/dvb/bt8xx/dst_ca.c new file mode 100644 index 000000000000..d781504cc2fa --- /dev/null +++ b/drivers/media/dvb/bt8xx/dst_ca.c | |||
@@ -0,0 +1,861 @@ | |||
1 | /* | ||
2 | CA-driver for TwinHan DST Frontend/Card | ||
3 | |||
4 | Copyright (C) 2004, 2005 Manu Abraham (manu@kromtek.com) | ||
5 | |||
6 | This program is free software; you can redistribute it and/or modify | ||
7 | it under the terms of the GNU General Public License as published by | ||
8 | the Free Software Foundation; either version 2 of the License, or | ||
9 | (at your option) any later version. | ||
10 | |||
11 | This program is distributed in the hope that it will be useful, | ||
12 | but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
13 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||
14 | GNU General Public License for more details. | ||
15 | |||
16 | You should have received a copy of the GNU General Public License | ||
17 | along with this program; if not, write to the Free Software | ||
18 | Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. | ||
19 | */ | ||
20 | |||
21 | |||
22 | |||
23 | #include <linux/kernel.h> | ||
24 | #include <linux/module.h> | ||
25 | #include <linux/init.h> | ||
26 | #include <linux/string.h> | ||
27 | |||
28 | #include <linux/dvb/ca.h> | ||
29 | #include "dvbdev.h" | ||
30 | #include "dvb_frontend.h" | ||
31 | |||
32 | #include "dst_ca.h" | ||
33 | #include "dst_common.h" | ||
34 | |||
35 | static unsigned int verbose = 1; | ||
36 | module_param(verbose, int, 0644); | ||
37 | MODULE_PARM_DESC(verbose, "verbose startup messages, default is 1 (yes)"); | ||
38 | |||
39 | static unsigned int debug = 1; | ||
40 | module_param(debug, int, 0644); | ||
41 | MODULE_PARM_DESC(debug, "debug messages, default is 1 (yes)"); | ||
42 | |||
43 | #define dprintk if (debug) printk | ||
44 | |||
45 | /* Need some more work */ | ||
46 | static int ca_set_slot_descr(void) | ||
47 | { | ||
48 | /* We could make this more graceful ? */ | ||
49 | return -EOPNOTSUPP; | ||
50 | } | ||
51 | |||
52 | /* Need some more work */ | ||
53 | static int ca_set_pid(void) | ||
54 | { | ||
55 | /* We could make this more graceful ? */ | ||
56 | return -EOPNOTSUPP; | ||
57 | } | ||
58 | |||
59 | |||
60 | static int put_checksum(u8 *check_string, int length) | ||
61 | { | ||
62 | u8 i = 0, checksum = 0; | ||
63 | |||
64 | if (verbose > 3) { | ||
65 | dprintk("%s: ========================= Checksum calculation ===========================\n", __FUNCTION__); | ||
66 | dprintk("%s: String Length=[0x%02x]\n", __FUNCTION__, length); | ||
67 | |||
68 | dprintk("%s: String=[", __FUNCTION__); | ||
69 | } | ||
70 | while (i < length) { | ||
71 | if (verbose > 3) | ||
72 | dprintk(" %02x", check_string[i]); | ||
73 | checksum += check_string[i]; | ||
74 | i++; | ||
75 | } | ||
76 | if (verbose > 3) { | ||
77 | dprintk(" ]\n"); | ||
78 | dprintk("%s: Sum=[%02x]\n", __FUNCTION__, checksum); | ||
79 | } | ||
80 | check_string[length] = ~checksum + 1; | ||
81 | if (verbose > 3) { | ||
82 | dprintk("%s: Checksum=[%02x]\n", __FUNCTION__, check_string[length]); | ||
83 | dprintk("%s: ==========================================================================\n", __FUNCTION__); | ||
84 | } | ||
85 | |||
86 | return 0; | ||
87 | } | ||
88 | |||
89 | static int dst_ci_command(struct dst_state* state, u8 * data, u8 *ca_string, u8 len, int read) | ||
90 | { | ||
91 | u8 reply; | ||
92 | |||
93 | dst_comm_init(state); | ||
94 | msleep(65); | ||
95 | |||
96 | if (write_dst(state, data, len)) { | ||
97 | dprintk("%s: Write not successful, trying to recover\n", __FUNCTION__); | ||
98 | dst_error_recovery(state); | ||
99 | return -1; | ||
100 | } | ||
101 | |||
102 | if ((dst_pio_disable(state)) < 0) { | ||
103 | dprintk("%s: DST PIO disable failed.\n", __FUNCTION__); | ||
104 | return -1; | ||
105 | } | ||
106 | |||
107 | if (read_dst(state, &reply, GET_ACK) < 0) { | ||
108 | dprintk("%s: Read not successful, trying to recover\n", __FUNCTION__); | ||
109 | dst_error_recovery(state); | ||
110 | return -1; | ||
111 | } | ||
112 | |||
113 | if (read) { | ||
114 | if (! dst_wait_dst_ready(state, LONG_DELAY)) { | ||
115 | dprintk("%s: 8820 not ready\n", __FUNCTION__); | ||
116 | return -1; | ||
117 | } | ||
118 | |||
119 | if (read_dst(state, ca_string, 128) < 0) { /* Try to make this dynamic */ | ||
120 | dprintk("%s: Read not successful, trying to recover\n", __FUNCTION__); | ||
121 | dst_error_recovery(state); | ||
122 | return -1; | ||
123 | } | ||
124 | } | ||
125 | |||
126 | return 0; | ||
127 | } | ||
128 | |||
129 | |||
130 | static int dst_put_ci(struct dst_state *state, u8 *data, int len, u8 *ca_string, int read) | ||
131 | { | ||
132 | u8 dst_ca_comm_err = 0; | ||
133 | |||
134 | while (dst_ca_comm_err < RETRIES) { | ||
135 | dst_comm_init(state); | ||
136 | if (verbose > 2) | ||
137 | dprintk("%s: Put Command\n", __FUNCTION__); | ||
138 | if (dst_ci_command(state, data, ca_string, len, read)) { // If error | ||
139 | dst_error_recovery(state); | ||
140 | dst_ca_comm_err++; // work required here. | ||
141 | } | ||
142 | break; | ||
143 | } | ||
144 | |||
145 | return 0; | ||
146 | } | ||
147 | |||
148 | |||
149 | |||
150 | static int ca_get_app_info(struct dst_state *state) | ||
151 | { | ||
152 | static u8 command[8] = {0x07, 0x40, 0x01, 0x00, 0x01, 0x00, 0x00, 0xff}; | ||
153 | |||
154 | put_checksum(&command[0], command[0]); | ||
155 | if ((dst_put_ci(state, command, sizeof(command), state->messages, GET_REPLY)) < 0) { | ||
156 | dprintk("%s: -->dst_put_ci FAILED !\n", __FUNCTION__); | ||
157 | return -1; | ||
158 | } | ||
159 | if (verbose > 1) { | ||
160 | dprintk("%s: -->dst_put_ci SUCCESS !\n", __FUNCTION__); | ||
161 | |||
162 | dprintk("%s: ================================ CI Module Application Info ======================================\n", __FUNCTION__); | ||
163 | dprintk("%s: Application Type=[%d], Application Vendor=[%d], Vendor Code=[%d]\n%s: Application info=[%s]\n", | ||
164 | __FUNCTION__, state->messages[7], (state->messages[8] << 8) | state->messages[9], | ||
165 | (state->messages[10] << 8) | state->messages[11], __FUNCTION__, (char *)(&state->messages[12])); | ||
166 | dprintk("%s: ==================================================================================================\n", __FUNCTION__); | ||
167 | } | ||
168 | |||
169 | return 0; | ||
170 | } | ||
171 | |||
172 | static int ca_get_slot_caps(struct dst_state *state, struct ca_caps *p_ca_caps, void *arg) | ||
173 | { | ||
174 | int i; | ||
175 | u8 slot_cap[256]; | ||
176 | static u8 slot_command[8] = {0x07, 0x40, 0x02, 0x00, 0x02, 0x00, 0x00, 0xff}; | ||
177 | |||
178 | put_checksum(&slot_command[0], slot_command[0]); | ||
179 | if ((dst_put_ci(state, slot_command, sizeof (slot_command), slot_cap, GET_REPLY)) < 0) { | ||
180 | dprintk("%s: -->dst_put_ci FAILED !\n", __FUNCTION__); | ||
181 | return -1; | ||
182 | } | ||
183 | if (verbose > 1) | ||
184 | dprintk("%s: -->dst_put_ci SUCCESS !\n", __FUNCTION__); | ||
185 | |||
186 | /* Will implement the rest soon */ | ||
187 | |||
188 | if (verbose > 1) { | ||
189 | dprintk("%s: Slot cap = [%d]\n", __FUNCTION__, slot_cap[7]); | ||
190 | dprintk("===================================\n"); | ||
191 | for (i = 0; i < 8; i++) | ||
192 | dprintk(" %d", slot_cap[i]); | ||
193 | dprintk("\n"); | ||
194 | } | ||
195 | |||
196 | p_ca_caps->slot_num = 1; | ||
197 | p_ca_caps->slot_type = 1; | ||
198 | p_ca_caps->descr_num = slot_cap[7]; | ||
199 | p_ca_caps->descr_type = 1; | ||
200 | |||
201 | |||
202 | if (copy_to_user((struct ca_caps *)arg, p_ca_caps, sizeof (struct ca_caps))) { | ||
203 | return -EFAULT; | ||
204 | } | ||
205 | |||
206 | return 0; | ||
207 | } | ||
208 | |||
209 | /* Need some more work */ | ||
210 | static int ca_get_slot_descr(struct dst_state *state, struct ca_msg *p_ca_message, void *arg) | ||
211 | { | ||
212 | return -EOPNOTSUPP; | ||
213 | } | ||
214 | |||
215 | |||
216 | static int ca_get_slot_info(struct dst_state *state, struct ca_slot_info *p_ca_slot_info, void *arg) | ||
217 | { | ||
218 | int i; | ||
219 | static u8 slot_command[8] = {0x00, 0x05, 0x00, 0x00, 0x00, 0x00, 0x00, 0xff}; | ||
220 | |||
221 | u8 *slot_info = state->rxbuffer; | ||
222 | |||
223 | put_checksum(&slot_command[0], 7); | ||
224 | if ((dst_put_ci(state, slot_command, sizeof (slot_command), slot_info, GET_REPLY)) < 0) { | ||
225 | dprintk("%s: -->dst_put_ci FAILED !\n", __FUNCTION__); | ||
226 | return -1; | ||
227 | } | ||
228 | if (verbose > 1) | ||
229 | dprintk("%s: -->dst_put_ci SUCCESS !\n", __FUNCTION__); | ||
230 | |||
231 | /* Will implement the rest soon */ | ||
232 | |||
233 | if (verbose > 1) { | ||
234 | dprintk("%s: Slot info = [%d]\n", __FUNCTION__, slot_info[3]); | ||
235 | dprintk("===================================\n"); | ||
236 | for (i = 0; i < 8; i++) | ||
237 | dprintk(" %d", slot_info[i]); | ||
238 | dprintk("\n"); | ||
239 | } | ||
240 | |||
241 | if (slot_info[4] & 0x80) { | ||
242 | p_ca_slot_info->flags = CA_CI_MODULE_PRESENT; | ||
243 | p_ca_slot_info->num = 1; | ||
244 | p_ca_slot_info->type = CA_CI; | ||
245 | } | ||
246 | else if (slot_info[4] & 0x40) { | ||
247 | p_ca_slot_info->flags = CA_CI_MODULE_READY; | ||
248 | p_ca_slot_info->num = 1; | ||
249 | p_ca_slot_info->type = CA_CI; | ||
250 | } | ||
251 | else { | ||
252 | p_ca_slot_info->flags = 0; | ||
253 | } | ||
254 | |||
255 | if (copy_to_user((struct ca_slot_info *)arg, p_ca_slot_info, sizeof (struct ca_slot_info))) { | ||
256 | return -EFAULT; | ||
257 | } | ||
258 | |||
259 | return 0; | ||
260 | } | ||
261 | |||
262 | |||
263 | |||
264 | |||
265 | static int ca_get_message(struct dst_state *state, struct ca_msg *p_ca_message, void *arg) | ||
266 | { | ||
267 | u8 i = 0; | ||
268 | u32 command = 0; | ||
269 | |||
270 | if (copy_from_user(p_ca_message, (void *)arg, sizeof (struct ca_msg))) | ||
271 | return -EFAULT; | ||
272 | |||
273 | |||
274 | if (p_ca_message->msg) { | ||
275 | if (verbose > 3) | ||
276 | dprintk("Message = [%02x %02x %02x]\n", p_ca_message->msg[0], p_ca_message->msg[1], p_ca_message->msg[2]); | ||
277 | |||
278 | for (i = 0; i < 3; i++) { | ||
279 | command = command | p_ca_message->msg[i]; | ||
280 | if (i < 2) | ||
281 | command = command << 8; | ||
282 | } | ||
283 | if (verbose > 3) | ||
284 | dprintk("%s:Command=[0x%x]\n", __FUNCTION__, command); | ||
285 | |||
286 | switch (command) { | ||
287 | case CA_APP_INFO: | ||
288 | memcpy(p_ca_message->msg, state->messages, 128); | ||
289 | if (copy_to_user((void *)arg, p_ca_message, sizeof (struct ca_msg)) ) | ||
290 | return -EFAULT; | ||
291 | break; | ||
292 | } | ||
293 | } | ||
294 | |||
295 | return 0; | ||
296 | } | ||
297 | |||
298 | static int handle_en50221_tag(struct dst_state *state, struct ca_msg *p_ca_message, struct ca_msg *hw_buffer) | ||
299 | { | ||
300 | if (state->dst_hw_cap & DST_TYPE_HAS_SESSION) { | ||
301 | hw_buffer->msg[2] = p_ca_message->msg[1]; /* MSB */ | ||
302 | hw_buffer->msg[3] = p_ca_message->msg[2]; /* LSB */ | ||
303 | } | ||
304 | else { | ||
305 | hw_buffer->msg[2] = 0x03; | ||
306 | hw_buffer->msg[3] = 0x00; | ||
307 | } | ||
308 | return 0; | ||
309 | } | ||
310 | |||
311 | static int debug_8820_buffer(struct ca_msg *hw_buffer) | ||
312 | { | ||
313 | unsigned int i; | ||
314 | |||
315 | dprintk("%s:Debug=[", __FUNCTION__); | ||
316 | for (i = 0; i < (hw_buffer->msg[0] + 1); i++) | ||
317 | dprintk(" %02x", hw_buffer->msg[i]); | ||
318 | dprintk("]\n"); | ||
319 | |||
320 | return 0; | ||
321 | } | ||
322 | |||
323 | static int write_to_8820(struct dst_state *state, struct ca_msg *hw_buffer, u8 reply) | ||
324 | { | ||
325 | if ((dst_put_ci(state, hw_buffer->msg, (hw_buffer->length + 1), hw_buffer->msg, reply)) < 0) { | ||
326 | dprintk("%s: DST-CI Command failed.\n", __FUNCTION__); | ||
327 | dprintk("%s: Resetting DST.\n", __FUNCTION__); | ||
328 | rdc_reset_state(state); | ||
329 | return -1; | ||
330 | } | ||
331 | if (verbose > 2) | ||
332 | dprintk("%s: DST-CI Command succes.\n", __FUNCTION__); | ||
333 | |||
334 | return 0; | ||
335 | } | ||
336 | |||
337 | |||
338 | static int ca_set_pmt(struct dst_state *state, struct ca_msg *p_ca_message, struct ca_msg *hw_buffer, u8 reply, u8 query) | ||
339 | { | ||
340 | u32 hw_offset, buf_offset, i, k; | ||
341 | u32 program_info_length = 0, es_info_length = 0, length = 0, words = 0; | ||
342 | u8 found_prog_ca_desc = 0, found_stream_ca_desc = 0, error_condition = 0, hw_buffer_length = 0; | ||
343 | |||
344 | if (verbose > 3) | ||
345 | dprintk("%s, p_ca_message length %d (0x%x)\n", __FUNCTION__,p_ca_message->length,p_ca_message->length ); | ||
346 | |||
347 | handle_en50221_tag(state, p_ca_message, hw_buffer); /* EN50221 tag */ | ||
348 | |||
349 | /* Handle the length field (variable) */ | ||
350 | if (!(p_ca_message->msg[3] & 0x80)) { /* Length = 1 */ | ||
351 | length = p_ca_message->msg[3] & 0x7f; | ||
352 | words = 0; /* domi's suggestion */ | ||
353 | } | ||
354 | else { /* Length = words */ | ||
355 | words = p_ca_message->msg[3] & 0x7f; | ||
356 | for (i = 0; i < words; i++) { | ||
357 | length = length << 8; | ||
358 | length = length | p_ca_message->msg[4 + i]; | ||
359 | } | ||
360 | } | ||
361 | if (verbose > 4) { | ||
362 | dprintk("%s:Length=[%d (0x%x)], Words=[%d]\n", __FUNCTION__, length,length, words); | ||
363 | |||
364 | /* Debug Input string */ | ||
365 | for (i = 0; i < length; i++) | ||
366 | dprintk(" %02x", p_ca_message->msg[i]); | ||
367 | dprintk("]\n"); | ||
368 | } | ||
369 | |||
370 | hw_offset = 7; | ||
371 | buf_offset = words + 4; | ||
372 | |||
373 | /* Program Header */ | ||
374 | if (verbose > 4) | ||
375 | dprintk("\n%s:Program Header=[", __FUNCTION__); | ||
376 | for (i = 0; i < 6; i++) { | ||
377 | hw_buffer->msg[hw_offset] = p_ca_message->msg[buf_offset]; | ||
378 | if (verbose > 4) | ||
379 | dprintk(" %02x", p_ca_message->msg[buf_offset]); | ||
380 | hw_offset++, buf_offset++, hw_buffer_length++; | ||
381 | } | ||
382 | if (verbose > 4) | ||
383 | dprintk("]\n"); | ||
384 | |||
385 | program_info_length = 0; | ||
386 | program_info_length = (((program_info_length | p_ca_message->msg[words + 8]) & 0x0f) << 8) | p_ca_message->msg[words + 9]; | ||
387 | if (verbose > 4) | ||
388 | dprintk("%s:Program info Length=[%d][%02x], hw_offset=[%d], buf_offset=[%d] \n", | ||
389 | __FUNCTION__, program_info_length, program_info_length, hw_offset, buf_offset); | ||
390 | |||
391 | if (program_info_length && (program_info_length < 256)) { /* If program_info_length */ | ||
392 | hw_buffer->msg[11] = hw_buffer->msg[11] & 0x0f; /* req only 4 bits */ | ||
393 | hw_buffer->msg[12] = hw_buffer->msg[12] + 1; /* increment! ASIC bug! */ | ||
394 | |||
395 | if (p_ca_message->msg[buf_offset + 1] == 0x09) { /* Check CA descriptor */ | ||
396 | found_prog_ca_desc = 1; | ||
397 | if (verbose > 4) | ||
398 | dprintk("%s: Found CA descriptor @ Program level\n", __FUNCTION__); | ||
399 | } | ||
400 | |||
401 | if (found_prog_ca_desc) { /* Command only if CA descriptor */ | ||
402 | hw_buffer->msg[13] = p_ca_message->msg[buf_offset]; /* CA PMT command ID */ | ||
403 | hw_offset++, buf_offset++, hw_buffer_length++; | ||
404 | } | ||
405 | |||
406 | /* Program descriptors */ | ||
407 | if (verbose > 4) { | ||
408 | dprintk("%s:**********>buf_offset=[%d], hw_offset=[%d]\n", __FUNCTION__, buf_offset, hw_offset); | ||
409 | dprintk("%s:Program descriptors=[", __FUNCTION__); | ||
410 | } | ||
411 | while (program_info_length && !error_condition) { /* Copy prog descriptors */ | ||
412 | if (program_info_length > p_ca_message->length) { /* Error situation */ | ||
413 | dprintk ("%s:\"WARNING\" Length error, line=[%d], prog_info_length=[%d]\n", | ||
414 | __FUNCTION__, __LINE__, program_info_length); | ||
415 | dprintk("%s:\"WARNING\" Bailing out of possible loop\n", __FUNCTION__); | ||
416 | error_condition = 1; | ||
417 | break; | ||
418 | } | ||
419 | |||
420 | hw_buffer->msg[hw_offset] = p_ca_message->msg[buf_offset]; | ||
421 | dprintk(" %02x", p_ca_message->msg[buf_offset]); | ||
422 | hw_offset++, buf_offset++, hw_buffer_length++, program_info_length--; | ||
423 | } | ||
424 | if (verbose > 4) { | ||
425 | dprintk("]\n"); | ||
426 | dprintk("%s:**********>buf_offset=[%d], hw_offset=[%d]\n", __FUNCTION__, buf_offset, hw_offset); | ||
427 | } | ||
428 | if (found_prog_ca_desc) { | ||
429 | if (!reply) { | ||
430 | hw_buffer->msg[13] = 0x01; /* OK descrambling */ | ||
431 | if (verbose > 1) | ||
432 | dprintk("CA PMT Command = OK Descrambling\n"); | ||
433 | } | ||
434 | else { | ||
435 | hw_buffer->msg[13] = 0x02; /* Ok MMI */ | ||
436 | if (verbose > 1) | ||
437 | dprintk("CA PMT Command = Ok MMI\n"); | ||
438 | } | ||
439 | if (query) { | ||
440 | hw_buffer->msg[13] = 0x03; /* Query */ | ||
441 | if (verbose > 1) | ||
442 | dprintk("CA PMT Command = CA PMT query\n"); | ||
443 | } | ||
444 | } | ||
445 | } | ||
446 | else { | ||
447 | hw_buffer->msg[11] = hw_buffer->msg[11] & 0xf0; /* Don't write to ASIC */ | ||
448 | hw_buffer->msg[12] = hw_buffer->msg[12] = 0x00; | ||
449 | } | ||
450 | if (verbose > 4) | ||
451 | dprintk("%s:**********>p_ca_message->length=[%d], buf_offset=[%d], hw_offset=[%d]\n", | ||
452 | __FUNCTION__, p_ca_message->length, buf_offset, hw_offset); | ||
453 | |||
454 | while ((buf_offset < p_ca_message->length) && !error_condition) { | ||
455 | /* Bail out in case of an indefinite loop */ | ||
456 | if ((es_info_length > p_ca_message->length) || (buf_offset > p_ca_message->length)) { | ||
457 | dprintk("%s:\"WARNING\" Length error, line=[%d], prog_info_length=[%d], buf_offset=[%d]\n", | ||
458 | __FUNCTION__, __LINE__, program_info_length, buf_offset); | ||
459 | |||
460 | dprintk("%s:\"WARNING\" Bailing out of possible loop\n", __FUNCTION__); | ||
461 | error_condition = 1; | ||
462 | break; | ||
463 | } | ||
464 | |||
465 | /* Stream Header */ | ||
466 | |||
467 | for (k = 0; k < 5; k++) { | ||
468 | hw_buffer->msg[hw_offset + k] = p_ca_message->msg[buf_offset + k]; | ||
469 | } | ||
470 | |||
471 | es_info_length = 0; | ||
472 | es_info_length = (es_info_length | (p_ca_message->msg[buf_offset + 3] & 0x0f)) << 8 | p_ca_message->msg[buf_offset + 4]; | ||
473 | |||
474 | if (verbose > 4) { | ||
475 | dprintk("\n%s:----->Stream header=[%02x %02x %02x %02x %02x]\n", __FUNCTION__, | ||
476 | p_ca_message->msg[buf_offset + 0], p_ca_message->msg[buf_offset + 1], | ||
477 | p_ca_message->msg[buf_offset + 2], p_ca_message->msg[buf_offset + 3], | ||
478 | p_ca_message->msg[buf_offset + 4]); | ||
479 | |||
480 | dprintk("%s:----->Stream type=[%02x], es length=[%d (0x%x)], Chars=[%02x] [%02x], buf_offset=[%d]\n", __FUNCTION__, | ||
481 | p_ca_message->msg[buf_offset + 0], es_info_length, es_info_length, | ||
482 | p_ca_message->msg[buf_offset + 3], p_ca_message->msg[buf_offset + 4], buf_offset); | ||
483 | } | ||
484 | |||
485 | hw_buffer->msg[hw_offset + 3] &= 0x0f; /* req only 4 bits */ | ||
486 | |||
487 | if (found_prog_ca_desc) { | ||
488 | hw_buffer->msg[hw_offset + 3] = 0x00; | ||
489 | hw_buffer->msg[hw_offset + 4] = 0x00; | ||
490 | } | ||
491 | |||
492 | hw_offset += 5, buf_offset += 5, hw_buffer_length += 5; | ||
493 | |||
494 | /* Check for CA descriptor */ | ||
495 | if (p_ca_message->msg[buf_offset + 1] == 0x09) { | ||
496 | if (verbose > 4) | ||
497 | dprintk("%s:Found CA descriptor @ Stream level\n", __FUNCTION__); | ||
498 | found_stream_ca_desc = 1; | ||
499 | } | ||
500 | |||
501 | /* ES descriptors */ | ||
502 | |||
503 | if (es_info_length && !error_condition && !found_prog_ca_desc && found_stream_ca_desc) { | ||
504 | // if (!ca_pmt_done) { | ||
505 | hw_buffer->msg[hw_offset] = p_ca_message->msg[buf_offset]; /* CA PMT cmd(es) */ | ||
506 | if (verbose > 4) | ||
507 | printk("%s:----->CA PMT Command ID=[%02x]\n", __FUNCTION__, p_ca_message->msg[buf_offset]); | ||
508 | // hw_offset++, buf_offset++, hw_buffer_length++, es_info_length--, ca_pmt_done = 1; | ||
509 | hw_offset++, buf_offset++, hw_buffer_length++, es_info_length--; | ||
510 | // } | ||
511 | if (verbose > 4) | ||
512 | dprintk("%s:----->ES descriptors=[", __FUNCTION__); | ||
513 | |||
514 | while (es_info_length && !error_condition) { /* ES descriptors */ | ||
515 | if ((es_info_length > p_ca_message->length) || (buf_offset > p_ca_message->length)) { | ||
516 | if (verbose > 4) { | ||
517 | dprintk("%s:\"WARNING\" ES Length error, line=[%d], es_info_length=[%d], buf_offset=[%d]\n", | ||
518 | __FUNCTION__, __LINE__, es_info_length, buf_offset); | ||
519 | |||
520 | dprintk("%s:\"WARNING\" Bailing out of possible loop\n", __FUNCTION__); | ||
521 | } | ||
522 | error_condition = 1; | ||
523 | break; | ||
524 | } | ||
525 | |||
526 | hw_buffer->msg[hw_offset] = p_ca_message->msg[buf_offset]; | ||
527 | if (verbose > 3) | ||
528 | dprintk("%02x ", hw_buffer->msg[hw_offset]); | ||
529 | hw_offset++, buf_offset++, hw_buffer_length++, es_info_length--; | ||
530 | } | ||
531 | found_stream_ca_desc = 0; /* unset for new streams */ | ||
532 | dprintk("]\n"); | ||
533 | } | ||
534 | } | ||
535 | |||
536 | /* MCU Magic words */ | ||
537 | |||
538 | hw_buffer_length += 7; | ||
539 | hw_buffer->msg[0] = hw_buffer_length; | ||
540 | hw_buffer->msg[1] = 64; | ||
541 | hw_buffer->msg[4] = 3; | ||
542 | hw_buffer->msg[5] = hw_buffer->msg[0] - 7; | ||
543 | hw_buffer->msg[6] = 0; | ||
544 | |||
545 | |||
546 | /* Fix length */ | ||
547 | hw_buffer->length = hw_buffer->msg[0]; | ||
548 | |||
549 | put_checksum(&hw_buffer->msg[0], hw_buffer->msg[0]); | ||
550 | /* Do the actual write */ | ||
551 | if (verbose > 4) { | ||
552 | dprintk("%s:======================DEBUGGING================================\n", __FUNCTION__); | ||
553 | dprintk("%s: Actual Length=[%d]\n", __FUNCTION__, hw_buffer_length); | ||
554 | } | ||
555 | /* Only for debugging! */ | ||
556 | if (verbose > 2) | ||
557 | debug_8820_buffer(hw_buffer); | ||
558 | if (verbose > 3) | ||
559 | dprintk("%s: Reply = [%d]\n", __FUNCTION__, reply); | ||
560 | write_to_8820(state, hw_buffer, reply); | ||
561 | |||
562 | return 0; | ||
563 | } | ||
564 | |||
565 | /* Board supports CA PMT reply ? */ | ||
566 | static int dst_check_ca_pmt(struct dst_state *state, struct ca_msg *p_ca_message, struct ca_msg *hw_buffer) | ||
567 | { | ||
568 | int ca_pmt_reply_test = 0; | ||
569 | |||
570 | /* Do test board */ | ||
571 | /* Not there yet but soon */ | ||
572 | |||
573 | |||
574 | /* CA PMT Reply capable */ | ||
575 | if (ca_pmt_reply_test) { | ||
576 | if ((ca_set_pmt(state, p_ca_message, hw_buffer, 1, GET_REPLY)) < 0) { | ||
577 | dprintk("%s: ca_set_pmt.. failed !\n", __FUNCTION__); | ||
578 | return -1; | ||
579 | } | ||
580 | |||
581 | /* Process CA PMT Reply */ | ||
582 | /* will implement soon */ | ||
583 | dprintk("%s: Not there yet\n", __FUNCTION__); | ||
584 | } | ||
585 | /* CA PMT Reply not capable */ | ||
586 | if (!ca_pmt_reply_test) { | ||
587 | if ((ca_set_pmt(state, p_ca_message, hw_buffer, 0, NO_REPLY)) < 0) { | ||
588 | dprintk("%s: ca_set_pmt.. failed !\n", __FUNCTION__); | ||
589 | return -1; | ||
590 | } | ||
591 | if (verbose > 3) | ||
592 | dprintk("%s: ca_set_pmt.. success !\n", __FUNCTION__); | ||
593 | /* put a dummy message */ | ||
594 | |||
595 | } | ||
596 | return 0; | ||
597 | } | ||
598 | |||
599 | static int ca_send_message(struct dst_state *state, struct ca_msg *p_ca_message, void *arg) | ||
600 | { | ||
601 | int i = 0; | ||
602 | unsigned int ca_message_header_len; | ||
603 | |||
604 | u32 command = 0; | ||
605 | struct ca_msg *hw_buffer; | ||
606 | |||
607 | if ((hw_buffer = (struct ca_msg *) kmalloc(sizeof (struct ca_msg), GFP_KERNEL)) == NULL) { | ||
608 | printk("%s: Memory allocation failure\n", __FUNCTION__); | ||
609 | return -ENOMEM; | ||
610 | } | ||
611 | if (verbose > 3) | ||
612 | dprintk("%s\n", __FUNCTION__); | ||
613 | |||
614 | if (copy_from_user(p_ca_message, (void *)arg, sizeof (struct ca_msg))) | ||
615 | return -EFAULT; | ||
616 | |||
617 | if (p_ca_message->msg) { | ||
618 | ca_message_header_len = p_ca_message->length; /* Restore it back when you are done */ | ||
619 | /* EN50221 tag */ | ||
620 | command = 0; | ||
621 | |||
622 | for (i = 0; i < 3; i++) { | ||
623 | command = command | p_ca_message->msg[i]; | ||
624 | if (i < 2) | ||
625 | command = command << 8; | ||
626 | } | ||
627 | if (verbose > 3) | ||
628 | dprintk("%s:Command=[0x%x]\n", __FUNCTION__, command); | ||
629 | |||
630 | switch (command) { | ||
631 | case CA_PMT: | ||
632 | if (verbose > 3) | ||
633 | dprintk("Command = SEND_CA_PMT\n"); | ||
634 | if ((ca_set_pmt(state, p_ca_message, hw_buffer, 0, 0)) < 0) { | ||
635 | dprintk("%s: -->CA_PMT Failed !\n", __FUNCTION__); | ||
636 | return -1; | ||
637 | } | ||
638 | if (verbose > 3) | ||
639 | dprintk("%s: -->CA_PMT Success !\n", __FUNCTION__); | ||
640 | // retval = dummy_set_pmt(state, p_ca_message, hw_buffer, 0, 0); | ||
641 | |||
642 | break; | ||
643 | |||
644 | case CA_PMT_REPLY: | ||
645 | if (verbose > 3) | ||
646 | dprintk("Command = CA_PMT_REPLY\n"); | ||
647 | /* Have to handle the 2 basic types of cards here */ | ||
648 | if ((dst_check_ca_pmt(state, p_ca_message, hw_buffer)) < 0) { | ||
649 | dprintk("%s: -->CA_PMT_REPLY Failed !\n", __FUNCTION__); | ||
650 | return -1; | ||
651 | } | ||
652 | if (verbose > 3) | ||
653 | dprintk("%s: -->CA_PMT_REPLY Success !\n", __FUNCTION__); | ||
654 | |||
655 | /* Certain boards do behave different ? */ | ||
656 | // retval = ca_set_pmt(state, p_ca_message, hw_buffer, 1, 1); | ||
657 | |||
658 | case CA_APP_INFO_ENQUIRY: // only for debugging | ||
659 | if (verbose > 3) | ||
660 | dprintk("%s: Getting Cam Application information\n", __FUNCTION__); | ||
661 | |||
662 | if ((ca_get_app_info(state)) < 0) { | ||
663 | dprintk("%s: -->CA_APP_INFO_ENQUIRY Failed !\n", __FUNCTION__); | ||
664 | return -1; | ||
665 | } | ||
666 | if (verbose > 3) | ||
667 | printk("%s: -->CA_APP_INFO_ENQUIRY Success !\n", __FUNCTION__); | ||
668 | |||
669 | break; | ||
670 | } | ||
671 | } | ||
672 | return 0; | ||
673 | } | ||
674 | |||
675 | static int dst_ca_ioctl(struct inode *inode, struct file *file, unsigned int cmd, void *arg) | ||
676 | { | ||
677 | struct dvb_device* dvbdev = (struct dvb_device*) file->private_data; | ||
678 | struct dst_state* state = (struct dst_state*) dvbdev->priv; | ||
679 | struct ca_slot_info *p_ca_slot_info; | ||
680 | struct ca_caps *p_ca_caps; | ||
681 | struct ca_msg *p_ca_message; | ||
682 | |||
683 | if ((p_ca_message = (struct ca_msg *) kmalloc(sizeof (struct ca_msg), GFP_KERNEL)) == NULL) { | ||
684 | printk("%s: Memory allocation failure\n", __FUNCTION__); | ||
685 | return -ENOMEM; | ||
686 | } | ||
687 | |||
688 | if ((p_ca_slot_info = (struct ca_slot_info *) kmalloc(sizeof (struct ca_slot_info), GFP_KERNEL)) == NULL) { | ||
689 | printk("%s: Memory allocation failure\n", __FUNCTION__); | ||
690 | return -ENOMEM; | ||
691 | } | ||
692 | |||
693 | if ((p_ca_caps = (struct ca_caps *) kmalloc(sizeof (struct ca_caps), GFP_KERNEL)) == NULL) { | ||
694 | printk("%s: Memory allocation failure\n", __FUNCTION__); | ||
695 | return -ENOMEM; | ||
696 | } | ||
697 | |||
698 | /* We have now only the standard ioctl's, the driver is upposed to handle internals. */ | ||
699 | switch (cmd) { | ||
700 | case CA_SEND_MSG: | ||
701 | if (verbose > 1) | ||
702 | dprintk("%s: Sending message\n", __FUNCTION__); | ||
703 | if ((ca_send_message(state, p_ca_message, arg)) < 0) { | ||
704 | dprintk("%s: -->CA_SEND_MSG Failed !\n", __FUNCTION__); | ||
705 | return -1; | ||
706 | } | ||
707 | |||
708 | break; | ||
709 | |||
710 | case CA_GET_MSG: | ||
711 | if (verbose > 1) | ||
712 | dprintk("%s: Getting message\n", __FUNCTION__); | ||
713 | if ((ca_get_message(state, p_ca_message, arg)) < 0) { | ||
714 | dprintk("%s: -->CA_GET_MSG Failed !\n", __FUNCTION__); | ||
715 | return -1; | ||
716 | } | ||
717 | if (verbose > 1) | ||
718 | dprintk("%s: -->CA_GET_MSG Success !\n", __FUNCTION__); | ||
719 | |||
720 | break; | ||
721 | |||
722 | case CA_RESET: | ||
723 | if (verbose > 1) | ||
724 | dprintk("%s: Resetting DST\n", __FUNCTION__); | ||
725 | dst_error_bailout(state); | ||
726 | msleep(4000); | ||
727 | |||
728 | break; | ||
729 | |||
730 | case CA_GET_SLOT_INFO: | ||
731 | if (verbose > 1) | ||
732 | dprintk("%s: Getting Slot info\n", __FUNCTION__); | ||
733 | if ((ca_get_slot_info(state, p_ca_slot_info, arg)) < 0) { | ||
734 | dprintk("%s: -->CA_GET_SLOT_INFO Failed !\n", __FUNCTION__); | ||
735 | return -1; | ||
736 | } | ||
737 | if (verbose > 1) | ||
738 | dprintk("%s: -->CA_GET_SLOT_INFO Success !\n", __FUNCTION__); | ||
739 | |||
740 | break; | ||
741 | |||
742 | case CA_GET_CAP: | ||
743 | if (verbose > 1) | ||
744 | dprintk("%s: Getting Slot capabilities\n", __FUNCTION__); | ||
745 | if ((ca_get_slot_caps(state, p_ca_caps, arg)) < 0) { | ||
746 | dprintk("%s: -->CA_GET_CAP Failed !\n", __FUNCTION__); | ||
747 | return -1; | ||
748 | } | ||
749 | if (verbose > 1) | ||
750 | dprintk("%s: -->CA_GET_CAP Success !\n", __FUNCTION__); | ||
751 | |||
752 | break; | ||
753 | |||
754 | case CA_GET_DESCR_INFO: | ||
755 | if (verbose > 1) | ||
756 | dprintk("%s: Getting descrambler description\n", __FUNCTION__); | ||
757 | if ((ca_get_slot_descr(state, p_ca_message, arg)) < 0) { | ||
758 | dprintk("%s: -->CA_GET_DESCR_INFO Failed !\n", __FUNCTION__); | ||
759 | return -1; | ||
760 | } | ||
761 | if (verbose > 1) | ||
762 | dprintk("%s: -->CA_GET_DESCR_INFO Success !\n", __FUNCTION__); | ||
763 | |||
764 | break; | ||
765 | |||
766 | case CA_SET_DESCR: | ||
767 | if (verbose > 1) | ||
768 | dprintk("%s: Setting descrambler\n", __FUNCTION__); | ||
769 | if ((ca_set_slot_descr()) < 0) { | ||
770 | dprintk("%s: -->CA_SET_DESCR Failed !\n", __FUNCTION__); | ||
771 | return -1; | ||
772 | } | ||
773 | if (verbose > 1) | ||
774 | dprintk("%s: -->CA_SET_DESCR Success !\n", __FUNCTION__); | ||
775 | |||
776 | break; | ||
777 | |||
778 | case CA_SET_PID: | ||
779 | if (verbose > 1) | ||
780 | dprintk("%s: Setting PID\n", __FUNCTION__); | ||
781 | if ((ca_set_pid()) < 0) { | ||
782 | dprintk("%s: -->CA_SET_PID Failed !\n", __FUNCTION__); | ||
783 | return -1; | ||
784 | } | ||
785 | if (verbose > 1) | ||
786 | dprintk("%s: -->CA_SET_PID Success !\n", __FUNCTION__); | ||
787 | |||
788 | default: | ||
789 | return -EOPNOTSUPP; | ||
790 | }; | ||
791 | |||
792 | return 0; | ||
793 | } | ||
794 | |||
795 | static int dst_ca_open(struct inode *inode, struct file *file) | ||
796 | { | ||
797 | if (verbose > 4) | ||
798 | dprintk("%s:Device opened [%p]\n", __FUNCTION__, file); | ||
799 | try_module_get(THIS_MODULE); | ||
800 | |||
801 | return 0; | ||
802 | } | ||
803 | |||
804 | static int dst_ca_release(struct inode *inode, struct file *file) | ||
805 | { | ||
806 | if (verbose > 4) | ||
807 | dprintk("%s:Device closed.\n", __FUNCTION__); | ||
808 | module_put(THIS_MODULE); | ||
809 | |||
810 | return 0; | ||
811 | } | ||
812 | |||
813 | static int dst_ca_read(struct file *file, char __user * buffer, size_t length, loff_t * offset) | ||
814 | { | ||
815 | int bytes_read = 0; | ||
816 | |||
817 | if (verbose > 4) | ||
818 | dprintk("%s:Device read.\n", __FUNCTION__); | ||
819 | |||
820 | return bytes_read; | ||
821 | } | ||
822 | |||
823 | static int dst_ca_write(struct file *file, const char __user * buffer, size_t length, loff_t * offset) | ||
824 | { | ||
825 | if (verbose > 4) | ||
826 | dprintk("%s:Device write.\n", __FUNCTION__); | ||
827 | |||
828 | return 0; | ||
829 | } | ||
830 | |||
831 | static struct file_operations dst_ca_fops = { | ||
832 | .owner = THIS_MODULE, | ||
833 | .ioctl = (void *)dst_ca_ioctl, | ||
834 | .open = dst_ca_open, | ||
835 | .release = dst_ca_release, | ||
836 | .read = dst_ca_read, | ||
837 | .write = dst_ca_write | ||
838 | }; | ||
839 | |||
840 | static struct dvb_device dvbdev_ca = { | ||
841 | .priv = NULL, | ||
842 | .users = 1, | ||
843 | .readers = 1, | ||
844 | .writers = 1, | ||
845 | .fops = &dst_ca_fops | ||
846 | }; | ||
847 | |||
848 | int dst_ca_attach(struct dst_state *dst, struct dvb_adapter *dvb_adapter) | ||
849 | { | ||
850 | struct dvb_device *dvbdev; | ||
851 | if (verbose > 4) | ||
852 | dprintk("%s:registering DST-CA device\n", __FUNCTION__); | ||
853 | dvb_register_device(dvb_adapter, &dvbdev, &dvbdev_ca, dst, DVB_DEVICE_CA); | ||
854 | return 0; | ||
855 | } | ||
856 | |||
857 | EXPORT_SYMBOL(dst_ca_attach); | ||
858 | |||
859 | MODULE_DESCRIPTION("DST DVB-S/T/C Combo CA driver"); | ||
860 | MODULE_AUTHOR("Manu Abraham"); | ||
861 | MODULE_LICENSE("GPL"); | ||