cregit-Linux how code gets into the kernel

Release 4.11 drivers/media/usb/au0828/au0828-dvb.c

/*
 *  Driver for the Auvitek USB bridge
 *
 *  Copyright (c) 2008 Steven Toth <stoth@linuxtv.org>
 *
 *  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.
 */

#include "au0828.h"

#include <linux/module.h>
#include <linux/slab.h>
#include <linux/init.h>
#include <linux/device.h>
#include <media/v4l2-common.h>
#include <media/tuner.h>

#include "au8522.h"
#include "xc5000.h"
#include "mxl5007t.h"
#include "tda18271.h"


static int preallocate_big_buffers;
module_param_named(preallocate_big_buffers, preallocate_big_buffers, int, 0644);
MODULE_PARM_DESC(preallocate_big_buffers, "Preallocate the larger transfer buffers at module load time");


DVB_DEFINE_MOD_OPT_ADAPTER_NR(adapter_nr);


#define _AU0828_BULKPIPE 0x83

#define _BULKPIPESIZE 0xe522


static u8 hauppauge_hvr950q_led_states[] = {
	0x00, /* off */
	0x02, /* yellow */
	0x04, /* green */
};


static struct au8522_led_config hauppauge_hvr950q_led_cfg = {
	.gpio_output = 0x00e0,
	.gpio_output_enable  = 0x6006,
	.gpio_output_disable = 0x0660,

	.gpio_leds = 0x00e2,
	.led_states  = hauppauge_hvr950q_led_states,
	.num_led_states = sizeof(hauppauge_hvr950q_led_states),

	.vsb8_strong   = 20 /* dB */ * 10,
	.qam64_strong  = 25 /* dB */ * 10,
	.qam256_strong = 32 /* dB */ * 10,
};


static struct au8522_config hauppauge_hvr950q_config = {
	.demod_address = 0x8e >> 1,
	.status_mode   = AU8522_DEMODLOCKING,
	.qam_if        = AU8522_IF_6MHZ,
	.vsb_if        = AU8522_IF_6MHZ,
	.led_cfg       = &hauppauge_hvr950q_led_cfg,
};


static struct au8522_config fusionhdtv7usb_config = {
	.demod_address = 0x8e >> 1,
	.status_mode   = AU8522_DEMODLOCKING,
	.qam_if        = AU8522_IF_6MHZ,
	.vsb_if        = AU8522_IF_6MHZ,
};


static struct au8522_config hauppauge_woodbury_config = {
	.demod_address = 0x8e >> 1,
	.status_mode   = AU8522_DEMODLOCKING,
	.qam_if        = AU8522_IF_4MHZ,
	.vsb_if        = AU8522_IF_3_25MHZ,
};


static struct xc5000_config hauppauge_xc5000a_config = {
	.i2c_address      = 0x61,
	.if_khz           = 6000,
	.chip_id          = XC5000A,
	.output_amp       = 0x8f,
};


static struct xc5000_config hauppauge_xc5000c_config = {
	.i2c_address      = 0x61,
	.if_khz           = 6000,
	.chip_id          = XC5000C,
	.output_amp       = 0x8f,
};


static struct mxl5007t_config mxl5007t_hvr950q_config = {
	.xtal_freq_hz = MxL_XTAL_24_MHZ,
	.if_freq_hz = MxL_IF_6_MHZ,
};


static struct tda18271_config hauppauge_woodbury_tunerconfig = {
	.gate    = TDA18271_GATE_DIGITAL,
};

static void au0828_restart_dvb_streaming(struct work_struct *work);

/*-------------------------------------------------------------------*/

