Linux Audio

Check our new training course

Loading...
v6.8
   1// SPDX-License-Identifier: GPL-2.0+
   2/*****************************************************************************/
   3
   4/*
   5 *      devio.c  --  User space communication with USB devices.
   6 *
   7 *      Copyright (C) 1999-2000  Thomas Sailer (sailer@ife.ee.ethz.ch)
   8 *
 
 
 
 
 
 
 
 
 
 
 
 
 
 
   9 *  This file implements the usbfs/x/y files, where
  10 *  x is the bus number and y the device number.
  11 *
  12 *  It allows user space programs/"drivers" to communicate directly
  13 *  with USB devices without intervening kernel driver.
  14 *
  15 *  Revision history
  16 *    22.12.1999   0.1   Initial release (split from proc_usb.c)
  17 *    04.01.2000   0.2   Turned into its own filesystem
  18 *    30.09.2005   0.3   Fix user-triggerable oops in async URB delivery
  19 *    			 (CAN-2005-3055)
  20 */
  21
  22/*****************************************************************************/
  23
  24#include <linux/fs.h>
  25#include <linux/mm.h>
  26#include <linux/sched/signal.h>
  27#include <linux/slab.h>
  28#include <linux/signal.h>
  29#include <linux/poll.h>
  30#include <linux/module.h>
  31#include <linux/string.h>
  32#include <linux/usb.h>
  33#include <linux/usbdevice_fs.h>
  34#include <linux/usb/hcd.h>	/* for usbcore internals */
  35#include <linux/usb/quirks.h>
  36#include <linux/cdev.h>
  37#include <linux/notifier.h>
  38#include <linux/security.h>
  39#include <linux/user_namespace.h>
  40#include <linux/scatterlist.h>
  41#include <linux/uaccess.h>
  42#include <linux/dma-mapping.h>
  43#include <asm/byteorder.h>
  44#include <linux/moduleparam.h>
  45
  46#include "usb.h"
  47
  48#ifdef CONFIG_PM
  49#define MAYBE_CAP_SUSPEND	USBDEVFS_CAP_SUSPEND
  50#else
  51#define MAYBE_CAP_SUSPEND	0
  52#endif
  53
  54#define USB_MAXBUS			64
  55#define USB_DEVICE_MAX			(USB_MAXBUS * 128)
  56#define USB_SG_SIZE			16384 /* split-size for large txs */
  57
  58/* Mutual exclusion for ps->list in resume vs. release and remove */
  59static DEFINE_MUTEX(usbfs_mutex);
  60
  61struct usb_dev_state {
  62	struct list_head list;      /* state list */
  63	struct usb_device *dev;
  64	struct file *file;
  65	spinlock_t lock;            /* protects the async urb lists */
  66	struct list_head async_pending;
  67	struct list_head async_completed;
  68	struct list_head memory_list;
  69	wait_queue_head_t wait;     /* wake up if a request completed */
  70	wait_queue_head_t wait_for_resume;   /* wake up upon runtime resume */
  71	unsigned int discsignr;
  72	struct pid *disc_pid;
  73	const struct cred *cred;
  74	sigval_t disccontext;
  75	unsigned long ifclaimed;
 
  76	u32 disabled_bulk_eps;
  77	unsigned long interface_allowed_mask;
  78	int not_yet_resumed;
  79	bool suspend_allowed;
  80	bool privileges_dropped;
  81};
  82
  83struct usb_memory {
  84	struct list_head memlist;
  85	int vma_use_count;
  86	int urb_use_count;
  87	u32 size;
  88	void *mem;
  89	dma_addr_t dma_handle;
  90	unsigned long vm_start;
  91	struct usb_dev_state *ps;
  92};
  93
  94struct async {
  95	struct list_head asynclist;
  96	struct usb_dev_state *ps;
  97	struct pid *pid;
  98	const struct cred *cred;
  99	unsigned int signr;
 100	unsigned int ifnum;
 101	void __user *userbuffer;
 102	void __user *userurb;
 103	sigval_t userurb_sigval;
 104	struct urb *urb;
 105	struct usb_memory *usbm;
 106	unsigned int mem_usage;
 107	int status;
 
 108	u8 bulk_addr;
 109	u8 bulk_status;
 110};
 111
 112static bool usbfs_snoop;
 113module_param(usbfs_snoop, bool, S_IRUGO | S_IWUSR);
 114MODULE_PARM_DESC(usbfs_snoop, "true to log all usbfs traffic");
 115
 116static unsigned usbfs_snoop_max = 65536;
 117module_param(usbfs_snoop_max, uint, S_IRUGO | S_IWUSR);
 118MODULE_PARM_DESC(usbfs_snoop_max,
 119		"maximum number of bytes to print while snooping");
 120
 121#define snoop(dev, format, arg...)				\
 122	do {							\
 123		if (usbfs_snoop)				\
 124			dev_info(dev, format, ## arg);		\
 125	} while (0)
 126
 127enum snoop_when {
 128	SUBMIT, COMPLETE
 129};
 130
 131#define USB_DEVICE_DEV		MKDEV(USB_DEVICE_MAJOR, 0)
 132
 133/* Limit on the total amount of memory we can allocate for transfers */
 134static u32 usbfs_memory_mb = 16;
 135module_param(usbfs_memory_mb, uint, 0644);
 136MODULE_PARM_DESC(usbfs_memory_mb,
 137		"maximum MB allowed for usbfs buffers (0 = no limit)");
 138
 139/* Hard limit, necessary to avoid arithmetic overflow */
 140#define USBFS_XFER_MAX         (UINT_MAX / 2 - 1000000)
 141
 142static DEFINE_SPINLOCK(usbfs_memory_usage_lock);
 143static u64 usbfs_memory_usage;	/* Total memory currently allocated */
 144
 145/* Check whether it's okay to allocate more memory for a transfer */
 146static int usbfs_increase_memory_usage(u64 amount)
 147{
 148	u64 lim, total_mem;
 149	unsigned long flags;
 150	int ret;
 151
 152	lim = READ_ONCE(usbfs_memory_mb);
 153	lim <<= 20;
 154
 155	ret = 0;
 156	spin_lock_irqsave(&usbfs_memory_usage_lock, flags);
 157	total_mem = usbfs_memory_usage + amount;
 158	if (lim > 0 && total_mem > lim)
 159		ret = -ENOMEM;
 160	else
 161		usbfs_memory_usage = total_mem;
 162	spin_unlock_irqrestore(&usbfs_memory_usage_lock, flags);
 163
 164	return ret;
 
 
 
 
 165}
 166
 167/* Memory for a transfer is being deallocated */
 168static void usbfs_decrease_memory_usage(u64 amount)
 169{
 170	unsigned long flags;
 171
 172	spin_lock_irqsave(&usbfs_memory_usage_lock, flags);
 173	if (amount > usbfs_memory_usage)
 174		usbfs_memory_usage = 0;
 175	else
 176		usbfs_memory_usage -= amount;
 177	spin_unlock_irqrestore(&usbfs_memory_usage_lock, flags);
 178}
 179
 180static int connected(struct usb_dev_state *ps)
 181{
 182	return (!list_empty(&ps->list) &&
 183			ps->dev->state != USB_STATE_NOTATTACHED);
 184}
 185
 186static void dec_usb_memory_use_count(struct usb_memory *usbm, int *count)
 187{
 188	struct usb_dev_state *ps = usbm->ps;
 189	struct usb_hcd *hcd = bus_to_hcd(ps->dev->bus);
 190	unsigned long flags;
 191
 192	spin_lock_irqsave(&ps->lock, flags);
 193	--*count;
 194	if (usbm->urb_use_count == 0 && usbm->vma_use_count == 0) {
 195		list_del(&usbm->memlist);
 196		spin_unlock_irqrestore(&ps->lock, flags);
 197
 198		hcd_buffer_free_pages(hcd, usbm->size,
 199				usbm->mem, usbm->dma_handle);
 200		usbfs_decrease_memory_usage(
 201			usbm->size + sizeof(struct usb_memory));
 202		kfree(usbm);
 203	} else {
 204		spin_unlock_irqrestore(&ps->lock, flags);
 205	}
 206}
 207
 208static void usbdev_vm_open(struct vm_area_struct *vma)
 209{
 210	struct usb_memory *usbm = vma->vm_private_data;
 211	unsigned long flags;
 212
 213	spin_lock_irqsave(&usbm->ps->lock, flags);
 214	++usbm->vma_use_count;
 215	spin_unlock_irqrestore(&usbm->ps->lock, flags);
 216}
 217
 218static void usbdev_vm_close(struct vm_area_struct *vma)
 219{
 220	struct usb_memory *usbm = vma->vm_private_data;
 221
 222	dec_usb_memory_use_count(usbm, &usbm->vma_use_count);
 223}
 224
 225static const struct vm_operations_struct usbdev_vm_ops = {
 226	.open = usbdev_vm_open,
 227	.close = usbdev_vm_close
 228};
 229
 230static int usbdev_mmap(struct file *file, struct vm_area_struct *vma)
 231{
 232	struct usb_memory *usbm = NULL;
 233	struct usb_dev_state *ps = file->private_data;
 234	struct usb_hcd *hcd = bus_to_hcd(ps->dev->bus);
 235	size_t size = vma->vm_end - vma->vm_start;
 236	void *mem;
 237	unsigned long flags;
 238	dma_addr_t dma_handle = DMA_MAPPING_ERROR;
 239	int ret;
 240
 241	ret = usbfs_increase_memory_usage(size + sizeof(struct usb_memory));
 242	if (ret)
 243		goto error;
 244
 245	usbm = kzalloc(sizeof(struct usb_memory), GFP_KERNEL);
 246	if (!usbm) {
 247		ret = -ENOMEM;
 248		goto error_decrease_mem;
 249	}
 250
 251	mem = hcd_buffer_alloc_pages(hcd,
 252			size, GFP_USER | __GFP_NOWARN, &dma_handle);
 253	if (!mem) {
 254		ret = -ENOMEM;
 255		goto error_free_usbm;
 256	}
 257
 258	memset(mem, 0, size);
 259
 260	usbm->mem = mem;
 261	usbm->dma_handle = dma_handle;
 262	usbm->size = size;
 263	usbm->ps = ps;
 264	usbm->vm_start = vma->vm_start;
 265	usbm->vma_use_count = 1;
 266	INIT_LIST_HEAD(&usbm->memlist);
 267
 268	/*
 269	 * In DMA-unavailable cases, hcd_buffer_alloc_pages allocates
 270	 * normal pages and assigns DMA_MAPPING_ERROR to dma_handle. Check
 271	 * whether we are in such cases, and then use remap_pfn_range (or
 272	 * dma_mmap_coherent) to map normal (or DMA) pages into the user
 273	 * space, respectively.
 274	 */
 275	if (dma_handle == DMA_MAPPING_ERROR) {
 276		if (remap_pfn_range(vma, vma->vm_start,
 277				    virt_to_phys(usbm->mem) >> PAGE_SHIFT,
 278				    size, vma->vm_page_prot) < 0) {
 279			dec_usb_memory_use_count(usbm, &usbm->vma_use_count);
 280			return -EAGAIN;
 281		}
 282	} else {
 283		if (dma_mmap_coherent(hcd->self.sysdev, vma, mem, dma_handle,
 284				      size)) {
 285			dec_usb_memory_use_count(usbm, &usbm->vma_use_count);
 286			return -EAGAIN;
 287		}
 288	}
 289
 290	vm_flags_set(vma, VM_IO | VM_DONTEXPAND | VM_DONTDUMP);
 291	vma->vm_ops = &usbdev_vm_ops;
 292	vma->vm_private_data = usbm;
 293
 294	spin_lock_irqsave(&ps->lock, flags);
 295	list_add_tail(&usbm->memlist, &ps->memory_list);
 296	spin_unlock_irqrestore(&ps->lock, flags);
 297
 298	return 0;
 299
 300error_free_usbm:
 301	kfree(usbm);
 302error_decrease_mem:
 303	usbfs_decrease_memory_usage(size + sizeof(struct usb_memory));
 304error:
 305	return ret;
 306}
 307
 308static ssize_t usbdev_read(struct file *file, char __user *buf, size_t nbytes,
 309			   loff_t *ppos)
 310{
 311	struct usb_dev_state *ps = file->private_data;
 312	struct usb_device *dev = ps->dev;
 313	ssize_t ret = 0;
 314	unsigned len;
 315	loff_t pos;
 316	int i;
 317
 318	pos = *ppos;
 319	usb_lock_device(dev);
 320	if (!connected(ps)) {
 321		ret = -ENODEV;
 322		goto err;
 323	} else if (pos < 0) {
 324		ret = -EINVAL;
 325		goto err;
 326	}
 327
 328	if (pos < sizeof(struct usb_device_descriptor)) {
 329		/* 18 bytes - fits on the stack */
 330		struct usb_device_descriptor temp_desc;
 331
 332		memcpy(&temp_desc, &dev->descriptor, sizeof(dev->descriptor));
 333		le16_to_cpus(&temp_desc.bcdUSB);
 334		le16_to_cpus(&temp_desc.idVendor);
 335		le16_to_cpus(&temp_desc.idProduct);
 336		le16_to_cpus(&temp_desc.bcdDevice);
 337
 338		len = sizeof(struct usb_device_descriptor) - pos;
 339		if (len > nbytes)
 340			len = nbytes;
 341		if (copy_to_user(buf, ((char *)&temp_desc) + pos, len)) {
 342			ret = -EFAULT;
 343			goto err;
 344		}
 345
 346		*ppos += len;
 347		buf += len;
 348		nbytes -= len;
 349		ret += len;
 350	}
 351
 352	pos = sizeof(struct usb_device_descriptor);
 353	for (i = 0; nbytes && i < dev->descriptor.bNumConfigurations; i++) {
 354		struct usb_config_descriptor *config =
 355			(struct usb_config_descriptor *)dev->rawdescriptors[i];
 356		unsigned int length = le16_to_cpu(config->wTotalLength);
 357
 358		if (*ppos < pos + length) {
 359
 360			/* The descriptor may claim to be longer than it
 361			 * really is.  Here is the actual allocated length. */
 362			unsigned alloclen =
 363				le16_to_cpu(dev->config[i].desc.wTotalLength);
 364
 365			len = length - (*ppos - pos);
 366			if (len > nbytes)
 367				len = nbytes;
 368
 369			/* Simply don't write (skip over) unallocated parts */
 370			if (alloclen > (*ppos - pos)) {
 371				alloclen -= (*ppos - pos);
 372				if (copy_to_user(buf,
 373				    dev->rawdescriptors[i] + (*ppos - pos),
 374				    min(len, alloclen))) {
 375					ret = -EFAULT;
 376					goto err;
 377				}
 378			}
 379
 380			*ppos += len;
 381			buf += len;
 382			nbytes -= len;
 383			ret += len;
 384		}
 385
 386		pos += length;
 387	}
 388
 389err:
 390	usb_unlock_device(dev);
 391	return ret;
 392}
 393
 394/*
 395 * async list handling
 396 */
 397
 398static struct async *alloc_async(unsigned int numisoframes)
 399{
 400	struct async *as;
 401
 402	as = kzalloc(sizeof(struct async), GFP_KERNEL);
 403	if (!as)
 404		return NULL;
 405	as->urb = usb_alloc_urb(numisoframes, GFP_KERNEL);
 406	if (!as->urb) {
 407		kfree(as);
 408		return NULL;
 409	}
 410	return as;
 411}
 412
 413static void free_async(struct async *as)
 414{
 415	int i;
 416
 417	put_pid(as->pid);
 418	if (as->cred)
 419		put_cred(as->cred);
 420	for (i = 0; i < as->urb->num_sgs; i++) {
 421		if (sg_page(&as->urb->sg[i]))
 422			kfree(sg_virt(&as->urb->sg[i]));
 423	}
 424
 425	kfree(as->urb->sg);
 426	if (as->usbm == NULL)
 427		kfree(as->urb->transfer_buffer);
 428	else
 429		dec_usb_memory_use_count(as->usbm, &as->usbm->urb_use_count);
 430
 431	kfree(as->urb->setup_packet);
 432	usb_free_urb(as->urb);
 433	usbfs_decrease_memory_usage(as->mem_usage);
 434	kfree(as);
 435}
 436
 437static void async_newpending(struct async *as)
 438{
 439	struct usb_dev_state *ps = as->ps;
 440	unsigned long flags;
 441
 442	spin_lock_irqsave(&ps->lock, flags);
 443	list_add_tail(&as->asynclist, &ps->async_pending);
 444	spin_unlock_irqrestore(&ps->lock, flags);
 445}
 446
 447static void async_removepending(struct async *as)
 448{
 449	struct usb_dev_state *ps = as->ps;
 450	unsigned long flags;
 451
 452	spin_lock_irqsave(&ps->lock, flags);
 453	list_del_init(&as->asynclist);
 454	spin_unlock_irqrestore(&ps->lock, flags);
 455}
 456
 457static struct async *async_getcompleted(struct usb_dev_state *ps)
 458{
 459	unsigned long flags;
 460	struct async *as = NULL;
 461
 462	spin_lock_irqsave(&ps->lock, flags);
 463	if (!list_empty(&ps->async_completed)) {
 464		as = list_entry(ps->async_completed.next, struct async,
 465				asynclist);
 466		list_del_init(&as->asynclist);
 467	}
 468	spin_unlock_irqrestore(&ps->lock, flags);
 469	return as;
 470}
 471
 472static struct async *async_getpending(struct usb_dev_state *ps,
 473					     void __user *userurb)
 474{
 475	struct async *as;
 476
 477	list_for_each_entry(as, &ps->async_pending, asynclist)
 478		if (as->userurb == userurb) {
 479			list_del_init(&as->asynclist);
 480			return as;
 481		}
 482
 483	return NULL;
 484}
 485
 486static void snoop_urb(struct usb_device *udev,
 487		void __user *userurb, int pipe, unsigned length,
 488		int timeout_or_status, enum snoop_when when,
 489		unsigned char *data, unsigned data_len)
 490{
 491	static const char *types[] = {"isoc", "int", "ctrl", "bulk"};
 492	static const char *dirs[] = {"out", "in"};
 493	int ep;
 494	const char *t, *d;
 495
 496	if (!usbfs_snoop)
 497		return;
 498
 499	ep = usb_pipeendpoint(pipe);
 500	t = types[usb_pipetype(pipe)];
 501	d = dirs[!!usb_pipein(pipe)];
 502
 503	if (userurb) {		/* Async */
 504		if (when == SUBMIT)
 505			dev_info(&udev->dev, "userurb %px, ep%d %s-%s, "
 506					"length %u\n",
 507					userurb, ep, t, d, length);
 508		else
 509			dev_info(&udev->dev, "userurb %px, ep%d %s-%s, "
 510					"actual_length %u status %d\n",
 511					userurb, ep, t, d, length,
 512					timeout_or_status);
 513	} else {
 514		if (when == SUBMIT)
 515			dev_info(&udev->dev, "ep%d %s-%s, length %u, "
 516					"timeout %d\n",
 517					ep, t, d, length, timeout_or_status);
 518		else
 519			dev_info(&udev->dev, "ep%d %s-%s, actual_length %u, "
 520					"status %d\n",
 521					ep, t, d, length, timeout_or_status);
 522	}
 523
 524	data_len = min(data_len, usbfs_snoop_max);
 525	if (data && data_len > 0) {
 526		print_hex_dump(KERN_DEBUG, "data: ", DUMP_PREFIX_NONE, 32, 1,
 527			data, data_len, 1);
 528	}
 529}
 530
 531static void snoop_urb_data(struct urb *urb, unsigned len)
 532{
 533	int i, size;
 534
 535	len = min(len, usbfs_snoop_max);
 536	if (!usbfs_snoop || len == 0)
 537		return;
 538
 539	if (urb->num_sgs == 0) {
 540		print_hex_dump(KERN_DEBUG, "data: ", DUMP_PREFIX_NONE, 32, 1,
 541			urb->transfer_buffer, len, 1);
 542		return;
 543	}
 544
 545	for (i = 0; i < urb->num_sgs && len; i++) {
 546		size = (len > USB_SG_SIZE) ? USB_SG_SIZE : len;
 547		print_hex_dump(KERN_DEBUG, "data: ", DUMP_PREFIX_NONE, 32, 1,
 548			sg_virt(&urb->sg[i]), size, 1);
 549		len -= size;
 550	}
 551}
 552
 553static int copy_urb_data_to_user(u8 __user *userbuffer, struct urb *urb)
 554{
 555	unsigned i, len, size;
 556
 557	if (urb->number_of_packets > 0)		/* Isochronous */
 558		len = urb->transfer_buffer_length;
 559	else					/* Non-Isoc */
 560		len = urb->actual_length;
 561
 562	if (urb->num_sgs == 0) {
 563		if (copy_to_user(userbuffer, urb->transfer_buffer, len))
 564			return -EFAULT;
 565		return 0;
 566	}
 567
 568	for (i = 0; i < urb->num_sgs && len; i++) {
 569		size = (len > USB_SG_SIZE) ? USB_SG_SIZE : len;
 570		if (copy_to_user(userbuffer, sg_virt(&urb->sg[i]), size))
 571			return -EFAULT;
 572		userbuffer += size;
 573		len -= size;
 574	}
 575
 576	return 0;
 577}
 578
 579#define AS_CONTINUATION	1
 580#define AS_UNLINK	2
 581
 582static void cancel_bulk_urbs(struct usb_dev_state *ps, unsigned bulk_addr)
 583__releases(ps->lock)
 584__acquires(ps->lock)
 585{
 586	struct urb *urb;
 587	struct async *as;
 588
 589	/* Mark all the pending URBs that match bulk_addr, up to but not
 590	 * including the first one without AS_CONTINUATION.  If such an
 591	 * URB is encountered then a new transfer has already started so
 592	 * the endpoint doesn't need to be disabled; otherwise it does.
 593	 */
 594	list_for_each_entry(as, &ps->async_pending, asynclist) {
 595		if (as->bulk_addr == bulk_addr) {
 596			if (as->bulk_status != AS_CONTINUATION)
 597				goto rescan;
 598			as->bulk_status = AS_UNLINK;
 599			as->bulk_addr = 0;
 600		}
 601	}
 602	ps->disabled_bulk_eps |= (1 << bulk_addr);
 603
 604	/* Now carefully unlink all the marked pending URBs */
 605 rescan:
 606	list_for_each_entry_reverse(as, &ps->async_pending, asynclist) {
 607		if (as->bulk_status == AS_UNLINK) {
 608			as->bulk_status = 0;		/* Only once */
 609			urb = as->urb;
 610			usb_get_urb(urb);
 611			spin_unlock(&ps->lock);		/* Allow completions */
 612			usb_unlink_urb(urb);
 613			usb_put_urb(urb);
 614			spin_lock(&ps->lock);
 615			goto rescan;
 616		}
 617	}
 618}
 619
 620static void async_completed(struct urb *urb)
 621{
 622	struct async *as = urb->context;
 623	struct usb_dev_state *ps = as->ps;
 
 624	struct pid *pid = NULL;
 
 625	const struct cred *cred = NULL;
 626	unsigned long flags;
 627	sigval_t addr;
 628	int signr, errno;
 629
 630	spin_lock_irqsave(&ps->lock, flags);
 631	list_move_tail(&as->asynclist, &ps->async_completed);
 632	as->status = urb->status;
 633	signr = as->signr;
 634	if (signr) {
 635		errno = as->status;
 636		addr = as->userurb_sigval;
 
 
 637		pid = get_pid(as->pid);
 638		cred = get_cred(as->cred);
 
 639	}
 640	snoop(&urb->dev->dev, "urb complete\n");
 641	snoop_urb(urb->dev, as->userurb, urb->pipe, urb->actual_length,
 642			as->status, COMPLETE, NULL, 0);
 643	if (usb_urb_dir_in(urb))
 644		snoop_urb_data(urb, urb->actual_length);
 645
 646	if (as->status < 0 && as->bulk_addr && as->status != -ECONNRESET &&
 647			as->status != -ENOENT)
 648		cancel_bulk_urbs(ps, as->bulk_addr);
 649
 650	wake_up(&ps->wait);
 651	spin_unlock_irqrestore(&ps->lock, flags);
 652
 653	if (signr) {
 654		kill_pid_usb_asyncio(signr, errno, addr, pid, cred);
 655		put_pid(pid);
 656		put_cred(cred);
 657	}
 
 
 658}
 659
 660static void destroy_async(struct usb_dev_state *ps, struct list_head *list)
 661{
 662	struct urb *urb;
 663	struct async *as;
 664	unsigned long flags;
 665
 666	spin_lock_irqsave(&ps->lock, flags);
 667	while (!list_empty(list)) {
 668		as = list_last_entry(list, struct async, asynclist);
 669		list_del_init(&as->asynclist);
 670		urb = as->urb;
 671		usb_get_urb(urb);
 672
 673		/* drop the spinlock so the completion handler can run */
 674		spin_unlock_irqrestore(&ps->lock, flags);
 675		usb_kill_urb(urb);
 676		usb_put_urb(urb);
 677		spin_lock_irqsave(&ps->lock, flags);
 678	}
 679	spin_unlock_irqrestore(&ps->lock, flags);
 680}
 681
 682static void destroy_async_on_interface(struct usb_dev_state *ps,
 683				       unsigned int ifnum)
 684{
 685	struct list_head *p, *q, hitlist;
 686	unsigned long flags;
 687
 688	INIT_LIST_HEAD(&hitlist);
 689	spin_lock_irqsave(&ps->lock, flags);
 690	list_for_each_safe(p, q, &ps->async_pending)
 691		if (ifnum == list_entry(p, struct async, asynclist)->ifnum)
 692			list_move_tail(p, &hitlist);
 693	spin_unlock_irqrestore(&ps->lock, flags);
 694	destroy_async(ps, &hitlist);
 695}
 696
 697static void destroy_all_async(struct usb_dev_state *ps)
 698{
 699	destroy_async(ps, &ps->async_pending);
 700}
 701
 702/*
 703 * interface claims are made only at the request of user level code,
 704 * which can also release them (explicitly or by closing files).
 705 * they're also undone when devices disconnect.
 706 */
 707
 708static int driver_probe(struct usb_interface *intf,
 709			const struct usb_device_id *id)
 710{
 711	return -ENODEV;
 712}
 713
 714static void driver_disconnect(struct usb_interface *intf)
 715{
 716	struct usb_dev_state *ps = usb_get_intfdata(intf);
 717	unsigned int ifnum = intf->altsetting->desc.bInterfaceNumber;
 718
 719	if (!ps)
 720		return;
 721
 722	/* NOTE:  this relies on usbcore having canceled and completed
 723	 * all pending I/O requests; 2.6 does that.
 724	 */
 725
 726	if (likely(ifnum < 8*sizeof(ps->ifclaimed)))
 727		clear_bit(ifnum, &ps->ifclaimed);
 728	else
 729		dev_warn(&intf->dev, "interface number %u out of range\n",
 730			 ifnum);
 731
 732	usb_set_intfdata(intf, NULL);
 733
 734	/* force async requests to complete */
 735	destroy_async_on_interface(ps, ifnum);
 736}
 737
 738/* We don't care about suspend/resume of claimed interfaces */
 
 
 739static int driver_suspend(struct usb_interface *intf, pm_message_t msg)
 740{
 741	return 0;
 742}
 743
 744static int driver_resume(struct usb_interface *intf)
 745{
 746	return 0;
 747}
 748
 749#ifdef CONFIG_PM
 750/* The following routines apply to the entire device, not interfaces */
 751void usbfs_notify_suspend(struct usb_device *udev)
 752{
 753	/* We don't need to handle this */
 754}
 755
 756void usbfs_notify_resume(struct usb_device *udev)
 757{
 758	struct usb_dev_state *ps;
 759
 760	/* Protect against simultaneous remove or release */
 761	mutex_lock(&usbfs_mutex);
 762	list_for_each_entry(ps, &udev->filelist, list) {
 763		WRITE_ONCE(ps->not_yet_resumed, 0);
 764		wake_up_all(&ps->wait_for_resume);
 765	}
 766	mutex_unlock(&usbfs_mutex);
 767}
 768#endif
 769
 770struct usb_driver usbfs_driver = {
 771	.name =		"usbfs",
 772	.probe =	driver_probe,
 773	.disconnect =	driver_disconnect,
 774	.suspend =	driver_suspend,
 775	.resume =	driver_resume,
 776	.supports_autosuspend = 1,
 777};
 778
 779static int claimintf(struct usb_dev_state *ps, unsigned int ifnum)
 780{
 781	struct usb_device *dev = ps->dev;
 782	struct usb_interface *intf;
 783	int err;
 784
 785	if (ifnum >= 8*sizeof(ps->ifclaimed))
 786		return -EINVAL;
 787	/* already claimed */
 788	if (test_bit(ifnum, &ps->ifclaimed))
 789		return 0;
 790
 791	if (ps->privileges_dropped &&
 792			!test_bit(ifnum, &ps->interface_allowed_mask))
 793		return -EACCES;
 794
 795	intf = usb_ifnum_to_if(dev, ifnum);
 796	if (!intf)
 797		err = -ENOENT;
 798	else {
 799		unsigned int old_suppress;
 800
 801		/* suppress uevents while claiming interface */
 802		old_suppress = dev_get_uevent_suppress(&intf->dev);
 803		dev_set_uevent_suppress(&intf->dev, 1);
 804		err = usb_driver_claim_interface(&usbfs_driver, intf, ps);
 805		dev_set_uevent_suppress(&intf->dev, old_suppress);
 806	}
 807	if (err == 0)
 808		set_bit(ifnum, &ps->ifclaimed);
 809	return err;
 810}
 811
 812static int releaseintf(struct usb_dev_state *ps, unsigned int ifnum)
 813{
 814	struct usb_device *dev;
 815	struct usb_interface *intf;
 816	int err;
 817
 818	err = -EINVAL;
 819	if (ifnum >= 8*sizeof(ps->ifclaimed))
 820		return err;
 821	dev = ps->dev;
 822	intf = usb_ifnum_to_if(dev, ifnum);
 823	if (!intf)
 824		err = -ENOENT;
 825	else if (test_and_clear_bit(ifnum, &ps->ifclaimed)) {
 826		unsigned int old_suppress;
 827
 828		/* suppress uevents while releasing interface */
 829		old_suppress = dev_get_uevent_suppress(&intf->dev);
 830		dev_set_uevent_suppress(&intf->dev, 1);
 831		usb_driver_release_interface(&usbfs_driver, intf);
 832		dev_set_uevent_suppress(&intf->dev, old_suppress);
 833		err = 0;
 834	}
 835	return err;
 836}
 837
 838static int checkintf(struct usb_dev_state *ps, unsigned int ifnum)
 839{
 840	if (ps->dev->state != USB_STATE_CONFIGURED)
 841		return -EHOSTUNREACH;
 842	if (ifnum >= 8*sizeof(ps->ifclaimed))
 843		return -EINVAL;
 844	if (test_bit(ifnum, &ps->ifclaimed))
 845		return 0;
 846	/* if not yet claimed, claim it for the driver */
 847	dev_warn(&ps->dev->dev, "usbfs: process %d (%s) did not claim "
 848		 "interface %u before use\n", task_pid_nr(current),
 849		 current->comm, ifnum);
 850	return claimintf(ps, ifnum);
 851}
 852
 853static int findintfep(struct usb_device *dev, unsigned int ep)
 854{
 855	unsigned int i, j, e;
 856	struct usb_interface *intf;
 857	struct usb_host_interface *alts;
 858	struct usb_endpoint_descriptor *endpt;
 859
 860	if (ep & ~(USB_DIR_IN|0xf))
 861		return -EINVAL;
 862	if (!dev->actconfig)
 863		return -ESRCH;
 864	for (i = 0; i < dev->actconfig->desc.bNumInterfaces; i++) {
 865		intf = dev->actconfig->interface[i];
 866		for (j = 0; j < intf->num_altsetting; j++) {
 867			alts = &intf->altsetting[j];
 868			for (e = 0; e < alts->desc.bNumEndpoints; e++) {
 869				endpt = &alts->endpoint[e].desc;
 870				if (endpt->bEndpointAddress == ep)
 871					return alts->desc.bInterfaceNumber;
 872			}
 873		}
 874	}
 875	return -ENOENT;
 876}
 877
 878static int check_ctrlrecip(struct usb_dev_state *ps, unsigned int requesttype,
 879			   unsigned int request, unsigned int index)
 880{
 881	int ret = 0;
 882	struct usb_host_interface *alt_setting;
 883
 884	if (ps->dev->state != USB_STATE_UNAUTHENTICATED
 885	 && ps->dev->state != USB_STATE_ADDRESS
 886	 && ps->dev->state != USB_STATE_CONFIGURED)
 887		return -EHOSTUNREACH;
 888	if (USB_TYPE_VENDOR == (USB_TYPE_MASK & requesttype))
 889		return 0;
 890
 891	/*
 892	 * check for the special corner case 'get_device_id' in the printer
 893	 * class specification, which we always want to allow as it is used
 894	 * to query things like ink level, etc.
 895	 */
 896	if (requesttype == 0xa1 && request == 0) {
 897		alt_setting = usb_find_alt_setting(ps->dev->actconfig,
 898						   index >> 8, index & 0xff);
 899		if (alt_setting
 900		 && alt_setting->desc.bInterfaceClass == USB_CLASS_PRINTER)
 901			return 0;
 902	}
 903
 904	index &= 0xff;
 905	switch (requesttype & USB_RECIP_MASK) {
 906	case USB_RECIP_ENDPOINT:
 907		if ((index & ~USB_DIR_IN) == 0)
 908			return 0;
 909		ret = findintfep(ps->dev, index);
 910		if (ret < 0) {
 911			/*
 912			 * Some not fully compliant Win apps seem to get
 913			 * index wrong and have the endpoint number here
 914			 * rather than the endpoint address (with the
 915			 * correct direction). Win does let this through,
 916			 * so we'll not reject it here but leave it to
 917			 * the device to not break KVM. But we warn.
 918			 */
 919			ret = findintfep(ps->dev, index ^ 0x80);
 920			if (ret >= 0)
 921				dev_info(&ps->dev->dev,
 922					"%s: process %i (%s) requesting ep %02x but needs %02x\n",
 923					__func__, task_pid_nr(current),
 924					current->comm, index, index ^ 0x80);
 925		}
 926		if (ret >= 0)
 927			ret = checkintf(ps, ret);
 928		break;
 929
 930	case USB_RECIP_INTERFACE:
 931		ret = checkintf(ps, index);
 932		break;
 933	}
 934	return ret;
 935}
 936
 937static struct usb_host_endpoint *ep_to_host_endpoint(struct usb_device *dev,
 938						     unsigned char ep)
 939{
 940	if (ep & USB_ENDPOINT_DIR_MASK)
 941		return dev->ep_in[ep & USB_ENDPOINT_NUMBER_MASK];
 942	else
 943		return dev->ep_out[ep & USB_ENDPOINT_NUMBER_MASK];
 944}
 945
 946static int parse_usbdevfs_streams(struct usb_dev_state *ps,
 947				  struct usbdevfs_streams __user *streams,
 948				  unsigned int *num_streams_ret,
 949				  unsigned int *num_eps_ret,
 950				  struct usb_host_endpoint ***eps_ret,
 951				  struct usb_interface **intf_ret)
 952{
 953	unsigned int i, num_streams, num_eps;
 954	struct usb_host_endpoint **eps;
 955	struct usb_interface *intf = NULL;
 956	unsigned char ep;
 957	int ifnum, ret;
 958
 959	if (get_user(num_streams, &streams->num_streams) ||
 960	    get_user(num_eps, &streams->num_eps))
 961		return -EFAULT;
 962
 963	if (num_eps < 1 || num_eps > USB_MAXENDPOINTS)
 964		return -EINVAL;
 965
 966	/* The XHCI controller allows max 2 ^ 16 streams */
 967	if (num_streams_ret && (num_streams < 2 || num_streams > 65536))
 968		return -EINVAL;
 969
 970	eps = kmalloc_array(num_eps, sizeof(*eps), GFP_KERNEL);
 971	if (!eps)
 972		return -ENOMEM;
 973
 974	for (i = 0; i < num_eps; i++) {
 975		if (get_user(ep, &streams->eps[i])) {
 976			ret = -EFAULT;
 977			goto error;
 978		}
 979		eps[i] = ep_to_host_endpoint(ps->dev, ep);
 980		if (!eps[i]) {
 981			ret = -EINVAL;
 982			goto error;
 983		}
 984
 985		/* usb_alloc/free_streams operate on an usb_interface */
 986		ifnum = findintfep(ps->dev, ep);
 987		if (ifnum < 0) {
 988			ret = ifnum;
 989			goto error;
 990		}
 991
 992		if (i == 0) {
 993			ret = checkintf(ps, ifnum);
 994			if (ret < 0)
 995				goto error;
 996			intf = usb_ifnum_to_if(ps->dev, ifnum);
 997		} else {
 998			/* Verify all eps belong to the same interface */
 999			if (ifnum != intf->altsetting->desc.bInterfaceNumber) {
1000				ret = -EINVAL;
1001				goto error;
1002			}
1003		}
1004	}
1005
1006	if (num_streams_ret)
1007		*num_streams_ret = num_streams;
1008	*num_eps_ret = num_eps;
1009	*eps_ret = eps;
1010	*intf_ret = intf;
1011
1012	return 0;
1013
1014error:
1015	kfree(eps);
1016	return ret;
1017}
1018
1019static struct usb_device *usbdev_lookup_by_devt(dev_t devt)
1020{
1021	struct device *dev;
1022
1023	dev = bus_find_device_by_devt(&usb_bus_type, devt);
 
1024	if (!dev)
1025		return NULL;
1026	return to_usb_device(dev);
1027}
1028
1029/*
1030 * file operations
1031 */
1032static int usbdev_open(struct inode *inode, struct file *file)
1033{
1034	struct usb_device *dev = NULL;
1035	struct usb_dev_state *ps;
1036	int ret;
1037
1038	ret = -ENOMEM;
1039	ps = kzalloc(sizeof(struct usb_dev_state), GFP_KERNEL);
1040	if (!ps)
1041		goto out_free_ps;
1042
1043	ret = -ENODEV;
1044
 
 
 
1045	/* usbdev device-node */
1046	if (imajor(inode) == USB_DEVICE_MAJOR)
1047		dev = usbdev_lookup_by_devt(inode->i_rdev);
 
 
 
1048	if (!dev)
1049		goto out_free_ps;
1050
1051	usb_lock_device(dev);
1052	if (dev->state == USB_STATE_NOTATTACHED)
1053		goto out_unlock_device;
1054
1055	ret = usb_autoresume_device(dev);
1056	if (ret)
1057		goto out_unlock_device;
1058
1059	ps->dev = dev;
1060	ps->file = file;
1061	ps->interface_allowed_mask = 0xFFFFFFFF; /* 32 bits */
1062	spin_lock_init(&ps->lock);
1063	INIT_LIST_HEAD(&ps->list);
1064	INIT_LIST_HEAD(&ps->async_pending);
1065	INIT_LIST_HEAD(&ps->async_completed);
1066	INIT_LIST_HEAD(&ps->memory_list);
1067	init_waitqueue_head(&ps->wait);
1068	init_waitqueue_head(&ps->wait_for_resume);
1069	ps->disc_pid = get_pid(task_pid(current));
1070	ps->cred = get_current_cred();
 
 
 
1071	smp_wmb();
1072
1073	/* Can't race with resume; the device is already active */
1074	list_add_tail(&ps->list, &dev->filelist);
1075	file->private_data = ps;
1076	usb_unlock_device(dev);
1077	snoop(&dev->dev, "opened by process %d: %s\n", task_pid_nr(current),
1078			current->comm);
1079	return ret;
1080
1081 out_unlock_device:
1082	usb_unlock_device(dev);
1083	usb_put_dev(dev);
1084 out_free_ps:
1085	kfree(ps);
1086	return ret;
1087}
1088
1089static int usbdev_release(struct inode *inode, struct file *file)
1090{
1091	struct usb_dev_state *ps = file->private_data;
1092	struct usb_device *dev = ps->dev;
1093	unsigned int ifnum;
1094	struct async *as;
1095
1096	usb_lock_device(dev);
1097	usb_hub_release_all_ports(dev, ps);
1098
1099	/* Protect against simultaneous resume */
1100	mutex_lock(&usbfs_mutex);
1101	list_del_init(&ps->list);
1102	mutex_unlock(&usbfs_mutex);
1103
1104	for (ifnum = 0; ps->ifclaimed && ifnum < 8*sizeof(ps->ifclaimed);
1105			ifnum++) {
1106		if (test_bit(ifnum, &ps->ifclaimed))
1107			releaseintf(ps, ifnum);
1108	}
1109	destroy_all_async(ps);
1110	if (!ps->suspend_allowed)
1111		usb_autosuspend_device(dev);
1112	usb_unlock_device(dev);
1113	usb_put_dev(dev);
1114	put_pid(ps->disc_pid);
1115	put_cred(ps->cred);
1116
1117	as = async_getcompleted(ps);
1118	while (as) {
1119		free_async(as);
1120		as = async_getcompleted(ps);
1121	}
1122
1123	kfree(ps);
1124	return 0;
1125}
1126
1127static void usbfs_blocking_completion(struct urb *urb)
1128{
1129	complete((struct completion *) urb->context);
1130}
1131
1132/*
1133 * Much like usb_start_wait_urb, but returns status separately from
1134 * actual_length and uses a killable wait.
1135 */
1136static int usbfs_start_wait_urb(struct urb *urb, int timeout,
1137		unsigned int *actlen)
1138{
1139	DECLARE_COMPLETION_ONSTACK(ctx);
1140	unsigned long expire;
1141	int rc;
1142
1143	urb->context = &ctx;
1144	urb->complete = usbfs_blocking_completion;
1145	*actlen = 0;
1146	rc = usb_submit_urb(urb, GFP_KERNEL);
1147	if (unlikely(rc))
1148		return rc;
1149
1150	expire = (timeout ? msecs_to_jiffies(timeout) : MAX_SCHEDULE_TIMEOUT);
1151	rc = wait_for_completion_killable_timeout(&ctx, expire);
1152	if (rc <= 0) {
1153		usb_kill_urb(urb);
1154		*actlen = urb->actual_length;
1155		if (urb->status != -ENOENT)
1156			;	/* Completed before it was killed */
1157		else if (rc < 0)
1158			return -EINTR;
1159		else
1160			return -ETIMEDOUT;
1161	}
1162	*actlen = urb->actual_length;
1163	return urb->status;
1164}
1165
1166static int do_proc_control(struct usb_dev_state *ps,
1167		struct usbdevfs_ctrltransfer *ctrl)
1168{
1169	struct usb_device *dev = ps->dev;
 
1170	unsigned int tmo;
1171	unsigned char *tbuf;
1172	unsigned int wLength, actlen;
1173	int i, pipe, ret;
1174	struct urb *urb = NULL;
1175	struct usb_ctrlrequest *dr = NULL;
1176
1177	ret = check_ctrlrecip(ps, ctrl->bRequestType, ctrl->bRequest,
1178			      ctrl->wIndex);
 
 
1179	if (ret)
1180		return ret;
1181	wLength = ctrl->wLength;	/* To suppress 64k PAGE_SIZE warning */
1182	if (wLength > PAGE_SIZE)
1183		return -EINVAL;
1184	ret = usbfs_increase_memory_usage(PAGE_SIZE + sizeof(struct urb) +
1185			sizeof(struct usb_ctrlrequest));
1186	if (ret)
1187		return ret;
1188
1189	ret = -ENOMEM;
1190	tbuf = (unsigned char *)__get_free_page(GFP_KERNEL);
1191	if (!tbuf)
1192		goto done;
1193	urb = usb_alloc_urb(0, GFP_NOIO);
1194	if (!urb)
1195		goto done;
1196	dr = kmalloc(sizeof(struct usb_ctrlrequest), GFP_NOIO);
1197	if (!dr)
1198		goto done;
1199
1200	dr->bRequestType = ctrl->bRequestType;
1201	dr->bRequest = ctrl->bRequest;
1202	dr->wValue = cpu_to_le16(ctrl->wValue);
1203	dr->wIndex = cpu_to_le16(ctrl->wIndex);
1204	dr->wLength = cpu_to_le16(ctrl->wLength);
1205
1206	tmo = ctrl->timeout;
1207	snoop(&dev->dev, "control urb: bRequestType=%02x "
1208		"bRequest=%02x wValue=%04x "
1209		"wIndex=%04x wLength=%04x\n",
1210		ctrl->bRequestType, ctrl->bRequest, ctrl->wValue,
1211		ctrl->wIndex, ctrl->wLength);
1212
1213	if ((ctrl->bRequestType & USB_DIR_IN) && wLength) {
 
 
 
 
 
 
1214		pipe = usb_rcvctrlpipe(dev, 0);
1215		usb_fill_control_urb(urb, dev, pipe, (unsigned char *) dr, tbuf,
1216				wLength, NULL, NULL);
1217		snoop_urb(dev, NULL, pipe, wLength, tmo, SUBMIT, NULL, 0);
1218
1219		usb_unlock_device(dev);
1220		i = usbfs_start_wait_urb(urb, tmo, &actlen);
1221
1222		/* Linger a bit, prior to the next control message. */
1223		if (dev->quirks & USB_QUIRK_DELAY_CTRL_MSG)
1224			msleep(200);
1225		usb_lock_device(dev);
1226		snoop_urb(dev, NULL, pipe, actlen, i, COMPLETE, tbuf, actlen);
1227		if (!i && actlen) {
1228			if (copy_to_user(ctrl->data, tbuf, actlen)) {
 
1229				ret = -EFAULT;
1230				goto done;
1231			}
1232		}
1233	} else {
1234		if (wLength) {
1235			if (copy_from_user(tbuf, ctrl->data, wLength)) {
1236				ret = -EFAULT;
1237				goto done;
1238			}
1239		}
1240		pipe = usb_sndctrlpipe(dev, 0);
1241		usb_fill_control_urb(urb, dev, pipe, (unsigned char *) dr, tbuf,
1242				wLength, NULL, NULL);
1243		snoop_urb(dev, NULL, pipe, wLength, tmo, SUBMIT, tbuf, wLength);
1244
1245		usb_unlock_device(dev);
1246		i = usbfs_start_wait_urb(urb, tmo, &actlen);
1247
1248		/* Linger a bit, prior to the next control message. */
1249		if (dev->quirks & USB_QUIRK_DELAY_CTRL_MSG)
1250			msleep(200);
1251		usb_lock_device(dev);
1252		snoop_urb(dev, NULL, pipe, actlen, i, COMPLETE, NULL, 0);
1253	}
1254	if (i < 0 && i != -EPIPE) {
1255		dev_printk(KERN_DEBUG, &dev->dev, "usbfs: USBDEVFS_CONTROL "
1256			   "failed cmd %s rqt %u rq %u len %u ret %d\n",
1257			   current->comm, ctrl->bRequestType, ctrl->bRequest,
1258			   ctrl->wLength, i);
1259	}
1260	ret = (i < 0 ? i : actlen);
1261
1262 done:
1263	kfree(dr);
1264	usb_free_urb(urb);
1265	free_page((unsigned long) tbuf);
1266	usbfs_decrease_memory_usage(PAGE_SIZE + sizeof(struct urb) +
1267			sizeof(struct usb_ctrlrequest));
1268	return ret;
1269}
1270
1271static int proc_control(struct usb_dev_state *ps, void __user *arg)
1272{
1273	struct usbdevfs_ctrltransfer ctrl;
1274
1275	if (copy_from_user(&ctrl, arg, sizeof(ctrl)))
1276		return -EFAULT;
1277	return do_proc_control(ps, &ctrl);
1278}
1279
1280static int do_proc_bulk(struct usb_dev_state *ps,
1281		struct usbdevfs_bulktransfer *bulk)
1282{
1283	struct usb_device *dev = ps->dev;
1284	unsigned int tmo, len1, len2, pipe;
 
 
1285	unsigned char *tbuf;
1286	int i, ret;
1287	struct urb *urb = NULL;
1288	struct usb_host_endpoint *ep;
1289
1290	ret = findintfep(ps->dev, bulk->ep);
 
 
1291	if (ret < 0)
1292		return ret;
1293	ret = checkintf(ps, ret);
1294	if (ret)
1295		return ret;
1296
1297	len1 = bulk->len;
1298	if (len1 < 0 || len1 >= (INT_MAX - sizeof(struct urb)))
1299		return -EINVAL;
1300
1301	if (bulk->ep & USB_DIR_IN)
1302		pipe = usb_rcvbulkpipe(dev, bulk->ep & 0x7f);
1303	else
1304		pipe = usb_sndbulkpipe(dev, bulk->ep & 0x7f);
1305	ep = usb_pipe_endpoint(dev, pipe);
1306	if (!ep || !usb_endpoint_maxp(&ep->desc))
 
 
1307		return -EINVAL;
1308	ret = usbfs_increase_memory_usage(len1 + sizeof(struct urb));
1309	if (ret)
1310		return ret;
1311
1312	/*
1313	 * len1 can be almost arbitrarily large.  Don't WARN if it's
1314	 * too big, just fail the request.
1315	 */
1316	ret = -ENOMEM;
1317	tbuf = kmalloc(len1, GFP_KERNEL | __GFP_NOWARN);
1318	if (!tbuf)
1319		goto done;
1320	urb = usb_alloc_urb(0, GFP_KERNEL);
1321	if (!urb)
1322		goto done;
1323
1324	if ((ep->desc.bmAttributes & USB_ENDPOINT_XFERTYPE_MASK) ==
1325			USB_ENDPOINT_XFER_INT) {
1326		pipe = (pipe & ~(3 << 30)) | (PIPE_INTERRUPT << 30);
1327		usb_fill_int_urb(urb, dev, pipe, tbuf, len1,
1328				NULL, NULL, ep->desc.bInterval);
1329	} else {
1330		usb_fill_bulk_urb(urb, dev, pipe, tbuf, len1, NULL, NULL);
1331	}
1332
1333	tmo = bulk->timeout;
1334	if (bulk->ep & 0x80) {
 
 
 
1335		snoop_urb(dev, NULL, pipe, len1, tmo, SUBMIT, NULL, 0);
1336
1337		usb_unlock_device(dev);
1338		i = usbfs_start_wait_urb(urb, tmo, &len2);
1339		usb_lock_device(dev);
1340		snoop_urb(dev, NULL, pipe, len2, i, COMPLETE, tbuf, len2);
1341
1342		if (!i && len2) {
1343			if (copy_to_user(bulk->data, tbuf, len2)) {
1344				ret = -EFAULT;
1345				goto done;
1346			}
1347		}
1348	} else {
1349		if (len1) {
1350			if (copy_from_user(tbuf, bulk->data, len1)) {
1351				ret = -EFAULT;
1352				goto done;
1353			}
1354		}
1355		snoop_urb(dev, NULL, pipe, len1, tmo, SUBMIT, tbuf, len1);
1356
1357		usb_unlock_device(dev);
1358		i = usbfs_start_wait_urb(urb, tmo, &len2);
1359		usb_lock_device(dev);
1360		snoop_urb(dev, NULL, pipe, len2, i, COMPLETE, NULL, 0);
1361	}
1362	ret = (i < 0 ? i : len2);
1363 done:
1364	usb_free_urb(urb);
1365	kfree(tbuf);
1366	usbfs_decrease_memory_usage(len1 + sizeof(struct urb));
1367	return ret;
1368}
1369
1370static int proc_bulk(struct usb_dev_state *ps, void __user *arg)
1371{
1372	struct usbdevfs_bulktransfer bulk;
1373
1374	if (copy_from_user(&bulk, arg, sizeof(bulk)))
1375		return -EFAULT;
1376	return do_proc_bulk(ps, &bulk);
1377}
1378
1379static void check_reset_of_active_ep(struct usb_device *udev,
1380		unsigned int epnum, char *ioctl_name)
1381{
1382	struct usb_host_endpoint **eps;
1383	struct usb_host_endpoint *ep;
1384
1385	eps = (epnum & USB_DIR_IN) ? udev->ep_in : udev->ep_out;
1386	ep = eps[epnum & 0x0f];
1387	if (ep && !list_empty(&ep->urb_list))
1388		dev_warn(&udev->dev, "Process %d (%s) called USBDEVFS_%s for active endpoint 0x%02x\n",
1389				task_pid_nr(current), current->comm,
1390				ioctl_name, epnum);
1391}
1392
1393static int proc_resetep(struct usb_dev_state *ps, void __user *arg)
1394{
1395	unsigned int ep;
1396	int ret;
1397
1398	if (get_user(ep, (unsigned int __user *)arg))
1399		return -EFAULT;
1400	ret = findintfep(ps->dev, ep);
1401	if (ret < 0)
1402		return ret;
1403	ret = checkintf(ps, ret);
1404	if (ret)
1405		return ret;
1406	check_reset_of_active_ep(ps->dev, ep, "RESETEP");
1407	usb_reset_endpoint(ps->dev, ep);
1408	return 0;
1409}
1410
1411static int proc_clearhalt(struct usb_dev_state *ps, void __user *arg)
1412{
1413	unsigned int ep;
1414	int pipe;
1415	int ret;
1416
1417	if (get_user(ep, (unsigned int __user *)arg))
1418		return -EFAULT;
1419	ret = findintfep(ps->dev, ep);
1420	if (ret < 0)
1421		return ret;
1422	ret = checkintf(ps, ret);
1423	if (ret)
1424		return ret;
1425	check_reset_of_active_ep(ps->dev, ep, "CLEAR_HALT");
1426	if (ep & USB_DIR_IN)
1427		pipe = usb_rcvbulkpipe(ps->dev, ep & 0x7f);
1428	else
1429		pipe = usb_sndbulkpipe(ps->dev, ep & 0x7f);
1430
1431	return usb_clear_halt(ps->dev, pipe);
1432}
1433
1434static int proc_getdriver(struct usb_dev_state *ps, void __user *arg)
1435{
1436	struct usbdevfs_getdriver gd;
1437	struct usb_interface *intf;
1438	int ret;
1439
1440	if (copy_from_user(&gd, arg, sizeof(gd)))
1441		return -EFAULT;
1442	intf = usb_ifnum_to_if(ps->dev, gd.interface);
1443	if (!intf || !intf->dev.driver)
1444		ret = -ENODATA;
1445	else {
1446		strscpy(gd.driver, intf->dev.driver->name,
1447				sizeof(gd.driver));
1448		ret = (copy_to_user(arg, &gd, sizeof(gd)) ? -EFAULT : 0);
1449	}
1450	return ret;
1451}
1452
1453static int proc_connectinfo(struct usb_dev_state *ps, void __user *arg)
1454{
1455	struct usbdevfs_connectinfo ci;
1456
1457	memset(&ci, 0, sizeof(ci));
1458	ci.devnum = ps->dev->devnum;
1459	ci.slow = ps->dev->speed == USB_SPEED_LOW;
1460
1461	if (copy_to_user(arg, &ci, sizeof(ci)))
1462		return -EFAULT;
1463	return 0;
1464}
1465
1466static int proc_conninfo_ex(struct usb_dev_state *ps,
1467			    void __user *arg, size_t size)
1468{
1469	struct usbdevfs_conninfo_ex ci;
1470	struct usb_device *udev = ps->dev;
1471
1472	if (size < sizeof(ci.size))
1473		return -EINVAL;
1474
1475	memset(&ci, 0, sizeof(ci));
1476	ci.size = sizeof(ci);
1477	ci.busnum = udev->bus->busnum;
1478	ci.devnum = udev->devnum;
1479	ci.speed = udev->speed;
1480
1481	while (udev && udev->portnum != 0) {
1482		if (++ci.num_ports <= ARRAY_SIZE(ci.ports))
1483			ci.ports[ARRAY_SIZE(ci.ports) - ci.num_ports] =
1484					udev->portnum;
1485		udev = udev->parent;
1486	}
1487
1488	if (ci.num_ports < ARRAY_SIZE(ci.ports))
1489		memmove(&ci.ports[0],
1490			&ci.ports[ARRAY_SIZE(ci.ports) - ci.num_ports],
1491			ci.num_ports);
1492
1493	if (copy_to_user(arg, &ci, min(sizeof(ci), size)))
1494		return -EFAULT;
1495
1496	return 0;
1497}
1498
1499static int proc_resetdevice(struct usb_dev_state *ps)
1500{
1501	struct usb_host_config *actconfig = ps->dev->actconfig;
1502	struct usb_interface *interface;
1503	int i, number;
1504
1505	/* Don't allow a device reset if the process has dropped the
1506	 * privilege to do such things and any of the interfaces are
1507	 * currently claimed.
1508	 */
1509	if (ps->privileges_dropped && actconfig) {
1510		for (i = 0; i < actconfig->desc.bNumInterfaces; ++i) {
1511			interface = actconfig->interface[i];
1512			number = interface->cur_altsetting->desc.bInterfaceNumber;
1513			if (usb_interface_claimed(interface) &&
1514					!test_bit(number, &ps->ifclaimed)) {
1515				dev_warn(&ps->dev->dev,
1516					"usbfs: interface %d claimed by %s while '%s' resets device\n",
1517					number,	interface->dev.driver->name, current->comm);
1518				return -EACCES;
1519			}
1520		}
1521	}
1522
1523	return usb_reset_device(ps->dev);
1524}
1525
1526static int proc_setintf(struct usb_dev_state *ps, void __user *arg)
1527{
1528	struct usbdevfs_setinterface setintf;
1529	int ret;
1530
1531	if (copy_from_user(&setintf, arg, sizeof(setintf)))
1532		return -EFAULT;
1533	ret = checkintf(ps, setintf.interface);
1534	if (ret)
1535		return ret;
1536
1537	destroy_async_on_interface(ps, setintf.interface);
1538
1539	return usb_set_interface(ps->dev, setintf.interface,
1540			setintf.altsetting);
1541}
1542
1543static int proc_setconfig(struct usb_dev_state *ps, void __user *arg)
1544{
1545	int u;
1546	int status = 0;
1547	struct usb_host_config *actconfig;
1548
1549	if (get_user(u, (int __user *)arg))
1550		return -EFAULT;
1551
1552	actconfig = ps->dev->actconfig;
1553
1554	/* Don't touch the device if any interfaces are claimed.
1555	 * It could interfere with other drivers' operations, and if
1556	 * an interface is claimed by usbfs it could easily deadlock.
1557	 */
1558	if (actconfig) {
1559		int i;
1560
1561		for (i = 0; i < actconfig->desc.bNumInterfaces; ++i) {
1562			if (usb_interface_claimed(actconfig->interface[i])) {
1563				dev_warn(&ps->dev->dev,
1564					"usbfs: interface %d claimed by %s "
1565					"while '%s' sets config #%d\n",
1566					actconfig->interface[i]
1567						->cur_altsetting
1568						->desc.bInterfaceNumber,
1569					actconfig->interface[i]
1570						->dev.driver->name,
1571					current->comm, u);
1572				status = -EBUSY;
1573				break;
1574			}
1575		}
1576	}
1577
1578	/* SET_CONFIGURATION is often abused as a "cheap" driver reset,
1579	 * so avoid usb_set_configuration()'s kick to sysfs
1580	 */
1581	if (status == 0) {
1582		if (actconfig && actconfig->desc.bConfigurationValue == u)
1583			status = usb_reset_configuration(ps->dev);
1584		else
1585			status = usb_set_configuration(ps->dev, u);
1586	}
1587
1588	return status;
1589}
1590
1591static struct usb_memory *
1592find_memory_area(struct usb_dev_state *ps, const struct usbdevfs_urb *uurb)
1593{
1594	struct usb_memory *usbm = NULL, *iter;
1595	unsigned long flags;
1596	unsigned long uurb_start = (unsigned long)uurb->buffer;
1597
1598	spin_lock_irqsave(&ps->lock, flags);
1599	list_for_each_entry(iter, &ps->memory_list, memlist) {
1600		if (uurb_start >= iter->vm_start &&
1601				uurb_start < iter->vm_start + iter->size) {
1602			if (uurb->buffer_length > iter->vm_start + iter->size -
1603					uurb_start) {
1604				usbm = ERR_PTR(-EINVAL);
1605			} else {
1606				usbm = iter;
1607				usbm->urb_use_count++;
1608			}
1609			break;
1610		}
1611	}
1612	spin_unlock_irqrestore(&ps->lock, flags);
1613	return usbm;
1614}
1615
1616static int proc_do_submiturb(struct usb_dev_state *ps, struct usbdevfs_urb *uurb,
1617			struct usbdevfs_iso_packet_desc __user *iso_frame_desc,
1618			void __user *arg, sigval_t userurb_sigval)
1619{
1620	struct usbdevfs_iso_packet_desc *isopkt = NULL;
1621	struct usb_host_endpoint *ep;
1622	struct async *as = NULL;
1623	struct usb_ctrlrequest *dr = NULL;
1624	unsigned int u, totlen, isofrmlen;
1625	int i, ret, num_sgs = 0, ifnum = -1;
1626	int number_of_packets = 0;
1627	unsigned int stream_id = 0;
1628	void *buf;
1629	bool is_in;
1630	bool allow_short = false;
1631	bool allow_zero = false;
1632	unsigned long mask =	USBDEVFS_URB_SHORT_NOT_OK |
1633				USBDEVFS_URB_BULK_CONTINUATION |
1634				USBDEVFS_URB_NO_FSBR |
1635				USBDEVFS_URB_ZERO_PACKET |
1636				USBDEVFS_URB_NO_INTERRUPT;
1637	/* USBDEVFS_URB_ISO_ASAP is a special case */
1638	if (uurb->type == USBDEVFS_URB_TYPE_ISO)
1639		mask |= USBDEVFS_URB_ISO_ASAP;
1640
1641	if (uurb->flags & ~mask)
1642			return -EINVAL;
1643
1644	if ((unsigned int)uurb->buffer_length >= USBFS_XFER_MAX)
1645		return -EINVAL;
1646	if (uurb->buffer_length > 0 && !uurb->buffer)
1647		return -EINVAL;
1648	if (!(uurb->type == USBDEVFS_URB_TYPE_CONTROL &&
1649	    (uurb->endpoint & ~USB_ENDPOINT_DIR_MASK) == 0)) {
1650		ifnum = findintfep(ps->dev, uurb->endpoint);
1651		if (ifnum < 0)
1652			return ifnum;
1653		ret = checkintf(ps, ifnum);
1654		if (ret)
1655			return ret;
1656	}
1657	ep = ep_to_host_endpoint(ps->dev, uurb->endpoint);
 
 
 
 
 
 
1658	if (!ep)
1659		return -ENOENT;
1660	is_in = (uurb->endpoint & USB_ENDPOINT_DIR_MASK) != 0;
1661
1662	u = 0;
1663	switch (uurb->type) {
1664	case USBDEVFS_URB_TYPE_CONTROL:
1665		if (!usb_endpoint_xfer_control(&ep->desc))
1666			return -EINVAL;
1667		/* min 8 byte setup packet */
1668		if (uurb->buffer_length < 8)
1669			return -EINVAL;
1670		dr = kmalloc(sizeof(struct usb_ctrlrequest), GFP_KERNEL);
1671		if (!dr)
1672			return -ENOMEM;
1673		if (copy_from_user(dr, uurb->buffer, 8)) {
1674			ret = -EFAULT;
1675			goto error;
1676		}
1677		if (uurb->buffer_length < (le16_to_cpu(dr->wLength) + 8)) {
1678			ret = -EINVAL;
1679			goto error;
1680		}
1681		ret = check_ctrlrecip(ps, dr->bRequestType, dr->bRequest,
1682				      le16_to_cpu(dr->wIndex));
1683		if (ret)
1684			goto error;
1685		uurb->buffer_length = le16_to_cpu(dr->wLength);
 
1686		uurb->buffer += 8;
1687		if ((dr->bRequestType & USB_DIR_IN) && uurb->buffer_length) {
1688			is_in = true;
1689			uurb->endpoint |= USB_DIR_IN;
1690		} else {
1691			is_in = false;
1692			uurb->endpoint &= ~USB_DIR_IN;
1693		}
1694		if (is_in)
1695			allow_short = true;
1696		snoop(&ps->dev->dev, "control urb: bRequestType=%02x "
1697			"bRequest=%02x wValue=%04x "
1698			"wIndex=%04x wLength=%04x\n",
1699			dr->bRequestType, dr->bRequest,
1700			__le16_to_cpu(dr->wValue),
1701			__le16_to_cpu(dr->wIndex),
1702			__le16_to_cpu(dr->wLength));
1703		u = sizeof(struct usb_ctrlrequest);
1704		break;
1705
1706	case USBDEVFS_URB_TYPE_BULK:
1707		if (!is_in)
1708			allow_zero = true;
1709		else
1710			allow_short = true;
1711		switch (usb_endpoint_type(&ep->desc)) {
1712		case USB_ENDPOINT_XFER_CONTROL:
1713		case USB_ENDPOINT_XFER_ISOC:
1714			return -EINVAL;
1715		case USB_ENDPOINT_XFER_INT:
1716			/* allow single-shot interrupt transfers */
1717			uurb->type = USBDEVFS_URB_TYPE_INTERRUPT;
1718			goto interrupt_urb;
1719		}
1720		num_sgs = DIV_ROUND_UP(uurb->buffer_length, USB_SG_SIZE);
1721		if (num_sgs == 1 || num_sgs > ps->dev->bus->sg_tablesize)
1722			num_sgs = 0;
1723		if (ep->streams)
1724			stream_id = uurb->stream_id;
1725		break;
1726
1727	case USBDEVFS_URB_TYPE_INTERRUPT:
1728		if (!usb_endpoint_xfer_int(&ep->desc))
1729			return -EINVAL;
1730 interrupt_urb:
1731		if (!is_in)
1732			allow_zero = true;
1733		else
1734			allow_short = true;
1735		break;
1736
1737	case USBDEVFS_URB_TYPE_ISO:
1738		/* arbitrary limit */
1739		if (uurb->number_of_packets < 1 ||
1740		    uurb->number_of_packets > 128)
1741			return -EINVAL;
1742		if (!usb_endpoint_xfer_isoc(&ep->desc))
1743			return -EINVAL;
1744		number_of_packets = uurb->number_of_packets;
1745		isofrmlen = sizeof(struct usbdevfs_iso_packet_desc) *
1746				   number_of_packets;
1747		isopkt = memdup_user(iso_frame_desc, isofrmlen);
1748		if (IS_ERR(isopkt)) {
1749			ret = PTR_ERR(isopkt);
1750			isopkt = NULL;
1751			goto error;
1752		}
1753		for (totlen = u = 0; u < number_of_packets; u++) {
1754			/*
1755			 * arbitrary limit need for USB 3.1 Gen2
1756			 * sizemax: 96 DPs at SSP, 96 * 1024 = 98304
1757			 */
1758			if (isopkt[u].length > 98304) {
1759				ret = -EINVAL;
1760				goto error;
1761			}
1762			totlen += isopkt[u].length;
1763		}
1764		u *= sizeof(struct usb_iso_packet_descriptor);
1765		uurb->buffer_length = totlen;
1766		break;
1767
1768	default:
1769		return -EINVAL;
1770	}
1771
 
 
 
 
1772	if (uurb->buffer_length > 0 &&
1773			!access_ok(uurb->buffer, uurb->buffer_length)) {
 
1774		ret = -EFAULT;
1775		goto error;
1776	}
1777	as = alloc_async(number_of_packets);
1778	if (!as) {
1779		ret = -ENOMEM;
1780		goto error;
1781	}
1782
1783	as->usbm = find_memory_area(ps, uurb);
1784	if (IS_ERR(as->usbm)) {
1785		ret = PTR_ERR(as->usbm);
1786		as->usbm = NULL;
1787		goto error;
1788	}
1789
1790	/* do not use SG buffers when memory mapped segments
1791	 * are in use
1792	 */
1793	if (as->usbm)
1794		num_sgs = 0;
1795
1796	u += sizeof(struct async) + sizeof(struct urb) +
1797	     (as->usbm ? 0 : uurb->buffer_length) +
1798	     num_sgs * sizeof(struct scatterlist);
1799	ret = usbfs_increase_memory_usage(u);
1800	if (ret)
1801		goto error;
1802	as->mem_usage = u;
1803
1804	if (num_sgs) {
1805		as->urb->sg = kmalloc_array(num_sgs,
1806					    sizeof(struct scatterlist),
1807					    GFP_KERNEL | __GFP_NOWARN);
1808		if (!as->urb->sg) {
1809			ret = -ENOMEM;
1810			goto error;
1811		}
1812		as->urb->num_sgs = num_sgs;
1813		sg_init_table(as->urb->sg, as->urb->num_sgs);
1814
1815		totlen = uurb->buffer_length;
1816		for (i = 0; i < as->urb->num_sgs; i++) {
1817			u = (totlen > USB_SG_SIZE) ? USB_SG_SIZE : totlen;
1818			buf = kmalloc(u, GFP_KERNEL);
1819			if (!buf) {
1820				ret = -ENOMEM;
1821				goto error;
1822			}
1823			sg_set_buf(&as->urb->sg[i], buf, u);
1824
1825			if (!is_in) {
1826				if (copy_from_user(buf, uurb->buffer, u)) {
1827					ret = -EFAULT;
1828					goto error;
1829				}
1830				uurb->buffer += u;
1831			}
1832			totlen -= u;
1833		}
1834	} else if (uurb->buffer_length > 0) {
1835		if (as->usbm) {
1836			unsigned long uurb_start = (unsigned long)uurb->buffer;
1837
1838			as->urb->transfer_buffer = as->usbm->mem +
1839					(uurb_start - as->usbm->vm_start);
1840		} else {
1841			as->urb->transfer_buffer = kmalloc(uurb->buffer_length,
1842					GFP_KERNEL | __GFP_NOWARN);
1843			if (!as->urb->transfer_buffer) {
1844				ret = -ENOMEM;
1845				goto error;
1846			}
1847			if (!is_in) {
1848				if (copy_from_user(as->urb->transfer_buffer,
1849						   uurb->buffer,
1850						   uurb->buffer_length)) {
1851					ret = -EFAULT;
1852					goto error;
1853				}
1854			} else if (uurb->type == USBDEVFS_URB_TYPE_ISO) {
1855				/*
1856				 * Isochronous input data may end up being
1857				 * discontiguous if some of the packets are
1858				 * short. Clear the buffer so that the gaps
1859				 * don't leak kernel data to userspace.
1860				 */
1861				memset(as->urb->transfer_buffer, 0,
1862						uurb->buffer_length);
1863			}
1864		}
1865	}
1866	as->urb->dev = ps->dev;
1867	as->urb->pipe = (uurb->type << 30) |
1868			__create_pipe(ps->dev, uurb->endpoint & 0xf) |
1869			(uurb->endpoint & USB_DIR_IN);
1870
1871	/* This tedious sequence is necessary because the URB_* flags
1872	 * are internal to the kernel and subject to change, whereas
1873	 * the USBDEVFS_URB_* flags are a user API and must not be changed.
1874	 */
1875	u = (is_in ? URB_DIR_IN : URB_DIR_OUT);
1876	if (uurb->flags & USBDEVFS_URB_ISO_ASAP)
1877		u |= URB_ISO_ASAP;
1878	if (allow_short && uurb->flags & USBDEVFS_URB_SHORT_NOT_OK)
1879		u |= URB_SHORT_NOT_OK;
1880	if (allow_zero && uurb->flags & USBDEVFS_URB_ZERO_PACKET)
 
 
1881		u |= URB_ZERO_PACKET;
1882	if (uurb->flags & USBDEVFS_URB_NO_INTERRUPT)
1883		u |= URB_NO_INTERRUPT;
1884	as->urb->transfer_flags = u;
1885
1886	if (!allow_short && uurb->flags & USBDEVFS_URB_SHORT_NOT_OK)
1887		dev_warn(&ps->dev->dev, "Requested nonsensical USBDEVFS_URB_SHORT_NOT_OK.\n");
1888	if (!allow_zero && uurb->flags & USBDEVFS_URB_ZERO_PACKET)
1889		dev_warn(&ps->dev->dev, "Requested nonsensical USBDEVFS_URB_ZERO_PACKET.\n");
1890
1891	as->urb->transfer_buffer_length = uurb->buffer_length;
1892	as->urb->setup_packet = (unsigned char *)dr;
1893	dr = NULL;
1894	as->urb->start_frame = uurb->start_frame;
1895	as->urb->number_of_packets = number_of_packets;
1896	as->urb->stream_id = stream_id;
1897
1898	if (ep->desc.bInterval) {
1899		if (uurb->type == USBDEVFS_URB_TYPE_ISO ||
1900				ps->dev->speed == USB_SPEED_HIGH ||
1901				ps->dev->speed >= USB_SPEED_SUPER)
1902			as->urb->interval = 1 <<
1903					min(15, ep->desc.bInterval - 1);
1904		else
1905			as->urb->interval = ep->desc.bInterval;
1906	}
1907
1908	as->urb->context = as;
1909	as->urb->complete = async_completed;
1910	for (totlen = u = 0; u < number_of_packets; u++) {
1911		as->urb->iso_frame_desc[u].offset = totlen;
1912		as->urb->iso_frame_desc[u].length = isopkt[u].length;
1913		totlen += isopkt[u].length;
1914	}
1915	kfree(isopkt);
1916	isopkt = NULL;
1917	as->ps = ps;
1918	as->userurb = arg;
1919	as->userurb_sigval = userurb_sigval;
1920	if (as->usbm) {
1921		unsigned long uurb_start = (unsigned long)uurb->buffer;
1922
1923		as->urb->transfer_flags |= URB_NO_TRANSFER_DMA_MAP;
1924		as->urb->transfer_dma = as->usbm->dma_handle +
1925				(uurb_start - as->usbm->vm_start);
1926	} else if (is_in && uurb->buffer_length > 0)
1927		as->userbuffer = uurb->buffer;
 
 
1928	as->signr = uurb->signr;
1929	as->ifnum = ifnum;
1930	as->pid = get_pid(task_pid(current));
1931	as->cred = get_current_cred();
 
 
 
 
 
 
 
 
1932	snoop_urb(ps->dev, as->userurb, as->urb->pipe,
1933			as->urb->transfer_buffer_length, 0, SUBMIT,
1934			NULL, 0);
1935	if (!is_in)
1936		snoop_urb_data(as->urb, as->urb->transfer_buffer_length);
1937
1938	async_newpending(as);
1939
1940	if (usb_endpoint_xfer_bulk(&ep->desc)) {
1941		spin_lock_irq(&ps->lock);
1942
1943		/* Not exactly the endpoint address; the direction bit is
1944		 * shifted to the 0x10 position so that the value will be
1945		 * between 0 and 31.
1946		 */
1947		as->bulk_addr = usb_endpoint_num(&ep->desc) |
1948			((ep->desc.bEndpointAddress & USB_ENDPOINT_DIR_MASK)
1949				>> 3);
1950
1951		/* If this bulk URB is the start of a new transfer, re-enable
1952		 * the endpoint.  Otherwise mark it as a continuation URB.
1953		 */
1954		if (uurb->flags & USBDEVFS_URB_BULK_CONTINUATION)
1955			as->bulk_status = AS_CONTINUATION;
1956		else
1957			ps->disabled_bulk_eps &= ~(1 << as->bulk_addr);
1958
1959		/* Don't accept continuation URBs if the endpoint is
1960		 * disabled because of an earlier error.
1961		 */
1962		if (ps->disabled_bulk_eps & (1 << as->bulk_addr))
1963			ret = -EREMOTEIO;
1964		else
1965			ret = usb_submit_urb(as->urb, GFP_ATOMIC);
1966		spin_unlock_irq(&ps->lock);
1967	} else {
1968		ret = usb_submit_urb(as->urb, GFP_KERNEL);
1969	}
1970
1971	if (ret) {
1972		dev_printk(KERN_DEBUG, &ps->dev->dev,
1973			   "usbfs: usb_submit_urb returned %d\n", ret);
1974		snoop_urb(ps->dev, as->userurb, as->urb->pipe,
1975				0, ret, COMPLETE, NULL, 0);
1976		async_removepending(as);
1977		goto error;
1978	}
1979	return 0;
1980
1981 error:
1982	kfree(isopkt);
1983	kfree(dr);
1984	if (as)
1985		free_async(as);
1986	return ret;
1987}
1988
1989static int proc_submiturb(struct usb_dev_state *ps, void __user *arg)
1990{
1991	struct usbdevfs_urb uurb;
1992	sigval_t userurb_sigval;
1993
1994	if (copy_from_user(&uurb, arg, sizeof(uurb)))
1995		return -EFAULT;
1996
1997	memset(&userurb_sigval, 0, sizeof(userurb_sigval));
1998	userurb_sigval.sival_ptr = arg;
1999
2000	return proc_do_submiturb(ps, &uurb,
2001			(((struct usbdevfs_urb __user *)arg)->iso_frame_desc),
2002			arg, userurb_sigval);
2003}
2004
2005static int proc_unlinkurb(struct usb_dev_state *ps, void __user *arg)
2006{
2007	struct urb *urb;
2008	struct async *as;
2009	unsigned long flags;
2010
2011	spin_lock_irqsave(&ps->lock, flags);
2012	as = async_getpending(ps, arg);
2013	if (!as) {
2014		spin_unlock_irqrestore(&ps->lock, flags);
2015		return -EINVAL;
2016	}
2017
2018	urb = as->urb;
2019	usb_get_urb(urb);
2020	spin_unlock_irqrestore(&ps->lock, flags);
2021
2022	usb_kill_urb(urb);
2023	usb_put_urb(urb);
2024
2025	return 0;
2026}
2027
2028static void compute_isochronous_actual_length(struct urb *urb)
2029{
2030	unsigned int i;
2031
2032	if (urb->number_of_packets > 0) {
2033		urb->actual_length = 0;
2034		for (i = 0; i < urb->number_of_packets; i++)
2035			urb->actual_length +=
2036					urb->iso_frame_desc[i].actual_length;
2037	}
2038}
2039
2040static int processcompl(struct async *as, void __user * __user *arg)
2041{
2042	struct urb *urb = as->urb;
2043	struct usbdevfs_urb __user *userurb = as->userurb;
2044	void __user *addr = as->userurb;
2045	unsigned int i;
2046
2047	compute_isochronous_actual_length(urb);
2048	if (as->userbuffer && urb->actual_length) {
2049		if (copy_urb_data_to_user(as->userbuffer, urb))
 
 
 
 
2050			goto err_out;
2051	}
2052	if (put_user(as->status, &userurb->status))
2053		goto err_out;
2054	if (put_user(urb->actual_length, &userurb->actual_length))
2055		goto err_out;
2056	if (put_user(urb->error_count, &userurb->error_count))
2057		goto err_out;
2058
2059	if (usb_endpoint_xfer_isoc(&urb->ep->desc)) {
2060		for (i = 0; i < urb->number_of_packets; i++) {
2061			if (put_user(urb->iso_frame_desc[i].actual_length,
2062				     &userurb->iso_frame_desc[i].actual_length))
2063				goto err_out;
2064			if (put_user(urb->iso_frame_desc[i].status,
2065				     &userurb->iso_frame_desc[i].status))
2066				goto err_out;
2067		}
2068	}
2069
2070	if (put_user(addr, (void __user * __user *)arg))
2071		return -EFAULT;
2072	return 0;
2073
2074err_out:
2075	return -EFAULT;
2076}
2077
2078static struct async *reap_as(struct usb_dev_state *ps)
2079{
2080	DECLARE_WAITQUEUE(wait, current);
2081	struct async *as = NULL;
2082	struct usb_device *dev = ps->dev;
2083
2084	add_wait_queue(&ps->wait, &wait);
2085	for (;;) {
2086		__set_current_state(TASK_INTERRUPTIBLE);
2087		as = async_getcompleted(ps);
2088		if (as || !connected(ps))
2089			break;
2090		if (signal_pending(current))
2091			break;
2092		usb_unlock_device(dev);
2093		schedule();
2094		usb_lock_device(dev);
2095	}
2096	remove_wait_queue(&ps->wait, &wait);
2097	set_current_state(TASK_RUNNING);
2098	return as;
2099}
2100
2101static int proc_reapurb(struct usb_dev_state *ps, void __user *arg)
2102{
2103	struct async *as = reap_as(ps);
2104
2105	if (as) {
2106		int retval;
2107
2108		snoop(&ps->dev->dev, "reap %px\n", as->userurb);
2109		retval = processcompl(as, (void __user * __user *)arg);
2110		free_async(as);
2111		return retval;
2112	}
2113	if (signal_pending(current))
2114		return -EINTR;
2115	return -ENODEV;
2116}
2117
2118static int proc_reapurbnonblock(struct usb_dev_state *ps, void __user *arg)
2119{
2120	int retval;
2121	struct async *as;
2122
2123	as = async_getcompleted(ps);
 
2124	if (as) {
2125		snoop(&ps->dev->dev, "reap %px\n", as->userurb);
2126		retval = processcompl(as, (void __user * __user *)arg);
2127		free_async(as);
2128	} else {
2129		retval = (connected(ps) ? -EAGAIN : -ENODEV);
2130	}
2131	return retval;
2132}
2133
2134#ifdef CONFIG_COMPAT
2135static int proc_control_compat(struct usb_dev_state *ps,
2136				struct usbdevfs_ctrltransfer32 __user *p32)
2137{
2138	struct usbdevfs_ctrltransfer ctrl;
2139	u32 udata;
2140
2141	if (copy_from_user(&ctrl, p32, sizeof(*p32) - sizeof(compat_caddr_t)) ||
2142	    get_user(udata, &p32->data))
 
2143		return -EFAULT;
2144	ctrl.data = compat_ptr(udata);
2145	return do_proc_control(ps, &ctrl);
2146}
2147
2148static int proc_bulk_compat(struct usb_dev_state *ps,
2149			struct usbdevfs_bulktransfer32 __user *p32)
2150{
2151	struct usbdevfs_bulktransfer bulk;
2152	compat_caddr_t addr;
 
2153
2154	if (get_user(bulk.ep, &p32->ep) ||
2155	    get_user(bulk.len, &p32->len) ||
2156	    get_user(bulk.timeout, &p32->timeout) ||
2157	    get_user(addr, &p32->data))
2158		return -EFAULT;
2159	bulk.data = compat_ptr(addr);
2160	return do_proc_bulk(ps, &bulk);
2161}
2162
2163static int proc_disconnectsignal_compat(struct usb_dev_state *ps, void __user *arg)
 
 
2164{
2165	struct usbdevfs_disconnectsignal32 ds;
2166
2167	if (copy_from_user(&ds, arg, sizeof(ds)))
2168		return -EFAULT;
2169	ps->discsignr = ds.signr;
2170	ps->disccontext.sival_int = ds.context;
2171	return 0;
2172}
2173
2174static int get_urb32(struct usbdevfs_urb *kurb,
2175		     struct usbdevfs_urb32 __user *uurb)
2176{
2177	struct usbdevfs_urb32 urb32;
2178	if (copy_from_user(&urb32, uurb, sizeof(*uurb)))
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
2179		return -EFAULT;
2180	kurb->type = urb32.type;
2181	kurb->endpoint = urb32.endpoint;
2182	kurb->status = urb32.status;
2183	kurb->flags = urb32.flags;
2184	kurb->buffer = compat_ptr(urb32.buffer);
2185	kurb->buffer_length = urb32.buffer_length;
2186	kurb->actual_length = urb32.actual_length;
2187	kurb->start_frame = urb32.start_frame;
2188	kurb->number_of_packets = urb32.number_of_packets;
2189	kurb->error_count = urb32.error_count;
2190	kurb->signr = urb32.signr;
2191	kurb->usercontext = compat_ptr(urb32.usercontext);
2192	return 0;
2193}
2194
2195static int proc_submiturb_compat(struct usb_dev_state *ps, void __user *arg)
2196{
2197	struct usbdevfs_urb uurb;
2198	sigval_t userurb_sigval;
2199
2200	if (get_urb32(&uurb, (struct usbdevfs_urb32 __user *)arg))
2201		return -EFAULT;
2202
2203	memset(&userurb_sigval, 0, sizeof(userurb_sigval));
2204	userurb_sigval.sival_int = ptr_to_compat(arg);
2205
2206	return proc_do_submiturb(ps, &uurb,
2207			((struct usbdevfs_urb32 __user *)arg)->iso_frame_desc,
2208			arg, userurb_sigval);
2209}
2210
2211static int processcompl_compat(struct async *as, void __user * __user *arg)
2212{
2213	struct urb *urb = as->urb;
2214	struct usbdevfs_urb32 __user *userurb = as->userurb;
2215	void __user *addr = as->userurb;
2216	unsigned int i;
2217
2218	compute_isochronous_actual_length(urb);
2219	if (as->userbuffer && urb->actual_length) {
2220		if (copy_urb_data_to_user(as->userbuffer, urb))
 
 
 
 
2221			return -EFAULT;
2222	}
2223	if (put_user(as->status, &userurb->status))
2224		return -EFAULT;
2225	if (put_user(urb->actual_length, &userurb->actual_length))
2226		return -EFAULT;
2227	if (put_user(urb->error_count, &userurb->error_count))
2228		return -EFAULT;
2229
2230	if (usb_endpoint_xfer_isoc(&urb->ep->desc)) {
2231		for (i = 0; i < urb->number_of_packets; i++) {
2232			if (put_user(urb->iso_frame_desc[i].actual_length,
2233				     &userurb->iso_frame_desc[i].actual_length))
2234				return -EFAULT;
2235			if (put_user(urb->iso_frame_desc[i].status,
2236				     &userurb->iso_frame_desc[i].status))
2237				return -EFAULT;
2238		}
2239	}
2240
2241	if (put_user(ptr_to_compat(addr), (u32 __user *)arg))
2242		return -EFAULT;
2243	return 0;
2244}
2245
2246static int proc_reapurb_compat(struct usb_dev_state *ps, void __user *arg)
2247{
2248	struct async *as = reap_as(ps);
2249
2250	if (as) {
2251		int retval;
2252
2253		snoop(&ps->dev->dev, "reap %px\n", as->userurb);
2254		retval = processcompl_compat(as, (void __user * __user *)arg);
2255		free_async(as);
2256		return retval;
2257	}
2258	if (signal_pending(current))
2259		return -EINTR;
2260	return -ENODEV;
2261}
2262
2263static int proc_reapurbnonblock_compat(struct usb_dev_state *ps, void __user *arg)
2264{
2265	int retval;
2266	struct async *as;
2267
 
2268	as = async_getcompleted(ps);
2269	if (as) {
2270		snoop(&ps->dev->dev, "reap %px\n", as->userurb);
2271		retval = processcompl_compat(as, (void __user * __user *)arg);
2272		free_async(as);
2273	} else {
2274		retval = (connected(ps) ? -EAGAIN : -ENODEV);
2275	}
2276	return retval;
2277}
2278
2279
2280#endif
2281
2282static int proc_disconnectsignal(struct usb_dev_state *ps, void __user *arg)
2283{
2284	struct usbdevfs_disconnectsignal ds;
2285
2286	if (copy_from_user(&ds, arg, sizeof(ds)))
2287		return -EFAULT;
2288	ps->discsignr = ds.signr;
2289	ps->disccontext.sival_ptr = ds.context;
2290	return 0;
2291}
2292
2293static int proc_claiminterface(struct usb_dev_state *ps, void __user *arg)
2294{
2295	unsigned int ifnum;
2296
2297	if (get_user(ifnum, (unsigned int __user *)arg))
2298		return -EFAULT;
2299	return claimintf(ps, ifnum);
2300}
2301
2302static int proc_releaseinterface(struct usb_dev_state *ps, void __user *arg)
2303{
2304	unsigned int ifnum;
2305	int ret;
2306
2307	if (get_user(ifnum, (unsigned int __user *)arg))
2308		return -EFAULT;
2309	ret = releaseintf(ps, ifnum);
2310	if (ret < 0)
2311		return ret;
2312	destroy_async_on_interface(ps, ifnum);
2313	return 0;
2314}
2315
2316static int proc_ioctl(struct usb_dev_state *ps, struct usbdevfs_ioctl *ctl)
2317{
2318	int			size;
2319	void			*buf = NULL;
2320	int			retval = 0;
2321	struct usb_interface    *intf = NULL;
2322	struct usb_driver       *driver = NULL;
2323
2324	if (ps->privileges_dropped)
2325		return -EACCES;
2326
2327	if (!connected(ps))
2328		return -ENODEV;
2329
2330	/* alloc buffer */
2331	size = _IOC_SIZE(ctl->ioctl_code);
2332	if (size > 0) {
2333		buf = kmalloc(size, GFP_KERNEL);
2334		if (buf == NULL)
2335			return -ENOMEM;
2336		if ((_IOC_DIR(ctl->ioctl_code) & _IOC_WRITE)) {
2337			if (copy_from_user(buf, ctl->data, size)) {
2338				kfree(buf);
2339				return -EFAULT;
2340			}
2341		} else {
2342			memset(buf, 0, size);
2343		}
2344	}
2345
 
 
 
 
 
2346	if (ps->dev->state != USB_STATE_CONFIGURED)
2347		retval = -EHOSTUNREACH;
2348	else if (!(intf = usb_ifnum_to_if(ps->dev, ctl->ifno)))
2349		retval = -EINVAL;
2350	else switch (ctl->ioctl_code) {
2351
2352	/* disconnect kernel driver from interface */
2353	case USBDEVFS_DISCONNECT:
2354		if (intf->dev.driver) {
2355			driver = to_usb_driver(intf->dev.driver);
2356			dev_dbg(&intf->dev, "disconnect by usbfs\n");
2357			usb_driver_release_interface(driver, intf);
2358		} else
2359			retval = -ENODATA;
2360		break;
2361
2362	/* let kernel drivers try to (re)bind to the interface */
2363	case USBDEVFS_CONNECT:
2364		if (!intf->dev.driver)
2365			retval = device_attach(&intf->dev);
2366		else
2367			retval = -EBUSY;
2368		break;
2369
2370	/* talk directly to the interface's driver */
2371	default:
2372		if (intf->dev.driver)
2373			driver = to_usb_driver(intf->dev.driver);
2374		if (driver == NULL || driver->unlocked_ioctl == NULL) {
2375			retval = -ENOTTY;
2376		} else {
2377			retval = driver->unlocked_ioctl(intf, ctl->ioctl_code, buf);
2378			if (retval == -ENOIOCTLCMD)
2379				retval = -ENOTTY;
2380		}
2381	}
2382
2383	/* cleanup and return */
2384	if (retval >= 0
2385			&& (_IOC_DIR(ctl->ioctl_code) & _IOC_READ) != 0
2386			&& size > 0
2387			&& copy_to_user(ctl->data, buf, size) != 0)
2388		retval = -EFAULT;
2389
2390	kfree(buf);
2391	return retval;
2392}
2393
2394static int proc_ioctl_default(struct usb_dev_state *ps, void __user *arg)
2395{
2396	struct usbdevfs_ioctl	ctrl;
2397
2398	if (copy_from_user(&ctrl, arg, sizeof(ctrl)))
2399		return -EFAULT;
2400	return proc_ioctl(ps, &ctrl);
2401}
2402
2403#ifdef CONFIG_COMPAT
2404static int proc_ioctl_compat(struct usb_dev_state *ps, compat_uptr_t arg)
2405{
2406	struct usbdevfs_ioctl32 ioc32;
2407	struct usbdevfs_ioctl ctrl;
 
2408
2409	if (copy_from_user(&ioc32, compat_ptr(arg), sizeof(ioc32)))
 
 
 
 
2410		return -EFAULT;
2411	ctrl.ifno = ioc32.ifno;
2412	ctrl.ioctl_code = ioc32.ioctl_code;
2413	ctrl.data = compat_ptr(ioc32.data);
2414	return proc_ioctl(ps, &ctrl);
2415}
2416#endif
2417
2418static int proc_claim_port(struct usb_dev_state *ps, void __user *arg)
2419{
2420	unsigned portnum;
2421	int rc;
2422
2423	if (get_user(portnum, (unsigned __user *) arg))
2424		return -EFAULT;
2425	rc = usb_hub_claim_port(ps->dev, portnum, ps);
2426	if (rc == 0)
2427		snoop(&ps->dev->dev, "port %d claimed by process %d: %s\n",
2428			portnum, task_pid_nr(current), current->comm);
2429	return rc;
2430}
2431
2432static int proc_release_port(struct usb_dev_state *ps, void __user *arg)
2433{
2434	unsigned portnum;
2435
2436	if (get_user(portnum, (unsigned __user *) arg))
2437		return -EFAULT;
2438	return usb_hub_release_port(ps->dev, portnum, ps);
2439}
2440
2441static int proc_get_capabilities(struct usb_dev_state *ps, void __user *arg)
2442{
2443	__u32 caps;
2444
2445	caps = USBDEVFS_CAP_ZERO_PACKET | USBDEVFS_CAP_NO_PACKET_SIZE_LIM |
2446			USBDEVFS_CAP_REAP_AFTER_DISCONNECT | USBDEVFS_CAP_MMAP |
2447			USBDEVFS_CAP_DROP_PRIVILEGES |
2448			USBDEVFS_CAP_CONNINFO_EX | MAYBE_CAP_SUSPEND;
2449	if (!ps->dev->bus->no_stop_on_short)
2450		caps |= USBDEVFS_CAP_BULK_CONTINUATION;
2451	if (ps->dev->bus->sg_tablesize)
2452		caps |= USBDEVFS_CAP_BULK_SCATTER_GATHER;
2453
2454	if (put_user(caps, (__u32 __user *)arg))
2455		return -EFAULT;
2456
2457	return 0;
2458}
2459
2460static int proc_disconnect_claim(struct usb_dev_state *ps, void __user *arg)
2461{
2462	struct usbdevfs_disconnect_claim dc;
2463	struct usb_interface *intf;
2464
2465	if (copy_from_user(&dc, arg, sizeof(dc)))
2466		return -EFAULT;
2467
2468	intf = usb_ifnum_to_if(ps->dev, dc.interface);
2469	if (!intf)
2470		return -EINVAL;
2471
2472	if (intf->dev.driver) {
2473		struct usb_driver *driver = to_usb_driver(intf->dev.driver);
2474
2475		if (ps->privileges_dropped)
2476			return -EACCES;
2477
2478		if ((dc.flags & USBDEVFS_DISCONNECT_CLAIM_IF_DRIVER) &&
2479				strncmp(dc.driver, intf->dev.driver->name,
2480					sizeof(dc.driver)) != 0)
2481			return -EBUSY;
2482
2483		if ((dc.flags & USBDEVFS_DISCONNECT_CLAIM_EXCEPT_DRIVER) &&
2484				strncmp(dc.driver, intf->dev.driver->name,
2485					sizeof(dc.driver)) == 0)
2486			return -EBUSY;
2487
2488		dev_dbg(&intf->dev, "disconnect by usbfs\n");
2489		usb_driver_release_interface(driver, intf);
2490	}
2491
2492	return claimintf(ps, dc.interface);
2493}
2494
2495static int proc_alloc_streams(struct usb_dev_state *ps, void __user *arg)
2496{
2497	unsigned num_streams, num_eps;
2498	struct usb_host_endpoint **eps;
2499	struct usb_interface *intf;
2500	int r;
2501
2502	r = parse_usbdevfs_streams(ps, arg, &num_streams, &num_eps,
2503				   &eps, &intf);
2504	if (r)
2505		return r;
2506
2507	destroy_async_on_interface(ps,
2508				   intf->altsetting[0].desc.bInterfaceNumber);
2509
2510	r = usb_alloc_streams(intf, eps, num_eps, num_streams, GFP_KERNEL);
2511	kfree(eps);
2512	return r;
2513}
2514
2515static int proc_free_streams(struct usb_dev_state *ps, void __user *arg)
2516{
2517	unsigned num_eps;
2518	struct usb_host_endpoint **eps;
2519	struct usb_interface *intf;
2520	int r;
2521
2522	r = parse_usbdevfs_streams(ps, arg, NULL, &num_eps, &eps, &intf);
2523	if (r)
2524		return r;
2525
2526	destroy_async_on_interface(ps,
2527				   intf->altsetting[0].desc.bInterfaceNumber);
2528
2529	r = usb_free_streams(intf, eps, num_eps, GFP_KERNEL);
2530	kfree(eps);
2531	return r;
2532}
2533
2534static int proc_drop_privileges(struct usb_dev_state *ps, void __user *arg)
2535{
2536	u32 data;
2537
2538	if (copy_from_user(&data, arg, sizeof(data)))
2539		return -EFAULT;
2540
2541	/* This is a one way operation. Once privileges are
2542	 * dropped, you cannot regain them. You may however reissue
2543	 * this ioctl to shrink the allowed interfaces mask.
2544	 */
2545	ps->interface_allowed_mask &= data;
2546	ps->privileges_dropped = true;
2547
2548	return 0;
2549}
2550
2551static int proc_forbid_suspend(struct usb_dev_state *ps)
2552{
2553	int ret = 0;
2554
2555	if (ps->suspend_allowed) {
2556		ret = usb_autoresume_device(ps->dev);
2557		if (ret == 0)
2558			ps->suspend_allowed = false;
2559		else if (ret != -ENODEV)
2560			ret = -EIO;
2561	}
2562	return ret;
2563}
2564
2565static int proc_allow_suspend(struct usb_dev_state *ps)
2566{
2567	if (!connected(ps))
2568		return -ENODEV;
2569
2570	WRITE_ONCE(ps->not_yet_resumed, 1);
2571	if (!ps->suspend_allowed) {
2572		usb_autosuspend_device(ps->dev);
2573		ps->suspend_allowed = true;
2574	}
2575	return 0;
2576}
2577
2578static int proc_wait_for_resume(struct usb_dev_state *ps)
2579{
2580	int ret;
2581
2582	usb_unlock_device(ps->dev);
2583	ret = wait_event_interruptible(ps->wait_for_resume,
2584			READ_ONCE(ps->not_yet_resumed) == 0);
2585	usb_lock_device(ps->dev);
2586
2587	if (ret != 0)
2588		return -EINTR;
2589	return proc_forbid_suspend(ps);
2590}
2591
2592/*
2593 * NOTE:  All requests here that have interface numbers as parameters
2594 * are assuming that somehow the configuration has been prevented from
2595 * changing.  But there's no mechanism to ensure that...
2596 */
2597static long usbdev_do_ioctl(struct file *file, unsigned int cmd,
2598				void __user *p)
2599{
2600	struct usb_dev_state *ps = file->private_data;
2601	struct inode *inode = file_inode(file);
2602	struct usb_device *dev = ps->dev;
2603	int ret = -ENOTTY;
2604
2605	if (!(file->f_mode & FMODE_WRITE))
2606		return -EPERM;
2607
2608	usb_lock_device(dev);
2609
2610	/* Reap operations are allowed even after disconnection */
2611	switch (cmd) {
2612	case USBDEVFS_REAPURB:
2613		snoop(&dev->dev, "%s: REAPURB\n", __func__);
2614		ret = proc_reapurb(ps, p);
2615		goto done;
2616
2617	case USBDEVFS_REAPURBNDELAY:
2618		snoop(&dev->dev, "%s: REAPURBNDELAY\n", __func__);
2619		ret = proc_reapurbnonblock(ps, p);
2620		goto done;
2621
2622#ifdef CONFIG_COMPAT
2623	case USBDEVFS_REAPURB32:
2624		snoop(&dev->dev, "%s: REAPURB32\n", __func__);
2625		ret = proc_reapurb_compat(ps, p);
2626		goto done;
2627
2628	case USBDEVFS_REAPURBNDELAY32:
2629		snoop(&dev->dev, "%s: REAPURBNDELAY32\n", __func__);
2630		ret = proc_reapurbnonblock_compat(ps, p);
2631		goto done;
2632#endif
2633	}
2634
2635	if (!connected(ps)) {
2636		usb_unlock_device(dev);
2637		return -ENODEV;
2638	}
2639
2640	switch (cmd) {
2641	case USBDEVFS_CONTROL:
2642		snoop(&dev->dev, "%s: CONTROL\n", __func__);
2643		ret = proc_control(ps, p);
2644		if (ret >= 0)
2645			inode_set_mtime_to_ts(inode,
2646					      inode_set_ctime_current(inode));
2647		break;
2648
2649	case USBDEVFS_BULK:
2650		snoop(&dev->dev, "%s: BULK\n", __func__);
2651		ret = proc_bulk(ps, p);
2652		if (ret >= 0)
2653			inode_set_mtime_to_ts(inode,
2654					      inode_set_ctime_current(inode));
2655		break;
2656
2657	case USBDEVFS_RESETEP:
2658		snoop(&dev->dev, "%s: RESETEP\n", __func__);
2659		ret = proc_resetep(ps, p);
2660		if (ret >= 0)
2661			inode_set_mtime_to_ts(inode,
2662					      inode_set_ctime_current(inode));
2663		break;
2664
2665	case USBDEVFS_RESET:
2666		snoop(&dev->dev, "%s: RESET\n", __func__);
2667		ret = proc_resetdevice(ps);
2668		break;
2669
2670	case USBDEVFS_CLEAR_HALT:
2671		snoop(&dev->dev, "%s: CLEAR_HALT\n", __func__);
2672		ret = proc_clearhalt(ps, p);
2673		if (ret >= 0)
2674			inode_set_mtime_to_ts(inode,
2675					      inode_set_ctime_current(inode));
2676		break;
2677
2678	case USBDEVFS_GETDRIVER:
2679		snoop(&dev->dev, "%s: GETDRIVER\n", __func__);
2680		ret = proc_getdriver(ps, p);
2681		break;
2682
2683	case USBDEVFS_CONNECTINFO:
2684		snoop(&dev->dev, "%s: CONNECTINFO\n", __func__);
2685		ret = proc_connectinfo(ps, p);
2686		break;
2687
2688	case USBDEVFS_SETINTERFACE:
2689		snoop(&dev->dev, "%s: SETINTERFACE\n", __func__);
2690		ret = proc_setintf(ps, p);
2691		break;
2692
2693	case USBDEVFS_SETCONFIGURATION:
2694		snoop(&dev->dev, "%s: SETCONFIGURATION\n", __func__);
2695		ret = proc_setconfig(ps, p);
2696		break;
2697
2698	case USBDEVFS_SUBMITURB:
2699		snoop(&dev->dev, "%s: SUBMITURB\n", __func__);
2700		ret = proc_submiturb(ps, p);
2701		if (ret >= 0)
2702			inode_set_mtime_to_ts(inode,
2703					      inode_set_ctime_current(inode));
2704		break;
2705
2706#ifdef CONFIG_COMPAT
2707	case USBDEVFS_CONTROL32:
2708		snoop(&dev->dev, "%s: CONTROL32\n", __func__);
2709		ret = proc_control_compat(ps, p);
2710		if (ret >= 0)
2711			inode_set_mtime_to_ts(inode,
2712					      inode_set_ctime_current(inode));
2713		break;
2714
2715	case USBDEVFS_BULK32:
2716		snoop(&dev->dev, "%s: BULK32\n", __func__);
2717		ret = proc_bulk_compat(ps, p);
2718		if (ret >= 0)
2719			inode_set_mtime_to_ts(inode,
2720					      inode_set_ctime_current(inode));
2721		break;
2722
2723	case USBDEVFS_DISCSIGNAL32:
2724		snoop(&dev->dev, "%s: DISCSIGNAL32\n", __func__);
2725		ret = proc_disconnectsignal_compat(ps, p);
2726		break;
2727
2728	case USBDEVFS_SUBMITURB32:
2729		snoop(&dev->dev, "%s: SUBMITURB32\n", __func__);
2730		ret = proc_submiturb_compat(ps, p);
2731		if (ret >= 0)
2732			inode_set_mtime_to_ts(inode,
2733					      inode_set_ctime_current(inode));
 
 
 
 
 
 
 
 
 
2734		break;
2735
2736	case USBDEVFS_IOCTL32:
2737		snoop(&dev->dev, "%s: IOCTL32\n", __func__);
2738		ret = proc_ioctl_compat(ps, ptr_to_compat(p));
2739		break;
2740#endif
2741
2742	case USBDEVFS_DISCARDURB:
2743		snoop(&dev->dev, "%s: DISCARDURB %px\n", __func__, p);
2744		ret = proc_unlinkurb(ps, p);
2745		break;
2746
 
 
 
 
 
 
 
 
 
 
2747	case USBDEVFS_DISCSIGNAL:
2748		snoop(&dev->dev, "%s: DISCSIGNAL\n", __func__);
2749		ret = proc_disconnectsignal(ps, p);
2750		break;
2751
2752	case USBDEVFS_CLAIMINTERFACE:
2753		snoop(&dev->dev, "%s: CLAIMINTERFACE\n", __func__);
2754		ret = proc_claiminterface(ps, p);
2755		break;
2756
2757	case USBDEVFS_RELEASEINTERFACE:
2758		snoop(&dev->dev, "%s: RELEASEINTERFACE\n", __func__);
2759		ret = proc_releaseinterface(ps, p);
2760		break;
2761
2762	case USBDEVFS_IOCTL:
2763		snoop(&dev->dev, "%s: IOCTL\n", __func__);
2764		ret = proc_ioctl_default(ps, p);
2765		break;
2766
2767	case USBDEVFS_CLAIM_PORT:
2768		snoop(&dev->dev, "%s: CLAIM_PORT\n", __func__);
2769		ret = proc_claim_port(ps, p);
2770		break;
2771
2772	case USBDEVFS_RELEASE_PORT:
2773		snoop(&dev->dev, "%s: RELEASE_PORT\n", __func__);
2774		ret = proc_release_port(ps, p);
2775		break;
2776	case USBDEVFS_GET_CAPABILITIES:
2777		ret = proc_get_capabilities(ps, p);
2778		break;
2779	case USBDEVFS_DISCONNECT_CLAIM:
2780		ret = proc_disconnect_claim(ps, p);
2781		break;
2782	case USBDEVFS_ALLOC_STREAMS:
2783		ret = proc_alloc_streams(ps, p);
2784		break;
2785	case USBDEVFS_FREE_STREAMS:
2786		ret = proc_free_streams(ps, p);
2787		break;
2788	case USBDEVFS_DROP_PRIVILEGES:
2789		ret = proc_drop_privileges(ps, p);
2790		break;
2791	case USBDEVFS_GET_SPEED:
2792		ret = ps->dev->speed;
2793		break;
2794	case USBDEVFS_FORBID_SUSPEND:
2795		ret = proc_forbid_suspend(ps);
2796		break;
2797	case USBDEVFS_ALLOW_SUSPEND:
2798		ret = proc_allow_suspend(ps);
2799		break;
2800	case USBDEVFS_WAIT_FOR_RESUME:
2801		ret = proc_wait_for_resume(ps);
2802		break;
2803	}
2804
2805	/* Handle variable-length commands */
2806	switch (cmd & ~IOCSIZE_MASK) {
2807	case USBDEVFS_CONNINFO_EX(0):
2808		ret = proc_conninfo_ex(ps, p, _IOC_SIZE(cmd));
2809		break;
2810	}
2811
2812 done:
2813	usb_unlock_device(dev);
2814	if (ret >= 0)
2815		inode_set_atime_to_ts(inode, current_time(inode));
2816	return ret;
2817}
2818
2819static long usbdev_ioctl(struct file *file, unsigned int cmd,
2820			unsigned long arg)
2821{
2822	int ret;
2823
2824	ret = usbdev_do_ioctl(file, cmd, (void __user *)arg);
2825
2826	return ret;
2827}
2828
 
 
 
 
 
 
 
 
 
 
 
 
2829/* No kernel lock - fine */
2830static __poll_t usbdev_poll(struct file *file,
2831				struct poll_table_struct *wait)
2832{
2833	struct usb_dev_state *ps = file->private_data;
2834	__poll_t mask = 0;
2835
2836	poll_wait(file, &ps->wait, wait);
2837	if (file->f_mode & FMODE_WRITE && !list_empty(&ps->async_completed))
2838		mask |= EPOLLOUT | EPOLLWRNORM;
2839	if (!connected(ps))
2840		mask |= EPOLLHUP;
2841	if (list_empty(&ps->list))
2842		mask |= EPOLLERR;
2843	return mask;
2844}
2845
2846const struct file_operations usbdev_file_operations = {
2847	.owner =	  THIS_MODULE,
2848	.llseek =	  no_seek_end_llseek,
2849	.read =		  usbdev_read,
2850	.poll =		  usbdev_poll,
2851	.unlocked_ioctl = usbdev_ioctl,
2852	.compat_ioctl =   compat_ptr_ioctl,
2853	.mmap =           usbdev_mmap,
 
2854	.open =		  usbdev_open,
2855	.release =	  usbdev_release,
2856};
2857
2858static void usbdev_remove(struct usb_device *udev)
2859{
2860	struct usb_dev_state *ps;
 
2861
2862	/* Protect against simultaneous resume */
2863	mutex_lock(&usbfs_mutex);
2864	while (!list_empty(&udev->filelist)) {
2865		ps = list_entry(udev->filelist.next, struct usb_dev_state, list);
2866		destroy_all_async(ps);
2867		wake_up_all(&ps->wait);
2868		WRITE_ONCE(ps->not_yet_resumed, 0);
2869		wake_up_all(&ps->wait_for_resume);
2870		list_del_init(&ps->list);
2871		if (ps->discsignr)
2872			kill_pid_usb_asyncio(ps->discsignr, EPIPE, ps->disccontext,
2873					     ps->disc_pid, ps->cred);
 
 
 
 
 
2874	}
2875	mutex_unlock(&usbfs_mutex);
2876}
2877
2878static int usbdev_notify(struct notifier_block *self,
2879			       unsigned long action, void *dev)
2880{
2881	switch (action) {
2882	case USB_DEVICE_ADD:
2883		break;
2884	case USB_DEVICE_REMOVE:
2885		usbdev_remove(dev);
2886		break;
2887	}
2888	return NOTIFY_OK;
2889}
2890
2891static struct notifier_block usbdev_nb = {
2892	.notifier_call =	usbdev_notify,
2893};
2894
2895static struct cdev usb_device_cdev;
2896
2897int __init usb_devio_init(void)
2898{
2899	int retval;
2900
2901	retval = register_chrdev_region(USB_DEVICE_DEV, USB_DEVICE_MAX,
2902					"usb_device");
2903	if (retval) {
2904		printk(KERN_ERR "Unable to register minors for usb_device\n");
2905		goto out;
2906	}
2907	cdev_init(&usb_device_cdev, &usbdev_file_operations);
2908	retval = cdev_add(&usb_device_cdev, USB_DEVICE_DEV, USB_DEVICE_MAX);
2909	if (retval) {
2910		printk(KERN_ERR "Unable to get usb_device major %d\n",
2911		       USB_DEVICE_MAJOR);
2912		goto error_cdev;
2913	}
2914	usb_register_notify(&usbdev_nb);
2915out:
2916	return retval;
2917
2918error_cdev:
2919	unregister_chrdev_region(USB_DEVICE_DEV, USB_DEVICE_MAX);
2920	goto out;
2921}
2922
2923void usb_devio_cleanup(void)
2924{
2925	usb_unregister_notify(&usbdev_nb);
2926	cdev_del(&usb_device_cdev);
2927	unregister_chrdev_region(USB_DEVICE_DEV, USB_DEVICE_MAX);
2928}
v3.5.6
 
   1/*****************************************************************************/
   2
   3/*
   4 *      devio.c  --  User space communication with USB devices.
   5 *
   6 *      Copyright (C) 1999-2000  Thomas Sailer (sailer@ife.ee.ethz.ch)
   7 *
   8 *      This program is free software; you can redistribute it and/or modify
   9 *      it under the terms of the GNU General Public License as published by
  10 *      the Free Software Foundation; either version 2 of the License, or
  11 *      (at your option) any later version.
  12 *
  13 *      This program is distributed in the hope that it will be useful,
  14 *      but WITHOUT ANY WARRANTY; without even the implied warranty of
  15 *      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16 *      GNU General Public License for more details.
  17 *
  18 *      You should have received a copy of the GNU General Public License
  19 *      along with this program; if not, write to the Free Software
  20 *      Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  21 *
  22 *  This file implements the usbfs/x/y files, where
  23 *  x is the bus number and y the device number.
  24 *
  25 *  It allows user space programs/"drivers" to communicate directly
  26 *  with USB devices without intervening kernel driver.
  27 *
  28 *  Revision history
  29 *    22.12.1999   0.1   Initial release (split from proc_usb.c)
  30 *    04.01.2000   0.2   Turned into its own filesystem
  31 *    30.09.2005   0.3   Fix user-triggerable oops in async URB delivery
  32 *    			 (CAN-2005-3055)
  33 */
  34
  35/*****************************************************************************/
  36
  37#include <linux/fs.h>
  38#include <linux/mm.h>
 
  39#include <linux/slab.h>
  40#include <linux/signal.h>
  41#include <linux/poll.h>
  42#include <linux/module.h>
 
  43#include <linux/usb.h>
  44#include <linux/usbdevice_fs.h>
  45#include <linux/usb/hcd.h>	/* for usbcore internals */
 
  46#include <linux/cdev.h>
  47#include <linux/notifier.h>
  48#include <linux/security.h>
  49#include <linux/user_namespace.h>
  50#include <asm/uaccess.h>
 
 
  51#include <asm/byteorder.h>
  52#include <linux/moduleparam.h>
  53
  54#include "usb.h"
  55
 
 
 
 
 
 
  56#define USB_MAXBUS			64
  57#define USB_DEVICE_MAX			USB_MAXBUS * 128
 
  58
  59/* Mutual exclusion for removal, open, and release */
  60DEFINE_MUTEX(usbfs_mutex);
  61
  62struct dev_state {
  63	struct list_head list;      /* state list */
  64	struct usb_device *dev;
  65	struct file *file;
  66	spinlock_t lock;            /* protects the async urb lists */
  67	struct list_head async_pending;
  68	struct list_head async_completed;
 
  69	wait_queue_head_t wait;     /* wake up if a request completed */
 
  70	unsigned int discsignr;
  71	struct pid *disc_pid;
  72	const struct cred *cred;
  73	void __user *disccontext;
  74	unsigned long ifclaimed;
  75	u32 secid;
  76	u32 disabled_bulk_eps;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
  77};
  78
  79struct async {
  80	struct list_head asynclist;
  81	struct dev_state *ps;
  82	struct pid *pid;
  83	const struct cred *cred;
  84	unsigned int signr;
  85	unsigned int ifnum;
  86	void __user *userbuffer;
  87	void __user *userurb;
 
  88	struct urb *urb;
 
  89	unsigned int mem_usage;
  90	int status;
  91	u32 secid;
  92	u8 bulk_addr;
  93	u8 bulk_status;
  94};
  95
  96static bool usbfs_snoop;
  97module_param(usbfs_snoop, bool, S_IRUGO | S_IWUSR);
  98MODULE_PARM_DESC(usbfs_snoop, "true to log all usbfs traffic");
  99
 
 
 
 
 
 100#define snoop(dev, format, arg...)				\
 101	do {							\
 102		if (usbfs_snoop)				\
 103			dev_info(dev , format , ## arg);	\
 104	} while (0)
 105
 106enum snoop_when {
 107	SUBMIT, COMPLETE
 108};
 109
 110#define USB_DEVICE_DEV		MKDEV(USB_DEVICE_MAJOR, 0)
 111
 112/* Limit on the total amount of memory we can allocate for transfers */
 113static unsigned usbfs_memory_mb = 16;
 114module_param(usbfs_memory_mb, uint, 0644);
 115MODULE_PARM_DESC(usbfs_memory_mb,
 116		"maximum MB allowed for usbfs buffers (0 = no limit)");
 117
 118/* Hard limit, necessary to avoid aithmetic overflow */
 119#define USBFS_XFER_MAX		(UINT_MAX / 2 - 1000000)
 120
 121static atomic_t usbfs_memory_usage;	/* Total memory currently allocated */
 
 122
 123/* Check whether it's okay to allocate more memory for a transfer */
 124static int usbfs_increase_memory_usage(unsigned amount)
 125{
 126	unsigned lim;
 
 
 127
 128	/*
 129	 * Convert usbfs_memory_mb to bytes, avoiding overflows.
 130	 * 0 means use the hard limit (effectively unlimited).
 131	 */
 132	lim = ACCESS_ONCE(usbfs_memory_mb);
 133	if (lim == 0 || lim > (USBFS_XFER_MAX >> 20))
 134		lim = USBFS_XFER_MAX;
 
 135	else
 136		lim <<= 20;
 
 137
 138	atomic_add(amount, &usbfs_memory_usage);
 139	if (atomic_read(&usbfs_memory_usage) <= lim)
 140		return 0;
 141	atomic_sub(amount, &usbfs_memory_usage);
 142	return -ENOMEM;
 143}
 144
 145/* Memory for a transfer is being deallocated */
 146static void usbfs_decrease_memory_usage(unsigned amount)
 147{
 148	atomic_sub(amount, &usbfs_memory_usage);
 
 
 
 
 
 
 
 149}
 150
 151static int connected(struct dev_state *ps)
 152{
 153	return (!list_empty(&ps->list) &&
 154			ps->dev->state != USB_STATE_NOTATTACHED);
 155}
 156
 157static loff_t usbdev_lseek(struct file *file, loff_t offset, int orig)
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 158{
 159	loff_t ret;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 160
 161	mutex_lock(&file->f_dentry->d_inode->i_mutex);
 162
 163	switch (orig) {
 164	case 0:
 165		file->f_pos = offset;
 166		ret = file->f_pos;
 167		break;
 168	case 1:
 169		file->f_pos += offset;
 170		ret = file->f_pos;
 171		break;
 172	case 2:
 173	default:
 174		ret = -EINVAL;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 175	}
 176
 177	mutex_unlock(&file->f_dentry->d_inode->i_mutex);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 178	return ret;
 179}
 180
 181static ssize_t usbdev_read(struct file *file, char __user *buf, size_t nbytes,
 182			   loff_t *ppos)
 183{
 184	struct dev_state *ps = file->private_data;
 185	struct usb_device *dev = ps->dev;
 186	ssize_t ret = 0;
 187	unsigned len;
 188	loff_t pos;
 189	int i;
 190
 191	pos = *ppos;
 192	usb_lock_device(dev);
 193	if (!connected(ps)) {
 194		ret = -ENODEV;
 195		goto err;
 196	} else if (pos < 0) {
 197		ret = -EINVAL;
 198		goto err;
 199	}
 200
 201	if (pos < sizeof(struct usb_device_descriptor)) {
 202		/* 18 bytes - fits on the stack */
 203		struct usb_device_descriptor temp_desc;
 204
 205		memcpy(&temp_desc, &dev->descriptor, sizeof(dev->descriptor));
 206		le16_to_cpus(&temp_desc.bcdUSB);
 207		le16_to_cpus(&temp_desc.idVendor);
 208		le16_to_cpus(&temp_desc.idProduct);
 209		le16_to_cpus(&temp_desc.bcdDevice);
 210
 211		len = sizeof(struct usb_device_descriptor) - pos;
 212		if (len > nbytes)
 213			len = nbytes;
 214		if (copy_to_user(buf, ((char *)&temp_desc) + pos, len)) {
 215			ret = -EFAULT;
 216			goto err;
 217		}
 218
 219		*ppos += len;
 220		buf += len;
 221		nbytes -= len;
 222		ret += len;
 223	}
 224
 225	pos = sizeof(struct usb_device_descriptor);
 226	for (i = 0; nbytes && i < dev->descriptor.bNumConfigurations; i++) {
 227		struct usb_config_descriptor *config =
 228			(struct usb_config_descriptor *)dev->rawdescriptors[i];
 229		unsigned int length = le16_to_cpu(config->wTotalLength);
 230
 231		if (*ppos < pos + length) {
 232
 233			/* The descriptor may claim to be longer than it
 234			 * really is.  Here is the actual allocated length. */
 235			unsigned alloclen =
 236				le16_to_cpu(dev->config[i].desc.wTotalLength);
 237
 238			len = length - (*ppos - pos);
 239			if (len > nbytes)
 240				len = nbytes;
 241
 242			/* Simply don't write (skip over) unallocated parts */
 243			if (alloclen > (*ppos - pos)) {
 244				alloclen -= (*ppos - pos);
 245				if (copy_to_user(buf,
 246				    dev->rawdescriptors[i] + (*ppos - pos),
 247				    min(len, alloclen))) {
 248					ret = -EFAULT;
 249					goto err;
 250				}
 251			}
 252
 253			*ppos += len;
 254			buf += len;
 255			nbytes -= len;
 256			ret += len;
 257		}
 258
 259		pos += length;
 260	}
 261
 262err:
 263	usb_unlock_device(dev);
 264	return ret;
 265}
 266
 267/*
 268 * async list handling
 269 */
 270
 271static struct async *alloc_async(unsigned int numisoframes)
 272{
 273	struct async *as;
 274
 275	as = kzalloc(sizeof(struct async), GFP_KERNEL);
 276	if (!as)
 277		return NULL;
 278	as->urb = usb_alloc_urb(numisoframes, GFP_KERNEL);
 279	if (!as->urb) {
 280		kfree(as);
 281		return NULL;
 282	}
 283	return as;
 284}
 285
 286static void free_async(struct async *as)
 287{
 
 
 288	put_pid(as->pid);
 289	if (as->cred)
 290		put_cred(as->cred);
 291	kfree(as->urb->transfer_buffer);
 
 
 
 
 
 
 
 
 
 
 292	kfree(as->urb->setup_packet);
 293	usb_free_urb(as->urb);
 294	usbfs_decrease_memory_usage(as->mem_usage);
 295	kfree(as);
 296}
 297
 298static void async_newpending(struct async *as)
 299{
 300	struct dev_state *ps = as->ps;
 301	unsigned long flags;
 302
 303	spin_lock_irqsave(&ps->lock, flags);
 304	list_add_tail(&as->asynclist, &ps->async_pending);
 305	spin_unlock_irqrestore(&ps->lock, flags);
 306}
 307
 308static void async_removepending(struct async *as)
 309{
 310	struct dev_state *ps = as->ps;
 311	unsigned long flags;
 312
 313	spin_lock_irqsave(&ps->lock, flags);
 314	list_del_init(&as->asynclist);
 315	spin_unlock_irqrestore(&ps->lock, flags);
 316}
 317
 318static struct async *async_getcompleted(struct dev_state *ps)
 319{
 320	unsigned long flags;
 321	struct async *as = NULL;
 322
 323	spin_lock_irqsave(&ps->lock, flags);
 324	if (!list_empty(&ps->async_completed)) {
 325		as = list_entry(ps->async_completed.next, struct async,
 326				asynclist);
 327		list_del_init(&as->asynclist);
 328	}
 329	spin_unlock_irqrestore(&ps->lock, flags);
 330	return as;
 331}
 332
 333static struct async *async_getpending(struct dev_state *ps,
 334					     void __user *userurb)
 335{
 336	struct async *as;
 337
 338	list_for_each_entry(as, &ps->async_pending, asynclist)
 339		if (as->userurb == userurb) {
 340			list_del_init(&as->asynclist);
 341			return as;
 342		}
 343
 344	return NULL;
 345}
 346
 347static void snoop_urb(struct usb_device *udev,
 348		void __user *userurb, int pipe, unsigned length,
 349		int timeout_or_status, enum snoop_when when,
 350		unsigned char *data, unsigned data_len)
 351{
 352	static const char *types[] = {"isoc", "int", "ctrl", "bulk"};
 353	static const char *dirs[] = {"out", "in"};
 354	int ep;
 355	const char *t, *d;
 356
 357	if (!usbfs_snoop)
 358		return;
 359
 360	ep = usb_pipeendpoint(pipe);
 361	t = types[usb_pipetype(pipe)];
 362	d = dirs[!!usb_pipein(pipe)];
 363
 364	if (userurb) {		/* Async */
 365		if (when == SUBMIT)
 366			dev_info(&udev->dev, "userurb %p, ep%d %s-%s, "
 367					"length %u\n",
 368					userurb, ep, t, d, length);
 369		else
 370			dev_info(&udev->dev, "userurb %p, ep%d %s-%s, "
 371					"actual_length %u status %d\n",
 372					userurb, ep, t, d, length,
 373					timeout_or_status);
 374	} else {
 375		if (when == SUBMIT)
 376			dev_info(&udev->dev, "ep%d %s-%s, length %u, "
 377					"timeout %d\n",
 378					ep, t, d, length, timeout_or_status);
 379		else
 380			dev_info(&udev->dev, "ep%d %s-%s, actual_length %u, "
 381					"status %d\n",
 382					ep, t, d, length, timeout_or_status);
 383	}
 384
 
 385	if (data && data_len > 0) {
 386		print_hex_dump(KERN_DEBUG, "data: ", DUMP_PREFIX_NONE, 32, 1,
 387			data, data_len, 1);
 388	}
 389}
 390
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 391#define AS_CONTINUATION	1
 392#define AS_UNLINK	2
 393
 394static void cancel_bulk_urbs(struct dev_state *ps, unsigned bulk_addr)
 395__releases(ps->lock)
 396__acquires(ps->lock)
 397{
 398	struct urb *urb;
 399	struct async *as;
 400
 401	/* Mark all the pending URBs that match bulk_addr, up to but not
 402	 * including the first one without AS_CONTINUATION.  If such an
 403	 * URB is encountered then a new transfer has already started so
 404	 * the endpoint doesn't need to be disabled; otherwise it does.
 405	 */
 406	list_for_each_entry(as, &ps->async_pending, asynclist) {
 407		if (as->bulk_addr == bulk_addr) {
 408			if (as->bulk_status != AS_CONTINUATION)
 409				goto rescan;
 410			as->bulk_status = AS_UNLINK;
 411			as->bulk_addr = 0;
 412		}
 413	}
 414	ps->disabled_bulk_eps |= (1 << bulk_addr);
 415
 416	/* Now carefully unlink all the marked pending URBs */
 417 rescan:
 418	list_for_each_entry(as, &ps->async_pending, asynclist) {
 419		if (as->bulk_status == AS_UNLINK) {
 420			as->bulk_status = 0;		/* Only once */
 421			urb = as->urb;
 422			usb_get_urb(urb);
 423			spin_unlock(&ps->lock);		/* Allow completions */
 424			usb_unlink_urb(urb);
 425			usb_put_urb(urb);
 426			spin_lock(&ps->lock);
 427			goto rescan;
 428		}
 429	}
 430}
 431
 432static void async_completed(struct urb *urb)
 433{
 434	struct async *as = urb->context;
 435	struct dev_state *ps = as->ps;
 436	struct siginfo sinfo;
 437	struct pid *pid = NULL;
 438	u32 secid = 0;
 439	const struct cred *cred = NULL;
 440	int signr;
 
 
 441
 442	spin_lock(&ps->lock);
 443	list_move_tail(&as->asynclist, &ps->async_completed);
 444	as->status = urb->status;
 445	signr = as->signr;
 446	if (signr) {
 447		sinfo.si_signo = as->signr;
 448		sinfo.si_errno = as->status;
 449		sinfo.si_code = SI_ASYNCIO;
 450		sinfo.si_addr = as->userurb;
 451		pid = get_pid(as->pid);
 452		cred = get_cred(as->cred);
 453		secid = as->secid;
 454	}
 455	snoop(&urb->dev->dev, "urb complete\n");
 456	snoop_urb(urb->dev, as->userurb, urb->pipe, urb->actual_length,
 457			as->status, COMPLETE,
 458			((urb->transfer_flags & URB_DIR_MASK) == USB_DIR_OUT) ?
 459				NULL : urb->transfer_buffer, urb->actual_length);
 
 460	if (as->status < 0 && as->bulk_addr && as->status != -ECONNRESET &&
 461			as->status != -ENOENT)
 462		cancel_bulk_urbs(ps, as->bulk_addr);
 463	spin_unlock(&ps->lock);
 
 
 464
 465	if (signr) {
 466		kill_pid_info_as_cred(sinfo.si_signo, &sinfo, pid, cred, secid);
 467		put_pid(pid);
 468		put_cred(cred);
 469	}
 470
 471	wake_up(&ps->wait);
 472}
 473
 474static void destroy_async(struct dev_state *ps, struct list_head *list)
 475{
 476	struct urb *urb;
 477	struct async *as;
 478	unsigned long flags;
 479
 480	spin_lock_irqsave(&ps->lock, flags);
 481	while (!list_empty(list)) {
 482		as = list_entry(list->next, struct async, asynclist);
 483		list_del_init(&as->asynclist);
 484		urb = as->urb;
 485		usb_get_urb(urb);
 486
 487		/* drop the spinlock so the completion handler can run */
 488		spin_unlock_irqrestore(&ps->lock, flags);
 489		usb_kill_urb(urb);
 490		usb_put_urb(urb);
 491		spin_lock_irqsave(&ps->lock, flags);
 492	}
 493	spin_unlock_irqrestore(&ps->lock, flags);
 494}
 495
 496static void destroy_async_on_interface(struct dev_state *ps,
 497				       unsigned int ifnum)
 498{
 499	struct list_head *p, *q, hitlist;
 500	unsigned long flags;
 501
 502	INIT_LIST_HEAD(&hitlist);
 503	spin_lock_irqsave(&ps->lock, flags);
 504	list_for_each_safe(p, q, &ps->async_pending)
 505		if (ifnum == list_entry(p, struct async, asynclist)->ifnum)
 506			list_move_tail(p, &hitlist);
 507	spin_unlock_irqrestore(&ps->lock, flags);
 508	destroy_async(ps, &hitlist);
 509}
 510
 511static void destroy_all_async(struct dev_state *ps)
 512{
 513	destroy_async(ps, &ps->async_pending);
 514}
 515
 516/*
 517 * interface claims are made only at the request of user level code,
 518 * which can also release them (explicitly or by closing files).
 519 * they're also undone when devices disconnect.
 520 */
 521
 522static int driver_probe(struct usb_interface *intf,
 523			const struct usb_device_id *id)
 524{
 525	return -ENODEV;
 526}
 527
 528static void driver_disconnect(struct usb_interface *intf)
 529{
 530	struct dev_state *ps = usb_get_intfdata(intf);
 531	unsigned int ifnum = intf->altsetting->desc.bInterfaceNumber;
 532
 533	if (!ps)
 534		return;
 535
 536	/* NOTE:  this relies on usbcore having canceled and completed
 537	 * all pending I/O requests; 2.6 does that.
 538	 */
 539
 540	if (likely(ifnum < 8*sizeof(ps->ifclaimed)))
 541		clear_bit(ifnum, &ps->ifclaimed);
 542	else
 543		dev_warn(&intf->dev, "interface number %u out of range\n",
 544			 ifnum);
 545
 546	usb_set_intfdata(intf, NULL);
 547
 548	/* force async requests to complete */
 549	destroy_async_on_interface(ps, ifnum);
 550}
 551
 552/* The following routines are merely placeholders.  There is no way
 553 * to inform a user task about suspend or resumes.
 554 */
 555static int driver_suspend(struct usb_interface *intf, pm_message_t msg)
 556{
 557	return 0;
 558}
 559
 560static int driver_resume(struct usb_interface *intf)
 561{
 562	return 0;
 563}
 564
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 565struct usb_driver usbfs_driver = {
 566	.name =		"usbfs",
 567	.probe =	driver_probe,
 568	.disconnect =	driver_disconnect,
 569	.suspend =	driver_suspend,
 570	.resume =	driver_resume,
 
 571};
 572
 573static int claimintf(struct dev_state *ps, unsigned int ifnum)
 574{
 575	struct usb_device *dev = ps->dev;
 576	struct usb_interface *intf;
 577	int err;
 578
 579	if (ifnum >= 8*sizeof(ps->ifclaimed))
 580		return -EINVAL;
 581	/* already claimed */
 582	if (test_bit(ifnum, &ps->ifclaimed))
 583		return 0;
 584
 
 
 
 
 585	intf = usb_ifnum_to_if(dev, ifnum);
 586	if (!intf)
 587		err = -ENOENT;
 588	else
 
 
 
 
 
 589		err = usb_driver_claim_interface(&usbfs_driver, intf, ps);
 
 
 590	if (err == 0)
 591		set_bit(ifnum, &ps->ifclaimed);
 592	return err;
 593}
 594
 595static int releaseintf(struct dev_state *ps, unsigned int ifnum)
 596{
 597	struct usb_device *dev;
 598	struct usb_interface *intf;
 599	int err;
 600
 601	err = -EINVAL;
 602	if (ifnum >= 8*sizeof(ps->ifclaimed))
 603		return err;
 604	dev = ps->dev;
 605	intf = usb_ifnum_to_if(dev, ifnum);
 606	if (!intf)
 607		err = -ENOENT;
 608	else if (test_and_clear_bit(ifnum, &ps->ifclaimed)) {
 
 
 
 
 
 609		usb_driver_release_interface(&usbfs_driver, intf);
 
 610		err = 0;
 611	}
 612	return err;
 613}
 614
 615static int checkintf(struct dev_state *ps, unsigned int ifnum)
 616{
 617	if (ps->dev->state != USB_STATE_CONFIGURED)
 618		return -EHOSTUNREACH;
 619	if (ifnum >= 8*sizeof(ps->ifclaimed))
 620		return -EINVAL;
 621	if (test_bit(ifnum, &ps->ifclaimed))
 622		return 0;
 623	/* if not yet claimed, claim it for the driver */
 624	dev_warn(&ps->dev->dev, "usbfs: process %d (%s) did not claim "
 625		 "interface %u before use\n", task_pid_nr(current),
 626		 current->comm, ifnum);
 627	return claimintf(ps, ifnum);
 628}
 629
 630static int findintfep(struct usb_device *dev, unsigned int ep)
 631{
 632	unsigned int i, j, e;
 633	struct usb_interface *intf;
 634	struct usb_host_interface *alts;
 635	struct usb_endpoint_descriptor *endpt;
 636
 637	if (ep & ~(USB_DIR_IN|0xf))
 638		return -EINVAL;
 639	if (!dev->actconfig)
 640		return -ESRCH;
 641	for (i = 0; i < dev->actconfig->desc.bNumInterfaces; i++) {
 642		intf = dev->actconfig->interface[i];
 643		for (j = 0; j < intf->num_altsetting; j++) {
 644			alts = &intf->altsetting[j];
 645			for (e = 0; e < alts->desc.bNumEndpoints; e++) {
 646				endpt = &alts->endpoint[e].desc;
 647				if (endpt->bEndpointAddress == ep)
 648					return alts->desc.bInterfaceNumber;
 649			}
 650		}
 651	}
 652	return -ENOENT;
 653}
 654
 655static int check_ctrlrecip(struct dev_state *ps, unsigned int requesttype,
 656			   unsigned int request, unsigned int index)
 657{
 658	int ret = 0;
 659	struct usb_host_interface *alt_setting;
 660
 661	if (ps->dev->state != USB_STATE_UNAUTHENTICATED
 662	 && ps->dev->state != USB_STATE_ADDRESS
 663	 && ps->dev->state != USB_STATE_CONFIGURED)
 664		return -EHOSTUNREACH;
 665	if (USB_TYPE_VENDOR == (USB_TYPE_MASK & requesttype))
 666		return 0;
 667
 668	/*
 669	 * check for the special corner case 'get_device_id' in the printer
 670	 * class specification, where wIndex is (interface << 8 | altsetting)
 671	 * instead of just interface
 672	 */
 673	if (requesttype == 0xa1 && request == 0) {
 674		alt_setting = usb_find_alt_setting(ps->dev->actconfig,
 675						   index >> 8, index & 0xff);
 676		if (alt_setting
 677		 && alt_setting->desc.bInterfaceClass == USB_CLASS_PRINTER)
 678			index >>= 8;
 679	}
 680
 681	index &= 0xff;
 682	switch (requesttype & USB_RECIP_MASK) {
 683	case USB_RECIP_ENDPOINT:
 
 
 684		ret = findintfep(ps->dev, index);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 685		if (ret >= 0)
 686			ret = checkintf(ps, ret);
 687		break;
 688
 689	case USB_RECIP_INTERFACE:
 690		ret = checkintf(ps, index);
 691		break;
 692	}
 693	return ret;
 694}
 695
 696static int match_devt(struct device *dev, void *data)
 
 697{
 698	return dev->devt == (dev_t) (unsigned long) data;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 699}
 700
 701static struct usb_device *usbdev_lookup_by_devt(dev_t devt)
 702{
 703	struct device *dev;
 704
 705	dev = bus_find_device(&usb_bus_type, NULL,
 706			      (void *) (unsigned long) devt, match_devt);
 707	if (!dev)
 708		return NULL;
 709	return container_of(dev, struct usb_device, dev);
 710}
 711
 712/*
 713 * file operations
 714 */
 715static int usbdev_open(struct inode *inode, struct file *file)
 716{
 717	struct usb_device *dev = NULL;
 718	struct dev_state *ps;
 719	int ret;
 720
 721	ret = -ENOMEM;
 722	ps = kmalloc(sizeof(struct dev_state), GFP_KERNEL);
 723	if (!ps)
 724		goto out_free_ps;
 725
 726	ret = -ENODEV;
 727
 728	/* Protect against simultaneous removal or release */
 729	mutex_lock(&usbfs_mutex);
 730
 731	/* usbdev device-node */
 732	if (imajor(inode) == USB_DEVICE_MAJOR)
 733		dev = usbdev_lookup_by_devt(inode->i_rdev);
 734
 735	mutex_unlock(&usbfs_mutex);
 736
 737	if (!dev)
 738		goto out_free_ps;
 739
 740	usb_lock_device(dev);
 741	if (dev->state == USB_STATE_NOTATTACHED)
 742		goto out_unlock_device;
 743
 744	ret = usb_autoresume_device(dev);
 745	if (ret)
 746		goto out_unlock_device;
 747
 748	ps->dev = dev;
 749	ps->file = file;
 
 750	spin_lock_init(&ps->lock);
 751	INIT_LIST_HEAD(&ps->list);
 752	INIT_LIST_HEAD(&ps->async_pending);
 753	INIT_LIST_HEAD(&ps->async_completed);
 
 754	init_waitqueue_head(&ps->wait);
 755	ps->discsignr = 0;
 756	ps->disc_pid = get_pid(task_pid(current));
 757	ps->cred = get_current_cred();
 758	ps->disccontext = NULL;
 759	ps->ifclaimed = 0;
 760	security_task_getsecid(current, &ps->secid);
 761	smp_wmb();
 
 
 762	list_add_tail(&ps->list, &dev->filelist);
 763	file->private_data = ps;
 764	usb_unlock_device(dev);
 765	snoop(&dev->dev, "opened by process %d: %s\n", task_pid_nr(current),
 766			current->comm);
 767	return ret;
 768
 769 out_unlock_device:
 770	usb_unlock_device(dev);
 771	usb_put_dev(dev);
 772 out_free_ps:
 773	kfree(ps);
 774	return ret;
 775}
 776
 777static int usbdev_release(struct inode *inode, struct file *file)
 778{
 779	struct dev_state *ps = file->private_data;
 780	struct usb_device *dev = ps->dev;
 781	unsigned int ifnum;
 782	struct async *as;
 783
 784	usb_lock_device(dev);
 785	usb_hub_release_all_ports(dev, ps);
 786
 
 
 787	list_del_init(&ps->list);
 
 788
 789	for (ifnum = 0; ps->ifclaimed && ifnum < 8*sizeof(ps->ifclaimed);
 790			ifnum++) {
 791		if (test_bit(ifnum, &ps->ifclaimed))
 792			releaseintf(ps, ifnum);
 793	}
 794	destroy_all_async(ps);
 795	usb_autosuspend_device(dev);
 
 796	usb_unlock_device(dev);
 797	usb_put_dev(dev);
 798	put_pid(ps->disc_pid);
 799	put_cred(ps->cred);
 800
 801	as = async_getcompleted(ps);
 802	while (as) {
 803		free_async(as);
 804		as = async_getcompleted(ps);
 805	}
 
 806	kfree(ps);
 807	return 0;
 808}
 809
 810static int proc_control(struct dev_state *ps, void __user *arg)
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 811{
 812	struct usb_device *dev = ps->dev;
 813	struct usbdevfs_ctrltransfer ctrl;
 814	unsigned int tmo;
 815	unsigned char *tbuf;
 816	unsigned wLength;
 817	int i, pipe, ret;
 
 
 818
 819	if (copy_from_user(&ctrl, arg, sizeof(ctrl)))
 820		return -EFAULT;
 821	ret = check_ctrlrecip(ps, ctrl.bRequestType, ctrl.bRequest,
 822			      ctrl.wIndex);
 823	if (ret)
 824		return ret;
 825	wLength = ctrl.wLength;		/* To suppress 64k PAGE_SIZE warning */
 826	if (wLength > PAGE_SIZE)
 827		return -EINVAL;
 828	ret = usbfs_increase_memory_usage(PAGE_SIZE + sizeof(struct urb) +
 829			sizeof(struct usb_ctrlrequest));
 830	if (ret)
 831		return ret;
 
 
 832	tbuf = (unsigned char *)__get_free_page(GFP_KERNEL);
 833	if (!tbuf) {
 834		ret = -ENOMEM;
 
 
 
 
 
 835		goto done;
 836	}
 837	tmo = ctrl.timeout;
 
 
 
 
 
 
 838	snoop(&dev->dev, "control urb: bRequestType=%02x "
 839		"bRequest=%02x wValue=%04x "
 840		"wIndex=%04x wLength=%04x\n",
 841		ctrl.bRequestType, ctrl.bRequest,
 842		__le16_to_cpup(&ctrl.wValue),
 843		__le16_to_cpup(&ctrl.wIndex),
 844		__le16_to_cpup(&ctrl.wLength));
 845	if (ctrl.bRequestType & 0x80) {
 846		if (ctrl.wLength && !access_ok(VERIFY_WRITE, ctrl.data,
 847					       ctrl.wLength)) {
 848			ret = -EINVAL;
 849			goto done;
 850		}
 851		pipe = usb_rcvctrlpipe(dev, 0);
 852		snoop_urb(dev, NULL, pipe, ctrl.wLength, tmo, SUBMIT, NULL, 0);
 
 
 853
 854		usb_unlock_device(dev);
 855		i = usb_control_msg(dev, pipe, ctrl.bRequest,
 856				    ctrl.bRequestType, ctrl.wValue, ctrl.wIndex,
 857				    tbuf, ctrl.wLength, tmo);
 
 
 858		usb_lock_device(dev);
 859		snoop_urb(dev, NULL, pipe, max(i, 0), min(i, 0), COMPLETE,
 860			  tbuf, max(i, 0));
 861		if ((i > 0) && ctrl.wLength) {
 862			if (copy_to_user(ctrl.data, tbuf, i)) {
 863				ret = -EFAULT;
 864				goto done;
 865			}
 866		}
 867	} else {
 868		if (ctrl.wLength) {
 869			if (copy_from_user(tbuf, ctrl.data, ctrl.wLength)) {
 870				ret = -EFAULT;
 871				goto done;
 872			}
 873		}
 874		pipe = usb_sndctrlpipe(dev, 0);
 875		snoop_urb(dev, NULL, pipe, ctrl.wLength, tmo, SUBMIT,
 876			tbuf, ctrl.wLength);
 
 877
 878		usb_unlock_device(dev);
 879		i = usb_control_msg(dev, usb_sndctrlpipe(dev, 0), ctrl.bRequest,
 880				    ctrl.bRequestType, ctrl.wValue, ctrl.wIndex,
 881				    tbuf, ctrl.wLength, tmo);
 
 
 882		usb_lock_device(dev);
 883		snoop_urb(dev, NULL, pipe, max(i, 0), min(i, 0), COMPLETE, NULL, 0);
 884	}
 885	if (i < 0 && i != -EPIPE) {
 886		dev_printk(KERN_DEBUG, &dev->dev, "usbfs: USBDEVFS_CONTROL "
 887			   "failed cmd %s rqt %u rq %u len %u ret %d\n",
 888			   current->comm, ctrl.bRequestType, ctrl.bRequest,
 889			   ctrl.wLength, i);
 890	}
 891	ret = i;
 
 892 done:
 
 
 893	free_page((unsigned long) tbuf);
 894	usbfs_decrease_memory_usage(PAGE_SIZE + sizeof(struct urb) +
 895			sizeof(struct usb_ctrlrequest));
 896	return ret;
 897}
 898
 899static int proc_bulk(struct dev_state *ps, void __user *arg)
 
 
 
 
 
 
 
 
 
 
 900{
 901	struct usb_device *dev = ps->dev;
 902	struct usbdevfs_bulktransfer bulk;
 903	unsigned int tmo, len1, pipe;
 904	int len2;
 905	unsigned char *tbuf;
 906	int i, ret;
 
 
 907
 908	if (copy_from_user(&bulk, arg, sizeof(bulk)))
 909		return -EFAULT;
 910	ret = findintfep(ps->dev, bulk.ep);
 911	if (ret < 0)
 912		return ret;
 913	ret = checkintf(ps, ret);
 914	if (ret)
 915		return ret;
 916	if (bulk.ep & USB_DIR_IN)
 917		pipe = usb_rcvbulkpipe(dev, bulk.ep & 0x7f);
 
 
 
 
 
 918	else
 919		pipe = usb_sndbulkpipe(dev, bulk.ep & 0x7f);
 920	if (!usb_maxpacket(dev, pipe, !(bulk.ep & USB_DIR_IN)))
 921		return -EINVAL;
 922	len1 = bulk.len;
 923	if (len1 >= USBFS_XFER_MAX)
 924		return -EINVAL;
 925	ret = usbfs_increase_memory_usage(len1 + sizeof(struct urb));
 926	if (ret)
 927		return ret;
 928	if (!(tbuf = kmalloc(len1, GFP_KERNEL))) {
 929		ret = -ENOMEM;
 
 
 
 
 
 
 
 
 
 930		goto done;
 
 
 
 
 
 
 
 
 931	}
 932	tmo = bulk.timeout;
 933	if (bulk.ep & 0x80) {
 934		if (len1 && !access_ok(VERIFY_WRITE, bulk.data, len1)) {
 935			ret = -EINVAL;
 936			goto done;
 937		}
 938		snoop_urb(dev, NULL, pipe, len1, tmo, SUBMIT, NULL, 0);
 939
 940		usb_unlock_device(dev);
 941		i = usb_bulk_msg(dev, pipe, tbuf, len1, &len2, tmo);
 942		usb_lock_device(dev);
 943		snoop_urb(dev, NULL, pipe, len2, i, COMPLETE, tbuf, len2);
 944
 945		if (!i && len2) {
 946			if (copy_to_user(bulk.data, tbuf, len2)) {
 947				ret = -EFAULT;
 948				goto done;
 949			}
 950		}
 951	} else {
 952		if (len1) {
 953			if (copy_from_user(tbuf, bulk.data, len1)) {
 954				ret = -EFAULT;
 955				goto done;
 956			}
 957		}
 958		snoop_urb(dev, NULL, pipe, len1, tmo, SUBMIT, tbuf, len1);
 959
 960		usb_unlock_device(dev);
 961		i = usb_bulk_msg(dev, pipe, tbuf, len1, &len2, tmo);
 962		usb_lock_device(dev);
 963		snoop_urb(dev, NULL, pipe, len2, i, COMPLETE, NULL, 0);
 964	}
 965	ret = (i < 0 ? i : len2);
 966 done:
 
 967	kfree(tbuf);
 968	usbfs_decrease_memory_usage(len1 + sizeof(struct urb));
 969	return ret;
 970}
 971
 972static int proc_resetep(struct dev_state *ps, void __user *arg)
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 973{
 974	unsigned int ep;
 975	int ret;
 976
 977	if (get_user(ep, (unsigned int __user *)arg))
 978		return -EFAULT;
 979	ret = findintfep(ps->dev, ep);
 980	if (ret < 0)
 981		return ret;
 982	ret = checkintf(ps, ret);
 983	if (ret)
 984		return ret;
 
 985	usb_reset_endpoint(ps->dev, ep);
 986	return 0;
 987}
 988
 989static int proc_clearhalt(struct dev_state *ps, void __user *arg)
 990{
 991	unsigned int ep;
 992	int pipe;
 993	int ret;
 994
 995	if (get_user(ep, (unsigned int __user *)arg))
 996		return -EFAULT;
 997	ret = findintfep(ps->dev, ep);
 998	if (ret < 0)
 999		return ret;
1000	ret = checkintf(ps, ret);
1001	if (ret)
1002		return ret;
 
1003	if (ep & USB_DIR_IN)
1004		pipe = usb_rcvbulkpipe(ps->dev, ep & 0x7f);
1005	else
1006		pipe = usb_sndbulkpipe(ps->dev, ep & 0x7f);
1007
1008	return usb_clear_halt(ps->dev, pipe);
1009}
1010
1011static int proc_getdriver(struct dev_state *ps, void __user *arg)
1012{
1013	struct usbdevfs_getdriver gd;
1014	struct usb_interface *intf;
1015	int ret;
1016
1017	if (copy_from_user(&gd, arg, sizeof(gd)))
1018		return -EFAULT;
1019	intf = usb_ifnum_to_if(ps->dev, gd.interface);
1020	if (!intf || !intf->dev.driver)
1021		ret = -ENODATA;
1022	else {
1023		strncpy(gd.driver, intf->dev.driver->name,
1024				sizeof(gd.driver));
1025		ret = (copy_to_user(arg, &gd, sizeof(gd)) ? -EFAULT : 0);
1026	}
1027	return ret;
1028}
1029
1030static int proc_connectinfo(struct dev_state *ps, void __user *arg)
1031{
1032	struct usbdevfs_connectinfo ci = {
1033		.devnum = ps->dev->devnum,
1034		.slow = ps->dev->speed == USB_SPEED_LOW
1035	};
 
1036
1037	if (copy_to_user(arg, &ci, sizeof(ci)))
1038		return -EFAULT;
1039	return 0;
1040}
1041
1042static int proc_resetdevice(struct dev_state *ps)
 
1043{
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1044	return usb_reset_device(ps->dev);
1045}
1046
1047static int proc_setintf(struct dev_state *ps, void __user *arg)
1048{
1049	struct usbdevfs_setinterface setintf;
1050	int ret;
1051
1052	if (copy_from_user(&setintf, arg, sizeof(setintf)))
1053		return -EFAULT;
1054	if ((ret = checkintf(ps, setintf.interface)))
 
1055		return ret;
 
 
 
1056	return usb_set_interface(ps->dev, setintf.interface,
1057			setintf.altsetting);
1058}
1059
1060static int proc_setconfig(struct dev_state *ps, void __user *arg)
1061{
1062	int u;
1063	int status = 0;
1064	struct usb_host_config *actconfig;
1065
1066	if (get_user(u, (int __user *)arg))
1067		return -EFAULT;
1068
1069	actconfig = ps->dev->actconfig;
1070
1071	/* Don't touch the device if any interfaces are claimed.
1072	 * It could interfere with other drivers' operations, and if
1073	 * an interface is claimed by usbfs it could easily deadlock.
1074	 */
1075	if (actconfig) {
1076		int i;
1077
1078		for (i = 0; i < actconfig->desc.bNumInterfaces; ++i) {
1079			if (usb_interface_claimed(actconfig->interface[i])) {
1080				dev_warn(&ps->dev->dev,
1081					"usbfs: interface %d claimed by %s "
1082					"while '%s' sets config #%d\n",
1083					actconfig->interface[i]
1084						->cur_altsetting
1085						->desc.bInterfaceNumber,
1086					actconfig->interface[i]
1087						->dev.driver->name,
1088					current->comm, u);
1089				status = -EBUSY;
1090				break;
1091			}
1092		}
1093	}
1094
1095	/* SET_CONFIGURATION is often abused as a "cheap" driver reset,
1096	 * so avoid usb_set_configuration()'s kick to sysfs
1097	 */
1098	if (status == 0) {
1099		if (actconfig && actconfig->desc.bConfigurationValue == u)
1100			status = usb_reset_configuration(ps->dev);
1101		else
1102			status = usb_set_configuration(ps->dev, u);
1103	}
1104
1105	return status;
1106}
1107
1108static int proc_do_submiturb(struct dev_state *ps, struct usbdevfs_urb *uurb,
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1109			struct usbdevfs_iso_packet_desc __user *iso_frame_desc,
1110			void __user *arg)
1111{
1112	struct usbdevfs_iso_packet_desc *isopkt = NULL;
1113	struct usb_host_endpoint *ep;
1114	struct async *as = NULL;
1115	struct usb_ctrlrequest *dr = NULL;
1116	unsigned int u, totlen, isofrmlen;
1117	int ret, ifnum = -1;
1118	int is_in;
1119
1120	if (uurb->flags & ~(USBDEVFS_URB_ISO_ASAP |
1121				USBDEVFS_URB_SHORT_NOT_OK |
 
 
 
1122				USBDEVFS_URB_BULK_CONTINUATION |
1123				USBDEVFS_URB_NO_FSBR |
1124				USBDEVFS_URB_ZERO_PACKET |
1125				USBDEVFS_URB_NO_INTERRUPT))
 
 
 
 
 
 
 
 
1126		return -EINVAL;
1127	if (uurb->buffer_length > 0 && !uurb->buffer)
1128		return -EINVAL;
1129	if (!(uurb->type == USBDEVFS_URB_TYPE_CONTROL &&
1130	    (uurb->endpoint & ~USB_ENDPOINT_DIR_MASK) == 0)) {
1131		ifnum = findintfep(ps->dev, uurb->endpoint);
1132		if (ifnum < 0)
1133			return ifnum;
1134		ret = checkintf(ps, ifnum);
1135		if (ret)
1136			return ret;
1137	}
1138	if ((uurb->endpoint & USB_ENDPOINT_DIR_MASK) != 0) {
1139		is_in = 1;
1140		ep = ps->dev->ep_in[uurb->endpoint & USB_ENDPOINT_NUMBER_MASK];
1141	} else {
1142		is_in = 0;
1143		ep = ps->dev->ep_out[uurb->endpoint & USB_ENDPOINT_NUMBER_MASK];
1144	}
1145	if (!ep)
1146		return -ENOENT;
 
1147
1148	u = 0;
1149	switch(uurb->type) {
1150	case USBDEVFS_URB_TYPE_CONTROL:
1151		if (!usb_endpoint_xfer_control(&ep->desc))
1152			return -EINVAL;
1153		/* min 8 byte setup packet */
1154		if (uurb->buffer_length < 8)
1155			return -EINVAL;
1156		dr = kmalloc(sizeof(struct usb_ctrlrequest), GFP_KERNEL);
1157		if (!dr)
1158			return -ENOMEM;
1159		if (copy_from_user(dr, uurb->buffer, 8)) {
1160			ret = -EFAULT;
1161			goto error;
1162		}
1163		if (uurb->buffer_length < (le16_to_cpup(&dr->wLength) + 8)) {
1164			ret = -EINVAL;
1165			goto error;
1166		}
1167		ret = check_ctrlrecip(ps, dr->bRequestType, dr->bRequest,
1168				      le16_to_cpup(&dr->wIndex));
1169		if (ret)
1170			goto error;
1171		uurb->number_of_packets = 0;
1172		uurb->buffer_length = le16_to_cpup(&dr->wLength);
1173		uurb->buffer += 8;
1174		if ((dr->bRequestType & USB_DIR_IN) && uurb->buffer_length) {
1175			is_in = 1;
1176			uurb->endpoint |= USB_DIR_IN;
1177		} else {
1178			is_in = 0;
1179			uurb->endpoint &= ~USB_DIR_IN;
1180		}
 
 
1181		snoop(&ps->dev->dev, "control urb: bRequestType=%02x "
1182			"bRequest=%02x wValue=%04x "
1183			"wIndex=%04x wLength=%04x\n",
1184			dr->bRequestType, dr->bRequest,
1185			__le16_to_cpup(&dr->wValue),
1186			__le16_to_cpup(&dr->wIndex),
1187			__le16_to_cpup(&dr->wLength));
1188		u = sizeof(struct usb_ctrlrequest);
1189		break;
1190
1191	case USBDEVFS_URB_TYPE_BULK:
 
 
 
 
1192		switch (usb_endpoint_type(&ep->desc)) {
1193		case USB_ENDPOINT_XFER_CONTROL:
1194		case USB_ENDPOINT_XFER_ISOC:
1195			return -EINVAL;
1196		case USB_ENDPOINT_XFER_INT:
1197			/* allow single-shot interrupt transfers */
1198			uurb->type = USBDEVFS_URB_TYPE_INTERRUPT;
1199			goto interrupt_urb;
1200		}
1201		uurb->number_of_packets = 0;
 
 
 
 
1202		break;
1203
1204	case USBDEVFS_URB_TYPE_INTERRUPT:
1205		if (!usb_endpoint_xfer_int(&ep->desc))
1206			return -EINVAL;
1207 interrupt_urb:
1208		uurb->number_of_packets = 0;
 
 
 
1209		break;
1210
1211	case USBDEVFS_URB_TYPE_ISO:
1212		/* arbitrary limit */
1213		if (uurb->number_of_packets < 1 ||
1214		    uurb->number_of_packets > 128)
1215			return -EINVAL;
1216		if (!usb_endpoint_xfer_isoc(&ep->desc))
1217			return -EINVAL;
 
1218		isofrmlen = sizeof(struct usbdevfs_iso_packet_desc) *
1219				   uurb->number_of_packets;
1220		if (!(isopkt = kmalloc(isofrmlen, GFP_KERNEL)))
1221			return -ENOMEM;
1222		if (copy_from_user(isopkt, iso_frame_desc, isofrmlen)) {
1223			ret = -EFAULT;
1224			goto error;
1225		}
1226		for (totlen = u = 0; u < uurb->number_of_packets; u++) {
1227			/* arbitrary limit,
1228			 * sufficient for USB 2.0 high-bandwidth iso */
1229			if (isopkt[u].length > 8192) {
 
 
1230				ret = -EINVAL;
1231				goto error;
1232			}
1233			totlen += isopkt[u].length;
1234		}
1235		u *= sizeof(struct usb_iso_packet_descriptor);
1236		uurb->buffer_length = totlen;
1237		break;
1238
1239	default:
1240		return -EINVAL;
1241	}
1242
1243	if (uurb->buffer_length >= USBFS_XFER_MAX) {
1244		ret = -EINVAL;
1245		goto error;
1246	}
1247	if (uurb->buffer_length > 0 &&
1248			!access_ok(is_in ? VERIFY_WRITE : VERIFY_READ,
1249				uurb->buffer, uurb->buffer_length)) {
1250		ret = -EFAULT;
1251		goto error;
1252	}
1253	as = alloc_async(uurb->number_of_packets);
1254	if (!as) {
1255		ret = -ENOMEM;
1256		goto error;
1257	}
1258	u += sizeof(struct async) + sizeof(struct urb) + uurb->buffer_length;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1259	ret = usbfs_increase_memory_usage(u);
1260	if (ret)
1261		goto error;
1262	as->mem_usage = u;
1263
1264	if (uurb->buffer_length > 0) {
1265		as->urb->transfer_buffer = kmalloc(uurb->buffer_length,
1266				GFP_KERNEL);
1267		if (!as->urb->transfer_buffer) {
 
1268			ret = -ENOMEM;
1269			goto error;
1270		}
1271		/* Isochronous input data may end up being discontiguous
1272		 * if some of the packets are short.  Clear the buffer so
1273		 * that the gaps don't leak kernel data to userspace.
1274		 */
1275		if (is_in && uurb->type == USBDEVFS_URB_TYPE_ISO)
1276			memset(as->urb->transfer_buffer, 0,
1277					uurb->buffer_length);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1278	}
1279	as->urb->dev = ps->dev;
1280	as->urb->pipe = (uurb->type << 30) |
1281			__create_pipe(ps->dev, uurb->endpoint & 0xf) |
1282			(uurb->endpoint & USB_DIR_IN);
1283
1284	/* This tedious sequence is necessary because the URB_* flags
1285	 * are internal to the kernel and subject to change, whereas
1286	 * the USBDEVFS_URB_* flags are a user API and must not be changed.
1287	 */
1288	u = (is_in ? URB_DIR_IN : URB_DIR_OUT);
1289	if (uurb->flags & USBDEVFS_URB_ISO_ASAP)
1290		u |= URB_ISO_ASAP;
1291	if (uurb->flags & USBDEVFS_URB_SHORT_NOT_OK)
1292		u |= URB_SHORT_NOT_OK;
1293	if (uurb->flags & USBDEVFS_URB_NO_FSBR)
1294		u |= URB_NO_FSBR;
1295	if (uurb->flags & USBDEVFS_URB_ZERO_PACKET)
1296		u |= URB_ZERO_PACKET;
1297	if (uurb->flags & USBDEVFS_URB_NO_INTERRUPT)
1298		u |= URB_NO_INTERRUPT;
1299	as->urb->transfer_flags = u;
1300
 
 
 
 
 
1301	as->urb->transfer_buffer_length = uurb->buffer_length;
1302	as->urb->setup_packet = (unsigned char *)dr;
1303	dr = NULL;
1304	as->urb->start_frame = uurb->start_frame;
1305	as->urb->number_of_packets = uurb->number_of_packets;
1306	if (uurb->type == USBDEVFS_URB_TYPE_ISO ||
1307			ps->dev->speed == USB_SPEED_HIGH)
1308		as->urb->interval = 1 << min(15, ep->desc.bInterval - 1);
1309	else
1310		as->urb->interval = ep->desc.bInterval;
 
 
 
 
 
 
 
1311	as->urb->context = as;
1312	as->urb->complete = async_completed;
1313	for (totlen = u = 0; u < uurb->number_of_packets; u++) {
1314		as->urb->iso_frame_desc[u].offset = totlen;
1315		as->urb->iso_frame_desc[u].length = isopkt[u].length;
1316		totlen += isopkt[u].length;
1317	}
1318	kfree(isopkt);
1319	isopkt = NULL;
1320	as->ps = ps;
1321	as->userurb = arg;
1322	if (is_in && uurb->buffer_length > 0)
 
 
 
 
 
 
 
1323		as->userbuffer = uurb->buffer;
1324	else
1325		as->userbuffer = NULL;
1326	as->signr = uurb->signr;
1327	as->ifnum = ifnum;
1328	as->pid = get_pid(task_pid(current));
1329	as->cred = get_current_cred();
1330	security_task_getsecid(current, &as->secid);
1331	if (!is_in && uurb->buffer_length > 0) {
1332		if (copy_from_user(as->urb->transfer_buffer, uurb->buffer,
1333				uurb->buffer_length)) {
1334			ret = -EFAULT;
1335			goto error;
1336		}
1337	}
1338	snoop_urb(ps->dev, as->userurb, as->urb->pipe,
1339			as->urb->transfer_buffer_length, 0, SUBMIT,
1340			is_in ? NULL : as->urb->transfer_buffer,
1341				uurb->buffer_length);
 
 
1342	async_newpending(as);
1343
1344	if (usb_endpoint_xfer_bulk(&ep->desc)) {
1345		spin_lock_irq(&ps->lock);
1346
1347		/* Not exactly the endpoint address; the direction bit is
1348		 * shifted to the 0x10 position so that the value will be
1349		 * between 0 and 31.
1350		 */
1351		as->bulk_addr = usb_endpoint_num(&ep->desc) |
1352			((ep->desc.bEndpointAddress & USB_ENDPOINT_DIR_MASK)
1353				>> 3);
1354
1355		/* If this bulk URB is the start of a new transfer, re-enable
1356		 * the endpoint.  Otherwise mark it as a continuation URB.
1357		 */
1358		if (uurb->flags & USBDEVFS_URB_BULK_CONTINUATION)
1359			as->bulk_status = AS_CONTINUATION;
1360		else
1361			ps->disabled_bulk_eps &= ~(1 << as->bulk_addr);
1362
1363		/* Don't accept continuation URBs if the endpoint is
1364		 * disabled because of an earlier error.
1365		 */
1366		if (ps->disabled_bulk_eps & (1 << as->bulk_addr))
1367			ret = -EREMOTEIO;
1368		else
1369			ret = usb_submit_urb(as->urb, GFP_ATOMIC);
1370		spin_unlock_irq(&ps->lock);
1371	} else {
1372		ret = usb_submit_urb(as->urb, GFP_KERNEL);
1373	}
1374
1375	if (ret) {
1376		dev_printk(KERN_DEBUG, &ps->dev->dev,
1377			   "usbfs: usb_submit_urb returned %d\n", ret);
1378		snoop_urb(ps->dev, as->userurb, as->urb->pipe,
1379				0, ret, COMPLETE, NULL, 0);
1380		async_removepending(as);
1381		goto error;
1382	}
1383	return 0;
1384
1385 error:
1386	kfree(isopkt);
1387	kfree(dr);
1388	if (as)
1389		free_async(as);
1390	return ret;
1391}
1392
1393static int proc_submiturb(struct dev_state *ps, void __user *arg)
1394{
1395	struct usbdevfs_urb uurb;
 
1396
1397	if (copy_from_user(&uurb, arg, sizeof(uurb)))
1398		return -EFAULT;
1399
 
 
 
1400	return proc_do_submiturb(ps, &uurb,
1401			(((struct usbdevfs_urb __user *)arg)->iso_frame_desc),
1402			arg);
1403}
1404
1405static int proc_unlinkurb(struct dev_state *ps, void __user *arg)
1406{
1407	struct urb *urb;
1408	struct async *as;
1409	unsigned long flags;
1410
1411	spin_lock_irqsave(&ps->lock, flags);
1412	as = async_getpending(ps, arg);
1413	if (!as) {
1414		spin_unlock_irqrestore(&ps->lock, flags);
1415		return -EINVAL;
1416	}
1417
1418	urb = as->urb;
1419	usb_get_urb(urb);
1420	spin_unlock_irqrestore(&ps->lock, flags);
1421
1422	usb_kill_urb(urb);
1423	usb_put_urb(urb);
1424
1425	return 0;
1426}
1427
 
 
 
 
 
 
 
 
 
 
 
 
1428static int processcompl(struct async *as, void __user * __user *arg)
1429{
1430	struct urb *urb = as->urb;
1431	struct usbdevfs_urb __user *userurb = as->userurb;
1432	void __user *addr = as->userurb;
1433	unsigned int i;
1434
 
1435	if (as->userbuffer && urb->actual_length) {
1436		if (urb->number_of_packets > 0)		/* Isochronous */
1437			i = urb->transfer_buffer_length;
1438		else					/* Non-Isoc */
1439			i = urb->actual_length;
1440		if (copy_to_user(as->userbuffer, urb->transfer_buffer, i))
1441			goto err_out;
1442	}
1443	if (put_user(as->status, &userurb->status))
1444		goto err_out;
1445	if (put_user(urb->actual_length, &userurb->actual_length))
1446		goto err_out;
1447	if (put_user(urb->error_count, &userurb->error_count))
1448		goto err_out;
1449
1450	if (usb_endpoint_xfer_isoc(&urb->ep->desc)) {
1451		for (i = 0; i < urb->number_of_packets; i++) {
1452			if (put_user(urb->iso_frame_desc[i].actual_length,
1453				     &userurb->iso_frame_desc[i].actual_length))
1454				goto err_out;
1455			if (put_user(urb->iso_frame_desc[i].status,
1456				     &userurb->iso_frame_desc[i].status))
1457				goto err_out;
1458		}
1459	}
1460
1461	if (put_user(addr, (void __user * __user *)arg))
1462		return -EFAULT;
1463	return 0;
1464
1465err_out:
1466	return -EFAULT;
1467}
1468
1469static struct async *reap_as(struct dev_state *ps)
1470{
1471	DECLARE_WAITQUEUE(wait, current);
1472	struct async *as = NULL;
1473	struct usb_device *dev = ps->dev;
1474
1475	add_wait_queue(&ps->wait, &wait);
1476	for (;;) {
1477		__set_current_state(TASK_INTERRUPTIBLE);
1478		as = async_getcompleted(ps);
1479		if (as)
1480			break;
1481		if (signal_pending(current))
1482			break;
1483		usb_unlock_device(dev);
1484		schedule();
1485		usb_lock_device(dev);
1486	}
1487	remove_wait_queue(&ps->wait, &wait);
1488	set_current_state(TASK_RUNNING);
1489	return as;
1490}
1491
1492static int proc_reapurb(struct dev_state *ps, void __user *arg)
1493{
1494	struct async *as = reap_as(ps);
 
1495	if (as) {
1496		int retval = processcompl(as, (void __user * __user *)arg);
 
 
 
1497		free_async(as);
1498		return retval;
1499	}
1500	if (signal_pending(current))
1501		return -EINTR;
1502	return -EIO;
1503}
1504
1505static int proc_reapurbnonblock(struct dev_state *ps, void __user *arg)
1506{
1507	int retval;
1508	struct async *as;
1509
1510	as = async_getcompleted(ps);
1511	retval = -EAGAIN;
1512	if (as) {
 
1513		retval = processcompl(as, (void __user * __user *)arg);
1514		free_async(as);
 
 
1515	}
1516	return retval;
1517}
1518
1519#ifdef CONFIG_COMPAT
1520static int proc_control_compat(struct dev_state *ps,
1521				struct usbdevfs_ctrltransfer32 __user *p32)
1522{
1523        struct usbdevfs_ctrltransfer __user *p;
1524        __u32 udata;
1525        p = compat_alloc_user_space(sizeof(*p));
1526        if (copy_in_user(p, p32, (sizeof(*p32) - sizeof(compat_caddr_t))) ||
1527            get_user(udata, &p32->data) ||
1528	    put_user(compat_ptr(udata), &p->data))
1529		return -EFAULT;
1530        return proc_control(ps, p);
 
1531}
1532
1533static int proc_bulk_compat(struct dev_state *ps,
1534			struct usbdevfs_bulktransfer32 __user *p32)
1535{
1536        struct usbdevfs_bulktransfer __user *p;
1537        compat_uint_t n;
1538        compat_caddr_t addr;
1539
1540        p = compat_alloc_user_space(sizeof(*p));
1541
1542        if (get_user(n, &p32->ep) || put_user(n, &p->ep) ||
1543            get_user(n, &p32->len) || put_user(n, &p->len) ||
1544            get_user(n, &p32->timeout) || put_user(n, &p->timeout) ||
1545            get_user(addr, &p32->data) || put_user(compat_ptr(addr), &p->data))
1546                return -EFAULT;
 
1547
1548        return proc_bulk(ps, p);
1549}
1550static int proc_disconnectsignal_compat(struct dev_state *ps, void __user *arg)
1551{
1552	struct usbdevfs_disconnectsignal32 ds;
1553
1554	if (copy_from_user(&ds, arg, sizeof(ds)))
1555		return -EFAULT;
1556	ps->discsignr = ds.signr;
1557	ps->disccontext = compat_ptr(ds.context);
1558	return 0;
1559}
1560
1561static int get_urb32(struct usbdevfs_urb *kurb,
1562		     struct usbdevfs_urb32 __user *uurb)
1563{
1564	__u32  uptr;
1565	if (!access_ok(VERIFY_READ, uurb, sizeof(*uurb)) ||
1566	    __get_user(kurb->type, &uurb->type) ||
1567	    __get_user(kurb->endpoint, &uurb->endpoint) ||
1568	    __get_user(kurb->status, &uurb->status) ||
1569	    __get_user(kurb->flags, &uurb->flags) ||
1570	    __get_user(kurb->buffer_length, &uurb->buffer_length) ||
1571	    __get_user(kurb->actual_length, &uurb->actual_length) ||
1572	    __get_user(kurb->start_frame, &uurb->start_frame) ||
1573	    __get_user(kurb->number_of_packets, &uurb->number_of_packets) ||
1574	    __get_user(kurb->error_count, &uurb->error_count) ||
1575	    __get_user(kurb->signr, &uurb->signr))
1576		return -EFAULT;
1577
1578	if (__get_user(uptr, &uurb->buffer))
1579		return -EFAULT;
1580	kurb->buffer = compat_ptr(uptr);
1581	if (__get_user(uptr, &uurb->usercontext))
1582		return -EFAULT;
1583	kurb->usercontext = compat_ptr(uptr);
1584
 
 
 
 
 
 
 
 
 
 
1585	return 0;
1586}
1587
1588static int proc_submiturb_compat(struct dev_state *ps, void __user *arg)
1589{
1590	struct usbdevfs_urb uurb;
 
1591
1592	if (get_urb32(&uurb, (struct usbdevfs_urb32 __user *)arg))
1593		return -EFAULT;
1594
 
 
 
1595	return proc_do_submiturb(ps, &uurb,
1596			((struct usbdevfs_urb32 __user *)arg)->iso_frame_desc,
1597			arg);
1598}
1599
1600static int processcompl_compat(struct async *as, void __user * __user *arg)
1601{
1602	struct urb *urb = as->urb;
1603	struct usbdevfs_urb32 __user *userurb = as->userurb;
1604	void __user *addr = as->userurb;
1605	unsigned int i;
1606
 
1607	if (as->userbuffer && urb->actual_length) {
1608		if (urb->number_of_packets > 0)		/* Isochronous */
1609			i = urb->transfer_buffer_length;
1610		else					/* Non-Isoc */
1611			i = urb->actual_length;
1612		if (copy_to_user(as->userbuffer, urb->transfer_buffer, i))
1613			return -EFAULT;
1614	}
1615	if (put_user(as->status, &userurb->status))
1616		return -EFAULT;
1617	if (put_user(urb->actual_length, &userurb->actual_length))
1618		return -EFAULT;
1619	if (put_user(urb->error_count, &userurb->error_count))
1620		return -EFAULT;
1621
1622	if (usb_endpoint_xfer_isoc(&urb->ep->desc)) {
1623		for (i = 0; i < urb->number_of_packets; i++) {
1624			if (put_user(urb->iso_frame_desc[i].actual_length,
1625				     &userurb->iso_frame_desc[i].actual_length))
1626				return -EFAULT;
1627			if (put_user(urb->iso_frame_desc[i].status,
1628				     &userurb->iso_frame_desc[i].status))
1629				return -EFAULT;
1630		}
1631	}
1632
1633	if (put_user(ptr_to_compat(addr), (u32 __user *)arg))
1634		return -EFAULT;
1635	return 0;
1636}
1637
1638static int proc_reapurb_compat(struct dev_state *ps, void __user *arg)
1639{
1640	struct async *as = reap_as(ps);
 
1641	if (as) {
1642		int retval = processcompl_compat(as, (void __user * __user *)arg);
 
 
 
1643		free_async(as);
1644		return retval;
1645	}
1646	if (signal_pending(current))
1647		return -EINTR;
1648	return -EIO;
1649}
1650
1651static int proc_reapurbnonblock_compat(struct dev_state *ps, void __user *arg)
1652{
1653	int retval;
1654	struct async *as;
1655
1656	retval = -EAGAIN;
1657	as = async_getcompleted(ps);
1658	if (as) {
 
1659		retval = processcompl_compat(as, (void __user * __user *)arg);
1660		free_async(as);
 
 
1661	}
1662	return retval;
1663}
1664
1665
1666#endif
1667
1668static int proc_disconnectsignal(struct dev_state *ps, void __user *arg)
1669{
1670	struct usbdevfs_disconnectsignal ds;
1671
1672	if (copy_from_user(&ds, arg, sizeof(ds)))
1673		return -EFAULT;
1674	ps->discsignr = ds.signr;
1675	ps->disccontext = ds.context;
1676	return 0;
1677}
1678
1679static int proc_claiminterface(struct dev_state *ps, void __user *arg)
1680{
1681	unsigned int ifnum;
1682
1683	if (get_user(ifnum, (unsigned int __user *)arg))
1684		return -EFAULT;
1685	return claimintf(ps, ifnum);
1686}
1687
1688static int proc_releaseinterface(struct dev_state *ps, void __user *arg)
1689{
1690	unsigned int ifnum;
1691	int ret;
1692
1693	if (get_user(ifnum, (unsigned int __user *)arg))
1694		return -EFAULT;
1695	if ((ret = releaseintf(ps, ifnum)) < 0)
 
1696		return ret;
1697	destroy_async_on_interface (ps, ifnum);
1698	return 0;
1699}
1700
1701static int proc_ioctl(struct dev_state *ps, struct usbdevfs_ioctl *ctl)
1702{
1703	int			size;
1704	void			*buf = NULL;
1705	int			retval = 0;
1706	struct usb_interface    *intf = NULL;
1707	struct usb_driver       *driver = NULL;
1708
 
 
 
 
 
 
1709	/* alloc buffer */
1710	if ((size = _IOC_SIZE(ctl->ioctl_code)) > 0) {
1711		if ((buf = kmalloc(size, GFP_KERNEL)) == NULL)
 
 
1712			return -ENOMEM;
1713		if ((_IOC_DIR(ctl->ioctl_code) & _IOC_WRITE)) {
1714			if (copy_from_user(buf, ctl->data, size)) {
1715				kfree(buf);
1716				return -EFAULT;
1717			}
1718		} else {
1719			memset(buf, 0, size);
1720		}
1721	}
1722
1723	if (!connected(ps)) {
1724		kfree(buf);
1725		return -ENODEV;
1726	}
1727
1728	if (ps->dev->state != USB_STATE_CONFIGURED)
1729		retval = -EHOSTUNREACH;
1730	else if (!(intf = usb_ifnum_to_if(ps->dev, ctl->ifno)))
1731		retval = -EINVAL;
1732	else switch (ctl->ioctl_code) {
1733
1734	/* disconnect kernel driver from interface */
1735	case USBDEVFS_DISCONNECT:
1736		if (intf->dev.driver) {
1737			driver = to_usb_driver(intf->dev.driver);
1738			dev_dbg(&intf->dev, "disconnect by usbfs\n");
1739			usb_driver_release_interface(driver, intf);
1740		} else
1741			retval = -ENODATA;
1742		break;
1743
1744	/* let kernel drivers try to (re)bind to the interface */
1745	case USBDEVFS_CONNECT:
1746		if (!intf->dev.driver)
1747			retval = device_attach(&intf->dev);
1748		else
1749			retval = -EBUSY;
1750		break;
1751
1752	/* talk directly to the interface's driver */
1753	default:
1754		if (intf->dev.driver)
1755			driver = to_usb_driver(intf->dev.driver);
1756		if (driver == NULL || driver->unlocked_ioctl == NULL) {
1757			retval = -ENOTTY;
1758		} else {
1759			retval = driver->unlocked_ioctl(intf, ctl->ioctl_code, buf);
1760			if (retval == -ENOIOCTLCMD)
1761				retval = -ENOTTY;
1762		}
1763	}
1764
1765	/* cleanup and return */
1766	if (retval >= 0
1767			&& (_IOC_DIR(ctl->ioctl_code) & _IOC_READ) != 0
1768			&& size > 0
1769			&& copy_to_user(ctl->data, buf, size) != 0)
1770		retval = -EFAULT;
1771
1772	kfree(buf);
1773	return retval;
1774}
1775
1776static int proc_ioctl_default(struct dev_state *ps, void __user *arg)
1777{
1778	struct usbdevfs_ioctl	ctrl;
1779
1780	if (copy_from_user(&ctrl, arg, sizeof(ctrl)))
1781		return -EFAULT;
1782	return proc_ioctl(ps, &ctrl);
1783}
1784
1785#ifdef CONFIG_COMPAT
1786static int proc_ioctl_compat(struct dev_state *ps, compat_uptr_t arg)
1787{
1788	struct usbdevfs_ioctl32 __user *uioc;
1789	struct usbdevfs_ioctl ctrl;
1790	u32 udata;
1791
1792	uioc = compat_ptr((long)arg);
1793	if (!access_ok(VERIFY_READ, uioc, sizeof(*uioc)) ||
1794	    __get_user(ctrl.ifno, &uioc->ifno) ||
1795	    __get_user(ctrl.ioctl_code, &uioc->ioctl_code) ||
1796	    __get_user(udata, &uioc->data))
1797		return -EFAULT;
1798	ctrl.data = compat_ptr(udata);
1799
 
1800	return proc_ioctl(ps, &ctrl);
1801}
1802#endif
1803
1804static int proc_claim_port(struct dev_state *ps, void __user *arg)
1805{
1806	unsigned portnum;
1807	int rc;
1808
1809	if (get_user(portnum, (unsigned __user *) arg))
1810		return -EFAULT;
1811	rc = usb_hub_claim_port(ps->dev, portnum, ps);
1812	if (rc == 0)
1813		snoop(&ps->dev->dev, "port %d claimed by process %d: %s\n",
1814			portnum, task_pid_nr(current), current->comm);
1815	return rc;
1816}
1817
1818static int proc_release_port(struct dev_state *ps, void __user *arg)
1819{
1820	unsigned portnum;
1821
1822	if (get_user(portnum, (unsigned __user *) arg))
1823		return -EFAULT;
1824	return usb_hub_release_port(ps->dev, portnum, ps);
1825}
1826
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1827/*
1828 * NOTE:  All requests here that have interface numbers as parameters
1829 * are assuming that somehow the configuration has been prevented from
1830 * changing.  But there's no mechanism to ensure that...
1831 */
1832static long usbdev_do_ioctl(struct file *file, unsigned int cmd,
1833				void __user *p)
1834{
1835	struct dev_state *ps = file->private_data;
1836	struct inode *inode = file->f_path.dentry->d_inode;
1837	struct usb_device *dev = ps->dev;
1838	int ret = -ENOTTY;
1839
1840	if (!(file->f_mode & FMODE_WRITE))
1841		return -EPERM;
1842
1843	usb_lock_device(dev);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1844	if (!connected(ps)) {
1845		usb_unlock_device(dev);
1846		return -ENODEV;
1847	}
1848
1849	switch (cmd) {
1850	case USBDEVFS_CONTROL:
1851		snoop(&dev->dev, "%s: CONTROL\n", __func__);
1852		ret = proc_control(ps, p);
1853		if (ret >= 0)
1854			inode->i_mtime = CURRENT_TIME;
 
1855		break;
1856
1857	case USBDEVFS_BULK:
1858		snoop(&dev->dev, "%s: BULK\n", __func__);
1859		ret = proc_bulk(ps, p);
1860		if (ret >= 0)
1861			inode->i_mtime = CURRENT_TIME;
 
1862		break;
1863
1864	case USBDEVFS_RESETEP:
1865		snoop(&dev->dev, "%s: RESETEP\n", __func__);
1866		ret = proc_resetep(ps, p);
1867		if (ret >= 0)
1868			inode->i_mtime = CURRENT_TIME;
 
1869		break;
1870
1871	case USBDEVFS_RESET:
1872		snoop(&dev->dev, "%s: RESET\n", __func__);
1873		ret = proc_resetdevice(ps);
1874		break;
1875
1876	case USBDEVFS_CLEAR_HALT:
1877		snoop(&dev->dev, "%s: CLEAR_HALT\n", __func__);
1878		ret = proc_clearhalt(ps, p);
1879		if (ret >= 0)
1880			inode->i_mtime = CURRENT_TIME;
 
1881		break;
1882
1883	case USBDEVFS_GETDRIVER:
1884		snoop(&dev->dev, "%s: GETDRIVER\n", __func__);
1885		ret = proc_getdriver(ps, p);
1886		break;
1887
1888	case USBDEVFS_CONNECTINFO:
1889		snoop(&dev->dev, "%s: CONNECTINFO\n", __func__);
1890		ret = proc_connectinfo(ps, p);
1891		break;
1892
1893	case USBDEVFS_SETINTERFACE:
1894		snoop(&dev->dev, "%s: SETINTERFACE\n", __func__);
1895		ret = proc_setintf(ps, p);
1896		break;
1897
1898	case USBDEVFS_SETCONFIGURATION:
1899		snoop(&dev->dev, "%s: SETCONFIGURATION\n", __func__);
1900		ret = proc_setconfig(ps, p);
1901		break;
1902
1903	case USBDEVFS_SUBMITURB:
1904		snoop(&dev->dev, "%s: SUBMITURB\n", __func__);
1905		ret = proc_submiturb(ps, p);
1906		if (ret >= 0)
1907			inode->i_mtime = CURRENT_TIME;
 
1908		break;
1909
1910#ifdef CONFIG_COMPAT
1911	case USBDEVFS_CONTROL32:
1912		snoop(&dev->dev, "%s: CONTROL32\n", __func__);
1913		ret = proc_control_compat(ps, p);
1914		if (ret >= 0)
1915			inode->i_mtime = CURRENT_TIME;
 
1916		break;
1917
1918	case USBDEVFS_BULK32:
1919		snoop(&dev->dev, "%s: BULK32\n", __func__);
1920		ret = proc_bulk_compat(ps, p);
1921		if (ret >= 0)
1922			inode->i_mtime = CURRENT_TIME;
 
1923		break;
1924
1925	case USBDEVFS_DISCSIGNAL32:
1926		snoop(&dev->dev, "%s: DISCSIGNAL32\n", __func__);
1927		ret = proc_disconnectsignal_compat(ps, p);
1928		break;
1929
1930	case USBDEVFS_SUBMITURB32:
1931		snoop(&dev->dev, "%s: SUBMITURB32\n", __func__);
1932		ret = proc_submiturb_compat(ps, p);
1933		if (ret >= 0)
1934			inode->i_mtime = CURRENT_TIME;
1935		break;
1936
1937	case USBDEVFS_REAPURB32:
1938		snoop(&dev->dev, "%s: REAPURB32\n", __func__);
1939		ret = proc_reapurb_compat(ps, p);
1940		break;
1941
1942	case USBDEVFS_REAPURBNDELAY32:
1943		snoop(&dev->dev, "%s: REAPURBNDELAY32\n", __func__);
1944		ret = proc_reapurbnonblock_compat(ps, p);
1945		break;
1946
1947	case USBDEVFS_IOCTL32:
1948		snoop(&dev->dev, "%s: IOCTL32\n", __func__);
1949		ret = proc_ioctl_compat(ps, ptr_to_compat(p));
1950		break;
1951#endif
1952
1953	case USBDEVFS_DISCARDURB:
1954		snoop(&dev->dev, "%s: DISCARDURB\n", __func__);
1955		ret = proc_unlinkurb(ps, p);
1956		break;
1957
1958	case USBDEVFS_REAPURB:
1959		snoop(&dev->dev, "%s: REAPURB\n", __func__);
1960		ret = proc_reapurb(ps, p);
1961		break;
1962
1963	case USBDEVFS_REAPURBNDELAY:
1964		snoop(&dev->dev, "%s: REAPURBNDELAY\n", __func__);
1965		ret = proc_reapurbnonblock(ps, p);
1966		break;
1967
1968	case USBDEVFS_DISCSIGNAL:
1969		snoop(&dev->dev, "%s: DISCSIGNAL\n", __func__);
1970		ret = proc_disconnectsignal(ps, p);
1971		break;
1972
1973	case USBDEVFS_CLAIMINTERFACE:
1974		snoop(&dev->dev, "%s: CLAIMINTERFACE\n", __func__);
1975		ret = proc_claiminterface(ps, p);
1976		break;
1977
1978	case USBDEVFS_RELEASEINTERFACE:
1979		snoop(&dev->dev, "%s: RELEASEINTERFACE\n", __func__);
1980		ret = proc_releaseinterface(ps, p);
1981		break;
1982
1983	case USBDEVFS_IOCTL:
1984		snoop(&dev->dev, "%s: IOCTL\n", __func__);
1985		ret = proc_ioctl_default(ps, p);
1986		break;
1987
1988	case USBDEVFS_CLAIM_PORT:
1989		snoop(&dev->dev, "%s: CLAIM_PORT\n", __func__);
1990		ret = proc_claim_port(ps, p);
1991		break;
1992
1993	case USBDEVFS_RELEASE_PORT:
1994		snoop(&dev->dev, "%s: RELEASE_PORT\n", __func__);
1995		ret = proc_release_port(ps, p);
1996		break;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1997	}
 
 
1998	usb_unlock_device(dev);
1999	if (ret >= 0)
2000		inode->i_atime = CURRENT_TIME;
2001	return ret;
2002}
2003
2004static long usbdev_ioctl(struct file *file, unsigned int cmd,
2005			unsigned long arg)
2006{
2007	int ret;
2008
2009	ret = usbdev_do_ioctl(file, cmd, (void __user *)arg);
2010
2011	return ret;
2012}
2013
2014#ifdef CONFIG_COMPAT
2015static long usbdev_compat_ioctl(struct file *file, unsigned int cmd,
2016			unsigned long arg)
2017{
2018	int ret;
2019
2020	ret = usbdev_do_ioctl(file, cmd, compat_ptr(arg));
2021
2022	return ret;
2023}
2024#endif
2025
2026/* No kernel lock - fine */
2027static unsigned int usbdev_poll(struct file *file,
2028				struct poll_table_struct *wait)
2029{
2030	struct dev_state *ps = file->private_data;
2031	unsigned int mask = 0;
2032
2033	poll_wait(file, &ps->wait, wait);
2034	if (file->f_mode & FMODE_WRITE && !list_empty(&ps->async_completed))
2035		mask |= POLLOUT | POLLWRNORM;
2036	if (!connected(ps))
2037		mask |= POLLERR | POLLHUP;
 
 
2038	return mask;
2039}
2040
2041const struct file_operations usbdev_file_operations = {
2042	.owner =	  THIS_MODULE,
2043	.llseek =	  usbdev_lseek,
2044	.read =		  usbdev_read,
2045	.poll =		  usbdev_poll,
2046	.unlocked_ioctl = usbdev_ioctl,
2047#ifdef CONFIG_COMPAT
2048	.compat_ioctl =   usbdev_compat_ioctl,
2049#endif
2050	.open =		  usbdev_open,
2051	.release =	  usbdev_release,
2052};
2053
2054static void usbdev_remove(struct usb_device *udev)
2055{
2056	struct dev_state *ps;
2057	struct siginfo sinfo;
2058
 
 
2059	while (!list_empty(&udev->filelist)) {
2060		ps = list_entry(udev->filelist.next, struct dev_state, list);
2061		destroy_all_async(ps);
2062		wake_up_all(&ps->wait);
 
 
2063		list_del_init(&ps->list);
2064		if (ps->discsignr) {
2065			sinfo.si_signo = ps->discsignr;
2066			sinfo.si_errno = EPIPE;
2067			sinfo.si_code = SI_ASYNCIO;
2068			sinfo.si_addr = ps->disccontext;
2069			kill_pid_info_as_cred(ps->discsignr, &sinfo,
2070					ps->disc_pid, ps->cred, ps->secid);
2071		}
2072	}
 
2073}
2074
2075static int usbdev_notify(struct notifier_block *self,
2076			       unsigned long action, void *dev)
2077{
2078	switch (action) {
2079	case USB_DEVICE_ADD:
2080		break;
2081	case USB_DEVICE_REMOVE:
2082		usbdev_remove(dev);
2083		break;
2084	}
2085	return NOTIFY_OK;
2086}
2087
2088static struct notifier_block usbdev_nb = {
2089	.notifier_call = 	usbdev_notify,
2090};
2091
2092static struct cdev usb_device_cdev;
2093
2094int __init usb_devio_init(void)
2095{
2096	int retval;
2097
2098	retval = register_chrdev_region(USB_DEVICE_DEV, USB_DEVICE_MAX,
2099					"usb_device");
2100	if (retval) {
2101		printk(KERN_ERR "Unable to register minors for usb_device\n");
2102		goto out;
2103	}
2104	cdev_init(&usb_device_cdev, &usbdev_file_operations);
2105	retval = cdev_add(&usb_device_cdev, USB_DEVICE_DEV, USB_DEVICE_MAX);
2106	if (retval) {
2107		printk(KERN_ERR "Unable to get usb_device major %d\n",
2108		       USB_DEVICE_MAJOR);
2109		goto error_cdev;
2110	}
2111	usb_register_notify(&usbdev_nb);
2112out:
2113	return retval;
2114
2115error_cdev:
2116	unregister_chrdev_region(USB_DEVICE_DEV, USB_DEVICE_MAX);
2117	goto out;
2118}
2119
2120void usb_devio_cleanup(void)
2121{
2122	usb_unregister_notify(&usbdev_nb);
2123	cdev_del(&usb_device_cdev);
2124	unregister_chrdev_region(USB_DEVICE_DEV, USB_DEVICE_MAX);
2125}