1/* 2 * 3 * some helper function for simple DVB cards which simply DMA the 4 * complete transport stream and let the computer sort everything else 5 * (i.e. we are using the software demux, ...). Also uses the 6 * video-buf to manage DMA buffers. 7 * 8 * (c) 2004 Gerd Knorr <kraxel@bytesex.org> [SUSE Labs] 9 * 10 * This program is free software; you can redistribute it and/or modify 11 * it under the terms of the GNU General Public License as published by 12 * the Free Software Foundation; either version 2 of the License, or 13 * (at your option) any later version. 14 */ 15 16 17#include <linux/module.h> 18#include <linux/init.h> 19#include <linux/device.h> 20#include <linux/fs.h> 21#include <linux/kthread.h> 22#include <linux/file.h> 23#include <linux/freezer.h> 24 25#include <media/video-buf.h> 26#include <media/video-buf-dvb.h> 27 28/* ------------------------------------------------------------------ */ 29 30MODULE_AUTHOR("Gerd Knorr <kraxel@bytesex.org> [SuSE Labs]"); 31MODULE_LICENSE("GPL"); 32 33static unsigned int debug = 0; 34module_param(debug, int, 0644); 35MODULE_PARM_DESC(debug,"enable debug messages"); 36 37#define dprintk(fmt, arg...) if (debug) \ 38 printk(KERN_DEBUG "%s/dvb: " fmt, dvb->name , ## arg) 39 40/* ------------------------------------------------------------------ */ 41 42static int videobuf_dvb_thread(void *data) 43{ 44 struct videobuf_dvb *dvb = data; 45 struct videobuf_buffer *buf; 46 unsigned long flags; 47 int err; 48 49 dprintk("dvb thread started\n"); 50 videobuf_read_start(&dvb->dvbq); 51 52 for (;;) { 53 /* fetch next buffer */ 54 buf = list_entry(dvb->dvbq.stream.next, 55 struct videobuf_buffer, stream); 56 list_del(&buf->stream); 57 err = videobuf_waiton(buf,0,1); 58 BUG_ON(0 != err); 59 60 /* no more feeds left or stop_feed() asked us to quit */ 61 if (0 == dvb->nfeeds) 62 break; 63 if (kthread_should_stop()) 64 break; 65 try_to_freeze(); 66 67 /* feed buffer data to demux */ 68 if (buf->state == STATE_DONE) 69 dvb_dmx_swfilter(&dvb->demux, buf->dma.vmalloc, 70 buf->size); 71 72 /* requeue buffer */ 73 list_add_tail(&buf->stream,&dvb->dvbq.stream); 74 spin_lock_irqsave(dvb->dvbq.irqlock,flags); 75 dvb->dvbq.ops->buf_queue(&dvb->dvbq,buf); 76 spin_unlock_irqrestore(dvb->dvbq.irqlock,flags); 77 } 78 79 videobuf_read_stop(&dvb->dvbq); 80 dprintk("dvb thread stopped\n"); 81 82 /* Hmm, linux becomes *very* unhappy without this ... */ 83 while (!kthread_should_stop()) { 84 set_current_state(TASK_INTERRUPTIBLE); 85 schedule(); 86 } 87 return 0; 88} 89 90static int videobuf_dvb_start_feed(struct dvb_demux_feed *feed) 91{ 92 struct dvb_demux *demux = feed->demux; 93 struct videobuf_dvb *dvb = demux->priv; 94 int rc; 95 96 if (!demux->dmx.frontend) 97 return -EINVAL; 98 99 mutex_lock(&dvb->lock); 100 dvb->nfeeds++; 101 rc = dvb->nfeeds; 102 103 if (NULL != dvb->thread) 104 goto out; 105 dvb->thread = kthread_run(videobuf_dvb_thread, 106 dvb, "%s dvb", dvb->name); 107 if (IS_ERR(dvb->thread)) { 108 rc = PTR_ERR(dvb->thread); 109 dvb->thread = NULL; 110 } 111 112out: 113 mutex_unlock(&dvb->lock); 114 return rc; 115} 116 117static int videobuf_dvb_stop_feed(struct dvb_demux_feed *feed) 118{ 119 struct dvb_demux *demux = feed->demux; 120 struct videobuf_dvb *dvb = demux->priv; 121 int err = 0; 122 123 mutex_lock(&dvb->lock); 124 dvb->nfeeds--; 125 if (0 == dvb->nfeeds && NULL != dvb->thread) { 126 err = kthread_stop(dvb->thread); 127 dvb->thread = NULL; 128 } 129 mutex_unlock(&dvb->lock); 130 return err; 131} 132 133/* ------------------------------------------------------------------ */ 134 135int videobuf_dvb_register(struct videobuf_dvb *dvb, 136 struct module *module, 137 void *adapter_priv, 138 struct device *device) 139{ 140 int result; 141 142 mutex_init(&dvb->lock); 143 144 /* register adapter */ 145 result = dvb_register_adapter(&dvb->adapter, dvb->name, module, device); 146 if (result < 0) { 147 printk(KERN_WARNING "%s: dvb_register_adapter failed (errno = %d)\n", 148 dvb->name, result); 149 goto fail_adapter; 150 } 151 dvb->adapter.priv = adapter_priv; 152 153 /* register frontend */ 154 result = dvb_register_frontend(&dvb->adapter, dvb->frontend); 155 if (result < 0) { 156 printk(KERN_WARNING "%s: dvb_register_frontend failed (errno = %d)\n", 157 dvb->name, result); 158 goto fail_frontend; 159 } 160 161 /* register demux stuff */ 162 dvb->demux.dmx.capabilities = 163 DMX_TS_FILTERING | DMX_SECTION_FILTERING | 164 DMX_MEMORY_BASED_FILTERING; 165 dvb->demux.priv = dvb; 166 dvb->demux.filternum = 256; 167 dvb->demux.feednum = 256; 168 dvb->demux.start_feed = videobuf_dvb_start_feed; 169 dvb->demux.stop_feed = videobuf_dvb_stop_feed; 170 result = dvb_dmx_init(&dvb->demux); 171 if (result < 0) { 172 printk(KERN_WARNING "%s: dvb_dmx_init failed (errno = %d)\n", 173 dvb->name, result); 174 goto fail_dmx; 175 } 176 177 dvb->dmxdev.filternum = 256; 178 dvb->dmxdev.demux = &dvb->demux.dmx; 179 dvb->dmxdev.capabilities = 0; 180 result = dvb_dmxdev_init(&dvb->dmxdev, &dvb->adapter); 181 if (result < 0) { 182 printk(KERN_WARNING "%s: dvb_dmxdev_init failed (errno = %d)\n", 183 dvb->name, result); 184 goto fail_dmxdev; 185 } 186 187 dvb->fe_hw.source = DMX_FRONTEND_0; 188 result = dvb->demux.dmx.add_frontend(&dvb->demux.dmx, &dvb->fe_hw); 189 if (result < 0) { 190 printk(KERN_WARNING "%s: add_frontend failed (DMX_FRONTEND_0, errno = %d)\n", 191 dvb->name, result); 192 goto fail_fe_hw; 193 } 194 195 dvb->fe_mem.source = DMX_MEMORY_FE; 196 result = dvb->demux.dmx.add_frontend(&dvb->demux.dmx, &dvb->fe_mem); 197 if (result < 0) { 198 printk(KERN_WARNING "%s: add_frontend failed (DMX_MEMORY_FE, errno = %d)\n", 199 dvb->name, result); 200 goto fail_fe_mem; 201 } 202 203 result = dvb->demux.dmx.connect_frontend(&dvb->demux.dmx, &dvb->fe_hw); 204 if (result < 0) { 205 printk(KERN_WARNING "%s: connect_frontend failed (errno = %d)\n", 206 dvb->name, result); 207 goto fail_fe_conn; 208 } 209 210 /* register network adapter */ 211 dvb_net_init(&dvb->adapter, &dvb->net, &dvb->demux.dmx); 212 return 0; 213 214fail_fe_conn: 215 dvb->demux.dmx.remove_frontend(&dvb->demux.dmx, &dvb->fe_mem); 216fail_fe_mem: 217 dvb->demux.dmx.remove_frontend(&dvb->demux.dmx, &dvb->fe_hw); 218fail_fe_hw: 219 dvb_dmxdev_release(&dvb->dmxdev); 220fail_dmxdev: 221 dvb_dmx_release(&dvb->demux); 222fail_dmx: 223 dvb_unregister_frontend(dvb->frontend); 224fail_frontend: 225 dvb_frontend_detach(dvb->frontend); 226 dvb_unregister_adapter(&dvb->adapter); 227fail_adapter: 228 return result; 229} 230 231void videobuf_dvb_unregister(struct videobuf_dvb *dvb) 232{ 233 dvb_net_release(&dvb->net); 234 dvb->demux.dmx.remove_frontend(&dvb->demux.dmx, &dvb->fe_mem); 235 dvb->demux.dmx.remove_frontend(&dvb->demux.dmx, &dvb->fe_hw); 236 dvb_dmxdev_release(&dvb->dmxdev); 237 dvb_dmx_release(&dvb->demux); 238 dvb_unregister_frontend(dvb->frontend); 239 dvb_frontend_detach(dvb->frontend); 240 dvb_unregister_adapter(&dvb->adapter); 241} 242 243EXPORT_SYMBOL(videobuf_dvb_register); 244EXPORT_SYMBOL(videobuf_dvb_unregister); 245 246/* ------------------------------------------------------------------ */ 247/* 248 * Local variables: 249 * c-basic-offset: 8 250 * compile-command: "make DVB=1" 251 * End: 252 */ 253