devio.c
上传用户:jlfgdled
上传日期:2013-04-10
资源大小:33168k
文件大小:31k
源码类别:

Linux/Unix编程

开发平台:

Unix_Linux

  1. /*****************************************************************************/
  2. /*
  3.  *      devio.c  --  User space communication with USB devices.
  4.  *
  5.  *      Copyright (C) 1999-2000  Thomas Sailer (sailer@ife.ee.ethz.ch)
  6.  *
  7.  *      This program is free software; you can redistribute it and/or modify
  8.  *      it under the terms of the GNU General Public License as published by
  9.  *      the Free Software Foundation; either version 2 of the License, or
  10.  *      (at your option) any later version.
  11.  *
  12.  *      This program is distributed in the hope that it will be useful,
  13.  *      but WITHOUT ANY WARRANTY; without even the implied warranty of
  14.  *      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15.  *      GNU General Public License for more details.
  16.  *
  17.  *      You should have received a copy of the GNU General Public License
  18.  *      along with this program; if not, write to the Free Software
  19.  *      Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  20.  *
  21.  *  $Id: devio.c,v 1.7 2000/02/01 17:28:48 fliegl Exp $
  22.  *
  23.  *  This file implements the usbdevfs/x/y files, where
  24.  *  x is the bus number and y the device number.
  25.  *
  26.  *  It allows user space programs/"drivers" to communicate directly
  27.  *  with USB devices without intervening kernel driver.
  28.  *
  29.  *  Revision history
  30.  *    22.12.1999   0.1   Initial release (split from proc_usb.c)
  31.  *    04.01.2000   0.2   Turned into its own filesystem
  32.  */
  33. /*****************************************************************************/
  34. #include <linux/fs.h>
  35. #include <linux/mm.h>
  36. #include <linux/slab.h>
  37. #include <linux/smp_lock.h>
  38. #include <linux/signal.h>
  39. #include <linux/poll.h>
  40. #include <linux/usb.h>
  41. #include <linux/usbdevice_fs.h>
  42. #include <asm/uaccess.h>
  43. struct async {
  44.         struct list_head asynclist;
  45.         struct dev_state *ps;
  46. struct task_struct *task;
  47. unsigned int signr;
  48. void *userbuffer;
  49.         void *userurb;
  50.         struct urb urb;
  51. };
  52. static loff_t usbdev_lseek(struct file *file, loff_t offset, int orig)
  53. {
  54. switch (orig) {
  55. case 0:
  56. file->f_pos = offset;
  57. return file->f_pos;
  58. case 1:
  59. file->f_pos += offset;
  60. return file->f_pos;
  61. case 2:
  62. return -EINVAL;
  63. default:
  64. return -EINVAL;
  65. }
  66. }
  67. static ssize_t usbdev_read(struct file *file, char * buf, size_t nbytes, loff_t *ppos)
  68. {
  69. struct dev_state *ps = (struct dev_state *)file->private_data;
  70. ssize_t ret = 0;
  71. unsigned len;
  72. loff_t pos;
  73. int i;
  74. pos = *ppos;
  75. down_read(&ps->devsem);
  76. if (!ps->dev) {
  77. ret = -ENODEV;
  78. goto err;
  79. } else if (pos < 0) {
  80. ret = -EINVAL;
  81. goto err;
  82. }
  83. if (pos < sizeof(struct usb_device_descriptor)) {
  84. len = sizeof(struct usb_device_descriptor) - pos;
  85. if (len > nbytes)
  86. len = nbytes;
  87. if (copy_to_user(buf, ((char *)&ps->dev->descriptor) + pos, len)) {
  88. ret = -EFAULT;
  89. goto err;
  90. }
  91. *ppos += len;
  92. buf += len;
  93. nbytes -= len;
  94. ret += len;
  95. }
  96. pos = sizeof(struct usb_device_descriptor);
  97. for (i = 0; nbytes && i < ps->dev->descriptor.bNumConfigurations; i++) {
  98. struct usb_config_descriptor *config =
  99. (struct usb_config_descriptor *)ps->dev->rawdescriptors[i];
  100. unsigned int length = le16_to_cpu(config->wTotalLength);
  101. if (*ppos < pos + length) {
  102. len = length - (*ppos - pos);
  103. if (len > nbytes)
  104. len = nbytes;
  105. if (copy_to_user(buf,
  106.     ps->dev->rawdescriptors[i] + (*ppos - pos), len)) {
  107. ret = -EFAULT;
  108. goto err;
  109. }
  110. *ppos += len;
  111. buf += len;
  112. nbytes -= len;
  113. ret += len;
  114. }
  115. pos += length;
  116. }
  117. err:
  118. up_read(&ps->devsem);
  119. return ret;
  120. }
  121. static inline unsigned int ld2(unsigned int x)
  122. {
  123.         unsigned int r = 0;
  124.         
  125.         if (x >= 0x10000) {
  126.                 x >>= 16;
  127.                 r += 16;
  128.         }
  129.         if (x >= 0x100) {
  130.                 x >>= 8;
  131.                 r += 8;
  132.         }
  133.         if (x >= 0x10) {
  134.                 x >>= 4;
  135.                 r += 4;
  136.         }
  137.         if (x >= 4) {
  138.                 x >>= 2;
  139.                 r += 2;
  140.         }
  141.         if (x >= 2)
  142.                 r++;
  143.         return r;
  144. }
  145. /*
  146.  * async list handling
  147.  */
  148. static struct async *alloc_async(unsigned int numisoframes)
  149. {
  150.         unsigned int assize = sizeof(struct async) + numisoframes * sizeof(struct iso_packet_descriptor);
  151.         struct async *as = kmalloc(assize, GFP_KERNEL);
  152.         if (!as)
  153.                 return NULL;
  154.         memset(as, 0, assize);
  155.         as->urb.number_of_packets = numisoframes;
  156.         spin_lock_init(&as->urb.lock);
  157.         return as;
  158. }
  159. static void free_async(struct async *as)
  160. {
  161.         if (as->urb.transfer_buffer)
  162.                 kfree(as->urb.transfer_buffer);
  163.         if (as->urb.setup_packet)
  164.                 kfree(as->urb.setup_packet);
  165.         kfree(as);
  166. }
  167. static inline void async_newpending(struct async *as)
  168. {
  169.         struct dev_state *ps = as->ps;
  170.         unsigned long flags;
  171.         
  172.         spin_lock_irqsave(&ps->lock, flags);
  173.         list_add_tail(&as->asynclist, &ps->async_pending);
  174.         spin_unlock_irqrestore(&ps->lock, flags);
  175. }
  176. static inline void async_removepending(struct async *as)
  177. {
  178.         struct dev_state *ps = as->ps;
  179.         unsigned long flags;
  180.         
  181.         spin_lock_irqsave(&ps->lock, flags);
  182.         list_del(&as->asynclist);
  183.         INIT_LIST_HEAD(&as->asynclist);
  184.         spin_unlock_irqrestore(&ps->lock, flags);
  185. }
  186. static inline struct async *async_getcompleted(struct dev_state *ps)
  187. {
  188.         unsigned long flags;
  189.         struct async *as = NULL;
  190.         spin_lock_irqsave(&ps->lock, flags);
  191.         if (!list_empty(&ps->async_completed)) {
  192.                 as = list_entry(ps->async_completed.next, struct async, asynclist);
  193.                 list_del(&as->asynclist);
  194.                 INIT_LIST_HEAD(&as->asynclist);
  195.         }
  196.         spin_unlock_irqrestore(&ps->lock, flags);
  197.         return as;
  198. }
  199. static inline struct async *async_getpending(struct dev_state *ps, void *userurb)
  200. {
  201.         unsigned long flags;
  202.         struct async *as;
  203.         struct list_head *p;
  204.         spin_lock_irqsave(&ps->lock, flags);
  205.         for (p = ps->async_pending.next; p != &ps->async_pending; ) {
  206.                 as = list_entry(p, struct async, asynclist);
  207.                 p = p->next;
  208.                 if (as->userurb != userurb)
  209.                         continue;
  210.                 list_del(&as->asynclist);
  211.                 INIT_LIST_HEAD(&as->asynclist);
  212.                 spin_unlock_irqrestore(&ps->lock, flags);
  213.                 return as;
  214.         }
  215.         spin_unlock_irqrestore(&ps->lock, flags);
  216.         return NULL;
  217. }
  218. static void async_completed(struct urb *urb)
  219. {
  220.         struct async *as = (struct async *)urb->context;
  221.         struct dev_state *ps = as->ps;
  222. struct siginfo sinfo;
  223.         spin_lock(&ps->lock);
  224.         list_del(&as->asynclist);
  225.         list_add_tail(&as->asynclist, &ps->async_completed);
  226.         spin_unlock(&ps->lock);
  227.         wake_up(&ps->wait);
  228. if (as->signr) {
  229. sinfo.si_signo = as->signr;
  230. sinfo.si_errno = as->urb.status;
  231. sinfo.si_code = SI_ASYNCIO;
  232. sinfo.si_addr = as->userurb;
  233. send_sig_info(as->signr, &sinfo, as->task);
  234. }
  235. }
  236. static void destroy_all_async(struct dev_state *ps)
  237. {
  238.         struct async *as;
  239.         unsigned long flags;
  240.         spin_lock_irqsave(&ps->lock, flags);
  241.         while (!list_empty(&ps->async_pending)) {
  242.                 as = list_entry(ps->async_pending.next, struct async, asynclist);
  243.                 list_del(&as->asynclist);
  244.                 INIT_LIST_HEAD(&as->asynclist);
  245.                 spin_unlock_irqrestore(&ps->lock, flags);
  246.                 /* usb_unlink_urb calls the completion handler with status == USB_ST_URB_KILLED */
  247.                 usb_unlink_urb(&as->urb);
  248.                 spin_lock_irqsave(&ps->lock, flags);
  249.         }
  250.         spin_unlock_irqrestore(&ps->lock, flags);
  251.         while ((as = async_getcompleted(ps)))
  252.                 free_async(as);
  253. }
  254. /*
  255.  * interface claims are made only at the request of user level code,
  256.  * which can also release them (explicitly or by closing files).
  257.  * they're also undone when devices disconnect.
  258.  */
  259. static void *driver_probe(struct usb_device *dev, unsigned int intf,
  260.   const struct usb_device_id *id)
  261. {
  262. return NULL;
  263. }
  264. static void driver_disconnect(struct usb_device *dev, void *context)
  265. {
  266. struct dev_state *ps = (struct dev_state *)context;
  267. if (!ps)
  268. return;
  269. /* this waits till synchronous requests complete */
  270. down_write (&ps->devsem);
  271. /* prevent new I/O requests */
  272. ps->dev = 0;
  273. ps->ifclaimed = 0;
  274. /* force async requests to complete */
  275. destroy_all_async (ps);
  276. up_write (&ps->devsem);
  277. }
  278. struct usb_driver usbdevfs_driver = {
  279. name: "usbdevfs",
  280. probe: driver_probe,
  281. disconnect: driver_disconnect,
  282. };
  283. static int claimintf(struct dev_state *ps, unsigned int intf)
  284. {
  285. struct usb_device *dev = ps->dev;
  286. struct usb_interface *iface;
  287. int err;
  288. if (intf >= 8*sizeof(ps->ifclaimed) || !dev || intf >= dev->actconfig->bNumInterfaces)
  289. return -EINVAL;
  290. /* already claimed */
  291. if (test_bit(intf, &ps->ifclaimed))
  292. return 0;
  293. iface = &dev->actconfig->interface[intf];
  294. err = -EBUSY;
  295. lock_kernel();
  296. if (!usb_interface_claimed(iface)) {
  297. usb_driver_claim_interface(&usbdevfs_driver, iface, ps);
  298. set_bit(intf, &ps->ifclaimed);
  299. err = 0;
  300. }
  301. unlock_kernel();
  302. return err;
  303. }
  304. static int releaseintf(struct dev_state *ps, unsigned int intf)
  305. {
  306. struct usb_device *dev;
  307. struct usb_interface *iface;
  308. int err;
  309. if (intf >= 8*sizeof(ps->ifclaimed))
  310. return -EINVAL;
  311. err = -EINVAL;
  312. lock_kernel();
  313. dev = ps->dev;
  314. if (dev && test_and_clear_bit(intf, &ps->ifclaimed)) {
  315. iface = &dev->actconfig->interface[intf];
  316. usb_driver_release_interface(&usbdevfs_driver, iface);
  317. err = 0;
  318. }
  319. unlock_kernel();
  320. return err;
  321. }
  322. static int checkintf(struct dev_state *ps, unsigned int intf)
  323. {
  324. if (intf >= 8*sizeof(ps->ifclaimed))
  325. return -EINVAL;
  326. if (test_bit(intf, &ps->ifclaimed))
  327. return 0;
  328. /* if not yet claimed, claim it for the driver */
  329. printk(KERN_WARNING "usbdevfs: process %d (%s) did not claim interface %u before usen",
  330.        current->pid, current->comm, intf);
  331. return claimintf(ps, intf);
  332. }
  333. static int findintfep(struct usb_device *dev, unsigned int ep)
  334. {
  335. unsigned int i, j, e;
  336.         struct usb_interface *iface;
  337. struct usb_interface_descriptor *alts;
  338. struct usb_endpoint_descriptor *endpt;
  339. if (ep & ~(USB_DIR_IN|0xf))
  340. return -EINVAL;
  341. for (i = 0; i < dev->actconfig->bNumInterfaces; i++) {
  342. iface = &dev->actconfig->interface[i];
  343. for (j = 0; j < iface->num_altsetting; j++) {
  344.                         alts = &iface->altsetting[j];
  345. for (e = 0; e < alts->bNumEndpoints; e++) {
  346. endpt = &alts->endpoint[e];
  347. if (endpt->bEndpointAddress == ep)
  348. return i;
  349. }
  350. }
  351. }
  352. return -ENOENT; 
  353. }
  354. static int findintfif(struct usb_device *dev, unsigned int ifn)
  355. {
  356. unsigned int i, j;
  357.         struct usb_interface *iface;
  358. struct usb_interface_descriptor *alts;
  359. if (ifn & ~0xff)
  360. return -EINVAL;
  361. for (i = 0; i < dev->actconfig->bNumInterfaces; i++) {
  362. iface = &dev->actconfig->interface[i];
  363. for (j = 0; j < iface->num_altsetting; j++) {
  364.                         alts = &iface->altsetting[j];
  365. if (alts->bInterfaceNumber == ifn)
  366. return i;
  367. }
  368. }
  369. return -ENOENT; 
  370. }
  371. extern struct list_head usb_driver_list;
  372. #if 0
  373. static int finddriver(struct usb_driver **driver, char *name)
  374. {
  375. struct list_head *tmp;
  376. tmp = usb_driver_list.next;
  377. while (tmp != &usb_driver_list) {
  378. struct usb_driver *d = list_entry(tmp, struct usb_driver,
  379. driver_list);
  380. if (!strcmp(d->name, name)) {
  381. *driver = d;
  382. return 0;
  383. }
  384. tmp = tmp->next;
  385. }
  386. return -EINVAL;
  387. }
  388. #endif
  389. static int check_ctrlrecip(struct dev_state *ps, unsigned int requesttype, unsigned int index)
  390. {
  391. int ret;
  392. if (USB_TYPE_VENDOR == (USB_TYPE_MASK & requesttype))
  393. return 0;
  394. switch (requesttype & USB_RECIP_MASK) {
  395. case USB_RECIP_ENDPOINT:
  396. if ((ret = findintfep(ps->dev, index & 0xff)) < 0)
  397. return ret;
  398. if ((ret = checkintf(ps, ret)))
  399. return ret;
  400. break;
  401. case USB_RECIP_INTERFACE:
  402. if ((ret = findintfif(ps->dev, index & 0xff)) < 0)
  403. return ret;
  404. if ((ret = checkintf(ps, ret)))
  405. return ret;
  406. break;
  407. }
  408. return 0;
  409. }
  410. /*
  411.  * file operations
  412.  */
  413. static int usbdev_open(struct inode *inode, struct file *file)
  414. {
  415. struct usb_device *dev;
  416. struct dev_state *ps;
  417. int ret;
  418. /* 
  419.  * no locking necessary here, as both sys_open (actually filp_open)
  420.  * and the hub thread have the kernel lock
  421.  * (still acquire the kernel lock for safety)
  422.  */
  423. lock_kernel();
  424. ret = -ENOENT;
  425. if (ITYPE(inode->i_ino) != IDEVICE)
  426. goto out;
  427. dev = inode->u.usbdev_i.p.dev;
  428. if (!dev)
  429. goto out;
  430. ret = -ENOMEM;
  431. if (!(ps = kmalloc(sizeof(struct dev_state), GFP_KERNEL)))
  432. goto out;
  433. ret = 0;
  434. ps->dev = dev;
  435. ps->file = file;
  436. spin_lock_init(&ps->lock);
  437. INIT_LIST_HEAD(&ps->async_pending);
  438. INIT_LIST_HEAD(&ps->async_completed);
  439. init_waitqueue_head(&ps->wait);
  440. init_rwsem(&ps->devsem);
  441. ps->discsignr = 0;
  442. ps->disctask = current;
  443. ps->disccontext = NULL;
  444. ps->ifclaimed = 0;
  445. wmb();
  446. list_add_tail(&ps->list, &dev->filelist);
  447. file->private_data = ps;
  448.  out:
  449. unlock_kernel();
  450.         return ret;
  451. }
  452. static int usbdev_release(struct inode *inode, struct file *file)
  453. {
  454. struct dev_state *ps = (struct dev_state *)file->private_data;
  455. unsigned int i;
  456. lock_kernel();
  457. list_del(&ps->list);
  458. INIT_LIST_HEAD(&ps->list);
  459. if (ps->dev) {
  460. for (i = 0; ps->ifclaimed && i < 8*sizeof(ps->ifclaimed); i++)
  461. if (test_bit(i, &ps->ifclaimed))
  462. releaseintf(ps, i);
  463. }
  464. unlock_kernel();
  465. destroy_all_async(ps);
  466. kfree(ps);
  467.         return 0;
  468. }
  469. static int proc_control(struct dev_state *ps, void *arg)
  470. {
  471. struct usb_device *dev = ps->dev;
  472. struct usbdevfs_ctrltransfer ctrl;
  473. unsigned int tmo;
  474. unsigned char *tbuf;
  475. int i, ret;
  476. if (copy_from_user(&ctrl, (void *)arg, sizeof(ctrl)))
  477. return -EFAULT;
  478. if ((ret = check_ctrlrecip(ps, ctrl.requesttype, ctrl.index)))
  479. return ret;
  480. if (ctrl.length > PAGE_SIZE)
  481. return -EINVAL;
  482. if (!(tbuf = (unsigned char *)__get_free_page(GFP_KERNEL)))
  483. return -ENOMEM;
  484. tmo = (ctrl.timeout * HZ + 999) / 1000;
  485. if (ctrl.requesttype & 0x80) {
  486. if (ctrl.length && !access_ok(VERIFY_WRITE, ctrl.data, ctrl.length)) {
  487. free_page((unsigned long)tbuf);
  488. return -EINVAL;
  489. }
  490. i = usb_control_msg(dev, usb_rcvctrlpipe(dev, 0), ctrl.request, ctrl.requesttype,
  491.        ctrl.value, ctrl.index, tbuf, ctrl.length, tmo);
  492. if ((i > 0) && ctrl.length) {
  493. if (copy_to_user(ctrl.data, tbuf, ctrl.length)) {
  494. free_page((unsigned long)tbuf);
  495. return -EFAULT;
  496. }
  497. }
  498. } else {
  499. if (ctrl.length) {
  500. if (copy_from_user(tbuf, ctrl.data, ctrl.length)) {
  501. free_page((unsigned long)tbuf);
  502. return -EFAULT;
  503. }
  504. }
  505. i = usb_control_msg(dev, usb_sndctrlpipe(dev, 0), ctrl.request, ctrl.requesttype,
  506.        ctrl.value, ctrl.index, tbuf, ctrl.length, tmo);
  507. }
  508. free_page((unsigned long)tbuf);
  509. if (i<0) {
  510. printk(KERN_DEBUG "usbdevfs: USBDEVFS_CONTROL failed dev %d rqt %u rq %u len %u ret %dn", 
  511.        dev->devnum, ctrl.requesttype, ctrl.request, ctrl.length, i);
  512. }
  513. return i;
  514. }
  515. static int proc_bulk(struct dev_state *ps, void *arg)
  516. {
  517. struct usb_device *dev = ps->dev;
  518. struct usbdevfs_bulktransfer bulk;
  519. unsigned int tmo, len1, pipe;
  520. int len2;
  521. unsigned char *tbuf;
  522. int i, ret;
  523. if (copy_from_user(&bulk, (void *)arg, sizeof(bulk)))
  524. return -EFAULT;
  525. if ((ret = findintfep(ps->dev, bulk.ep)) < 0)
  526. return ret;
  527. if ((ret = checkintf(ps, ret)))
  528. return ret;
  529. if (bulk.ep & USB_DIR_IN)
  530. pipe = usb_rcvbulkpipe(dev, bulk.ep & 0x7f);
  531. else
  532. pipe = usb_sndbulkpipe(dev, bulk.ep & 0x7f);
  533. if (!usb_maxpacket(dev, pipe, !(bulk.ep & USB_DIR_IN)))
  534. return -EINVAL;
  535. len1 = bulk.len;
  536. if (len1 > PAGE_SIZE)
  537. return -EINVAL;
  538. if (!(tbuf = (unsigned char *)__get_free_page(GFP_KERNEL)))
  539. return -ENOMEM;
  540. tmo = (bulk.timeout * HZ + 999) / 1000;
  541. if (bulk.ep & 0x80) {
  542. if (len1 && !access_ok(VERIFY_WRITE, bulk.data, len1)) {
  543. free_page((unsigned long)tbuf);
  544. return -EINVAL;
  545. }
  546. i = usb_bulk_msg(dev, pipe, tbuf, len1, &len2, tmo);
  547. if (!i && len2) {
  548. if (copy_to_user(bulk.data, tbuf, len2)) {
  549. free_page((unsigned long)tbuf);
  550. return -EFAULT;
  551. }
  552. }
  553. } else {
  554. if (len1) {
  555. if (copy_from_user(tbuf, bulk.data, len1)) {
  556. free_page((unsigned long)tbuf);
  557. return -EFAULT;
  558. }
  559. }
  560. i = usb_bulk_msg(dev, pipe, tbuf, len1, &len2, tmo);
  561. }
  562. free_page((unsigned long)tbuf);
  563. if (i < 0) {
  564. printk(KERN_WARNING "usbdevfs: USBDEVFS_BULK failed dev %d ep 0x%x len %u ret %dn", 
  565.        dev->devnum, bulk.ep, bulk.len, i);
  566. return i;
  567. }
  568. return len2;
  569. }
  570. static int proc_resetep(struct dev_state *ps, void *arg)
  571. {
  572. unsigned int ep;
  573. int ret;
  574. if (get_user(ep, (unsigned int *)arg))
  575. return -EFAULT;
  576. if ((ret = findintfep(ps->dev, ep)) < 0)
  577. return ret;
  578. if ((ret = checkintf(ps, ret)))
  579. return ret;
  580. usb_settoggle(ps->dev, ep & 0xf, !(ep & USB_DIR_IN), 0);
  581. return 0;
  582. }
  583. static int proc_clearhalt(struct dev_state *ps, void *arg)
  584. {
  585. unsigned int ep;
  586. int pipe;
  587. int ret;
  588. if (get_user(ep, (unsigned int *)arg))
  589. return -EFAULT;
  590. if ((ret = findintfep(ps->dev, ep)) < 0)
  591. return ret;
  592. if ((ret = checkintf(ps, ret)))
  593. return ret;
  594. if (ep & USB_DIR_IN)
  595.                 pipe = usb_rcvbulkpipe(ps->dev, ep & 0x7f);
  596.         else
  597.                 pipe = usb_sndbulkpipe(ps->dev, ep & 0x7f);
  598. return usb_clear_halt(ps->dev, pipe);
  599. }
  600. static int proc_getdriver(struct dev_state *ps, void *arg)
  601. {
  602. struct usbdevfs_getdriver gd;
  603. struct usb_interface *interface;
  604. int ret;
  605. if (copy_from_user(&gd, arg, sizeof(gd)))
  606. return -EFAULT;
  607. if ((ret = findintfif(ps->dev, gd.interface)) < 0)
  608. return ret;
  609. interface = usb_ifnum_to_if(ps->dev, gd.interface);
  610. if (!interface)
  611. return -EINVAL;
  612. if (!interface->driver)
  613. return -ENODATA;
  614. strcpy(gd.driver, interface->driver->name);
  615. if (copy_to_user(arg, &gd, sizeof(gd)))
  616. return -EFAULT;
  617. return 0;
  618. }
  619. static int proc_connectinfo(struct dev_state *ps, void *arg)
  620. {
  621. struct usbdevfs_connectinfo ci;
  622. ci.devnum = ps->dev->devnum;
  623. ci.slow = ps->dev->speed == USB_SPEED_LOW;
  624. if (copy_to_user(arg, &ci, sizeof(ci)))
  625. return -EFAULT;
  626. return 0;
  627. }
  628. static int proc_resetdevice(struct dev_state *ps)
  629. {
  630. int i, ret;
  631. ret = usb_reset_device(ps->dev);
  632. if (ret < 0)
  633. return ret;
  634. for (i = 0; i < ps->dev->actconfig->bNumInterfaces; i++) {
  635. struct usb_interface *intf = &ps->dev->actconfig->interface[i];
  636. /* Don't simulate interfaces we've claimed */
  637. if (test_bit(i, &ps->ifclaimed))
  638. continue;
  639. if (intf->driver) {
  640. const struct usb_device_id *id;
  641. down(&intf->driver->serialize);
  642. intf->driver->disconnect(ps->dev, intf->private_data);
  643. id = usb_match_id(ps->dev,intf,intf->driver->id_table);
  644. intf->driver->probe(ps->dev, i, id);
  645. up(&intf->driver->serialize);
  646. }
  647. }
  648. return 0;
  649. }
  650. static int proc_setintf(struct dev_state *ps, void *arg)
  651. {
  652. struct usbdevfs_setinterface setintf;
  653. struct usb_interface *interface;
  654. int ret;
  655. if (copy_from_user(&setintf, arg, sizeof(setintf)))
  656. return -EFAULT;
  657. if ((ret = findintfif(ps->dev, setintf.interface)) < 0)
  658. return ret;
  659. interface = usb_ifnum_to_if(ps->dev, setintf.interface);
  660. if (!interface)
  661. return -EINVAL;
  662. if (interface->driver) {
  663. if ((ret = checkintf(ps, ret)))
  664. return ret;
  665. }
  666. if (usb_set_interface(ps->dev, setintf.interface, setintf.altsetting))
  667. return -EINVAL;
  668. return 0;
  669. }
  670. static int proc_setconfig(struct dev_state *ps, void *arg)
  671. {
  672. unsigned int u;
  673. if (get_user(u, (unsigned int *)arg))
  674. return -EFAULT;
  675. if (usb_set_configuration(ps->dev, u) < 0)
  676. return -EINVAL;
  677. return 0;
  678. }
  679. static int proc_submiturb(struct dev_state *ps, void *arg)
  680. {
  681. struct usbdevfs_urb uurb;
  682. struct usbdevfs_iso_packet_desc *isopkt = NULL;
  683. struct usb_endpoint_descriptor *ep_desc;
  684. struct async *as;
  685. struct usb_ctrlrequest *dr = NULL;
  686. unsigned int u, totlen, isofrmlen;
  687. int ret;
  688. if (copy_from_user(&uurb, arg, sizeof(uurb)))
  689. return -EFAULT;
  690. if (uurb.flags & ~(USBDEVFS_URB_ISO_ASAP|USBDEVFS_URB_DISABLE_SPD|USBDEVFS_URB_QUEUE_BULK|
  691.    USB_NO_FSBR|USB_ZERO_PACKET))
  692. return -EINVAL;
  693. if (!uurb.buffer)
  694. return -EINVAL;
  695. if (uurb.signr != 0 && (uurb.signr < SIGRTMIN || uurb.signr > SIGRTMAX))
  696. return -EINVAL;
  697. if (!(uurb.type == USBDEVFS_URB_TYPE_CONTROL && (uurb.endpoint & ~USB_ENDPOINT_DIR_MASK) == 0)) {
  698. if ((ret = findintfep(ps->dev, uurb.endpoint)) < 0)
  699. return ret;
  700. if ((ret = checkintf(ps, ret)))
  701. return ret;
  702. }
  703. switch(uurb.type) {
  704. case USBDEVFS_URB_TYPE_CONTROL:
  705. if ((uurb.endpoint & ~USB_ENDPOINT_DIR_MASK) != 0) {
  706. if (!(ep_desc = usb_epnum_to_ep_desc(ps->dev, uurb.endpoint)))
  707. return -ENOENT;
  708. if ((ep_desc->bmAttributes & USB_ENDPOINT_XFERTYPE_MASK) != USB_ENDPOINT_XFER_CONTROL)
  709. return -EINVAL;
  710. }
  711. /* min 8 byte setup packet, max arbitrary */
  712. if (uurb.buffer_length < 8 || uurb.buffer_length > PAGE_SIZE)
  713. return -EINVAL;
  714. if (!(dr = kmalloc(sizeof(struct usb_ctrlrequest), GFP_KERNEL)))
  715. return -ENOMEM;
  716. if (copy_from_user(dr, (unsigned char*)uurb.buffer, 8)) {
  717. kfree(dr);
  718. return -EFAULT;
  719. }
  720. if (uurb.buffer_length < (le16_to_cpup(&dr->wLength) + 8)) {
  721. kfree(dr);
  722. return -EINVAL;
  723. }
  724. if ((ret = check_ctrlrecip(ps, dr->bRequestType, le16_to_cpup(&dr->wIndex)))) {
  725. kfree(dr);
  726. return ret;
  727. }
  728. uurb.endpoint = (uurb.endpoint & ~USB_ENDPOINT_DIR_MASK) | (dr->bRequestType & USB_ENDPOINT_DIR_MASK);
  729. uurb.number_of_packets = 0;
  730. uurb.buffer_length = le16_to_cpup(&dr->wLength);
  731. uurb.buffer += 8;
  732. if (!access_ok((uurb.endpoint & USB_DIR_IN) ?  VERIFY_WRITE : VERIFY_READ, uurb.buffer, uurb.buffer_length)) {
  733. kfree(dr);
  734. return -EFAULT;
  735. }
  736. break;
  737. case USBDEVFS_URB_TYPE_BULK:
  738. uurb.number_of_packets = 0;
  739. if (uurb.buffer_length > 16384)
  740. return -EINVAL;
  741. if (!access_ok((uurb.endpoint & USB_DIR_IN) ? VERIFY_WRITE : VERIFY_READ, uurb.buffer, uurb.buffer_length))
  742. return -EFAULT;
  743. break;
  744. case USBDEVFS_URB_TYPE_ISO:
  745. /* arbitrary limit */
  746. if (uurb.number_of_packets < 1 || uurb.number_of_packets > 128)
  747. return -EINVAL;
  748. isofrmlen = sizeof(struct usbdevfs_iso_packet_desc) * uurb.number_of_packets;
  749. if (!(isopkt = kmalloc(isofrmlen, GFP_KERNEL)))
  750. return -ENOMEM;
  751. if (copy_from_user(isopkt, &((struct usbdevfs_urb *)arg)->iso_frame_desc, isofrmlen)) {
  752. kfree(isopkt);
  753. return -EFAULT;
  754. }
  755. for (totlen = u = 0; u < uurb.number_of_packets; u++) {
  756. if (isopkt[u].length > 1023) {
  757. kfree(isopkt);
  758. return -EINVAL;
  759. }
  760. totlen += isopkt[u].length;
  761. }
  762. if (totlen > 32768) {
  763. kfree(isopkt);
  764. return -EINVAL;
  765. }
  766. uurb.buffer_length = totlen;
  767. break;
  768. case USBDEVFS_URB_TYPE_INTERRUPT:
  769. uurb.number_of_packets = 0;
  770. if (uurb.buffer_length > 16384)
  771. return -EINVAL;
  772. if (!access_ok((uurb.endpoint & USB_DIR_IN) ? VERIFY_WRITE : VERIFY_READ, uurb.buffer, uurb.buffer_length))
  773. return -EFAULT;   
  774. break;
  775. default:
  776. return -EINVAL;
  777. }
  778. if (!(as = alloc_async(uurb.number_of_packets))) {
  779. if (isopkt)
  780. kfree(isopkt);
  781. if (dr)
  782. kfree(dr);
  783. return -ENOMEM;
  784. }
  785. if (!(as->urb.transfer_buffer = kmalloc(uurb.buffer_length, GFP_KERNEL))) {
  786. if (isopkt)
  787. kfree(isopkt);
  788. if (dr)
  789. kfree(dr);
  790. free_async(as);
  791. return -ENOMEM;
  792. }
  793.         as->urb.next = NULL;
  794.         as->urb.dev = ps->dev;
  795.         as->urb.pipe = (uurb.type << 30) | __create_pipe(ps->dev, uurb.endpoint & 0xf) | (uurb.endpoint & USB_DIR_IN);
  796.         as->urb.transfer_flags = uurb.flags;
  797. as->urb.transfer_buffer_length = uurb.buffer_length;
  798. as->urb.setup_packet = (unsigned char*)dr;
  799. as->urb.start_frame = uurb.start_frame;
  800. as->urb.number_of_packets = uurb.number_of_packets;
  801.         as->urb.context = as;
  802.         as->urb.complete = async_completed;
  803. for (totlen = u = 0; u < uurb.number_of_packets; u++) {
  804. as->urb.iso_frame_desc[u].offset = totlen;
  805. as->urb.iso_frame_desc[u].length = isopkt[u].length;
  806. totlen += isopkt[u].length;
  807. }
  808. if (isopkt)
  809. kfree(isopkt);
  810. as->ps = ps;
  811.         as->userurb = arg;
  812. if (uurb.endpoint & USB_DIR_IN)
  813. as->userbuffer = uurb.buffer;
  814. else
  815. as->userbuffer = NULL;
  816. as->signr = uurb.signr;
  817. as->task = current;
  818. if (!(uurb.endpoint & USB_DIR_IN)) {
  819. if (copy_from_user(as->urb.transfer_buffer, uurb.buffer, as->urb.transfer_buffer_length)) {
  820. free_async(as);
  821. return -EFAULT;
  822. }
  823. }
  824.         async_newpending(as);
  825.         if ((ret = usb_submit_urb(&as->urb))) {
  826. printk(KERN_DEBUG "usbdevfs: usb_submit_urb returned %dn", ret);
  827.                 async_removepending(as);
  828.                 free_async(as);
  829.                 return ret;
  830.         }
  831.         return 0;
  832. }
  833. static int proc_unlinkurb(struct dev_state *ps, void *arg)
  834. {
  835. struct async *as;
  836. as = async_getpending(ps, arg);
  837. if (!as)
  838. return -EINVAL;
  839. usb_unlink_urb(&as->urb);
  840. return 0;
  841. }
  842. static int processcompl(struct async *as)
  843. {
  844. unsigned int i;
  845. if (as->userbuffer)
  846. if (copy_to_user(as->userbuffer, as->urb.transfer_buffer, as->urb.transfer_buffer_length))
  847. return -EFAULT;
  848. if (put_user(as->urb.status,
  849.      &((struct usbdevfs_urb *)as->userurb)->status))
  850. return -EFAULT;
  851. if (put_user(as->urb.actual_length,
  852.      &((struct usbdevfs_urb *)as->userurb)->actual_length))
  853. return -EFAULT;
  854. if (put_user(as->urb.error_count,
  855.      &((struct usbdevfs_urb *)as->userurb)->error_count))
  856. return -EFAULT;
  857. if (!(usb_pipeisoc(as->urb.pipe)))
  858. return 0;
  859. for (i = 0; i < as->urb.number_of_packets; i++) {
  860. if (put_user(as->urb.iso_frame_desc[i].actual_length, 
  861.      &((struct usbdevfs_urb *)as->userurb)->iso_frame_desc[i].actual_length))
  862. return -EFAULT;
  863. if (put_user(as->urb.iso_frame_desc[i].status, 
  864.      &((struct usbdevfs_urb *)as->userurb)->iso_frame_desc[i].status))
  865. return -EFAULT;
  866. }
  867. return 0;
  868. }
  869. static int proc_reapurb(struct dev_state *ps, void *arg)
  870. {
  871.         DECLARE_WAITQUEUE(wait, current);
  872. struct async *as = NULL;
  873. void *addr;
  874. int ret;
  875. add_wait_queue(&ps->wait, &wait);
  876. while (ps->dev) {
  877. __set_current_state(TASK_INTERRUPTIBLE);
  878. if ((as = async_getcompleted(ps)))
  879. break;
  880. if (signal_pending(current))
  881. break;
  882. up_read(&ps->devsem);
  883. schedule();
  884. down_read(&ps->devsem);
  885. }
  886. remove_wait_queue(&ps->wait, &wait);
  887. set_current_state(TASK_RUNNING);
  888. if (as) {
  889. ret = processcompl(as);
  890. addr = as->userurb;
  891. free_async(as);
  892. if (ret)
  893. return ret;
  894. if (put_user(addr, (void **)arg))
  895. return -EFAULT;
  896. return 0;
  897. }
  898. if (signal_pending(current))
  899. return -EINTR;
  900. return -EIO;
  901. }
  902. static int proc_reapurbnonblock(struct dev_state *ps, void *arg)
  903. {
  904. struct async *as;
  905. void *addr;
  906. int ret;
  907. if (!(as = async_getcompleted(ps)))
  908. return -EAGAIN;
  909. ret = processcompl(as);
  910. addr = as->userurb;
  911. free_async(as);
  912. if (ret)
  913. return ret;
  914. if (put_user(addr, (void **)arg))
  915. return -EFAULT;
  916. return 0;
  917. }
  918. static int proc_disconnectsignal(struct dev_state *ps, void *arg)
  919. {
  920. struct usbdevfs_disconnectsignal ds;
  921. if (copy_from_user(&ds, arg, sizeof(ds)))
  922. return -EFAULT;
  923. if (ds.signr != 0 && (ds.signr < SIGRTMIN || ds.signr > SIGRTMAX))
  924. return -EINVAL;
  925. ps->discsignr = ds.signr;
  926. ps->disccontext = ds.context;
  927. return 0;
  928. }
  929. static int proc_claiminterface(struct dev_state *ps, void *arg)
  930. {
  931. unsigned int intf;
  932. int ret;
  933. if (get_user(intf, (unsigned int *)arg))
  934. return -EFAULT;
  935. if ((ret = findintfif(ps->dev, intf)) < 0)
  936. return ret;
  937. return claimintf(ps, ret);
  938. }
  939. static int proc_releaseinterface(struct dev_state *ps, void *arg)
  940. {
  941. unsigned int intf;
  942. int ret;
  943. if (get_user(intf, (unsigned int *)arg))
  944. return -EFAULT;
  945. if ((ret = findintfif(ps->dev, intf)) < 0)
  946. return ret;
  947. return releaseintf(ps, intf);
  948. }
  949. static int proc_ioctl (struct dev_state *ps, void *arg)
  950. {
  951. struct usbdevfs_ioctl ctrl;
  952. int size;
  953. void *buf = 0;
  954. int retval = 0;
  955. /* get input parameters and alloc buffer */
  956. if (copy_from_user(&ctrl, (void *) arg, sizeof (ctrl)))
  957. return -EFAULT;
  958. if ((size = _IOC_SIZE (ctrl.ioctl_code)) > 0) {
  959. if ((buf = kmalloc (size, GFP_KERNEL)) == 0)
  960. return -ENOMEM;
  961. if ((_IOC_DIR(ctrl.ioctl_code) & _IOC_WRITE)) {
  962. if (copy_from_user (buf, ctrl.data, size)) {
  963. kfree (buf);
  964. return -EFAULT;
  965. }
  966. } else {
  967. memset (buf, 0, size);
  968. }
  969. }
  970. /* ioctl to device */
  971. if (ctrl.ifno < 0) {
  972. switch (ctrl.ioctl_code) {
  973. /* access/release token for issuing control messages
  974.  * ask a particular driver to bind/unbind, ... etc
  975.  */
  976. }
  977. retval = -ENOSYS;
  978. /* ioctl to the driver which has claimed a given interface */
  979. } else {
  980. struct usb_interface *ifp = 0;
  981. if (!ps->dev)
  982. retval = -ENODEV;
  983. else if (ctrl.ifno >= ps->dev->actconfig->bNumInterfaces)
  984. retval = -EINVAL;
  985. else {
  986. if (!(ifp = usb_ifnum_to_if (ps->dev, ctrl.ifno)))
  987. retval = -EINVAL;
  988. else if (ifp->driver == 0 || ifp->driver->ioctl == 0)
  989. retval = -ENOSYS;
  990. }
  991. if (retval == 0)
  992. /* ifno might usefully be passed ... */
  993. retval = ifp->driver->ioctl (ps->dev, ctrl.ioctl_code, buf);
  994. /* size = min_t(int, size, retval)? */
  995. }
  996. /* cleanup and return */
  997. if (retval >= 0
  998. && (_IOC_DIR (ctrl.ioctl_code) & _IOC_READ) != 0
  999. && size > 0
  1000. && copy_to_user (ctrl.data, buf, size) != 0)
  1001. retval = -EFAULT;
  1002. if (buf != 0)
  1003. kfree (buf);
  1004. return retval;
  1005. }
  1006. static int usbdev_ioctl(struct inode *inode, struct file *file, unsigned int cmd, unsigned long arg)
  1007. {
  1008. struct dev_state *ps = (struct dev_state *)file->private_data;
  1009. int ret = -ENOIOCTLCMD;
  1010. if (!(file->f_mode & FMODE_WRITE))
  1011. return -EPERM;
  1012. down_read(&ps->devsem);
  1013. if (!ps->dev) {
  1014. up_read(&ps->devsem);
  1015. return -ENODEV;
  1016. }
  1017. switch (cmd) {
  1018. case USBDEVFS_CONTROL:
  1019. ret = proc_control(ps, (void *)arg);
  1020. if (ret >= 0)
  1021. inode->i_mtime = CURRENT_TIME;
  1022. break;
  1023. case USBDEVFS_BULK:
  1024. ret = proc_bulk(ps, (void *)arg);
  1025. if (ret >= 0)
  1026. inode->i_mtime = CURRENT_TIME;
  1027. break;
  1028. case USBDEVFS_RESETEP:
  1029. ret = proc_resetep(ps, (void *)arg);
  1030. if (ret >= 0)
  1031. inode->i_mtime = CURRENT_TIME;
  1032. break;
  1033. case USBDEVFS_RESET:
  1034. ret = proc_resetdevice(ps);
  1035. break;
  1036. case USBDEVFS_CLEAR_HALT:
  1037. ret = proc_clearhalt(ps, (void *)arg);
  1038. if (ret >= 0)
  1039. inode->i_mtime = CURRENT_TIME;
  1040. break;
  1041. case USBDEVFS_GETDRIVER:
  1042. ret = proc_getdriver(ps, (void *)arg);
  1043. break;
  1044. case USBDEVFS_CONNECTINFO:
  1045. ret = proc_connectinfo(ps, (void *)arg);
  1046. break;
  1047. case USBDEVFS_SETINTERFACE:
  1048. ret = proc_setintf(ps, (void *)arg);
  1049. break;
  1050. case USBDEVFS_SETCONFIGURATION:
  1051. ret = proc_setconfig(ps, (void *)arg);
  1052. break;
  1053. case USBDEVFS_SUBMITURB:
  1054. ret = proc_submiturb(ps, (void *)arg);
  1055. if (ret >= 0)
  1056. inode->i_mtime = CURRENT_TIME;
  1057. break;
  1058. case USBDEVFS_DISCARDURB:
  1059. ret = proc_unlinkurb(ps, (void *)arg);
  1060. break;
  1061. case USBDEVFS_REAPURB:
  1062. ret = proc_reapurb(ps, (void *)arg);
  1063. break;
  1064. case USBDEVFS_REAPURBNDELAY:
  1065. ret = proc_reapurbnonblock(ps, (void *)arg);
  1066. break;
  1067. case USBDEVFS_DISCSIGNAL:
  1068. ret = proc_disconnectsignal(ps, (void *)arg);
  1069. break;
  1070. case USBDEVFS_CLAIMINTERFACE:
  1071. ret = proc_claiminterface(ps, (void *)arg);
  1072. break;
  1073. case USBDEVFS_RELEASEINTERFACE:
  1074. ret = proc_releaseinterface(ps, (void *)arg);
  1075. break;
  1076. case USBDEVFS_IOCTL:
  1077. ret = proc_ioctl(ps, (void *) arg);
  1078. break;
  1079. }
  1080. up_read(&ps->devsem);
  1081. if (ret >= 0)
  1082. inode->i_atime = CURRENT_TIME;
  1083. return ret;
  1084. }
  1085. /* No kernel lock - fine */
  1086. static unsigned int usbdev_poll(struct file *file, struct poll_table_struct *wait)
  1087. {
  1088. struct dev_state *ps = (struct dev_state *)file->private_data;
  1089.         unsigned int mask = 0;
  1090. poll_wait(file, &ps->wait, wait);
  1091. if (file->f_mode & FMODE_WRITE && !list_empty(&ps->async_completed))
  1092. mask |= POLLOUT | POLLWRNORM;
  1093. if (!ps->dev)
  1094. mask |= POLLERR | POLLHUP;
  1095. return mask;
  1096. }
  1097. struct file_operations usbdevfs_device_file_operations = {
  1098. llseek: usbdev_lseek,
  1099. read: usbdev_read,
  1100. poll: usbdev_poll,
  1101. ioctl: usbdev_ioctl,
  1102. open: usbdev_open,
  1103. release: usbdev_release,
  1104. };