Split av7110.c into a few separate modules:

- av7110.c: initialization and demux stuff
- av7110_hw.c: lowlevel hardware access and firmware interface
- av7110_ca.c: CI and ECD
- av7110_av.c: audio/video MPEG decoder and remuxing stuff
- av7110_v4l.c: v4l interface

It's all still ugly and needs lots of namespace and coding-style
cleanups. It's probably broken, too. But it's a start.
(My main motivation is easier porting to the V4 API).

1 files changed, 371 insertions, 0 deletions

diff --git a/linux/drivers/media/dvb/ttpci/av7110_ca.c b/linux/drivers/media/dvb/ttpci/av7110_ca.c
new file mode 100644
index 000000000..86af2ffc5
--- /dev/null
+++ b/linux/drivers/media/dvb/ttpci/av7110_ca.c
@@ -0,0 +1,371 @@
+/*
+ * 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/sched.h>
+#include <linux/types.h>
+#include <linux/delay.h>
+#include <linux/fs.h>
+#include <linux/timer.h>
+#include <linux/poll.h>
+#include <linux/byteorder/swabb.h>
+#include <linux/smp_lock.h>
+
+#define DEBUG_VARIABLE av7110_debug
+extern int av7110_debug;
+
+#include "dvb_i2c.h"
+#include "dvb_functions.h"
+#include "av7110.h"
+#include "av7110_hw.h"
+
+
+void CI_handle(struct av7110 *av7110, u8 *data, u16 len)
+{
+	DEB_EE(("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,0);
+
+        wake_up_interruptible(&cibuf->queue);
+}
+
+
+/******************************************************************************
+ * CI link layer file ops
+ ******************************************************************************/
+
+int ci_ll_init(struct dvb_ringbuffer *cirbuf, struct dvb_ringbuffer *ciwbuf, int size)
+{
+        dvb_ringbuffer_init(cirbuf, vmalloc(size), size);
+        dvb_ringbuffer_init(ciwbuf, vmalloc(size), size);
+        return 0;
+}
+
+void ci_ll_flush(struct dvb_ringbuffer *cirbuf, struct dvb_ringbuffer *ciwbuf)
+{
+        dvb_ringbuffer_flush_spinlock_wakeup(cirbuf);
+        dvb_ringbuffer_flush_spinlock_wakeup(ciwbuf);
+}
+
+void ci_ll_release(struct dvb_ringbuffer *cirbuf, struct dvb_ringbuffer *ciwbuf)
+{
+        vfree(cirbuf->data);
+        cirbuf->data=0;
+        vfree(ciwbuf->data);
+        ciwbuf->data=0;
+}
+
+
+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,0,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,0);
+			slot[i].flags=0;
+		}
+	}
+
+	return 0;
+}
+
+static ssize_t ci_ll_write(struct dvb_ringbuffer *cibuf, struct file *file,
+			   const char *buf, size_t count, loff_t *ppos)
+{
+        int free;
+        int non_blocking=file->f_flags&O_NONBLOCK;
+
+        if (count>2048)
+                return -EINVAL;
+        free=dvb_ringbuffer_free(cibuf);
+        if (count+2>free) {
+                if (non_blocking)
+                        return -EWOULDBLOCK;
+                if (wait_event_interruptible(cibuf->queue,
+                                             (dvb_ringbuffer_free(cibuf)>=count+2)))
+                        return 0;
+        }
+
+        DVB_RINGBUFFER_WRITE_BYTE(cibuf,count>>8);
+        DVB_RINGBUFFER_WRITE_BYTE(cibuf,count&0xff);
+
+        return dvb_ringbuffer_write(cibuf,buf,count,1);
+}
+
+static ssize_t ci_ll_read(struct dvb_ringbuffer *cibuf, struct file *file,
+			  char *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 0;
+	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(cibuf,buf,len,1);
+}
+
+static int dvb_ca_open(struct inode *inode, struct file *file)
+{
+	struct dvb_device *dvbdev=(struct dvb_device *) file->private_data;
+        struct av7110 *av7110=(struct av7110 *) dvbdev->priv;
+        int err=dvb_generic_open(inode, file);
+
+	DEB_EE(("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 = (struct dvb_device *) file->private_data;
+        struct av7110 *av7110 = (struct av7110 *) dvbdev->priv;
+        struct dvb_ringbuffer *rbuf = &av7110->ci_rbuffer;
+        struct dvb_ringbuffer *wbuf = &av7110->ci_wbuffer;
+        unsigned int mask = 0;
+
+	DEB_EE(("av7110: %p\n",av7110));
+
+        poll_wait (file, &rbuf->queue, wait);
+
+        if (!dvb_ringbuffer_empty(rbuf))
+                mask |= POLLIN;
+
+	if (dvb_ringbuffer_avail(wbuf)>1024)
+                mask |= POLLOUT;
+
+        return mask;
+}
+
+static int dvb_ca_ioctl(struct inode *inode, struct file *file,
+                 unsigned int cmd, void *parg)
+{
+	struct dvb_device *dvbdev=(struct dvb_device *) file->private_data;
+        struct av7110 *av7110=(struct av7110 *) dvbdev->priv;
+        unsigned long arg=(unsigned long) parg;
+
+	DEB_EE(("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;
+                outcom(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 *buf,
+             size_t count, loff_t *ppos)
+{
+	struct dvb_device *dvbdev=(struct dvb_device *) file->private_data;
+        struct av7110 *av7110=(struct av7110 *) dvbdev->priv;
+
+	DEB_EE(("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 *buf, size_t count, loff_t *ppos)
+{
+	struct dvb_device *dvbdev=(struct dvb_device *) file->private_data;
+        struct av7110 *av7110=(struct av7110 *) dvbdev->priv;
+
+	DEB_EE(("av7110: %p\n",av7110));
+        return ci_ll_read(&av7110->ci_rbuffer, file, buf, count, ppos);
+}
+
+
+
+/******************************************************************************
+ * driver registration
+ ******************************************************************************/
+
+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		= 0,
+	.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);
+}
+
+
+void av7110_ca_init(struct av7110* av7110)
+{
+        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);
+}