summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMichael Krufky <mkrufky@linuxtv.org>2008-02-03 23:55:07 -0300
committerMauro Carvalho Chehab <mchehab@infradead.org>2008-04-24 14:09:46 -0300
commitd8abe97d0063cf77e9bbbee076181e4657c7e09c (patch)
treef3e792f56bc232bda063cba7758a73242f98a908
parent99443ae04f7002530f666ba0747f7b1ecafb3002 (diff)
V4L/DVB (7681): pvrusb2-dvb: start working on streaming / buffer handling code
start work on streaming / buffer handling code to feed the software demux Signed-off-by: Michael Krufky <mkrufky@linuxtv.org> Signed-off-by: Mike Isely <isely@pobox.com> Signed-off-by: Mauro Carvalho Chehab <mchehab@infradead.org>
-rw-r--r--drivers/media/video/pvrusb2/pvrusb2-dvb.c44
-rw-r--r--drivers/media/video/pvrusb2/pvrusb2-dvb.h3
2 files changed, 45 insertions, 2 deletions
diff --git a/drivers/media/video/pvrusb2/pvrusb2-dvb.c b/drivers/media/video/pvrusb2/pvrusb2-dvb.c
index 250462265a4..c85477709e6 100644
--- a/drivers/media/video/pvrusb2/pvrusb2-dvb.c
+++ b/drivers/media/video/pvrusb2/pvrusb2-dvb.c
@@ -18,6 +18,7 @@
*
*/
+#include <linux/kthread.h>
#include "dvbdev.h"
#include "pvrusb2-hdw-internal.h"
#include "pvrusb2-hdw.h"
@@ -25,18 +26,56 @@
DVB_DEFINE_MOD_OPT_ADAPTER_NR(adapter_nr);
+static int pvr2_dvb_ctrl_feed(struct dvb_demux_feed *dvbdmxfeed, int onoff)
+{
+ struct pvr2_dvb_adapter *adap = dvbdmxfeed->demux->priv;
+ int newfeedcount, ret = 0;
+
+ if (adap == NULL)
+ return -ENODEV;
+
+ mutex_lock(&adap->lock);
+ newfeedcount = adap->feedcount + (onoff ? 1 : -1);
+
+ if (newfeedcount == 0) {
+ printk(KERN_DEBUG "stop feeding\n");
+
+ ret = kthread_stop(adap->thread);
+ adap->thread = NULL;
+ }
+
+ adap->feedcount = newfeedcount;
+
+ if (adap->feedcount == onoff && adap->feedcount > 0) {
+ if (NULL != adap->thread)
+ goto fail;
+
+ printk(KERN_DEBUG "start feeding\n");
+
+ if (IS_ERR(adap->thread)) {
+ ret = PTR_ERR(adap->thread);
+ adap->thread = NULL;
+ }
+ //ret = newfeedcount;
+ }
+fail:
+ mutex_unlock(&adap->lock);
+
+ return ret;
+}
+
static int pvr2_dvb_start_feed(struct dvb_demux_feed *dvbdmxfeed)
{
printk(KERN_DEBUG "start pid: 0x%04x, feedtype: %d\n",
dvbdmxfeed->pid, dvbdmxfeed->type);
- return 0; /* FIXME: pvr2_dvb_ctrl_feed(dvbdmxfeed, 1); */
+ return pvr2_dvb_ctrl_feed(dvbdmxfeed, 1);
}
static int pvr2_dvb_stop_feed(struct dvb_demux_feed *dvbdmxfeed)
{
printk(KERN_DEBUG "stop pid: 0x%04x, feedtype: %d\n",
dvbdmxfeed->pid, dvbdmxfeed->type);
- return 0; /* FIXME: pvr2_dvb_ctrl_feed(dvbdmxfeed, 0); */
+ return pvr2_dvb_ctrl_feed(dvbdmxfeed, 0);
}
static int pvr2_dvb_bus_ctrl(struct dvb_frontend *fe, int acquire)
@@ -172,6 +211,7 @@ int pvr2_dvb_init(struct pvr2_context *pvr)
int ret = 0;
pvr->hdw->dvb.pvr = pvr;
+ mutex_init(&pvr->hdw->dvb.lock);
ret = pvr2_dvb_adapter_init(&pvr->hdw->dvb);
if (ret < 0)
diff --git a/drivers/media/video/pvrusb2/pvrusb2-dvb.h b/drivers/media/video/pvrusb2/pvrusb2-dvb.h
index 0aff05cb941..98728d44a4b 100644
--- a/drivers/media/video/pvrusb2/pvrusb2-dvb.h
+++ b/drivers/media/video/pvrusb2/pvrusb2-dvb.h
@@ -19,6 +19,9 @@ struct pvr2_dvb_adapter {
int feedcount;
int max_feed_count;
+ struct task_struct *thread;
+ struct mutex lock;
+
unsigned int digital_up:1;
};