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.
8 * (c) 2004 Gerd Knorr <kraxel@bytesex.org> [SUSE Labs]
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.
16 #include <linux/module.h>
17 #include <linux/init.h>
18 #include <linux/device.h>
20 #include <linux/kthread.h>
21 #include <linux/file.h>
23 #include <linux/freezer.h>
25 #include <media/videobuf-core.h>
26 #include <media/videobuf-dvb.h>
28 /* ------------------------------------------------------------------ */
30 MODULE_AUTHOR("Gerd Knorr <kraxel@bytesex.org> [SuSE Labs]");
31 MODULE_LICENSE("GPL");
33 static unsigned int debug
;
34 module_param(debug
, int, 0644);
35 MODULE_PARM_DESC(debug
,"enable debug messages");
37 #define dprintk(fmt, arg...) if (debug) \
38 printk(KERN_DEBUG "%s/dvb: " fmt, dvb->name , ## arg)
40 /* ------------------------------------------------------------------ */
42 static int videobuf_dvb_thread(void *data
)
44 struct videobuf_dvb
*dvb
= data
;
45 struct videobuf_buffer
*buf
;
50 dprintk("dvb thread started\n");
52 videobuf_read_start(&dvb
->dvbq
);
55 /* fetch next buffer */
56 buf
= list_entry(dvb
->dvbq
.stream
.next
,
57 struct videobuf_buffer
, stream
);
58 list_del(&buf
->stream
);
59 err
= videobuf_waiton(buf
,0,1);
61 /* no more feeds left or stop_feed() asked us to quit */
64 if (kthread_should_stop())
68 /* feed buffer data to demux */
69 outp
= videobuf_queue_to_vmalloc (&dvb
->dvbq
, buf
);
71 if (buf
->state
== VIDEOBUF_DONE
)
72 dvb_dmx_swfilter(&dvb
->demux
, outp
,
76 list_add_tail(&buf
->stream
,&dvb
->dvbq
.stream
);
77 spin_lock_irqsave(dvb
->dvbq
.irqlock
,flags
);
78 dvb
->dvbq
.ops
->buf_queue(&dvb
->dvbq
,buf
);
79 spin_unlock_irqrestore(dvb
->dvbq
.irqlock
,flags
);
82 videobuf_read_stop(&dvb
->dvbq
);
83 dprintk("dvb thread stopped\n");
85 /* Hmm, linux becomes *very* unhappy without this ... */
86 while (!kthread_should_stop()) {
87 set_current_state(TASK_INTERRUPTIBLE
);
93 static int videobuf_dvb_start_feed(struct dvb_demux_feed
*feed
)
95 struct dvb_demux
*demux
= feed
->demux
;
96 struct videobuf_dvb
*dvb
= demux
->priv
;
99 if (!demux
->dmx
.frontend
)
102 mutex_lock(&dvb
->lock
);
106 if (NULL
!= dvb
->thread
)
108 dvb
->thread
= kthread_run(videobuf_dvb_thread
,
109 dvb
, "%s dvb", dvb
->name
);
110 if (IS_ERR(dvb
->thread
)) {
111 rc
= PTR_ERR(dvb
->thread
);
116 mutex_unlock(&dvb
->lock
);
120 static int videobuf_dvb_stop_feed(struct dvb_demux_feed
*feed
)
122 struct dvb_demux
*demux
= feed
->demux
;
123 struct videobuf_dvb
*dvb
= demux
->priv
;
126 mutex_lock(&dvb
->lock
);
128 if (0 == dvb
->nfeeds
&& NULL
!= dvb
->thread
) {
129 // FIXME: cx8802_cancel_buffers(dev);
130 err
= kthread_stop(dvb
->thread
);
133 mutex_unlock(&dvb
->lock
);
137 /* ------------------------------------------------------------------ */
138 /* Register a single adapter and one or more frontends */
139 int videobuf_dvb_register_bus(struct videobuf_dvb_frontends
*f
,
140 struct module
*module
,
142 struct device
*device
,
143 short *adapter_nr
) //NEW
145 struct list_head
*list
, *q
;
146 struct videobuf_dvb_frontend
*fe
;
149 fe
= videobuf_dvb_get_frontend(f
, 1);
151 printk(KERN_WARNING
"Unable to register the adapter which has no frontends\n");
155 /* Bring up the adapter */
156 res
= videobuf_dvb_register_adapter(f
, module
, adapter_priv
, device
, fe
->dvb
.name
, adapter_nr
); //NEW
158 printk(KERN_WARNING
"videobuf_dvb_register_adapter failed (errno = %d)\n", res
);
162 /* Attach all of the frontends to the adapter */
163 mutex_lock(&f
->lock
);
164 list_for_each_safe(list
, q
, &f
->frontend
.felist
) {
165 fe
= list_entry(list
, struct videobuf_dvb_frontend
, felist
);
167 res
= videobuf_dvb_register_frontend(&f
->adapter
, &fe
->dvb
);
169 printk(KERN_WARNING
"%s: videobuf_dvb_register_frontend failed (errno = %d)\n",
173 mutex_unlock(&f
->lock
);
179 int videobuf_dvb_register_adapter(struct videobuf_dvb_frontends
*fe
,
180 struct module
*module
,
182 struct device
*device
,
184 short *adapter_nr
) //NEW
188 mutex_init(&fe
->lock
);
190 /* register adapter */
191 result
= dvb_register_adapter(&fe
->adapter
, adapter_name
, module
, device
, adapter_nr
);
193 printk(KERN_WARNING
"%s: dvb_register_adapter failed (errno = %d)\n",
194 adapter_name
, result
);
196 fe
->adapter
.priv
= adapter_priv
;
201 int videobuf_dvb_register_frontend(struct dvb_adapter
*adapter
, struct videobuf_dvb
*dvb
)
205 /* register frontend */
206 result
= dvb_register_frontend(adapter
, dvb
->frontend
);
208 printk(KERN_WARNING
"%s: dvb_register_frontend failed (errno = %d)\n",
213 /* register demux stuff */
214 dvb
->demux
.dmx
.capabilities
=
215 DMX_TS_FILTERING
| DMX_SECTION_FILTERING
|
216 DMX_MEMORY_BASED_FILTERING
;
217 dvb
->demux
.priv
= dvb
;
218 dvb
->demux
.filternum
= 256;
219 dvb
->demux
.feednum
= 256;
220 dvb
->demux
.start_feed
= videobuf_dvb_start_feed
;
221 dvb
->demux
.stop_feed
= videobuf_dvb_stop_feed
;
222 result
= dvb_dmx_init(&dvb
->demux
);
224 printk(KERN_WARNING
"%s: dvb_dmx_init failed (errno = %d)\n",
229 dvb
->dmxdev
.filternum
= 256;
230 dvb
->dmxdev
.demux
= &dvb
->demux
.dmx
;
231 dvb
->dmxdev
.capabilities
= 0;
232 //result = dvb_dmxdev_init(&dvb->dmxdev, &dvb->adapter);
233 result
= dvb_dmxdev_init(&dvb
->dmxdev
, adapter
);
236 printk(KERN_WARNING
"%s: dvb_dmxdev_init failed (errno = %d)\n",
241 dvb
->fe_hw
.source
= DMX_FRONTEND_0
;
242 result
= dvb
->demux
.dmx
.add_frontend(&dvb
->demux
.dmx
, &dvb
->fe_hw
);
244 printk(KERN_WARNING
"%s: add_frontend failed (DMX_FRONTEND_0, errno = %d)\n",
249 dvb
->fe_mem
.source
= DMX_MEMORY_FE
;
250 result
= dvb
->demux
.dmx
.add_frontend(&dvb
->demux
.dmx
, &dvb
->fe_mem
);
252 printk(KERN_WARNING
"%s: add_frontend failed (DMX_MEMORY_FE, errno = %d)\n",
257 result
= dvb
->demux
.dmx
.connect_frontend(&dvb
->demux
.dmx
, &dvb
->fe_hw
);
259 printk(KERN_WARNING
"%s: connect_frontend failed (errno = %d)\n",
264 /* register network adapter */
265 dvb_net_init(adapter
, &dvb
->net
, &dvb
->demux
.dmx
);
269 dvb
->demux
.dmx
.remove_frontend(&dvb
->demux
.dmx
, &dvb
->fe_mem
);
271 dvb
->demux
.dmx
.remove_frontend(&dvb
->demux
.dmx
, &dvb
->fe_hw
);
273 dvb_dmxdev_release(&dvb
->dmxdev
);
275 dvb_dmx_release(&dvb
->demux
);
277 dvb_unregister_frontend(dvb
->frontend
);
279 dvb_frontend_detach(dvb
->frontend
);
280 dvb_unregister_adapter(&dvb
->adapter
);
285 void videobuf_dvb_unregister_bus(struct videobuf_dvb_frontends
*f
)
287 struct list_head
*list
, *q
;
288 struct videobuf_dvb_frontend
*fe
;
290 mutex_lock(&f
->lock
);
291 list_for_each_safe(list
, q
, &f
->frontend
.felist
) {
292 fe
= list_entry(list
, struct videobuf_dvb_frontend
, felist
);
294 dvb_net_release(&fe
->dvb
.net
);
295 fe
->dvb
.demux
.dmx
.remove_frontend(&fe
->dvb
.demux
.dmx
, &fe
->dvb
.fe_mem
);
296 fe
->dvb
.demux
.dmx
.remove_frontend(&fe
->dvb
.demux
.dmx
, &fe
->dvb
.fe_hw
);
297 dvb_dmxdev_release(&fe
->dvb
.dmxdev
);
298 dvb_dmx_release(&fe
->dvb
.demux
);
299 dvb_unregister_frontend(fe
->dvb
.frontend
);
300 dvb_frontend_detach(fe
->dvb
.frontend
);
305 mutex_unlock(&f
->lock
);
307 dvb_unregister_adapter(&f
->adapter
);
310 struct videobuf_dvb_frontend
* videobuf_dvb_get_frontend(struct videobuf_dvb_frontends
*f
, int id
)
312 struct list_head
*list
, *q
;
313 struct videobuf_dvb_frontend
*fe
, *ret
= NULL
;
315 mutex_lock(&f
->lock
);
317 list_for_each_safe(list
, q
, &f
->frontend
.felist
) {
318 fe
= list_entry(list
, struct videobuf_dvb_frontend
, felist
);
325 mutex_unlock(&f
->lock
);
330 int videobuf_dvb_find_frontend(struct videobuf_dvb_frontends
*f
, struct dvb_frontend
*p
)
332 struct list_head
*list
, *q
;
333 struct videobuf_dvb_frontend
*fe
= NULL
;
336 mutex_lock(&f
->lock
);
338 list_for_each_safe(list
, q
, &f
->frontend
.felist
) {
339 fe
= list_entry(list
, struct videobuf_dvb_frontend
, felist
);
340 if (fe
->dvb
.frontend
== p
) {
346 mutex_unlock(&f
->lock
);
351 struct videobuf_dvb_frontend
* videobuf_dvb_alloc_frontend(void *private, struct videobuf_dvb_frontends
*f
, int id
)
353 struct videobuf_dvb_frontend
*fe
;
355 fe
= kzalloc(sizeof(struct videobuf_dvb_frontend
),GFP_KERNEL
);
361 mutex_init(&fe
->dvb
.lock
);
363 mutex_lock(&f
->lock
);
364 list_add_tail(&fe
->felist
,&f
->frontend
.felist
);
365 mutex_unlock(&f
->lock
);
371 EXPORT_SYMBOL(videobuf_dvb_register_bus
);
372 EXPORT_SYMBOL(videobuf_dvb_unregister_bus
);
373 EXPORT_SYMBOL(videobuf_dvb_alloc_frontend
);
374 EXPORT_SYMBOL(videobuf_dvb_get_frontend
);
375 EXPORT_SYMBOL(videobuf_dvb_find_frontend
);
377 /* ------------------------------------------------------------------ */
381 * compile-command: "make DVB=1"