[deliverable/linux.git] / drivers / media / usb / dvb-usb / dvb-usb-urb.c

/* dvb-usb-urb.c is part of the DVB USB library.
 *
 * Copyright (C) 2004-6 Patrick Boettcher (patrick.boettcher@posteo.de)
 * see dvb-usb-init.c for copyright information.
 *
 * This file keeps functions for initializing and handling the
 * USB and URB stuff.
 */
#include "dvb-usb-common.h"

int dvb_usb_generic_rw(struct dvb_usb_device *d, u8 *wbuf, u16 wlen, u8 *rbuf,
	u16 rlen, int delay_ms)
{
	int actlen,ret = -ENOMEM;

	if (!d || wbuf == NULL || wlen == 0)
		return -EINVAL;

	if (d->props.generic_bulk_ctrl_endpoint == 0) {
		err("endpoint for generic control not specified.");
		return -EINVAL;
	}

	if ((ret = mutex_lock_interruptible(&d->usb_mutex)))
		return ret;

	deb_xfer(">>> ");
	debug_dump(wbuf,wlen,deb_xfer);

	ret = usb_bulk_msg(d->udev,usb_sndbulkpipe(d->udev,
			d->props.generic_bulk_ctrl_endpoint), wbuf,wlen,&actlen,
			2000);

	if (ret)
		err("bulk message failed: %d (%d/%d)",ret,wlen,actlen);
	else
		ret = actlen != wlen ? -1 : 0;

	/* an answer is expected, and no error before */
	if (!ret && rbuf && rlen) {
		if (delay_ms)
			msleep(delay_ms);

		ret = usb_bulk_msg(d->udev,usb_rcvbulkpipe(d->udev,
				d->props.generic_bulk_ctrl_endpoint_response ?
				d->props.generic_bulk_ctrl_endpoint_response :
				d->props.generic_bulk_ctrl_endpoint),rbuf,rlen,&actlen,
				2000);

		if (ret)
			err("recv bulk message failed: %d",ret);
		else {
			deb_xfer("<<< ");
			debug_dump(rbuf,actlen,deb_xfer);
		}
	}

	mutex_unlock(&d->usb_mutex);
	return ret;
}
EXPORT_SYMBOL(dvb_usb_generic_rw);

int dvb_usb_generic_write(struct dvb_usb_device *d, u8 *buf, u16 len)
{
	return dvb_usb_generic_rw(d,buf,len,NULL,0,0);
}
EXPORT_SYMBOL(dvb_usb_generic_write);

static void dvb_usb_data_complete(struct usb_data_stream *stream, u8 *buffer, size_t length)
{
	struct dvb_usb_adapter *adap = stream->user_priv;
	if (adap->feedcount > 0 && adap->state & DVB_USB_ADAP_STATE_DVB)
		dvb_dmx_swfilter(&adap->demux, buffer, length);
}

static void dvb_usb_data_complete_204(struct usb_data_stream *stream, u8 *buffer, size_t length)
{
	struct dvb_usb_adapter *adap = stream->user_priv;
	if (adap->feedcount > 0 && adap->state & DVB_USB_ADAP_STATE_DVB)
		dvb_dmx_swfilter_204(&adap->demux, buffer, length);
}

static void dvb_usb_data_complete_raw(struct usb_data_stream *stream,
				      u8 *buffer, size_t length)
{
	struct dvb_usb_adapter *adap = stream->user_priv;
	if (adap->feedcount > 0 && adap->state & DVB_USB_ADAP_STATE_DVB)
		dvb_dmx_swfilter_raw(&adap->demux, buffer, length);
}

int dvb_usb_adapter_stream_init(struct dvb_usb_adapter *adap)
{
	int i, ret = 0;
	for (i = 0; i < adap->props.num_frontends; i++) {

		adap->fe_adap[i].stream.udev      = adap->dev->udev;
		if (adap->props.fe[i].caps & DVB_USB_ADAP_RECEIVES_204_BYTE_TS)
			adap->fe_adap[i].stream.complete =
				dvb_usb_data_complete_204;
		else
		if (adap->props.fe[i].caps & DVB_USB_ADAP_RECEIVES_RAW_PAYLOAD)
			adap->fe_adap[i].stream.complete =
				dvb_usb_data_complete_raw;
		else
		adap->fe_adap[i].stream.complete  = dvb_usb_data_complete;
		adap->fe_adap[i].stream.user_priv = adap;
		ret = usb_urb_init(&adap->fe_adap[i].stream,
				   &adap->props.fe[i].stream);
		if (ret < 0)
			break;
	}
	return ret;
}