static void urb_completion(struct urb *purb) { struct au0828_dev *dev = purb->context; int ptype = usb_pipetype(purb->pipe); unsigned char *ptr; dprintk(2, "%s: %d\n", __func__, purb->actual_length); if (!dev) { dprintk(2, "%s: no dev!\n", __func__); return; } if (!dev->urb_streaming) { dprintk(2, "%s: not streaming!\n", __func__); return; } if (ptype != PIPE_BULK) { pr_err("%s: Unsupported URB type %d\n", __func__, ptype); return; } /* See if the stream is corrupted (to work around a hardware bug where the stream gets misaligned */ ptr = purb->transfer_buffer; if (purb->actual_length > 0 && ptr[0] != 0x47) { dprintk(1, "Need to restart streaming %02x len=%d!\n", ptr[0], purb->actual_length); schedule_work(&dev->restart_streaming); return; } /* Feed the transport payload into the kernel demux */ dvb_dmx_swfilter_packets(&dev->dvb.demux, purb->transfer_buffer, purb->actual_length / 188); /* Clean the buffer before we requeue */ memset(purb->transfer_buffer, 0, URB_BUFSIZE); /* Requeue URB */ usb_submit_urb(purb, GFP_ATOMIC); }

Contributors

PersonTokensPropCommitsCommitProp
Steven Toth10655.21%337.50%
Devin Heitmueller5428.12%112.50%
Mauro Carvalho Chehab3015.62%337.50%
Michael Ira Krufky21.04%112.50%
Total192100.00%8100.00%


