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 || wbuf == NULL || wlen == 0)
  17                 return -EINVAL;
  18
  19         if (d->props.generic_bulk_ctrl_endpoint == 0) {
  20                 err("endpoint for generic control not specified.");
  21                 return -EINVAL;
  22         }
  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_response ?
  46                                 d->props.generic_bulk_ctrl_endpoint_response :
  47                                 d->props.generic_bulk_ctrl_endpoint),rbuf,rlen,&actlen,
  48                                 2000);
  49
  50                 if (ret)
  51                         err("recv bulk message failed: %d",ret);
  52                 else {
  53                         deb_xfer("<<< ");
  54                         debug_dump(rbuf,actlen,deb_xfer);
  55                 }
  56         }
  57
  58         mutex_unlock(&d->usb_mutex);
  59         return ret;
  60 }
  61 EXPORT_SYMBOL(dvb_usb_generic_rw);
  62
  63 int dvb_usb_generic_write(struct dvb_usb_device *d, u8 *buf, u16 len)
  64 {
  65         return dvb_usb_generic_rw(d,buf,len,NULL,0,0);
  66 }
  67 EXPORT_SYMBOL(dvb_usb_generic_write);
  68
  69 static void dvb_usb_data_complete(struct usb_data_stream *stream, u8 *buffer, size_t length)
  70 {
  71         struct dvb_usb_adapter *adap = stream->user_priv;
  72         if (adap->feedcount > 0 && adap->state & DVB_USB_ADAP_STATE_DVB)
  73                 dvb_dmx_swfilter(&adap->demux, buffer, length);
  74 }
  75
  76 static void dvb_usb_data_complete_204(struct usb_data_stream *stream, u8 *buffer, size_t length)
  77 {
  78         struct dvb_usb_adapter *adap = stream->user_priv;
  79         if (adap->feedcount > 0 && adap->state & DVB_USB_ADAP_STATE_DVB)
  80                 dvb_dmx_swfilter_204(&adap->demux, buffer, length);
  81 }
  82
  83 int dvb_usb_adapter_stream_init(struct dvb_usb_adapter *adap)
  84 {
  85         adap->stream.udev      = adap->dev->udev;
  86         if (adap->props.caps & DVB_USB_ADAP_RECEIVES_204_BYTE_TS)
  87                 adap->stream.complete = dvb_usb_data_complete_204;
  88         else
  89         adap->stream.complete  = dvb_usb_data_complete;
  90         adap->stream.user_priv = adap;
  91         return usb_urb_init(&adap->stream, &adap->props.stream);
  92 }
  93
  94 int dvb_usb_adapter_stream_exit(struct dvb_usb_adapter *adap)
  95 {
  96         return usb_urb_exit(&adap->stream);
  97 }