Merge commit 'upstream/master'
[linux-2.6] / drivers / media / dvb / dvb-usb / dvb-usb-urb.c
1 /* dvb-usb-urb.c is part of the DVB USB library.
2  *
3  * Copyright (C) 2004-6 Patrick Boettcher (patrick.boettcher@desy.de)
4  * see dvb-usb-init.c for copyright information.
5  *
6  * This file keeps functions for initializing and handling the
7  * USB and URB stuff.
8  */
9 #include "dvb-usb-common.h"
10
11 int dvb_usb_generic_rw(struct dvb_usb_device *d, u8 *wbuf, u16 wlen, u8 *rbuf,
12         u16 rlen, int delay_ms)
13 {
14         int actlen,ret = -ENOMEM;
15
16         if (d->props.generic_bulk_ctrl_endpoint == 0) {
17                 err("endpoint for generic control not specified.");
18                 return -EINVAL;
19         }
20
21         if (wbuf == NULL || wlen == 0)
22                 return -EINVAL;
23
24         if ((ret = mutex_lock_interruptible(&d->usb_mutex)))
25                 return ret;
26
27         deb_xfer(">>> ");
28         debug_dump(wbuf,wlen,deb_xfer);
29
30         ret = usb_bulk_msg(d->udev,usb_sndbulkpipe(d->udev,
31                         d->props.generic_bulk_ctrl_endpoint), wbuf,wlen,&actlen,
32                         2000);
33
34         if (ret)
35                 err("bulk message failed: %d (%d/%d)",ret,wlen,actlen);
36         else
37                 ret = actlen != wlen ? -1 : 0;
38
39         /* an answer is expected, and no error before */
40         if (!ret && rbuf && rlen) {
41                 if (delay_ms)
42                         msleep(delay_ms);
43
44                 ret = usb_bulk_msg(d->udev,usb_rcvbulkpipe(d->udev,
45                                 d->props.generic_bulk_ctrl_endpoint),rbuf,rlen,&actlen,
46                                 2000);
47
48                 if (ret)
49                         err("recv bulk message failed: %d",ret);
50                 else {
51                         deb_xfer("<<< ");
52                         debug_dump(rbuf,actlen,deb_xfer);
53                 }
54         }
55
56         mutex_unlock(&d->usb_mutex);
57         return ret;
58 }
59 EXPORT_SYMBOL(dvb_usb_generic_rw);
60
61 int dvb_usb_generic_write(struct dvb_usb_device *d, u8 *buf, u16 len)
62 {
63         return dvb_usb_generic_rw(d,buf,len,NULL,0,0);
64 }
65 EXPORT_SYMBOL(dvb_usb_generic_write);
66
67 static void dvb_usb_data_complete(struct usb_data_stream *stream, u8 *buffer, size_t length)
68 {
69         struct dvb_usb_adapter *adap = stream->user_priv;
70         if (adap->feedcount > 0 && adap->state & DVB_USB_ADAP_STATE_DVB)
71                 dvb_dmx_swfilter(&adap->demux, buffer, length);
72 }
73
74 static void dvb_usb_data_complete_204(struct usb_data_stream *stream, u8 *buffer, size_t length)
75 {
76         struct dvb_usb_adapter *adap = stream->user_priv;
77         if (adap->feedcount > 0 && adap->state & DVB_USB_ADAP_STATE_DVB)
78                 dvb_dmx_swfilter_204(&adap->demux, buffer, length);
79 }
80
81 int dvb_usb_adapter_stream_init(struct dvb_usb_adapter *adap)
82 {
83         adap->stream.udev      = adap->dev->udev;
84         if (adap->props.caps & DVB_USB_ADAP_RECEIVES_204_BYTE_TS)
85                 adap->stream.complete = dvb_usb_data_complete_204;
86         else
87         adap->stream.complete  = dvb_usb_data_complete;
88         adap->stream.user_priv = adap;
89         return usb_urb_init(&adap->stream, &adap->props.stream);
90 }
91
92 int dvb_usb_adapter_stream_exit(struct dvb_usb_adapter *adap)
93 {
94         return usb_urb_exit(&adap->stream);
95 }