git.oblomov.eu Git - linux-2.6/blob - drivers/media/dvb/ttpci/av7110_ca.c

   1 /*
   2  * av7110_ca.c: CA and CI stuff
   3  *
   4  * Copyright (C) 1999-2002 Ralph  Metzler
   5  *                       & Marcus Metzler for convergence integrated media GmbH
   6  *
   7  * originally based on code by:
   8  * Copyright (C) 1998,1999 Christian Theiss <mistert@rz.fh-augsburg.de>
   9  *
  10  * This program is free software; you can redistribute it and/or
  11  * modify it under the terms of the GNU General Public License
  12  * as published by the Free Software Foundation; either version 2
  13  * of the License, or (at your option) any later version.
  14  *
  15  *
  16  * This program is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19  * GNU General Public License for more details.
  20  *
  21  *
  22  * You should have received a copy of the GNU General Public License
  23  * along with this program; if not, write to the Free Software
  24  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  25  * Or, point your browser to http://www.gnu.org/copyleft/gpl.html
  26  *
  27  *
  28  * the project's page is at http://www.linuxtv.org/dvb/
  29  */
  30
  31 #include <linux/kernel.h>
  32 #include <linux/types.h>
  33 #include <linux/delay.h>
  34 #include <linux/fs.h>
  35 #include <linux/timer.h>
  36 #include <linux/poll.h>
  37 #include <linux/smp_lock.h>
  38
  39 #include "av7110.h"
  40 #include "av7110_hw.h"
  41 #include "av7110_ca.h"
  42
  43
  44 void CI_handle(struct av7110 *av7110, u8 *data, u16 len)
  45 {
  46         dprintk(8, "av7110:%p\n",av7110);
  47
  48         if (len < 3)
  49                 return;
  50         switch (data[0]) {
  51         case CI_MSG_CI_INFO:
  52                 if (data[2] != 1 && data[2] != 2)
  53                         break;
  54                 switch (data[1]) {
  55                 case 0:
  56                         av7110->ci_slot[data[2] - 1].flags = 0;
  57                         break;
  58                 case 1:
  59                         av7110->ci_slot[data[2] - 1].flags |= CA_CI_MODULE_PRESENT;
  60                         break;
  61                 case 2:
  62                         av7110->ci_slot[data[2] - 1].flags |= CA_CI_MODULE_READY;
  63                         break;
  64                 }
  65                 break;
  66         case CI_SWITCH_PRG_REPLY:
  67                 //av7110->ci_stat=data[1];
  68                 break;
  69         default:
  70                 break;
  71         }
  72 }
  73
  74
  75 void ci_get_data(struct dvb_ringbuffer *cibuf, u8 *data, int len)
  76 {
  77         if (dvb_ringbuffer_free(cibuf) < len + 2)
  78                 return;
  79
  80         DVB_RINGBUFFER_WRITE_BYTE(cibuf, len >> 8);
  81         DVB_RINGBUFFER_WRITE_BYTE(cibuf, len & 0xff);
  82         dvb_ringbuffer_write(cibuf, data, len);
  83         wake_up_interruptible(&cibuf->queue);
  84 }
  85
  86
  87 /******************************************************************************
  88  * CI link layer file ops
  89  ******************************************************************************/
  90
  91 static int ci_ll_init(struct dvb_ringbuffer *cirbuf, struct dvb_ringbuffer *ciwbuf, int size)
  92 {
  93         struct dvb_ringbuffer *tab[] = { cirbuf, ciwbuf, NULL }, **p;
  94         void *data;
  95
  96         for (p = tab; *p; p++) {
  97                 data = vmalloc(size);
  98                 if (!data) {
  99                         while (p-- != tab) {
 100                                 vfree(p[0]->data);
 101                                 p[0]->data = NULL;
 102                         }
 103                         return -ENOMEM;
 104                 }
 105                 dvb_ringbuffer_init(*p, data, size);
 106         }
 107         return 0;
 108 }
 109
 110 static void ci_ll_flush(struct dvb_ringbuffer *cirbuf, struct dvb_ringbuffer *ciwbuf)
 111 {
 112         dvb_ringbuffer_flush_spinlock_wakeup(cirbuf);
 113         dvb_ringbuffer_flush_spinlock_wakeup(ciwbuf);
 114 }
 115
 116 static void ci_ll_release(struct dvb_ringbuffer *cirbuf, struct dvb_ringbuffer *ciwbuf)
 117 {
 118         vfree(cirbuf->data);
 119         cirbuf->data = NULL;
 120         vfree(ciwbuf->data);
 121         ciwbuf->data = NULL;
 122 }
 123
 124 static int ci_ll_reset(struct dvb_ringbuffer *cibuf, struct file *file,
 125                        int slots, ca_slot_info_t *slot)
 126 {
 127         int i;
 128         int len = 0;
 129         u8 msg[8] = { 0x00, 0x06, 0x00, 0x00, 0xff, 0x02, 0x00, 0x00 };
 130
 131         for (i = 0; i < 2; i++) {
 132                 if (slots & (1 << i))
 133                         len += 8;
 134         }
 135
 136         if (dvb_ringbuffer_free(cibuf) < len)
 137                 return -EBUSY;
 138
 139         for (i = 0; i < 2; i++) {
 140                 if (slots & (1 << i)) {
 141                         msg[2] = i;
 142                         dvb_ringbuffer_write(cibuf, msg, 8);
 143                         slot[i].flags = 0;
 144                 }
 145         }
 146
 147         return 0;
 148 }
 149
 150 static ssize_t ci_ll_write(struct dvb_ringbuffer *cibuf, struct file *file,
 151                            const char __user *buf, size_t count, loff_t *ppos)
 152 {
 153         int free;
 154         int non_blocking = file->f_flags & O_NONBLOCK;
 155         char *page = (char *)__get_free_page(GFP_USER);
 156         int res;
 157
 158         if (!page)
 159                 return -ENOMEM;
 160
 161         res = -EINVAL;
 162         if (count > 2048)
 163                 goto out;
 164
 165         res = -EFAULT;
 166         if (copy_from_user(page, buf, count))
 167                 goto out;
 168
 169         free = dvb_ringbuffer_free(cibuf);
 170         if (count + 2 > free) {
 171                 res = -EWOULDBLOCK;
 172                 if (non_blocking)
 173                         goto out;
 174                 res = -ERESTARTSYS;
 175                 if (wait_event_interruptible(cibuf->queue,
 176                                              (dvb_ringbuffer_free(cibuf) >= count + 2)))
 177                         goto out;
 178         }
 179
 180         DVB_RINGBUFFER_WRITE_BYTE(cibuf, count >> 8);
 181         DVB_RINGBUFFER_WRITE_BYTE(cibuf, count & 0xff);
 182
 183         res = dvb_ringbuffer_write(cibuf, page, count);
 184 out:
 185         free_page((unsigned long)page);
 186         return res;
 187 }
 188
 189 static ssize_t ci_ll_read(struct dvb_ringbuffer *cibuf, struct file *file,
 190                           char __user *buf, size_t count, loff_t *ppos)
 191 {
 192         int avail;
 193         int non_blocking = file->f_flags & O_NONBLOCK;
 194         ssize_t len;
 195
 196         if (!cibuf->data || !count)
 197                 return 0;
 198         if (non_blocking && (dvb_ringbuffer_empty(cibuf)))
 199                 return -EWOULDBLOCK;
 200         if (wait_event_interruptible(cibuf->queue,
 201                                      !dvb_ringbuffer_empty(cibuf)))
 202                 return -ERESTARTSYS;
 203         avail = dvb_ringbuffer_avail(cibuf);
 204         if (avail < 4)
 205                 return 0;
 206         len = DVB_RINGBUFFER_PEEK(cibuf, 0) << 8;
 207         len |= DVB_RINGBUFFER_PEEK(cibuf, 1);
 208         if (avail < len + 2 || count < len)
 209                 return -EINVAL;
 210         DVB_RINGBUFFER_SKIP(cibuf, 2);
 211
 212         return dvb_ringbuffer_read(cibuf, buf, len, 1);
 213 }
 214
 215 static int dvb_ca_open(struct inode *inode, struct file *file)
 216 {
 217         struct dvb_device *dvbdev = file->private_data;
 218         struct av7110 *av7110 = dvbdev->priv;
 219         int err = dvb_generic_open(inode, file);
 220
 221         dprintk(8, "av7110:%p\n",av7110);
 222
 223         if (err < 0)
 224                 return err;
 225         ci_ll_flush(&av7110->ci_rbuffer, &av7110->ci_wbuffer);
 226         return 0;
 227 }
 228
 229 static unsigned int dvb_ca_poll (struct file *file, poll_table *wait)
 230 {
 231         struct dvb_device *dvbdev = file->private_data;
 232         struct av7110 *av7110 = dvbdev->priv;
 233         struct dvb_ringbuffer *rbuf = &av7110->ci_rbuffer;
 234         struct dvb_ringbuffer *wbuf = &av7110->ci_wbuffer;
 235         unsigned int mask = 0;
 236
 237         dprintk(8, "av7110:%p\n",av7110);
 238
 239         poll_wait(file, &rbuf->queue, wait);
 240         poll_wait(file, &wbuf->queue, wait);
 241
 242         if (!dvb_ringbuffer_empty(rbuf))
 243                 mask |= (POLLIN | POLLRDNORM);
 244
 245         if (dvb_ringbuffer_free(wbuf) > 1024)
 246                 mask |= (POLLOUT | POLLWRNORM);
 247
 248         return mask;
 249 }
 250
 251 static int dvb_ca_ioctl(struct inode *inode, struct file *file,
 252                  unsigned int cmd, void *parg)
 253 {
 254         struct dvb_device *dvbdev = file->private_data;
 255         struct av7110 *av7110 = dvbdev->priv;
 256         unsigned long arg = (unsigned long) parg;
 257
 258         dprintk(8, "av7110:%p\n",av7110);
 259
 260         switch (cmd) {
 261         case CA_RESET:
 262                 return ci_ll_reset(&av7110->ci_wbuffer, file, arg, &av7110->ci_slot[0]);
 263                 break;
 264         case CA_GET_CAP:
 265         {
 266                 ca_caps_t cap;
 267
 268                 cap.slot_num = 2;
 269                 cap.slot_type = (FW_CI_LL_SUPPORT(av7110->arm_app) ?
 270                                  CA_CI_LINK : CA_CI) | CA_DESCR;
 271                 cap.descr_num = 16;
 272                 cap.descr_type = CA_ECD;
 273                 memcpy(parg, &cap, sizeof(cap));
 274                 break;
 275         }
 276
 277         case CA_GET_SLOT_INFO:
 278         {
 279                 ca_slot_info_t *info=(ca_slot_info_t *)parg;
 280
 281                 if (info->num > 1)
 282                         return -EINVAL;
 283                 av7110->ci_slot[info->num].num = info->num;
 284                 av7110->ci_slot[info->num].type = FW_CI_LL_SUPPORT(av7110->arm_app) ?
 285                                                         CA_CI_LINK : CA_CI;
 286                 memcpy(info, &av7110->ci_slot[info->num], sizeof(ca_slot_info_t));
 287                 break;
 288         }
 289
 290         case CA_GET_MSG:
 291                 break;
 292
 293         case CA_SEND_MSG:
 294                 break;
 295
 296         case CA_GET_DESCR_INFO:
 297         {
 298                 ca_descr_info_t info;
 299
 300                 info.num = 16;
 301                 info.type = CA_ECD;
 302                 memcpy(parg, &info, sizeof (info));
 303                 break;
 304         }
 305
 306         case CA_SET_DESCR:
 307         {
 308                 ca_descr_t *descr = (ca_descr_t*) parg;
 309
 310                 if (descr->index >= 16)
 311                         return -EINVAL;
 312                 if (descr->parity > 1)
 313                         return -EINVAL;
 314                 av7110_fw_cmd(av7110, COMTYPE_PIDFILTER, SetDescr, 5,
 315                               (descr->index<<8)|descr->parity,
 316                               (descr->cw[0]<<8)|descr->cw[1],
 317                               (descr->cw[2]<<8)|descr->cw[3],
 318                               (descr->cw[4]<<8)|descr->cw[5],
 319                               (descr->cw[6]<<8)|descr->cw[7]);
 320                 break;
 321         }
 322
 323         default:
 324                 return -EINVAL;
 325         }
 326         return 0;
 327 }
 328
 329 static ssize_t dvb_ca_write(struct file *file, const char __user *buf,
 330                             size_t count, loff_t *ppos)
 331 {
 332         struct dvb_device *dvbdev = file->private_data;
 333         struct av7110 *av7110 = dvbdev->priv;
 334
 335         dprintk(8, "av7110:%p\n",av7110);
 336         return ci_ll_write(&av7110->ci_wbuffer, file, buf, count, ppos);
 337 }
 338
 339 static ssize_t dvb_ca_read(struct file *file, char __user *buf,
 340                            size_t count, loff_t *ppos)
 341 {
 342         struct dvb_device *dvbdev = file->private_data;
 343         struct av7110 *av7110 = dvbdev->priv;
 344
 345         dprintk(8, "av7110:%p\n",av7110);
 346         return ci_ll_read(&av7110->ci_rbuffer, file, buf, count, ppos);
 347 }
 348
 349 static struct file_operations dvb_ca_fops = {
 350         .owner          = THIS_MODULE,
 351         .read           = dvb_ca_read,
 352         .write          = dvb_ca_write,
 353         .ioctl          = dvb_generic_ioctl,
 354         .open           = dvb_ca_open,
 355         .release        = dvb_generic_release,
 356         .poll           = dvb_ca_poll,
 357 };
 358
 359 static struct dvb_device dvbdev_ca = {
 360         .priv           = NULL,
 361         .users          = 1,
 362         .writers        = 1,
 363         .fops           = &dvb_ca_fops,
 364         .kernel_ioctl   = dvb_ca_ioctl,
 365 };
 366
 367
 368 int av7110_ca_register(struct av7110 *av7110)
 369 {
 370         return dvb_register_device(&av7110->dvb_adapter, &av7110->ca_dev,
 371                                    &dvbdev_ca, av7110, DVB_DEVICE_CA);
 372 }
 373
 374 void av7110_ca_unregister(struct av7110 *av7110)
 375 {
 376         dvb_unregister_device(av7110->ca_dev);
 377 }
 378
 379 int av7110_ca_init(struct av7110* av7110)
 380 {
 381         return ci_ll_init(&av7110->ci_rbuffer, &av7110->ci_wbuffer, 8192);
 382 }
 383
 384 void av7110_ca_exit(struct av7110* av7110)
 385 {
 386         ci_ll_release(&av7110->ci_rbuffer, &av7110->ci_wbuffer);
 387 }