static int stop_urb_transfer(struct au0828_dev *dev) { int i; dprintk(2, "%s()\n", __func__); if (!dev->urb_streaming) return 0; dev->urb_streaming = false; for (i = 0; i < URB_COUNT; i++) { if (dev->urbs[i]) { usb_kill_urb(dev->urbs[i]); if (!preallocate_big_buffers) kfree(dev->urbs[i]->transfer_buffer); usb_free_urb(dev->urbs[i]); } } return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Steven Toth7268.57%228.57%
Tim Mester1615.24%228.57%
Mauro Carvalho Chehab1110.48%114.29%
Devin Heitmueller54.76%114.29%
Michael Ira Krufky10.95%114.29%
Total105100.00%7100.00%


static int start_urb_transfer(struct au0828_dev *dev) { struct urb *purb; int i, ret; dprintk(2, "%s()\n", __func__); if (dev->urb_streaming) { dprintk(2, "%s: bulk xfer already running!\n", __func__); return 0; } for (i = 0; i < URB_COUNT; i++) { dev->urbs[i] = usb_alloc_urb(0, GFP_KERNEL); if (!dev->urbs[i]) return -ENOMEM; purb = dev->urbs[i]; if (preallocate_big_buffers) purb->transfer_buffer = dev->dig_transfer_buffer[i]; else purb->transfer_buffer = kzalloc(URB_BUFSIZE, GFP_KERNEL); if (!purb->transfer_buffer) { usb_free_urb(purb); dev->urbs[i] = NULL; ret = -ENOMEM; pr_err("%s: failed big buffer allocation, err = %d\n", __func__, ret); return ret; } purb->status = -EINPROGRESS; usb_fill_bulk_urb(purb, dev->usbdev, usb_rcvbulkpipe(dev->usbdev, _AU0828_BULKPIPE), purb->transfer_buffer, URB_BUFSIZE, urb_completion, dev); } for (i = 0; i < URB_COUNT; i++) { ret = usb_submit_urb(dev->urbs[i], GFP_ATOMIC); if (ret != 0) { stop_urb_transfer(dev); pr_err("%s: failed urb submission, err = %d\n", __func__, ret); return ret; } } dev->urb_streaming = true; return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Steven Toth22182.77%220.00%
Tim Mester248.99%220.00%
SF Markus Elfring134.87%110.00%
Michael Ira Krufky41.50%220.00%
Mauro Carvalho Chehab41.50%220.00%
Harvey Harrison10.37%110.00%
Total267100.00%10100.00%


static void au0828_start_transport(struct au0828_dev *dev) { au0828_write(dev, 0x608, 0x90); au0828_write(dev, 0x609, 0x72); au0828_write(dev, 0x60a, 0x71); au0828_write(dev, 0x60b, 0x01); }

Contributors

PersonTokensPropCommitsCommitProp
Tim Mester47100.00%1100.00%
Total47100.00%1100.00%


static void au0828_stop_transport(struct au0828_dev *dev, int full_stop) { if (full_stop) { au0828_write(dev, 0x608, 0x00); au0828_write(dev, 0x609, 0x00); au0828_write(dev, 0x60a, 0x00); } au0828_write(dev, 0x60b, 0x00); }

Contributors

PersonTokensPropCommitsCommitProp
Tim Mester56100.00%1100.00%
Total56100.00%1100.00%


static int au0828_dvb_start_feed(struct dvb_demux_feed *feed) { struct dvb_demux *demux = feed->demux; struct au0828_dev *dev = (struct au0828_dev *) demux->priv; struct au0828_dvb *dvb = &dev->dvb; int ret = 0; dprintk(1, "%s()\n", __func__); if (!demux->dmx.frontend) return -EINVAL; if (dvb->frontend) { mutex_lock(&dvb->lock); dvb->start_count++; dprintk(1, "%s(), start_count: %d, stop_count: %d\n", __func__, dvb->start_count, dvb->stop_count); if (dvb->feeding++ == 0) { /* Start transport */ au0828_start_transport(dev); ret = start_urb_transfer(dev); if (ret < 0) { au0828_stop_transport(dev, 0); dvb->feeding--; /* We ran out of memory... */ } } mutex_unlock(&dvb->lock); } return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Steven Toth12173.33%240.00%
Tim Mester4124.85%120.00%
Mauro Carvalho Chehab21.21%120.00%
Michael Ira Krufky10.61%120.00%
Total165100.00%5100.00%


static int au0828_dvb_stop_feed(struct dvb_demux_feed *feed) { struct dvb_demux *demux = feed->demux; struct au0828_dev *dev = (struct au0828_dev *) demux->priv; struct au0828_dvb *dvb = &dev->dvb; int ret = 0; dprintk(1, "%s()\n", __func__); if (dvb->frontend) { cancel_work_sync(&dev->restart_streaming); mutex_lock(&dvb->lock); dvb->stop_count++; dprintk(1, "%s(), start_count: %d, stop_count: %d\n", __func__, dvb->start_count, dvb->stop_count); if (dvb->feeding > 0) { dvb->feeding--; if (dvb->feeding == 0) { /* Stop transport */ ret = stop_urb_transfer(dev); au0828_stop_transport(dev, 0); } } mutex_unlock(&dvb->lock); } return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Steven Toth8051.61%228.57%
Tim Mester3824.52%114.29%
Devin Heitmueller2616.77%114.29%
Mauro Carvalho Chehab106.45%228.57%
Michael Ira Krufky10.65%114.29%
Total155100.00%7100.00%


static void au0828_restart_dvb_streaming(struct work_struct *work) { struct au0828_dev *dev = container_of(work, struct au0828_dev, restart_streaming); struct au0828_dvb *dvb = &dev->dvb; if (!dev->urb_streaming) return; dprintk(1, "Restarting streaming...!\n"); mutex_lock(&dvb->lock); /* Stop transport */ stop_urb_transfer(dev); au0828_stop_transport(dev, 1); /* Start transport */ au0828_start_transport(dev); start_urb_transfer(dev); mutex_unlock(&dvb->lock); }

Contributors

PersonTokensPropCommitsCommitProp
Devin Heitmueller6975.82%125.00%
Steven Toth1819.78%125.00%
Tim Mester33.30%125.00%
Mauro Carvalho Chehab11.10%125.00%
Total91100.00%4100.00%


static int au0828_set_frontend(struct dvb_frontend *fe) { struct au0828_dev *dev = fe->dvb->priv; struct au0828_dvb *dvb = &dev->dvb; int ret, was_streaming; mutex_lock(&dvb->lock); was_streaming = dev->urb_streaming; if (was_streaming) { au0828_stop_transport(dev, 1); /* * We can't hold a mutex here, as the restart_streaming * kthread may also hold it. */ mutex_unlock(&dvb->lock); cancel_work_sync(&dev->restart_streaming); mutex_lock(&dvb->lock); stop_urb_transfer(dev); } mutex_unlock(&dvb->lock); ret = dvb->set_frontend(fe); if (was_streaming) { mutex_lock(&dvb->lock); au0828_start_transport(dev); start_urb_transfer(dev); mutex_unlock(&dvb->lock); } return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Mauro Carvalho Chehab146100.00%1100.00%
Total146100.00%1100.00%


static int dvb_register(struct au0828_dev *dev) { struct au0828_dvb *dvb = &dev->dvb; int result; dprintk(1, "%s()\n", __func__); if (preallocate_big_buffers) { int i; for (i = 0; i < URB_COUNT; i++) { dev->dig_transfer_buffer[i] = kzalloc(URB_BUFSIZE, GFP_KERNEL); if (!dev->dig_transfer_buffer[i]) { result = -ENOMEM; pr_err("failed buffer allocation (errno = %d)\n", result); goto fail_adapter; } } } INIT_WORK(&dev->restart_streaming, au0828_restart_dvb_streaming); /* register adapter */ result = dvb_register_adapter(&dvb->adapter, KBUILD_MODNAME, THIS_MODULE, &dev->usbdev->dev, adapter_nr); if (result < 0) { pr_err("dvb_register_adapter failed (errno = %d)\n", result); goto fail_adapter; } #ifdef CONFIG_MEDIA_CONTROLLER_DVB dvb->adapter.mdev = dev->media_dev; #endif dvb->adapter.priv = dev; /* register frontend */ result = dvb_register_frontend(&dvb->adapter, dvb->frontend); if (result < 0) { pr_err("dvb_register_frontend failed (errno = %d)\n", result); goto fail_frontend; } /* Hook dvb frontend */ dvb->set_frontend = dvb->frontend->ops.set_frontend; dvb->frontend->ops.set_frontend = au0828_set_frontend; /* register demux stuff */ dvb->demux.dmx.capabilities = DMX_TS_FILTERING | DMX_SECTION_FILTERING | DMX_MEMORY_BASED_FILTERING; dvb->demux.priv = dev; dvb->demux.filternum = 256; dvb->demux.feednum = 256; dvb->demux.start_feed = au0828_dvb_start_feed; dvb->demux.stop_feed = au0828_dvb_stop_feed; result = dvb_dmx_init(&dvb->demux); if (result < 0) { pr_err("dvb_dmx_init failed (errno = %d)\n", result); goto fail_dmx; } dvb->dmxdev.filternum = 256; dvb->dmxdev.demux = &dvb->demux.dmx; dvb->dmxdev.capabilities = 0; result = dvb_dmxdev_init(&dvb->dmxdev, &dvb->adapter); if (result < 0) { pr_err("dvb_dmxdev_init failed (errno = %d)\n", result); goto fail_dmxdev; } dvb->fe_hw.source = DMX_FRONTEND_0; result = dvb->demux.dmx.add_frontend(&dvb->demux.dmx, &dvb->fe_hw); if (result < 0) { pr_err("add_frontend failed (DMX_FRONTEND_0, errno = %d)\n", result); goto fail_fe_hw; } dvb->fe_mem.source = DMX_MEMORY_FE; result = dvb->demux.dmx.add_frontend(&dvb->demux.dmx, &dvb->fe_mem); if (result < 0) { pr_err("add_frontend failed (DMX_MEMORY_FE, errno = %d)\n", result); goto fail_fe_mem; } result = dvb->demux.dmx.connect_frontend(&dvb->demux.dmx, &dvb->fe_hw); if (result < 0) { pr_err("connect_frontend failed (errno = %d)\n", result); goto fail_fe_conn; } /* register network adapter */ dvb_net_init(&dvb->adapter, &dvb->net, &dvb->demux.dmx); dvb->start_count = 0; dvb->stop_count = 0; result = dvb_create_media_graph(&dvb->adapter, false); if (result < 0) goto fail_create_graph; return 0; fail_create_graph: dvb_net_release(&dvb->net); fail_fe_conn: dvb->demux.dmx.remove_frontend(&dvb->demux.dmx, &dvb->fe_mem); fail_fe_mem: dvb->demux.dmx.remove_frontend(&dvb->demux.dmx, &dvb->fe_hw); fail_fe_hw: dvb_dmxdev_release(&dvb->dmxdev); fail_dmxdev: dvb_dmx_release(&dvb->demux); fail_dmx: dvb_unregister_frontend(dvb->frontend); fail_frontend: dvb_frontend_detach(dvb->frontend); dvb_unregister_adapter(&dvb->adapter); fail_adapter: if (preallocate_big_buffers) { int i; for (i = 0; i < URB_COUNT; i++) kfree(dev->dig_transfer_buffer[i]); } return result; }

Contributors

PersonTokensPropCommitsCommitProp
Steven Toth50471.09%216.67%
Tim Mester10715.09%216.67%
Mauro Carvalho Chehab638.89%433.33%
Rafael Lourenço de Lima Chehab233.24%18.33%
Devin Heitmueller101.41%18.33%
Adrian Bunk10.14%18.33%
Michael Ira Krufky10.14%18.33%
Total709100.00%12100.00%


void au0828_dvb_unregister(struct au0828_dev *dev) { struct au0828_dvb *dvb = &dev->dvb; dprintk(1, "%s()\n", __func__); if (dvb->frontend == NULL) return; cancel_work_sync(&dev->restart_streaming); dvb_net_release(&dvb->net); dvb->demux.dmx.remove_frontend(&dvb->demux.dmx, &dvb->fe_mem); dvb->demux.dmx.remove_frontend(&dvb->demux.dmx, &dvb->fe_hw); dvb_dmxdev_release(&dvb->dmxdev); dvb_dmx_release(&dvb->demux); dvb_unregister_frontend(dvb->frontend); dvb_frontend_detach(dvb->frontend); dvb_unregister_adapter(&dvb->adapter); if (preallocate_big_buffers) { int i; for (i = 0; i < URB_COUNT; i++) kfree(dev->dig_transfer_buffer[i]); } dvb->frontend = NULL; }

Contributors

PersonTokensPropCommitsCommitProp
Steven Toth12572.67%342.86%
Tim Mester3218.60%114.29%
Changbing Xiong84.65%114.29%
Mauro Carvalho Chehab63.49%114.29%
Michael Ira Krufky10.58%114.29%
Total172100.00%7100.00%

/* All the DVB attach calls go here, this function get's modified * for each new card. No other function in this file needs * to change. */
int au0828_dvb_register(struct au0828_dev *dev) { struct au0828_dvb *dvb = &dev->dvb; int ret; dprintk(1, "%s()\n", __func__); /* init frontend */ switch (dev->boardnr) { case AU0828_BOARD_HAUPPAUGE_HVR850: case AU0828_BOARD_HAUPPAUGE_HVR950Q: dvb->frontend = dvb_attach(au8522_attach, &hauppauge_hvr950q_config, &dev->i2c_adap); if (dvb->frontend != NULL) switch (dev->board.tuner_type) { default: case TUNER_XC5000: dvb_attach(xc5000_attach, dvb->frontend, &dev->i2c_adap, &hauppauge_xc5000a_config); break; case TUNER_XC5000C: dvb_attach(xc5000_attach, dvb->frontend, &dev->i2c_adap, &hauppauge_xc5000c_config); break; } break; case AU0828_BOARD_HAUPPAUGE_HVR950Q_MXL: dvb->frontend = dvb_attach(au8522_attach, &hauppauge_hvr950q_config, &dev->i2c_adap); if (dvb->frontend != NULL) dvb_attach(mxl5007t_attach, dvb->frontend, &dev->i2c_adap, 0x60, &mxl5007t_hvr950q_config); break; case AU0828_BOARD_HAUPPAUGE_WOODBURY: dvb->frontend = dvb_attach(au8522_attach, &hauppauge_woodbury_config, &dev->i2c_adap); if (dvb->frontend != NULL) dvb_attach(tda18271_attach, dvb->frontend, 0x60, &dev->i2c_adap, &hauppauge_woodbury_tunerconfig); break; case AU0828_BOARD_DVICO_FUSIONHDTV7: dvb->frontend = dvb_attach(au8522_attach, &fusionhdtv7usb_config, &dev->i2c_adap); if (dvb->frontend != NULL) { dvb_attach(xc5000_attach, dvb->frontend, &dev->i2c_adap, &hauppauge_xc5000a_config); } break; default: pr_warn("The frontend of your DVB/ATSC card isn't supported yet\n"); break; } if (NULL == dvb->frontend) { pr_err("%s() Frontend initialization failed\n", __func__); return -1; } /* define general-purpose callback pointer */ dvb->frontend->callback = au0828_tuner_callback; /* register everything */ ret = dvb_register(dev); if (ret < 0) { if (dvb->frontend->ops.release) dvb->frontend->ops.release(dvb->frontend); dvb->frontend = NULL; return ret; } return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Michael Ira Krufky19253.63%654.55%
Steven Toth15643.58%218.18%
Mauro Carvalho Chehab92.51%218.18%
Devin Heitmueller10.28%19.09%
Total358100.00%11100.00%


void au0828_dvb_suspend(struct au0828_dev *dev) { struct au0828_dvb *dvb = &dev->dvb; int rc; if (dvb->frontend) { if (dev->urb_streaming) { cancel_work_sync(&dev->restart_streaming); /* Stop transport */ mutex_lock(&dvb->lock); stop_urb_transfer(dev); au0828_stop_transport(dev, 1); mutex_unlock(&dvb->lock); dev->need_urb_start = true; } /* suspend frontend - does tuner and fe to sleep */ rc = dvb_frontend_suspend(dvb->frontend); pr_info("au0828_dvb_suspend(): Suspending DVB fe %d\n", rc); } }

Contributors

PersonTokensPropCommitsCommitProp
Mauro Carvalho Chehab7474.75%480.00%
Shuah Khan2525.25%120.00%
Total99100.00%5100.00%


void au0828_dvb_resume(struct au0828_dev *dev) { struct au0828_dvb *dvb = &dev->dvb; int rc; if (dvb->frontend) { /* resume frontend - does fe and tuner init */ rc = dvb_frontend_resume(dvb->frontend); pr_info("au0828_dvb_resume(): Resuming DVB fe %d\n", rc); if (dev->need_urb_start) { /* Start transport */ mutex_lock(&dvb->lock); au0828_start_transport(dev); start_urb_transfer(dev); mutex_unlock(&dvb->lock); } } }

Contributors

PersonTokensPropCommitsCommitProp
Mauro Carvalho Chehab6173.49%266.67%
Shuah Khan2226.51%133.33%
Total83100.00%3100.00%


Overall Contributors

PersonTokensPropCommitsCommitProp
Steven Toth147049.28%411.43%
Michael Ira Krufky42514.25%822.86%
Mauro Carvalho Chehab42014.08%925.71%
Tim Mester38512.91%25.71%
Devin Heitmueller1755.87%25.71%
Shuah Khan471.58%12.86%
Rafael Lourenço de Lima Chehab230.77%12.86%
SF Markus Elfring130.44%12.86%
Richard Vollkommer100.34%12.86%
Changbing Xiong80.27%12.86%
Tejun Heo30.10%12.86%
Wei Yongjun10.03%12.86%
Adrian Bunk10.03%12.86%
Sakari Ailus10.03%12.86%
Harvey Harrison10.03%12.86%
Total2983100.00%35100.00%
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.