cachepc-linux

Fork of AMDESE/linux with modifications for CachePC side-channel attack
git clone https://git.sinitax.com/sinitax/cachepc-linux
Log | Files | Refs | README | LICENSE | sfeed.txt

dvb-usb-urb.c (3422B)

      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}