dabusb.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874
  1. /*****************************************************************************/
  2. /*
  3. * dabusb.c -- dab usb driver.
  4. *
  5. * Copyright (C) 1999 Deti Fliegl (deti@fliegl.de)
  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. *
  22. *
  23. * $Id: dabusb.c,v 1.54 2000/07/24 21:39:39 deti Exp $
  24. *
  25. */
  26. /*****************************************************************************/
  27. #include <linux/module.h>
  28. #include <linux/socket.h>
  29. #include <linux/list.h>
  30. #include <linux/vmalloc.h>
  31. #include <linux/slab.h>
  32. #include <linux/init.h>
  33. #include <asm/uaccess.h>
  34. #include <asm/atomic.h>
  35. #include <linux/delay.h>
  36. #include <linux/usb.h>
  37. #include <linux/smp_lock.h>
  38. #include "dabusb.h"
  39. #include "dabfirmware.h"
  40. /*
  41. * Version Information
  42. */
  43. #define DRIVER_VERSION "v1.54"
  44. #define DRIVER_AUTHOR "Deti Fliegl, deti@fliegl.de"
  45. #define DRIVER_DESC "DAB-USB Interface Driver for Linux (c)1999"
  46. /* --------------------------------------------------------------------- */
  47. #ifdef CONFIG_USB_DYNAMIC_MINORS
  48. #define NRDABUSB 256
  49. #else
  50. #define NRDABUSB 4
  51. #endif
  52. /*-------------------------------------------------------------------*/
  53. static dabusb_t dabusb[NRDABUSB];
  54. static int buffers = 256;
  55. static struct usb_driver dabusb_driver;
  56. /*-------------------------------------------------------------------*/
  57. static int dabusb_add_buf_tail (pdabusb_t s, struct list_head *dst, struct list_head *src)
  58. {
  59. unsigned long flags;
  60. struct list_head *tmp;
  61. int ret = 0;
  62. spin_lock_irqsave (&s->lock, flags);
  63. if (list_empty (src)) {
  64. // no elements in source buffer
  65. ret = -1;
  66. goto err;
  67. }
  68. tmp = src->next;
  69. list_move_tail (tmp, dst);
  70. err: spin_unlock_irqrestore (&s->lock, flags);
  71. return ret;
  72. }
  73. /*-------------------------------------------------------------------*/
  74. #ifdef DEBUG
  75. static void dump_urb (struct urb *urb)
  76. {
  77. dbg("urb :%p", urb);
  78. dbg("dev :%p", urb->dev);
  79. dbg("pipe :%08X", urb->pipe);
  80. dbg("status :%d", urb->status);
  81. dbg("transfer_flags :%08X", urb->transfer_flags);
  82. dbg("transfer_buffer :%p", urb->transfer_buffer);
  83. dbg("transfer_buffer_length:%d", urb->transfer_buffer_length);
  84. dbg("actual_length :%d", urb->actual_length);
  85. dbg("setup_packet :%p", urb->setup_packet);
  86. dbg("start_frame :%d", urb->start_frame);
  87. dbg("number_of_packets :%d", urb->number_of_packets);
  88. dbg("interval :%d", urb->interval);
  89. dbg("error_count :%d", urb->error_count);
  90. dbg("context :%p", urb->context);
  91. dbg("complete :%p", urb->complete);
  92. }
  93. #endif
  94. /*-------------------------------------------------------------------*/
  95. static int dabusb_cancel_queue (pdabusb_t s, struct list_head *q)
  96. {
  97. unsigned long flags;
  98. pbuff_t b;
  99. dbg("dabusb_cancel_queue");
  100. spin_lock_irqsave (&s->lock, flags);
  101. list_for_each_entry(b, q, buff_list) {
  102. #ifdef DEBUG
  103. dump_urb(b->purb);
  104. #endif
  105. usb_unlink_urb (b->purb);
  106. }
  107. spin_unlock_irqrestore (&s->lock, flags);
  108. return 0;
  109. }
  110. /*-------------------------------------------------------------------*/
  111. static int dabusb_free_queue (struct list_head *q)
  112. {
  113. struct list_head *tmp;
  114. struct list_head *p;
  115. pbuff_t b;
  116. dbg("dabusb_free_queue");
  117. for (p = q->next; p != q;) {
  118. b = list_entry (p, buff_t, buff_list);
  119. #ifdef DEBUG
  120. dump_urb(b->purb);
  121. #endif
  122. kfree(b->purb->transfer_buffer);
  123. usb_free_urb(b->purb);
  124. tmp = p->next;
  125. list_del (p);
  126. kfree (b);
  127. p = tmp;
  128. }
  129. return 0;
  130. }
  131. /*-------------------------------------------------------------------*/
  132. static int dabusb_free_buffers (pdabusb_t s)
  133. {
  134. unsigned long flags;
  135. dbg("dabusb_free_buffers");
  136. spin_lock_irqsave(&s->lock, flags);
  137. dabusb_free_queue (&s->free_buff_list);
  138. dabusb_free_queue (&s->rec_buff_list);
  139. spin_unlock_irqrestore(&s->lock, flags);
  140. s->got_mem = 0;
  141. return 0;
  142. }
  143. /*-------------------------------------------------------------------*/
  144. static void dabusb_iso_complete (struct urb *purb, struct pt_regs *regs)
  145. {
  146. pbuff_t b = purb->context;
  147. pdabusb_t s = b->s;
  148. int i;
  149. int len;
  150. int dst = 0;
  151. void *buf = purb->transfer_buffer;
  152. dbg("dabusb_iso_complete");
  153. // process if URB was not killed
  154. if (purb->status != -ENOENT) {
  155. unsigned int pipe = usb_rcvisocpipe (purb->dev, _DABUSB_ISOPIPE);
  156. int pipesize = usb_maxpacket (purb->dev, pipe, usb_pipeout (pipe));
  157. for (i = 0; i < purb->number_of_packets; i++)
  158. if (!purb->iso_frame_desc[i].status) {
  159. len = purb->iso_frame_desc[i].actual_length;
  160. if (len <= pipesize) {
  161. memcpy (buf + dst, buf + purb->iso_frame_desc[i].offset, len);
  162. dst += len;
  163. }
  164. else
  165. err("dabusb_iso_complete: invalid len %d", len);
  166. }
  167. else
  168. warn("dabusb_iso_complete: corrupted packet status: %d", purb->iso_frame_desc[i].status);
  169. if (dst != purb->actual_length)
  170. err("dst!=purb->actual_length:%d!=%d", dst, purb->actual_length);
  171. }
  172. if (atomic_dec_and_test (&s->pending_io) && !s->remove_pending && s->state != _stopped) {
  173. s->overruns++;
  174. err("overrun (%d)", s->overruns);
  175. }
  176. wake_up (&s->wait);
  177. }
  178. /*-------------------------------------------------------------------*/
  179. static int dabusb_alloc_buffers (pdabusb_t s)
  180. {
  181. int buffers = 0;
  182. pbuff_t b;
  183. unsigned int pipe = usb_rcvisocpipe (s->usbdev, _DABUSB_ISOPIPE);
  184. int pipesize = usb_maxpacket (s->usbdev, pipe, usb_pipeout (pipe));
  185. int packets = _ISOPIPESIZE / pipesize;
  186. int transfer_buffer_length = packets * pipesize;
  187. int i;
  188. dbg("dabusb_alloc_buffers pipesize:%d packets:%d transfer_buffer_len:%d",
  189. pipesize, packets, transfer_buffer_length);
  190. while (buffers < (s->total_buffer_size << 10)) {
  191. b = (pbuff_t) kmalloc (sizeof (buff_t), GFP_KERNEL);
  192. if (!b) {
  193. err("kmalloc(sizeof(buff_t))==NULL");
  194. goto err;
  195. }
  196. memset (b, 0, sizeof (buff_t));
  197. b->s = s;
  198. b->purb = usb_alloc_urb(packets, GFP_KERNEL);
  199. if (!b->purb) {
  200. err("usb_alloc_urb == NULL");
  201. kfree (b);
  202. goto err;
  203. }
  204. b->purb->transfer_buffer = kmalloc (transfer_buffer_length, GFP_KERNEL);
  205. if (!b->purb->transfer_buffer) {
  206. kfree (b->purb);
  207. kfree (b);
  208. err("kmalloc(%d)==NULL", transfer_buffer_length);
  209. goto err;
  210. }
  211. b->purb->transfer_buffer_length = transfer_buffer_length;
  212. b->purb->number_of_packets = packets;
  213. b->purb->complete = dabusb_iso_complete;
  214. b->purb->context = b;
  215. b->purb->dev = s->usbdev;
  216. b->purb->pipe = pipe;
  217. b->purb->transfer_flags = URB_ISO_ASAP;
  218. for (i = 0; i < packets; i++) {
  219. b->purb->iso_frame_desc[i].offset = i * pipesize;
  220. b->purb->iso_frame_desc[i].length = pipesize;
  221. }
  222. buffers += transfer_buffer_length;
  223. list_add_tail (&b->buff_list, &s->free_buff_list);
  224. }
  225. s->got_mem = buffers;
  226. return 0;
  227. err:
  228. dabusb_free_buffers (s);
  229. return -ENOMEM;
  230. }
  231. /*-------------------------------------------------------------------*/
  232. static int dabusb_bulk (pdabusb_t s, pbulk_transfer_t pb)
  233. {
  234. int ret;
  235. unsigned int pipe;
  236. int actual_length;
  237. dbg("dabusb_bulk");
  238. if (!pb->pipe)
  239. pipe = usb_rcvbulkpipe (s->usbdev, 2);
  240. else
  241. pipe = usb_sndbulkpipe (s->usbdev, 2);
  242. ret=usb_bulk_msg(s->usbdev, pipe, pb->data, pb->size, &actual_length, 100);
  243. if(ret<0) {
  244. err("dabusb: usb_bulk_msg failed(%d)",ret);
  245. if (usb_set_interface (s->usbdev, _DABUSB_IF, 1) < 0) {
  246. err("set_interface failed");
  247. return -EINVAL;
  248. }
  249. }
  250. if( ret == -EPIPE ) {
  251. warn("CLEAR_FEATURE request to remove STALL condition.");
  252. if(usb_clear_halt(s->usbdev, usb_pipeendpoint(pipe)))
  253. err("request failed");
  254. }
  255. pb->size = actual_length;
  256. return ret;
  257. }
  258. /* --------------------------------------------------------------------- */
  259. static int dabusb_writemem (pdabusb_t s, int pos, unsigned char *data, int len)
  260. {
  261. int ret;
  262. unsigned char *transfer_buffer = kmalloc (len, GFP_KERNEL);
  263. if (!transfer_buffer) {
  264. err("dabusb_writemem: kmalloc(%d) failed.", len);
  265. return -ENOMEM;
  266. }
  267. memcpy (transfer_buffer, data, len);
  268. ret=usb_control_msg(s->usbdev, usb_sndctrlpipe( s->usbdev, 0 ), 0xa0, 0x40, pos, 0, transfer_buffer, len, 300);
  269. kfree (transfer_buffer);
  270. return ret;
  271. }
  272. /* --------------------------------------------------------------------- */
  273. static int dabusb_8051_reset (pdabusb_t s, unsigned char reset_bit)
  274. {
  275. dbg("dabusb_8051_reset: %d",reset_bit);
  276. return dabusb_writemem (s, CPUCS_REG, &reset_bit, 1);
  277. }
  278. /* --------------------------------------------------------------------- */
  279. static int dabusb_loadmem (pdabusb_t s, const char *fname)
  280. {
  281. int ret;
  282. PINTEL_HEX_RECORD ptr = firmware;
  283. dbg("Enter dabusb_loadmem (internal)");
  284. ret = dabusb_8051_reset (s, 1);
  285. while (ptr->Type == 0) {
  286. dbg("dabusb_writemem: %04X %p %d)", ptr->Address, ptr->Data, ptr->Length);
  287. ret = dabusb_writemem (s, ptr->Address, ptr->Data, ptr->Length);
  288. if (ret < 0) {
  289. err("dabusb_writemem failed (%d %04X %p %d)", ret, ptr->Address, ptr->Data, ptr->Length);
  290. break;
  291. }
  292. ptr++;
  293. }
  294. ret = dabusb_8051_reset (s, 0);
  295. dbg("dabusb_loadmem: exit");
  296. return ret;
  297. }
  298. /* --------------------------------------------------------------------- */
  299. static int dabusb_fpga_clear (pdabusb_t s, pbulk_transfer_t b)
  300. {
  301. b->size = 4;
  302. b->data[0] = 0x2a;
  303. b->data[1] = 0;
  304. b->data[2] = 0;
  305. b->data[3] = 0;
  306. dbg("dabusb_fpga_clear");
  307. return dabusb_bulk (s, b);
  308. }
  309. /* --------------------------------------------------------------------- */
  310. static int dabusb_fpga_init (pdabusb_t s, pbulk_transfer_t b)
  311. {
  312. b->size = 4;
  313. b->data[0] = 0x2c;
  314. b->data[1] = 0;
  315. b->data[2] = 0;
  316. b->data[3] = 0;
  317. dbg("dabusb_fpga_init");
  318. return dabusb_bulk (s, b);
  319. }
  320. /* --------------------------------------------------------------------- */
  321. static int dabusb_fpga_download (pdabusb_t s, const char *fname)
  322. {
  323. pbulk_transfer_t b = kmalloc (sizeof (bulk_transfer_t), GFP_KERNEL);
  324. unsigned int blen, n;
  325. int ret;
  326. unsigned char *buf = bitstream;
  327. dbg("Enter dabusb_fpga_download (internal)");
  328. if (!b) {
  329. err("kmalloc(sizeof(bulk_transfer_t))==NULL");
  330. return -ENOMEM;
  331. }
  332. b->pipe = 1;
  333. ret = dabusb_fpga_clear (s, b);
  334. mdelay (10);
  335. blen = buf[73] + (buf[72] << 8);
  336. dbg("Bitstream len: %i", blen);
  337. b->data[0] = 0x2b;
  338. b->data[1] = 0;
  339. b->data[2] = 0;
  340. b->data[3] = 60;
  341. for (n = 0; n <= blen + 60; n += 60) {
  342. // some cclks for startup
  343. b->size = 64;
  344. memcpy (b->data + 4, buf + 74 + n, 60);
  345. ret = dabusb_bulk (s, b);
  346. if (ret < 0) {
  347. err("dabusb_bulk failed.");
  348. break;
  349. }
  350. mdelay (1);
  351. }
  352. ret = dabusb_fpga_init (s, b);
  353. kfree (b);
  354. dbg("exit dabusb_fpga_download");
  355. return ret;
  356. }
  357. static int dabusb_stop (pdabusb_t s)
  358. {
  359. dbg("dabusb_stop");
  360. s->state = _stopped;
  361. dabusb_cancel_queue (s, &s->rec_buff_list);
  362. dbg("pending_io: %d", s->pending_io.counter);
  363. s->pending_io.counter = 0;
  364. return 0;
  365. }
  366. static int dabusb_startrek (pdabusb_t s)
  367. {
  368. if (!s->got_mem && s->state != _started) {
  369. dbg("dabusb_startrek");
  370. if (dabusb_alloc_buffers (s) < 0)
  371. return -ENOMEM;
  372. dabusb_stop (s);
  373. s->state = _started;
  374. s->readptr = 0;
  375. }
  376. if (!list_empty (&s->free_buff_list)) {
  377. pbuff_t end;
  378. int ret;
  379. while (!dabusb_add_buf_tail (s, &s->rec_buff_list, &s->free_buff_list)) {
  380. dbg("submitting: end:%p s->rec_buff_list:%p", s->rec_buff_list.prev, &s->rec_buff_list);
  381. end = list_entry (s->rec_buff_list.prev, buff_t, buff_list);
  382. ret = usb_submit_urb (end->purb, GFP_KERNEL);
  383. if (ret) {
  384. err("usb_submit_urb returned:%d", ret);
  385. if (dabusb_add_buf_tail (s, &s->free_buff_list, &s->rec_buff_list))
  386. err("startrek: dabusb_add_buf_tail failed");
  387. break;
  388. }
  389. else
  390. atomic_inc (&s->pending_io);
  391. }
  392. dbg("pending_io: %d",s->pending_io.counter);
  393. }
  394. return 0;
  395. }
  396. static ssize_t dabusb_read (struct file *file, char __user *buf, size_t count, loff_t * ppos)
  397. {
  398. pdabusb_t s = (pdabusb_t) file->private_data;
  399. unsigned long flags;
  400. unsigned ret = 0;
  401. int rem;
  402. int cnt;
  403. pbuff_t b;
  404. struct urb *purb = NULL;
  405. dbg("dabusb_read");
  406. if (*ppos)
  407. return -ESPIPE;
  408. if (s->remove_pending)
  409. return -EIO;
  410. if (!s->usbdev)
  411. return -EIO;
  412. while (count > 0) {
  413. dabusb_startrek (s);
  414. spin_lock_irqsave (&s->lock, flags);
  415. if (list_empty (&s->rec_buff_list)) {
  416. spin_unlock_irqrestore(&s->lock, flags);
  417. err("error: rec_buf_list is empty");
  418. goto err;
  419. }
  420. b = list_entry (s->rec_buff_list.next, buff_t, buff_list);
  421. purb = b->purb;
  422. spin_unlock_irqrestore(&s->lock, flags);
  423. if (purb->status == -EINPROGRESS) {
  424. if (file->f_flags & O_NONBLOCK) // return nonblocking
  425. {
  426. if (!ret)
  427. ret = -EAGAIN;
  428. goto err;
  429. }
  430. interruptible_sleep_on (&s->wait);
  431. if (signal_pending (current)) {
  432. if (!ret)
  433. ret = -ERESTARTSYS;
  434. goto err;
  435. }
  436. spin_lock_irqsave (&s->lock, flags);
  437. if (list_empty (&s->rec_buff_list)) {
  438. spin_unlock_irqrestore(&s->lock, flags);
  439. err("error: still no buffer available.");
  440. goto err;
  441. }
  442. spin_unlock_irqrestore(&s->lock, flags);
  443. s->readptr = 0;
  444. }
  445. if (s->remove_pending) {
  446. ret = -EIO;
  447. goto err;
  448. }
  449. rem = purb->actual_length - s->readptr; // set remaining bytes to copy
  450. if (count >= rem)
  451. cnt = rem;
  452. else
  453. cnt = count;
  454. dbg("copy_to_user:%p %p %d",buf, purb->transfer_buffer + s->readptr, cnt);
  455. if (copy_to_user (buf, purb->transfer_buffer + s->readptr, cnt)) {
  456. err("read: copy_to_user failed");
  457. if (!ret)
  458. ret = -EFAULT;
  459. goto err;
  460. }
  461. s->readptr += cnt;
  462. count -= cnt;
  463. buf += cnt;
  464. ret += cnt;
  465. if (s->readptr == purb->actual_length) {
  466. // finished, take next buffer
  467. if (dabusb_add_buf_tail (s, &s->free_buff_list, &s->rec_buff_list))
  468. err("read: dabusb_add_buf_tail failed");
  469. s->readptr = 0;
  470. }
  471. }
  472. err: //up(&s->mutex);
  473. return ret;
  474. }
  475. static int dabusb_open (struct inode *inode, struct file *file)
  476. {
  477. int devnum = iminor(inode);
  478. pdabusb_t s;
  479. if (devnum < DABUSB_MINOR || devnum >= (DABUSB_MINOR + NRDABUSB))
  480. return -EIO;
  481. s = &dabusb[devnum - DABUSB_MINOR];
  482. dbg("dabusb_open");
  483. down (&s->mutex);
  484. while (!s->usbdev || s->opened) {
  485. up (&s->mutex);
  486. if (file->f_flags & O_NONBLOCK) {
  487. return -EBUSY;
  488. }
  489. msleep_interruptible(500);
  490. if (signal_pending (current)) {
  491. return -EAGAIN;
  492. }
  493. down (&s->mutex);
  494. }
  495. if (usb_set_interface (s->usbdev, _DABUSB_IF, 1) < 0) {
  496. up(&s->mutex);
  497. err("set_interface failed");
  498. return -EINVAL;
  499. }
  500. s->opened = 1;
  501. up (&s->mutex);
  502. file->f_pos = 0;
  503. file->private_data = s;
  504. return nonseekable_open(inode, file);
  505. }
  506. static int dabusb_release (struct inode *inode, struct file *file)
  507. {
  508. pdabusb_t s = (pdabusb_t) file->private_data;
  509. dbg("dabusb_release");
  510. down (&s->mutex);
  511. dabusb_stop (s);
  512. dabusb_free_buffers (s);
  513. up (&s->mutex);
  514. if (!s->remove_pending) {
  515. if (usb_set_interface (s->usbdev, _DABUSB_IF, 0) < 0)
  516. err("set_interface failed");
  517. }
  518. else
  519. wake_up (&s->remove_ok);
  520. s->opened = 0;
  521. return 0;
  522. }
  523. static int dabusb_ioctl (struct inode *inode, struct file *file, unsigned int cmd, unsigned long arg)
  524. {
  525. pdabusb_t s = (pdabusb_t) file->private_data;
  526. pbulk_transfer_t pbulk;
  527. int ret = 0;
  528. int version = DABUSB_VERSION;
  529. dbg("dabusb_ioctl");
  530. if (s->remove_pending)
  531. return -EIO;
  532. down (&s->mutex);
  533. if (!s->usbdev) {
  534. up (&s->mutex);
  535. return -EIO;
  536. }
  537. switch (cmd) {
  538. case IOCTL_DAB_BULK:
  539. pbulk = (pbulk_transfer_t) kmalloc (sizeof (bulk_transfer_t), GFP_KERNEL);
  540. if (!pbulk) {
  541. ret = -ENOMEM;
  542. break;
  543. }
  544. if (copy_from_user (pbulk, (void __user *) arg, sizeof (bulk_transfer_t))) {
  545. ret = -EFAULT;
  546. kfree (pbulk);
  547. break;
  548. }
  549. ret=dabusb_bulk (s, pbulk);
  550. if(ret==0)
  551. if (copy_to_user((void __user *)arg, pbulk,
  552. sizeof(bulk_transfer_t)))
  553. ret = -EFAULT;
  554. kfree (pbulk);
  555. break;
  556. case IOCTL_DAB_OVERRUNS:
  557. ret = put_user (s->overruns, (unsigned int __user *) arg);
  558. break;
  559. case IOCTL_DAB_VERSION:
  560. ret = put_user (version, (unsigned int __user *) arg);
  561. break;
  562. default:
  563. ret = -ENOIOCTLCMD;
  564. break;
  565. }
  566. up (&s->mutex);
  567. return ret;
  568. }
  569. static struct file_operations dabusb_fops =
  570. {
  571. .owner = THIS_MODULE,
  572. .llseek = no_llseek,
  573. .read = dabusb_read,
  574. .ioctl = dabusb_ioctl,
  575. .open = dabusb_open,
  576. .release = dabusb_release,
  577. };
  578. static struct usb_class_driver dabusb_class = {
  579. .name = "dabusb%d",
  580. .fops = &dabusb_fops,
  581. .minor_base = DABUSB_MINOR,
  582. };
  583. /* --------------------------------------------------------------------- */
  584. static int dabusb_probe (struct usb_interface *intf,
  585. const struct usb_device_id *id)
  586. {
  587. struct usb_device *usbdev = interface_to_usbdev(intf);
  588. int retval;
  589. pdabusb_t s;
  590. dbg("dabusb: probe: vendor id 0x%x, device id 0x%x ifnum:%d",
  591. le16_to_cpu(usbdev->descriptor.idVendor),
  592. le16_to_cpu(usbdev->descriptor.idProduct),
  593. intf->altsetting->desc.bInterfaceNumber);
  594. /* We don't handle multiple configurations */
  595. if (usbdev->descriptor.bNumConfigurations != 1)
  596. return -ENODEV;
  597. if (intf->altsetting->desc.bInterfaceNumber != _DABUSB_IF &&
  598. le16_to_cpu(usbdev->descriptor.idProduct) == 0x9999)
  599. return -ENODEV;
  600. s = &dabusb[intf->minor];
  601. down (&s->mutex);
  602. s->remove_pending = 0;
  603. s->usbdev = usbdev;
  604. s->devnum = intf->minor;
  605. if (usb_reset_configuration (usbdev) < 0) {
  606. err("reset_configuration failed");
  607. goto reject;
  608. }
  609. if (le16_to_cpu(usbdev->descriptor.idProduct) == 0x2131) {
  610. dabusb_loadmem (s, NULL);
  611. goto reject;
  612. }
  613. else {
  614. dabusb_fpga_download (s, NULL);
  615. if (usb_set_interface (s->usbdev, _DABUSB_IF, 0) < 0) {
  616. err("set_interface failed");
  617. goto reject;
  618. }
  619. }
  620. dbg("bound to interface: %d", intf->altsetting->desc.bInterfaceNumber);
  621. usb_set_intfdata (intf, s);
  622. up (&s->mutex);
  623. retval = usb_register_dev(intf, &dabusb_class);
  624. if (retval) {
  625. usb_set_intfdata (intf, NULL);
  626. return -ENOMEM;
  627. }
  628. return 0;
  629. reject:
  630. up (&s->mutex);
  631. s->usbdev = NULL;
  632. return -ENODEV;
  633. }
  634. static void dabusb_disconnect (struct usb_interface *intf)
  635. {
  636. wait_queue_t __wait;
  637. pdabusb_t s = usb_get_intfdata (intf);
  638. dbg("dabusb_disconnect");
  639. init_waitqueue_entry(&__wait, current);
  640. usb_set_intfdata (intf, NULL);
  641. if (s) {
  642. usb_deregister_dev (intf, &dabusb_class);
  643. s->remove_pending = 1;
  644. wake_up (&s->wait);
  645. add_wait_queue(&s->remove_ok, &__wait);
  646. set_current_state(TASK_UNINTERRUPTIBLE);
  647. if (s->state == _started)
  648. schedule();
  649. current->state = TASK_RUNNING;
  650. remove_wait_queue(&s->remove_ok, &__wait);
  651. s->usbdev = NULL;
  652. s->overruns = 0;
  653. }
  654. }
  655. static struct usb_device_id dabusb_ids [] = {
  656. // { USB_DEVICE(0x0547, 0x2131) }, /* An2131 chip, no boot ROM */
  657. { USB_DEVICE(0x0547, 0x9999) },
  658. { } /* Terminating entry */
  659. };
  660. MODULE_DEVICE_TABLE (usb, dabusb_ids);
  661. static struct usb_driver dabusb_driver = {
  662. .name = "dabusb",
  663. .probe = dabusb_probe,
  664. .disconnect = dabusb_disconnect,
  665. .id_table = dabusb_ids,
  666. };
  667. /* --------------------------------------------------------------------- */
  668. static int __init dabusb_init (void)
  669. {
  670. int retval;
  671. unsigned u;
  672. /* initialize struct */
  673. for (u = 0; u < NRDABUSB; u++) {
  674. pdabusb_t s = &dabusb[u];
  675. memset (s, 0, sizeof (dabusb_t));
  676. init_MUTEX (&s->mutex);
  677. s->usbdev = NULL;
  678. s->total_buffer_size = buffers;
  679. init_waitqueue_head (&s->wait);
  680. init_waitqueue_head (&s->remove_ok);
  681. spin_lock_init (&s->lock);
  682. INIT_LIST_HEAD (&s->free_buff_list);
  683. INIT_LIST_HEAD (&s->rec_buff_list);
  684. }
  685. /* register misc device */
  686. retval = usb_register(&dabusb_driver);
  687. if (retval)
  688. goto out;
  689. dbg("dabusb_init: driver registered");
  690. info(DRIVER_VERSION ":" DRIVER_DESC);
  691. out:
  692. return retval;
  693. }
  694. static void __exit dabusb_cleanup (void)
  695. {
  696. dbg("dabusb_cleanup");
  697. usb_deregister (&dabusb_driver);
  698. }
  699. /* --------------------------------------------------------------------- */
  700. MODULE_AUTHOR( DRIVER_AUTHOR );
  701. MODULE_DESCRIPTION( DRIVER_DESC );
  702. MODULE_LICENSE("GPL");
  703. module_param(buffers, int, 0);
  704. MODULE_PARM_DESC (buffers, "Number of buffers (default=256)");
  705. module_init (dabusb_init);
  706. module_exit (dabusb_cleanup);
  707. /* --------------------------------------------------------------------- */