int dvb_usb_adapter_stream_exit(struct dvb_usb_adapter *adap)
{
	int i;
	for (i = 0; i < adap->props.num_frontends; i++)
		usb_urb_exit(&adap->fe_adap[i].stream);
	return 0;
}
Commit	Line	Data
776338e1 JS	1	/* dvb-usb-urb.c is part of the DVB USB library.
776338e1 JS	2	*
99e44da7	3	* Copyright (C) 2004-6 Patrick Boettcher (patrick.boettcher@posteo.de)
776338e1 JS	4	* see dvb-usb-init.c for copyright information.
776338e1 JS	5	*
4d43e13f	6	* This file keeps functions for initializing and handling the
776338e1 JS	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
8268c8f5 DB	16	if (!d \|\| wbuf == NULL \|\| wlen == 0)
	17	return -EINVAL;
	18
776338e1 JS	19	if (d->props.generic_bulk_ctrl_endpoint == 0) {
	20	err("endpoint for generic control not specified.");
	21	return -EINVAL;
	22	}
	23
3593cab5	24	if ((ret = mutex_lock_interruptible(&d->usb_mutex)))
776338e1 JS	25	return ret;
776338e1 JS	26
7f5fee57	27	deb_xfer(">>> ");
776338e1 JS	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,
e161f817	32	2000);
776338e1 JS	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,
4605664b MK	45	d->props.generic_bulk_ctrl_endpoint_response ?
4605664b MK	46	d->props.generic_bulk_ctrl_endpoint_response :
776338e1	47	d->props.generic_bulk_ctrl_endpoint),rbuf,rlen,&actlen,
e161f817	48	2000);
776338e1 JS	49
	50	if (ret)
	51	err("recv bulk message failed: %d",ret);
7f5fee57 PB	52	else {
7f5fee57 PB	53	deb_xfer("<<< ");
776338e1	54	debug_dump(rbuf,actlen,deb_xfer);
7f5fee57	55	}
776338e1 JS	56	}
776338e1 JS	57
3593cab5	58	mutex_unlock(&d->usb_mutex);
776338e1 JS	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
4d43e13f	69	static void dvb_usb_data_complete(struct usb_data_stream stream, u8 buffer, size_t length)
7f5fee57	70	{
4d43e13f PB	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);
776338e1 JS	74	}
776338e1 JS	75
0540c496 PB	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
379aa4d0 MK	83	static void dvb_usb_data_complete_raw(struct usb_data_stream *stream,
	84	u8 *buffer, size_t length)
	85	{
	86	struct dvb_usb_adapter *adap = stream->user_priv;
	87	if (adap->feedcount > 0 && adap->state & DVB_USB_ADAP_STATE_DVB)
	88	dvb_dmx_swfilter_raw(&adap->demux, buffer, length);
	89	}
	90
4d43e13f	91	int dvb_usb_adapter_stream_init(struct dvb_usb_adapter *adap)
7f5fee57	92	{
77eed219 MK	93	int i, ret = 0;
	94	for (i = 0; i < adap->props.num_frontends; i++) {
	95
	96	adap->fe_adap[i].stream.udev = adap->dev->udev;
	97	if (adap->props.fe[i].caps & DVB_USB_ADAP_RECEIVES_204_BYTE_TS)
	98	adap->fe_adap[i].stream.complete =
	99	dvb_usb_data_complete_204;
	100	else
379aa4d0 MK	101	if (adap->props.fe[i].caps & DVB_USB_ADAP_RECEIVES_RAW_PAYLOAD)
	102	adap->fe_adap[i].stream.complete =
	103	dvb_usb_data_complete_raw;
	104	else
77eed219 MK	105	adap->fe_adap[i].stream.complete = dvb_usb_data_complete;
	106	adap->fe_adap[i].stream.user_priv = adap;
	107	ret = usb_urb_init(&adap->fe_adap[i].stream,
	108	&adap->props.fe[i].stream);
	109	if (ret < 0)
	110	break;
	111	}
	112	return ret;
776338e1 JS	113	}
776338e1 JS	114
4d43e13f	115	int dvb_usb_adapter_stream_exit(struct dvb_usb_adapter *adap)
776338e1	116	{
77eed219 MK	117	int i;
	118	for (i = 0; i < adap->props.num_frontends; i++)
	119	usb_urb_exit(&adap->fe_adap[i].stream);
	120	return 0;
776338e1	121	}