/* * av7110_ca.c: CA and CI stuff * * Copyright (C) 1999-2002 Ralph Metzler * & Marcus Metzler for convergence integrated media GmbH * * originally based on code by: * Copyright (C) 1998,1999 Christian Theiss <mistert@rz.fh-augsburg.de> * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License * as published by the Free Software Foundation; either version 2 * of the License, or (at your option) any later version. * * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * Or, point your browser to http://www.gnu.org/copyleft/gpl.html * * * the project's page is at http://www.linuxtv.org/dvb/ */ #include <linux/kernel.h> #include <linux/types.h> #include <linux/delay.h> #include <linux/fs.h> #include <linux/timer.h> #include <linux/poll.h> #include "av7110.h" #include "av7110_hw.h" #include "av7110_ca.h" void CI_handle(struct av7110 *av7110, u8 *data, u16 len) { dprintk(8, "av7110:%p\n",av7110); if (len < 3) return; switch (data[0]) { case CI_MSG_CI_INFO: if (data[2] != 1 && data[2] != 2) break; switch (data[1]) { case 0: av7110->ci_slot[data[2] - 1].flags = 0; break; case 1: av7110->ci_slot[data[2] - 1].flags |= CA_CI_MODULE_PRESENT; break; case 2: av7110->ci_slot[data[2] - 1].flags |= CA_CI_MODULE_READY; break; } break; case CI_SWITCH_PRG_REPLY: //av7110->ci_stat=data[1]; break; default: break; } } void ci_get_data(struct dvb_ringbuffer *cibuf, u8 *data, int len) { if (dvb_ringbuffer_free(cibuf) < len + 2) return; DVB_RINGBUFFER_WRITE_BYTE(cibuf, len >> 8); DVB_RINGBUFFER_WRITE_BYTE(cibuf, len & 0xff); dvb_ringbuffer_write(cibuf, data, len); wake_up_interruptible(&cibuf->queue); } /****************************************************************************** * CI link layer file ops ******************************************************************************/ static int ci_ll_init(struct dvb_ringbuffer *cirbuf, struct dvb_ringbuffer *ciwbuf, int size) { struct dvb_ringbuffer *tab[] = { cirbuf, ciwbuf, NULL }, **p; void *data; for (p = tab; *p; p++) { data = vmalloc(size); if (!data) { while (p-- != tab) { vfree(p[0]->data); p[0]->data = NULL; } return -ENOMEM; } dvb_ringbuffer_init(*p, data, size); } return 0; } static void ci_ll_flush(struct dvb_ringbuffer *cirbuf, struct dvb_ringbuffer *ciwbuf) { dvb_ringbuffer_flush_spinlock_wakeup(cirbuf); dvb_ringbuffer_flush_spinlock_wakeup(ciwbuf); } static void ci_ll_release(struct dvb_ringbuffer *cirbuf, struct dvb_ringbuffer *ciwbuf) { vfree(cirbuf->data); cirbuf->data = NULL; vfree(ciwbuf->data); ciwbuf->data = NULL; } static int ci_ll_reset(struct dvb_ringbuffer *cibuf, struct file *file, int slots, ca_slot_info_t *slot) { int i; int len = 0; u8 msg[8] = { 0x00, 0x06, 0x00, 0x00, 0xff, 0x02, 0x00, 0x00 }; for (i = 0; i < 2; i++) { if (slots & (1 << i)) len += 8; } if (dvb_ringbuffer_free(cibuf) < len) return -EBUSY; for (i = 0; i < 2; i++) { if (slots & (1 << i)) { msg[2] = i; dvb_ringbuffer_write(cibuf, msg, 8); slot[i].flags = 0; } } return 0; } static ssize_t ci_ll_write(struct dvb_ringbuffer *cibuf, struct file *file, const char __user *buf, size_t count, loff_t *ppos) { int free; int non_blocking = file->f_flags & O_NONBLOCK; u8 *page = (u8 *)__get_free_page(GFP_USER); int res; if (!page) return -ENOMEM; res = -EINVAL; if (count > 2048) goto out; res = -EFAULT; if (copy_from_user(page, buf, count)) goto out; free = dvb_ringbuffer_free(cibuf); if (count + 2 > free) { res = -EWOULDBLOCK; if (non_blocking) goto out; res = -ERESTARTSYS; if (wait_event_interruptible(cibuf->queue, (dvb_ringbuffer_free(cibuf) >= count + 2))) goto out; } DVB_RINGBUFFER_WRITE_BYTE(cibuf, count >> 8); DVB_RINGBUFFER_WRITE_BYTE(cibuf, count & 0xff); res = dvb_ringbuffer_write(cibuf, page, count); out: free_page((unsigned long)page); return res; } static ssize_t ci_ll_read(struct dvb_ringbuffer *cibuf, struct file *file, char __user *buf, size_t count, loff_t *ppos) { int avail; int non_blocking = file->f_flags & O_NONBLOCK; ssize_t len; if (!cibuf->data || !count) return 0; if (non_blocking && (dvb_ringbuffer_empty(cibuf))) return -EWOULDBLOCK; if (wait_event_interruptible(cibuf->queue, !dvb_ringbuffer_empty(cibuf))) return -ERESTARTSYS; avail = dvb_ringbuffer_avail(cibuf); if (avail < 4) return 0; len = DVB_RINGBUFFER_PEEK(cibuf, 0) << 8; len |= DVB_RINGBUFFER_PEEK(cibuf, 1); if (avail < len + 2 || count < len) return -EINVAL; DVB_RINGBUFFER_SKIP(cibuf, 2); return dvb_ringbuffer_read_user(cibuf, buf, len); } static int dvb_ca_open(struct inode *inode, struct file *file) { struct dvb_device *dvbdev = file->private_data; struct av7110 *av7110 = dvbdev->priv; int err = dvb_generic_open(inode, file); dprintk(8, "av7110:%p\n",av7110); if (err < 0) return err; ci_ll_flush(&av7110->ci_rbuffer, &av7110->ci_wbuffer); return 0; } static unsigned int dvb_ca_poll (struct file *file, poll_table *wait) { struct dvb_device *dvbdev = file->private_data; struct av7110 *av7110 = dvbdev->priv; struct dvb_ringbuffer *rbuf = &av7110->ci_rbuffer; struct dvb_ringbuffer *wbuf = &av7110->ci_wbuffer; unsigned int mask = 0; dprintk(8, "av7110:%p\n",av7110); poll_wait(file, &rbuf->queue, wait); poll_wait(file, &wbuf->queue, wait); if (!dvb_ringbuffer_empty(rbuf)) mask |= (POLLIN | POLLRDNORM); if (dvb_ringbuffer_free(wbuf) > 1024) mask |= (POLLOUT | POLLWRNORM); return mask; } static int dvb_ca_ioctl(struct inode *inode, struct file *file, unsigned int cmd, void *parg) { struct dvb_device *dvbdev = file->private_data; struct av7110 *av7110 = dvbdev->priv; unsigned long arg = (unsigned long) parg; dprintk(8, "av7110:%p\n",av7110); switch (cmd) { case CA_RESET: return ci_ll_reset(&av7110->ci_wbuffer, file, arg, &av7110->ci_slot[0]); break; case CA_GET_CAP: { ca_caps_t cap; cap.slot_num = 2; cap.slot_type = (FW_CI_LL_SUPPORT(av7110->arm_app) ? CA_CI_LINK : CA_CI) | CA_DESCR; cap.descr_num = 16; cap.descr_type = CA_ECD; memcpy(parg, &cap, sizeof(cap)); break; } case CA_GET_SLOT_INFO: { ca_slot_info_t *info=(ca_slot_info_t *)parg; if (info->num > 1) return -EINVAL; av7110->ci_slot[info->num].num = info->num; av7110->ci_slot[info->num].type = FW_CI_LL_SUPPORT(av7110->arm_app) ? CA_CI_LINK : CA_CI; memcpy(info, &av7110->ci_slot[info->num], sizeof(ca_slot_info_t)); break; } case CA_GET_MSG: break; case CA_SEND_MSG: break; case CA_GET_DESCR_INFO: { ca_descr_info_t info; info.num = 16; info.type = CA_ECD; memcpy(parg, &info, sizeof (info)); break; } case CA_SET_DESCR: { ca_descr_t *descr = (ca_descr_t*) parg; if (descr->index >= 16) return -EINVAL; if (descr->parity > 1) return -EINVAL; av7110_fw_cmd(av7110, COMTYPE_PIDFILTER, SetDescr, 5, (descr->index<<8)|descr->parity, (descr->cw[0]<<8)|descr->cw[1], (descr->cw[2]<<8)|descr->cw[3], (descr->cw[4]<<8)|descr->cw[5], (descr->cw[6]<<8)|descr->cw[7]); break; } default: return -EINVAL; } return 0; } static ssize_t dvb_ca_write(struct file *file, const char __user *buf, size_t count, loff_t *ppos) { struct dvb_device *dvbdev = file->private_data; struct av7110 *av7110 = dvbdev->priv; dprintk(8, "av7110:%p\n",av7110); return ci_ll_write(&av7110->ci_wbuffer, file, buf, count, ppos); } static ssize_t dvb_ca_read(struct file *file, char __user *buf, size_t count, loff_t *ppos) { struct dvb_device *dvbdev = file->private_data; struct av7110 *av7110 = dvbdev->priv; dprintk(8, "av7110:%p\n",av7110); return ci_ll_read(&av7110->ci_rbuffer, file, buf, count, ppos); } static struct file_operations dvb_ca_fops = { .owner = THIS_MODULE, .read = dvb_ca_read, .write = dvb_ca_write, .ioctl = dvb_generic_ioctl, .open = dvb_ca_open, .release = dvb_generic_release, .poll = dvb_ca_poll, }; static struct dvb_device dvbdev_ca = { .priv = NULL, .users = 1, .writers = 1, .fops = &dvb_ca_fops, .kernel_ioctl = dvb_ca_ioctl, }; int av7110_ca_register(struct av7110 *av7110) { return dvb_register_device(&av7110->dvb_adapter, &av7110->ca_dev, &dvbdev_ca, av7110, DVB_DEVICE_CA); } void av7110_ca_unregister(struct av7110 *av7110) { dvb_unregister_device(av7110->ca_dev); } int av7110_ca_init(struct av7110* av7110) { return ci_ll_init(&av7110->ci_rbuffer, &av7110->ci_wbuffer, 8192); } void av7110_ca_exit(struct av7110* av7110) { ci_ll_release(&av7110->ci_rbuffer, &av7110->ci_wbuffer); }