dvb-usb-urb.c

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