dabusb.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873
  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/mutex.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)
  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 = kzalloc(sizeof (buff_t), GFP_KERNEL);
  192. if (!b) {
  193. err("kzalloc(sizeof(buff_t))==NULL");
  194. goto err;
  195. }
  196. b->s = s;
  197. b->purb = usb_alloc_urb(packets, GFP_KERNEL);
  198. if (!b->purb) {
  199. err("usb_alloc_urb == NULL");
  200. kfree (b);
  201. goto err;
  202. }
  203. b->purb->transfer_buffer = kmalloc (transfer_buffer_length, GFP_KERNEL);
  204. if (!b->purb->transfer_buffer) {
  205. kfree (b->purb);
  206. kfree (b);
  207. err("kmalloc(%d)==NULL", transfer_buffer_length);
  208. goto err;
  209. }
  210. b->purb->transfer_buffer_length = transfer_buffer_length;
  211. b->purb->number_of_packets = packets;
  212. b->purb->complete = dabusb_iso_complete;
  213. b->purb->context = b;
  214. b->purb->dev = s->usbdev;
  215. b->purb->pipe = pipe;
  216. b->purb->transfer_flags = URB_ISO_ASAP;
  217. for (i = 0; i < packets; i++) {
  218. b->purb->iso_frame_desc[i].offset = i * pipesize;
  219. b->purb->iso_frame_desc[i].length = pipesize;
  220. }
  221. buffers += transfer_buffer_length;
  222. list_add_tail (&b->buff_list, &s->free_buff_list);
  223. }
  224. s->got_mem = buffers;
  225. return 0;
  226. err:
  227. dabusb_free_buffers (s);
  228. return -ENOMEM;
  229. }
  230. /*-------------------------------------------------------------------*/
  231. static int dabusb_bulk (pdabusb_t s, pbulk_transfer_t pb)
  232. {
  233. int ret;
  234. unsigned int pipe;
  235. int actual_length;
  236. dbg("dabusb_bulk");
  237. if (!pb->pipe)
  238. pipe = usb_rcvbulkpipe (s->usbdev, 2);
  239. else
  240. pipe = usb_sndbulkpipe (s->usbdev, 2);
  241. ret=usb_bulk_msg(s->usbdev, pipe, pb->data, pb->size, &actual_length, 100);
  242. if(ret<0) {
  243. err("dabusb: usb_bulk_msg failed(%d)",ret);
  244. if (usb_set_interface (s->usbdev, _DABUSB_IF, 1) < 0) {
  245. err("set_interface failed");
  246. return -EINVAL;
  247. }
  248. }
  249. if( ret == -EPIPE ) {
  250. warn("CLEAR_FEATURE request to remove STALL condition.");
  251. if(usb_clear_halt(s->usbdev, usb_pipeendpoint(pipe)))
  252. err("request failed");
  253. }
  254. pb->size = actual_length;
  255. return ret;
  256. }
  257. /* --------------------------------------------------------------------- */
  258. static int dabusb_writemem (pdabusb_t s, int pos, unsigned char *data, int len)
  259. {
  260. int ret;
  261. unsigned char *transfer_buffer = kmalloc (len, GFP_KERNEL);
  262. if (!transfer_buffer) {
  263. err("dabusb_writemem: kmalloc(%d) failed.", len);
  264. return -ENOMEM;
  265. }
  266. memcpy (transfer_buffer, data, len);
  267. ret=usb_control_msg(s->usbdev, usb_sndctrlpipe( s->usbdev, 0 ), 0xa0, 0x40, pos, 0, transfer_buffer, len, 300);
  268. kfree (transfer_buffer);
  269. return ret;
  270. }
  271. /* --------------------------------------------------------------------- */
  272. static int dabusb_8051_reset (pdabusb_t s, unsigned char reset_bit)
  273. {
  274. dbg("dabusb_8051_reset: %d",reset_bit);
  275. return dabusb_writemem (s, CPUCS_REG, &reset_bit, 1);
  276. }
  277. /* --------------------------------------------------------------------- */
  278. static int dabusb_loadmem (pdabusb_t s, const char *fname)
  279. {
  280. int ret;
  281. PINTEL_HEX_RECORD ptr = firmware;
  282. dbg("Enter dabusb_loadmem (internal)");
  283. ret = dabusb_8051_reset (s, 1);
  284. while (ptr->Type == 0) {
  285. dbg("dabusb_writemem: %04X %p %d)", ptr->Address, ptr->Data, ptr->Length);
  286. ret = dabusb_writemem (s, ptr->Address, ptr->Data, ptr->Length);
  287. if (ret < 0) {
  288. err("dabusb_writemem failed (%d %04X %p %d)", ret, ptr->Address, ptr->Data, ptr->Length);
  289. break;
  290. }
  291. ptr++;
  292. }
  293. ret = dabusb_8051_reset (s, 0);
  294. dbg("dabusb_loadmem: exit");
  295. return ret;
  296. }
  297. /* --------------------------------------------------------------------- */
  298. static int dabusb_fpga_clear (pdabusb_t s, pbulk_transfer_t b)
  299. {
  300. b->size = 4;
  301. b->data[0] = 0x2a;
  302. b->data[1] = 0;
  303. b->data[2] = 0;
  304. b->data[3] = 0;
  305. dbg("dabusb_fpga_clear");
  306. return dabusb_bulk (s, b);
  307. }
  308. /* --------------------------------------------------------------------- */
  309. static int dabusb_fpga_init (pdabusb_t s, pbulk_transfer_t b)
  310. {
  311. b->size = 4;
  312. b->data[0] = 0x2c;
  313. b->data[1] = 0;
  314. b->data[2] = 0;
  315. b->data[3] = 0;
  316. dbg("dabusb_fpga_init");
  317. return dabusb_bulk (s, b);
  318. }
  319. /* --------------------------------------------------------------------- */
  320. static int dabusb_fpga_download (pdabusb_t s, const char *fname)
  321. {
  322. pbulk_transfer_t b = kmalloc (sizeof (bulk_transfer_t), GFP_KERNEL);
  323. unsigned int blen, n;
  324. int ret;
  325. unsigned char *buf = bitstream;
  326. dbg("Enter dabusb_fpga_download (internal)");
  327. if (!b) {
  328. err("kmalloc(sizeof(bulk_transfer_t))==NULL");
  329. return -ENOMEM;
  330. }
  331. b->pipe = 1;
  332. ret = dabusb_fpga_clear (s, b);
  333. mdelay (10);
  334. blen = buf[73] + (buf[72] << 8);
  335. dbg("Bitstream len: %i", blen);
  336. b->data[0] = 0x2b;
  337. b->data[1] = 0;
  338. b->data[2] = 0;
  339. b->data[3] = 60;
  340. for (n = 0; n <= blen + 60; n += 60) {
  341. // some cclks for startup
  342. b->size = 64;
  343. memcpy (b->data + 4, buf + 74 + n, 60);
  344. ret = dabusb_bulk (s, b);
  345. if (ret < 0) {
  346. err("dabusb_bulk failed.");
  347. break;
  348. }
  349. mdelay (1);
  350. }
  351. ret = dabusb_fpga_init (s, b);
  352. kfree (b);
  353. dbg("exit dabusb_fpga_download");
  354. return ret;
  355. }
  356. static int dabusb_stop (pdabusb_t s)
  357. {
  358. dbg("dabusb_stop");
  359. s->state = _stopped;
  360. dabusb_cancel_queue (s, &s->rec_buff_list);
  361. dbg("pending_io: %d", s->pending_io.counter);
  362. s->pending_io.counter = 0;
  363. return 0;
  364. }
  365. static int dabusb_startrek (pdabusb_t s)
  366. {
  367. if (!s->got_mem && s->state != _started) {
  368. dbg("dabusb_startrek");
  369. if (dabusb_alloc_buffers (s) < 0)
  370. return -ENOMEM;
  371. dabusb_stop (s);
  372. s->state = _started;
  373. s->readptr = 0;
  374. }
  375. if (!list_empty (&s->free_buff_list)) {
  376. pbuff_t end;
  377. int ret;
  378. while (!dabusb_add_buf_tail (s, &s->rec_buff_list, &s->free_buff_list)) {
  379. dbg("submitting: end:%p s->rec_buff_list:%p", s->rec_buff_list.prev, &s->rec_buff_list);
  380. end = list_entry (s->rec_buff_list.prev, buff_t, buff_list);
  381. ret = usb_submit_urb (end->purb, GFP_KERNEL);
  382. if (ret) {
  383. err("usb_submit_urb returned:%d", ret);
  384. if (dabusb_add_buf_tail (s, &s->free_buff_list, &s->rec_buff_list))
  385. err("startrek: dabusb_add_buf_tail failed");
  386. break;
  387. }
  388. else
  389. atomic_inc (&s->pending_io);
  390. }
  391. dbg("pending_io: %d",s->pending_io.counter);
  392. }
  393. return 0;
  394. }
  395. static ssize_t dabusb_read (struct file *file, char __user *buf, size_t count, loff_t * ppos)
  396. {
  397. pdabusb_t s = (pdabusb_t) file->private_data;
  398. unsigned long flags;
  399. unsigned ret = 0;
  400. int rem;
  401. int cnt;
  402. pbuff_t b;
  403. struct urb *purb = NULL;
  404. dbg("dabusb_read");
  405. if (*ppos)
  406. return -ESPIPE;
  407. if (s->remove_pending)
  408. return -EIO;
  409. if (!s->usbdev)
  410. return -EIO;
  411. while (count > 0) {
  412. dabusb_startrek (s);
  413. spin_lock_irqsave (&s->lock, flags);
  414. if (list_empty (&s->rec_buff_list)) {
  415. spin_unlock_irqrestore(&s->lock, flags);
  416. err("error: rec_buf_list is empty");
  417. goto err;
  418. }
  419. b = list_entry (s->rec_buff_list.next, buff_t, buff_list);
  420. purb = b->purb;
  421. spin_unlock_irqrestore(&s->lock, flags);
  422. if (purb->status == -EINPROGRESS) {
  423. if (file->f_flags & O_NONBLOCK) // return nonblocking
  424. {
  425. if (!ret)
  426. ret = -EAGAIN;
  427. goto err;
  428. }
  429. interruptible_sleep_on (&s->wait);
  430. if (signal_pending (current)) {
  431. if (!ret)
  432. ret = -ERESTARTSYS;
  433. goto err;
  434. }
  435. spin_lock_irqsave (&s->lock, flags);
  436. if (list_empty (&s->rec_buff_list)) {
  437. spin_unlock_irqrestore(&s->lock, flags);
  438. err("error: still no buffer available.");
  439. goto err;
  440. }
  441. spin_unlock_irqrestore(&s->lock, flags);
  442. s->readptr = 0;
  443. }
  444. if (s->remove_pending) {
  445. ret = -EIO;
  446. goto err;
  447. }
  448. rem = purb->actual_length - s->readptr; // set remaining bytes to copy
  449. if (count >= rem)
  450. cnt = rem;
  451. else
  452. cnt = count;
  453. dbg("copy_to_user:%p %p %d",buf, purb->transfer_buffer + s->readptr, cnt);
  454. if (copy_to_user (buf, purb->transfer_buffer + s->readptr, cnt)) {
  455. err("read: copy_to_user failed");
  456. if (!ret)
  457. ret = -EFAULT;
  458. goto err;
  459. }
  460. s->readptr += cnt;
  461. count -= cnt;
  462. buf += cnt;
  463. ret += cnt;
  464. if (s->readptr == purb->actual_length) {
  465. // finished, take next buffer
  466. if (dabusb_add_buf_tail (s, &s->free_buff_list, &s->rec_buff_list))
  467. err("read: dabusb_add_buf_tail failed");
  468. s->readptr = 0;
  469. }
  470. }
  471. err: //mutex_unlock(&s->mutex);
  472. return ret;
  473. }
  474. static int dabusb_open (struct inode *inode, struct file *file)
  475. {
  476. int devnum = iminor(inode);
  477. pdabusb_t s;
  478. if (devnum < DABUSB_MINOR || devnum >= (DABUSB_MINOR + NRDABUSB))
  479. return -EIO;
  480. s = &dabusb[devnum - DABUSB_MINOR];
  481. dbg("dabusb_open");
  482. mutex_lock(&s->mutex);
  483. while (!s->usbdev || s->opened) {
  484. mutex_unlock(&s->mutex);
  485. if (file->f_flags & O_NONBLOCK) {
  486. return -EBUSY;
  487. }
  488. msleep_interruptible(500);
  489. if (signal_pending (current)) {
  490. return -EAGAIN;
  491. }
  492. mutex_lock(&s->mutex);
  493. }
  494. if (usb_set_interface (s->usbdev, _DABUSB_IF, 1) < 0) {
  495. mutex_unlock(&s->mutex);
  496. err("set_interface failed");
  497. return -EINVAL;
  498. }
  499. s->opened = 1;
  500. mutex_unlock(&s->mutex);
  501. file->f_pos = 0;
  502. file->private_data = s;
  503. return nonseekable_open(inode, file);
  504. }
  505. static int dabusb_release (struct inode *inode, struct file *file)
  506. {
  507. pdabusb_t s = (pdabusb_t) file->private_data;
  508. dbg("dabusb_release");
  509. mutex_lock(&s->mutex);
  510. dabusb_stop (s);
  511. dabusb_free_buffers (s);
  512. mutex_unlock(&s->mutex);
  513. if (!s->remove_pending) {
  514. if (usb_set_interface (s->usbdev, _DABUSB_IF, 0) < 0)
  515. err("set_interface failed");
  516. }
  517. else
  518. wake_up (&s->remove_ok);
  519. s->opened = 0;
  520. return 0;
  521. }
  522. static int dabusb_ioctl (struct inode *inode, struct file *file, unsigned int cmd, unsigned long arg)
  523. {
  524. pdabusb_t s = (pdabusb_t) file->private_data;
  525. pbulk_transfer_t pbulk;
  526. int ret = 0;
  527. int version = DABUSB_VERSION;
  528. dbg("dabusb_ioctl");
  529. if (s->remove_pending)
  530. return -EIO;
  531. mutex_lock(&s->mutex);
  532. if (!s->usbdev) {
  533. mutex_unlock(&s->mutex);
  534. return -EIO;
  535. }
  536. switch (cmd) {
  537. case IOCTL_DAB_BULK:
  538. pbulk = kmalloc(sizeof (bulk_transfer_t), GFP_KERNEL);
  539. if (!pbulk) {
  540. ret = -ENOMEM;
  541. break;
  542. }
  543. if (copy_from_user (pbulk, (void __user *) arg, sizeof (bulk_transfer_t))) {
  544. ret = -EFAULT;
  545. kfree (pbulk);
  546. break;
  547. }
  548. ret=dabusb_bulk (s, pbulk);
  549. if(ret==0)
  550. if (copy_to_user((void __user *)arg, pbulk,
  551. sizeof(bulk_transfer_t)))
  552. ret = -EFAULT;
  553. kfree (pbulk);
  554. break;
  555. case IOCTL_DAB_OVERRUNS:
  556. ret = put_user (s->overruns, (unsigned int __user *) arg);
  557. break;
  558. case IOCTL_DAB_VERSION:
  559. ret = put_user (version, (unsigned int __user *) arg);
  560. break;
  561. default:
  562. ret = -ENOIOCTLCMD;
  563. break;
  564. }
  565. mutex_unlock(&s->mutex);
  566. return ret;
  567. }
  568. static const struct file_operations dabusb_fops =
  569. {
  570. .owner = THIS_MODULE,
  571. .llseek = no_llseek,
  572. .read = dabusb_read,
  573. .ioctl = dabusb_ioctl,
  574. .open = dabusb_open,
  575. .release = dabusb_release,
  576. };
  577. static struct usb_class_driver dabusb_class = {
  578. .name = "dabusb%d",
  579. .fops = &dabusb_fops,
  580. .minor_base = DABUSB_MINOR,
  581. };
  582. /* --------------------------------------------------------------------- */
  583. static int dabusb_probe (struct usb_interface *intf,
  584. const struct usb_device_id *id)
  585. {
  586. struct usb_device *usbdev = interface_to_usbdev(intf);
  587. int retval;
  588. pdabusb_t s;
  589. dbg("dabusb: probe: vendor id 0x%x, device id 0x%x ifnum:%d",
  590. le16_to_cpu(usbdev->descriptor.idVendor),
  591. le16_to_cpu(usbdev->descriptor.idProduct),
  592. intf->altsetting->desc.bInterfaceNumber);
  593. /* We don't handle multiple configurations */
  594. if (usbdev->descriptor.bNumConfigurations != 1)
  595. return -ENODEV;
  596. if (intf->altsetting->desc.bInterfaceNumber != _DABUSB_IF &&
  597. le16_to_cpu(usbdev->descriptor.idProduct) == 0x9999)
  598. return -ENODEV;
  599. s = &dabusb[intf->minor];
  600. mutex_lock(&s->mutex);
  601. s->remove_pending = 0;
  602. s->usbdev = usbdev;
  603. s->devnum = intf->minor;
  604. if (usb_reset_configuration (usbdev) < 0) {
  605. err("reset_configuration failed");
  606. goto reject;
  607. }
  608. if (le16_to_cpu(usbdev->descriptor.idProduct) == 0x2131) {
  609. dabusb_loadmem (s, NULL);
  610. goto reject;
  611. }
  612. else {
  613. dabusb_fpga_download (s, NULL);
  614. if (usb_set_interface (s->usbdev, _DABUSB_IF, 0) < 0) {
  615. err("set_interface failed");
  616. goto reject;
  617. }
  618. }
  619. dbg("bound to interface: %d", intf->altsetting->desc.bInterfaceNumber);
  620. usb_set_intfdata (intf, s);
  621. mutex_unlock(&s->mutex);
  622. retval = usb_register_dev(intf, &dabusb_class);
  623. if (retval) {
  624. usb_set_intfdata (intf, NULL);
  625. return -ENOMEM;
  626. }
  627. return 0;
  628. reject:
  629. mutex_unlock(&s->mutex);
  630. s->usbdev = NULL;
  631. return -ENODEV;
  632. }
  633. static void dabusb_disconnect (struct usb_interface *intf)
  634. {
  635. wait_queue_t __wait;
  636. pdabusb_t s = usb_get_intfdata (intf);
  637. dbg("dabusb_disconnect");
  638. init_waitqueue_entry(&__wait, current);
  639. usb_set_intfdata (intf, NULL);
  640. if (s) {
  641. usb_deregister_dev (intf, &dabusb_class);
  642. s->remove_pending = 1;
  643. wake_up (&s->wait);
  644. add_wait_queue(&s->remove_ok, &__wait);
  645. set_current_state(TASK_UNINTERRUPTIBLE);
  646. if (s->state == _started)
  647. schedule();
  648. current->state = TASK_RUNNING;
  649. remove_wait_queue(&s->remove_ok, &__wait);
  650. s->usbdev = NULL;
  651. s->overruns = 0;
  652. }
  653. }
  654. static struct usb_device_id dabusb_ids [] = {
  655. // { USB_DEVICE(0x0547, 0x2131) }, /* An2131 chip, no boot ROM */
  656. { USB_DEVICE(0x0547, 0x9999) },
  657. { } /* Terminating entry */
  658. };
  659. MODULE_DEVICE_TABLE (usb, dabusb_ids);
  660. static struct usb_driver dabusb_driver = {
  661. .name = "dabusb",
  662. .probe = dabusb_probe,
  663. .disconnect = dabusb_disconnect,
  664. .id_table = dabusb_ids,
  665. };
  666. /* --------------------------------------------------------------------- */
  667. static int __init dabusb_init (void)
  668. {
  669. int retval;
  670. unsigned u;
  671. /* initialize struct */
  672. for (u = 0; u < NRDABUSB; u++) {
  673. pdabusb_t s = &dabusb[u];
  674. memset (s, 0, sizeof (dabusb_t));
  675. mutex_init (&s->mutex);
  676. s->usbdev = NULL;
  677. s->total_buffer_size = buffers;
  678. init_waitqueue_head (&s->wait);
  679. init_waitqueue_head (&s->remove_ok);
  680. spin_lock_init (&s->lock);
  681. INIT_LIST_HEAD (&s->free_buff_list);
  682. INIT_LIST_HEAD (&s->rec_buff_list);
  683. }
  684. /* register misc device */
  685. retval = usb_register(&dabusb_driver);
  686. if (retval)
  687. goto out;
  688. dbg("dabusb_init: driver registered");
  689. info(DRIVER_VERSION ":" DRIVER_DESC);
  690. out:
  691. return retval;
  692. }
  693. static void __exit dabusb_cleanup (void)
  694. {
  695. dbg("dabusb_cleanup");
  696. usb_deregister (&dabusb_driver);
  697. }
  698. /* --------------------------------------------------------------------- */
  699. MODULE_AUTHOR( DRIVER_AUTHOR );
  700. MODULE_DESCRIPTION( DRIVER_DESC );
  701. MODULE_LICENSE("GPL");
  702. module_param(buffers, int, 0);
  703. MODULE_PARM_DESC (buffers, "Number of buffers (default=256)");
  704. module_init (dabusb_init);
  705. module_exit (dabusb_cleanup);
  706. /* --------------------------------------------------------------------- */