Staging: crystalhd: fix missing semicolon
[deliverable/linux.git] / drivers / staging / comedi / drivers.c
CommitLineData
ed9eccbe
DS
1/*
2 module/drivers.c
3 functions for manipulating drivers
4
5 COMEDI - Linux Control and Measurement Device Interface
6 Copyright (C) 1997-2000 David A. Schleef <ds@schleef.org>
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*/
23
24#define _GNU_SOURCE
25
26#define __NO_VERSION__
27#include "comedi_fops.h"
28#include <linux/device.h>
29#include <linux/module.h>
30#include <linux/pci.h>
c28264da 31#include <linux/usb.h>
ed9eccbe
DS
32#include <linux/errno.h>
33#include <linux/kernel.h>
34#include <linux/sched.h>
35#include <linux/fcntl.h>
36#include <linux/delay.h>
37#include <linux/ioport.h>
38#include <linux/mm.h>
39#include <linux/slab.h>
ed9eccbe
DS
40#include <linux/highmem.h> /* for SuSE brokenness */
41#include <linux/vmalloc.h>
42#include <linux/cdev.h>
43#include <linux/dma-mapping.h>
5617f9da 44#include <linux/io.h>
ed9eccbe
DS
45#include <asm/system.h>
46
242e7ad9
GKH
47#include "comedidev.h"
48#include "internal.h"
49
71b5f4f1 50static int postconfig(struct comedi_device *dev);
0a85b6f0
MT
51static int insn_rw_emulate_bits(struct comedi_device *dev,
52 struct comedi_subdevice *s,
53 struct comedi_insn *insn, unsigned int *data);
54static void *comedi_recognize(struct comedi_driver *driv, const char *name);
139dfbdf 55static void comedi_report_boards(struct comedi_driver *driv);
34c43922 56static int poll_invalid(struct comedi_device *dev, struct comedi_subdevice *s);
ed9eccbe 57
139dfbdf 58struct comedi_driver *comedi_drivers;
ed9eccbe 59
71b5f4f1 60static void cleanup_device(struct comedi_device *dev)
ed9eccbe
DS
61{
62 int i;
34c43922 63 struct comedi_subdevice *s;
ed9eccbe
DS
64
65 if (dev->subdevices) {
66 for (i = 0; i < dev->n_subdevices; i++) {
67 s = dev->subdevices + i;
68 comedi_free_subdevice_minor(s);
69 if (s->async) {
70 comedi_buf_alloc(dev, s, 0);
71 kfree(s->async);
72 }
73 }
74 kfree(dev->subdevices);
75 dev->subdevices = NULL;
76 dev->n_subdevices = 0;
77 }
dedd1325
BP
78 kfree(dev->private);
79 dev->private = NULL;
7029a874 80 dev->driver = NULL;
ed9eccbe
DS
81 dev->board_name = NULL;
82 dev->board_ptr = NULL;
83 dev->iobase = 0;
84 dev->irq = 0;
85 dev->read_subdev = NULL;
86 dev->write_subdev = NULL;
87 dev->open = NULL;
88 dev->close = NULL;
89 comedi_set_hw_dev(dev, NULL);
90}
91
71b5f4f1 92static void __comedi_device_detach(struct comedi_device *dev)
ed9eccbe
DS
93{
94 dev->attached = 0;
5617f9da 95 if (dev->driver)
ed9eccbe 96 dev->driver->detach(dev);
5617f9da 97 else
ac4898a0 98 printk(KERN_WARNING "BUG: dev->driver=NULL in comedi_device_detach()\n");
ed9eccbe
DS
99 cleanup_device(dev);
100}
101
71b5f4f1 102void comedi_device_detach(struct comedi_device *dev)
ed9eccbe
DS
103{
104 if (!dev->attached)
105 return;
106 __comedi_device_detach(dev);
107}
108
0707bb04 109int comedi_device_attach(struct comedi_device *dev, struct comedi_devconfig *it)
ed9eccbe 110{
139dfbdf 111 struct comedi_driver *driv;
ed9eccbe
DS
112 int ret;
113
114 if (dev->attached)
115 return -EBUSY;
116
117 for (driv = comedi_drivers; driv; driv = driv->next) {
118 if (!try_module_get(driv->module)) {
0a85b6f0 119 printk
ac4898a0 120 (KERN_INFO "comedi: failed to increment module count, skipping\n");
ed9eccbe
DS
121 continue;
122 }
123 if (driv->num_names) {
124 dev->board_ptr = comedi_recognize(driv, it->board_name);
125 if (dev->board_ptr == NULL) {
126 module_put(driv->module);
127 continue;
128 }
129 } else {
130 if (strcmp(driv->driver_name, it->board_name)) {
131 module_put(driv->module);
132 continue;
133 }
134 }
ac4898a0
ZR
135 /* initialize dev->driver here so
136 * comedi_error() can be called from attach */
ed9eccbe
DS
137 dev->driver = driv;
138 ret = driv->attach(dev, it);
139 if (ret < 0) {
140 module_put(dev->driver->module);
141 __comedi_device_detach(dev);
142 return ret;
143 }
144 goto attached;
145 }
146
b6c77757
BP
147 /* recognize has failed if we get here */
148 /* report valid board names before returning error */
ed9eccbe
DS
149 for (driv = comedi_drivers; driv; driv = driv->next) {
150 if (!try_module_get(driv->module)) {
ac4898a0 151 printk(KERN_INFO "comedi: failed to increment module count\n");
ed9eccbe
DS
152 continue;
153 }
154 comedi_report_boards(driv);
155 module_put(driv->module);
156 }
157 return -EIO;
158
159attached:
160 /* do a little post-config cleanup */
161 ret = postconfig(dev);
162 module_put(dev->driver->module);
163 if (ret < 0) {
164 __comedi_device_detach(dev);
165 return ret;
166 }
167
168 if (!dev->board_name) {
aad4029a
MR
169 printk(KERN_WARNING "BUG: dev->board_name=<%p>\n",
170 dev->board_name);
ed9eccbe
DS
171 dev->board_name = "BUG";
172 }
173 smp_wmb();
174 dev->attached = 1;
175
176 return 0;
177}
178
139dfbdf 179int comedi_driver_register(struct comedi_driver *driver)
ed9eccbe
DS
180{
181 driver->next = comedi_drivers;
182 comedi_drivers = driver;
183
184 return 0;
185}
d58214b0 186EXPORT_SYMBOL(comedi_driver_register);
ed9eccbe 187
139dfbdf 188int comedi_driver_unregister(struct comedi_driver *driver)
ed9eccbe 189{
139dfbdf 190 struct comedi_driver *prev;
ed9eccbe
DS
191 int i;
192
193 /* check for devices using this driver */
194 for (i = 0; i < COMEDI_NUM_BOARD_MINORS; i++) {
0a85b6f0
MT
195 struct comedi_device_file_info *dev_file_info =
196 comedi_get_device_file_info(i);
71b5f4f1 197 struct comedi_device *dev;
ed9eccbe 198
0a85b6f0
MT
199 if (dev_file_info == NULL)
200 continue;
ed9eccbe
DS
201 dev = dev_file_info->device;
202
203 mutex_lock(&dev->mutex);
204 if (dev->attached && dev->driver == driver) {
205 if (dev->use_count)
0a85b6f0 206 printk
ac4898a0 207 (KERN_WARNING "BUG! detaching device with use_count=%d\n",
0a85b6f0 208 dev->use_count);
ed9eccbe
DS
209 comedi_device_detach(dev);
210 }
211 mutex_unlock(&dev->mutex);
212 }
213
214 if (comedi_drivers == driver) {
215 comedi_drivers = driver->next;
216 return 0;
217 }
218
219 for (prev = comedi_drivers; prev->next; prev = prev->next) {
220 if (prev->next == driver) {
221 prev->next = driver->next;
222 return 0;
223 }
224 }
225 return -EINVAL;
226}
d58214b0 227EXPORT_SYMBOL(comedi_driver_unregister);
ed9eccbe 228
71b5f4f1 229static int postconfig(struct comedi_device *dev)
ed9eccbe
DS
230{
231 int i;
34c43922 232 struct comedi_subdevice *s;
d163679c 233 struct comedi_async *async = NULL;
ed9eccbe
DS
234 int ret;
235
236 for (i = 0; i < dev->n_subdevices; i++) {
237 s = dev->subdevices + i;
238
239 if (s->type == COMEDI_SUBD_UNUSED)
240 continue;
241
242 if (s->len_chanlist == 0)
243 s->len_chanlist = 1;
244
245 if (s->do_cmd) {
246 BUG_ON((s->subdev_flags & (SDF_CMD_READ |
0a85b6f0 247 SDF_CMD_WRITE)) == 0);
ed9eccbe
DS
248 BUG_ON(!s->do_cmdtest);
249
0a85b6f0
MT
250 async =
251 kzalloc(sizeof(struct comedi_async), GFP_KERNEL);
ed9eccbe 252 if (async == NULL) {
ac4898a0 253 printk(KERN_INFO "failed to allocate async struct\n");
ed9eccbe
DS
254 return -ENOMEM;
255 }
256 init_waitqueue_head(&async->wait_head);
257 async->subdevice = s;
258 s->async = async;
259
260#define DEFAULT_BUF_MAXSIZE (64*1024)
261#define DEFAULT_BUF_SIZE (64*1024)
262
263 async->max_bufsize = DEFAULT_BUF_MAXSIZE;
264
265 async->prealloc_buf = NULL;
266 async->prealloc_bufsz = 0;
267 if (comedi_buf_alloc(dev, s, DEFAULT_BUF_SIZE) < 0) {
ac4898a0 268 printk(KERN_INFO "Buffer allocation failed\n");
ed9eccbe
DS
269 return -ENOMEM;
270 }
271 if (s->buf_change) {
272 ret = s->buf_change(dev, s, DEFAULT_BUF_SIZE);
273 if (ret < 0)
274 return ret;
275 }
276 comedi_alloc_subdevice_minor(dev, s);
277 }
278
279 if (!s->range_table && !s->range_table_list)
280 s->range_table = &range_unknown;
281
282 if (!s->insn_read && s->insn_bits)
283 s->insn_read = insn_rw_emulate_bits;
284 if (!s->insn_write && s->insn_bits)
285 s->insn_write = insn_rw_emulate_bits;
286
287 if (!s->insn_read)
288 s->insn_read = insn_inval;
289 if (!s->insn_write)
290 s->insn_write = insn_inval;
291 if (!s->insn_bits)
292 s->insn_bits = insn_inval;
293 if (!s->insn_config)
294 s->insn_config = insn_inval;
295
296 if (!s->poll)
297 s->poll = poll_invalid;
298 }
299
300 return 0;
301}
302
ac4898a0
ZR
303/* generic recognize function for drivers
304 * that register their supported board names */
7029a874 305static void *comedi_recognize(struct comedi_driver *driv, const char *name)
ed9eccbe
DS
306{
307 unsigned i;
308 const char *const *name_ptr = driv->board_name;
309 for (i = 0; i < driv->num_names; i++) {
310 if (strcmp(*name_ptr, name) == 0)
311 return (void *)name_ptr;
312 name_ptr =
0a85b6f0
MT
313 (const char *const *)((const char *)name_ptr +
314 driv->offset);
ed9eccbe
DS
315 }
316
317 return NULL;
318}
319
7029a874 320static void comedi_report_boards(struct comedi_driver *driv)
ed9eccbe
DS
321{
322 unsigned int i;
323 const char *const *name_ptr;
324
ac4898a0 325 printk(KERN_INFO "comedi: valid board names for %s driver are:\n",
0a85b6f0 326 driv->driver_name);
ed9eccbe
DS
327
328 name_ptr = driv->board_name;
329 for (i = 0; i < driv->num_names; i++) {
ac4898a0 330 printk(KERN_INFO " %s\n", *name_ptr);
ed9eccbe
DS
331 name_ptr = (const char **)((char *)name_ptr + driv->offset);
332 }
333
334 if (driv->num_names == 0)
ac4898a0 335 printk(KERN_INFO " %s\n", driv->driver_name);
ed9eccbe
DS
336}
337
34c43922 338static int poll_invalid(struct comedi_device *dev, struct comedi_subdevice *s)
ed9eccbe
DS
339{
340 return -EINVAL;
341}
342
34c43922 343int insn_inval(struct comedi_device *dev, struct comedi_subdevice *s,
0a85b6f0 344 struct comedi_insn *insn, unsigned int *data)
ed9eccbe
DS
345{
346 return -EINVAL;
347}
348
0a85b6f0
MT
349static int insn_rw_emulate_bits(struct comedi_device *dev,
350 struct comedi_subdevice *s,
351 struct comedi_insn *insn, unsigned int *data)
ed9eccbe 352{
90035c08 353 struct comedi_insn new_insn;
ed9eccbe
DS
354 int ret;
355 static const unsigned channels_per_bitfield = 32;
356
357 unsigned chan = CR_CHAN(insn->chanspec);
358 const unsigned base_bitfield_channel =
0a85b6f0 359 (chan < channels_per_bitfield) ? 0 : chan;
790c5541 360 unsigned int new_data[2];
ed9eccbe
DS
361 memset(new_data, 0, sizeof(new_data));
362 memset(&new_insn, 0, sizeof(new_insn));
363 new_insn.insn = INSN_BITS;
364 new_insn.chanspec = base_bitfield_channel;
365 new_insn.n = 2;
366 new_insn.data = new_data;
367 new_insn.subdev = insn->subdev;
368
369 if (insn->insn == INSN_WRITE) {
370 if (!(s->subdev_flags & SDF_WRITABLE))
371 return -EINVAL;
aad4029a
MR
372 new_data[0] = 1 << (chan - base_bitfield_channel); /* mask */
373 new_data[1] = data[0] ? (1 << (chan - base_bitfield_channel))
374 : 0; /* bits */
ed9eccbe
DS
375 }
376
377 ret = s->insn_bits(dev, s, &new_insn, new_data);
378 if (ret < 0)
379 return ret;
380
5617f9da 381 if (insn->insn == INSN_READ)
ed9eccbe 382 data[0] = (new_data[1] >> (chan - base_bitfield_channel)) & 1;
ed9eccbe
DS
383
384 return 1;
385}
386
d43d27ab 387static inline unsigned long uvirt_to_kva(pgd_t *pgd, unsigned long adr)
ed9eccbe
DS
388{
389 unsigned long ret = 0UL;
390 pmd_t *pmd;
391 pte_t *ptep, pte;
392 pud_t *pud;
393
394 if (!pgd_none(*pgd)) {
395 pud = pud_offset(pgd, adr);
396 pmd = pmd_offset(pud, adr);
397 if (!pmd_none(*pmd)) {
398 ptep = pte_offset_kernel(pmd, adr);
399 pte = *ptep;
400 if (pte_present(pte)) {
401 ret = (unsigned long)
0a85b6f0 402 page_address(pte_page(pte));
ed9eccbe
DS
403 ret |= (adr & (PAGE_SIZE - 1));
404 }
405 }
406 }
407 return ret;
408}
409
410static inline unsigned long kvirt_to_kva(unsigned long adr)
411{
412 unsigned long va, kva;
413
414 va = adr;
415 kva = uvirt_to_kva(pgd_offset_k(va), va);
416
417 return kva;
418}
419
34c43922 420int comedi_buf_alloc(struct comedi_device *dev, struct comedi_subdevice *s,
0a85b6f0 421 unsigned long new_size)
ed9eccbe 422{
d163679c 423 struct comedi_async *async = s->async;
ed9eccbe
DS
424
425 /* Round up new_size to multiple of PAGE_SIZE */
426 new_size = (new_size + PAGE_SIZE - 1) & PAGE_MASK;
427
428 /* if no change is required, do nothing */
5617f9da 429 if (async->prealloc_buf && async->prealloc_bufsz == new_size)
ed9eccbe 430 return 0;
5617f9da 431
b6c77757 432 /* deallocate old buffer */
ed9eccbe
DS
433 if (async->prealloc_buf) {
434 vunmap(async->prealloc_buf);
435 async->prealloc_buf = NULL;
436 async->prealloc_bufsz = 0;
437 }
438 if (async->buf_page_list) {
439 unsigned i;
440 for (i = 0; i < async->n_buf_pages; ++i) {
441 if (async->buf_page_list[i].virt_addr) {
be29eac8 442 clear_bit(PG_reserved, &(virt_to_page(async->buf_page_list[i].virt_addr)->flags));
ed9eccbe
DS
443 if (s->async_dma_dir != DMA_NONE) {
444 dma_free_coherent(dev->hw_dev,
0a85b6f0
MT
445 PAGE_SIZE,
446 async->
447 buf_page_list
448 [i].virt_addr,
449 async->
450 buf_page_list
451 [i].dma_addr);
ed9eccbe 452 } else {
0a85b6f0
MT
453 free_page((unsigned long)
454 async->buf_page_list[i].
455 virt_addr);
ed9eccbe
DS
456 }
457 }
458 }
459 vfree(async->buf_page_list);
460 async->buf_page_list = NULL;
461 async->n_buf_pages = 0;
462 }
b6c77757 463 /* allocate new buffer */
ed9eccbe
DS
464 if (new_size) {
465 unsigned i = 0;
466 unsigned n_pages = new_size >> PAGE_SHIFT;
467 struct page **pages = NULL;
468
469 async->buf_page_list =
0a85b6f0 470 vmalloc(sizeof(struct comedi_buf_page) * n_pages);
ed9eccbe
DS
471 if (async->buf_page_list) {
472 memset(async->buf_page_list, 0,
0a85b6f0 473 sizeof(struct comedi_buf_page) * n_pages);
ed9eccbe
DS
474 pages = vmalloc(sizeof(struct page *) * n_pages);
475 }
476 if (pages) {
477 for (i = 0; i < n_pages; i++) {
478 if (s->async_dma_dir != DMA_NONE) {
479 async->buf_page_list[i].virt_addr =
0a85b6f0
MT
480 dma_alloc_coherent(dev->hw_dev,
481 PAGE_SIZE,
482 &async->
483 buf_page_list
484 [i].dma_addr,
485 GFP_KERNEL |
486 __GFP_COMP);
ed9eccbe
DS
487 } else {
488 async->buf_page_list[i].virt_addr =
0a85b6f0
MT
489 (void *)
490 get_zeroed_page(GFP_KERNEL);
ed9eccbe 491 }
5617f9da 492 if (async->buf_page_list[i].virt_addr == NULL)
ed9eccbe 493 break;
5617f9da 494
be29eac8
GKH
495 set_bit(PG_reserved,
496 &(virt_to_page(async->buf_page_list[i].virt_addr)->flags));
497 pages[i] = virt_to_page(async->buf_page_list[i].virt_addr);
ed9eccbe
DS
498 }
499 }
500 if (i == n_pages) {
501 async->prealloc_buf =
0a85b6f0 502 vmap(pages, n_pages, VM_MAP, PAGE_KERNEL_NOCACHE);
ed9eccbe 503 }
b455073c
F
504 vfree(pages);
505
ed9eccbe
DS
506 if (async->prealloc_buf == NULL) {
507 /* Some allocation failed above. */
508 if (async->buf_page_list) {
509 for (i = 0; i < n_pages; i++) {
510 if (async->buf_page_list[i].virt_addr ==
0a85b6f0 511 NULL) {
ed9eccbe
DS
512 break;
513 }
be29eac8 514 clear_bit(PG_reserved, &(virt_to_page(async->buf_page_list[i].virt_addr)->flags));
ed9eccbe
DS
515 if (s->async_dma_dir != DMA_NONE) {
516 dma_free_coherent(dev->hw_dev,
0a85b6f0
MT
517 PAGE_SIZE,
518 async->
519 buf_page_list
520 [i].virt_addr,
521 async->
522 buf_page_list
523 [i].dma_addr);
ed9eccbe 524 } else {
0a85b6f0
MT
525 free_page((unsigned long)
526 async->buf_page_list
527 [i].virt_addr);
ed9eccbe
DS
528 }
529 }
530 vfree(async->buf_page_list);
531 async->buf_page_list = NULL;
532 }
533 return -ENOMEM;
534 }
535 async->n_buf_pages = n_pages;
536 }
537 async->prealloc_bufsz = new_size;
538
539 return 0;
540}
541
542/* munging is applied to data by core as it passes between user
543 * and kernel space */
7029a874
GKH
544static unsigned int comedi_buf_munge(struct comedi_async *async,
545 unsigned int num_bytes)
ed9eccbe 546{
34c43922 547 struct comedi_subdevice *s = async->subdevice;
ed9eccbe
DS
548 unsigned int count = 0;
549 const unsigned num_sample_bytes = bytes_per_sample(s);
550
551 if (s->munge == NULL || (async->cmd.flags & CMDF_RAWDATA)) {
552 async->munge_count += num_bytes;
2961f24f 553 BUG_ON((int)(async->munge_count - async->buf_write_count) > 0);
ed9eccbe
DS
554 return num_bytes;
555 }
556 /* don't munge partial samples */
557 num_bytes -= num_bytes % num_sample_bytes;
558 while (count < num_bytes) {
559 int block_size;
560
561 block_size = num_bytes - count;
562 if (block_size < 0) {
ac4898a0 563 printk(KERN_WARNING "%s: %s: bug! block_size is negative\n",
0a85b6f0 564 __FILE__, __func__);
ed9eccbe
DS
565 break;
566 }
567 if ((int)(async->munge_ptr + block_size -
0a85b6f0 568 async->prealloc_bufsz) > 0)
ed9eccbe
DS
569 block_size = async->prealloc_bufsz - async->munge_ptr;
570
571 s->munge(s->device, s, async->prealloc_buf + async->munge_ptr,
0a85b6f0 572 block_size, async->munge_chan);
ed9eccbe 573
ac4898a0
ZR
574 smp_wmb(); /* barrier insures data is munged in buffer
575 * before munge_count is incremented */
ed9eccbe
DS
576
577 async->munge_chan += block_size / num_sample_bytes;
578 async->munge_chan %= async->cmd.chanlist_len;
579 async->munge_count += block_size;
580 async->munge_ptr += block_size;
581 async->munge_ptr %= async->prealloc_bufsz;
582 count += block_size;
583 }
2961f24f 584 BUG_ON((int)(async->munge_count - async->buf_write_count) > 0);
ed9eccbe
DS
585 return count;
586}
587
d163679c 588unsigned int comedi_buf_write_n_available(struct comedi_async *async)
ed9eccbe
DS
589{
590 unsigned int free_end;
591 unsigned int nbytes;
592
593 if (async == NULL)
594 return 0;
595
596 free_end = async->buf_read_count + async->prealloc_bufsz;
597 nbytes = free_end - async->buf_write_alloc_count;
598 nbytes -= nbytes % bytes_per_sample(async->subdevice);
599 /* barrier insures the read of buf_read_count in this
600 query occurs before any following writes to the buffer which
601 might be based on the return value from this query.
602 */
603 smp_mb();
604 return nbytes;
605}
606
607/* allocates chunk for the writer from free buffer space */
0a85b6f0
MT
608unsigned int comedi_buf_write_alloc(struct comedi_async *async,
609 unsigned int nbytes)
ed9eccbe
DS
610{
611 unsigned int free_end = async->buf_read_count + async->prealloc_bufsz;
612
5617f9da 613 if ((int)(async->buf_write_alloc_count + nbytes - free_end) > 0)
ed9eccbe 614 nbytes = free_end - async->buf_write_alloc_count;
5617f9da 615
ed9eccbe
DS
616 async->buf_write_alloc_count += nbytes;
617 /* barrier insures the read of buf_read_count above occurs before
618 we write data to the write-alloc'ed buffer space */
619 smp_mb();
620 return nbytes;
621}
d58214b0 622EXPORT_SYMBOL(comedi_buf_write_alloc);
ed9eccbe
DS
623
624/* allocates nothing unless it can completely fulfill the request */
d163679c 625unsigned int comedi_buf_write_alloc_strict(struct comedi_async *async,
0a85b6f0 626 unsigned int nbytes)
ed9eccbe
DS
627{
628 unsigned int free_end = async->buf_read_count + async->prealloc_bufsz;
629
5617f9da 630 if ((int)(async->buf_write_alloc_count + nbytes - free_end) > 0)
ed9eccbe 631 nbytes = 0;
5617f9da 632
ed9eccbe
DS
633 async->buf_write_alloc_count += nbytes;
634 /* barrier insures the read of buf_read_count above occurs before
635 we write data to the write-alloc'ed buffer space */
636 smp_mb();
637 return nbytes;
638}
639
640/* transfers a chunk from writer to filled buffer space */
d163679c 641unsigned comedi_buf_write_free(struct comedi_async *async, unsigned int nbytes)
ed9eccbe
DS
642{
643 if ((int)(async->buf_write_count + nbytes -
0a85b6f0
MT
644 async->buf_write_alloc_count) > 0) {
645 printk
ac4898a0 646 (KERN_INFO "comedi: attempted to write-free more bytes than have been write-allocated.\n");
ed9eccbe
DS
647 nbytes = async->buf_write_alloc_count - async->buf_write_count;
648 }
649 async->buf_write_count += nbytes;
650 async->buf_write_ptr += nbytes;
651 comedi_buf_munge(async, async->buf_write_count - async->munge_count);
5617f9da 652 if (async->buf_write_ptr >= async->prealloc_bufsz)
ed9eccbe 653 async->buf_write_ptr %= async->prealloc_bufsz;
5617f9da 654
ed9eccbe
DS
655 return nbytes;
656}
d58214b0 657EXPORT_SYMBOL(comedi_buf_write_free);
ed9eccbe
DS
658
659/* allocates a chunk for the reader from filled (and munged) buffer space */
d163679c 660unsigned comedi_buf_read_alloc(struct comedi_async *async, unsigned nbytes)
ed9eccbe
DS
661{
662 if ((int)(async->buf_read_alloc_count + nbytes - async->munge_count) >
0a85b6f0 663 0) {
ed9eccbe
DS
664 nbytes = async->munge_count - async->buf_read_alloc_count;
665 }
666 async->buf_read_alloc_count += nbytes;
667 /* barrier insures read of munge_count occurs before we actually read
668 data out of buffer */
669 smp_rmb();
670 return nbytes;
671}
d58214b0 672EXPORT_SYMBOL(comedi_buf_read_alloc);
ed9eccbe
DS
673
674/* transfers control of a chunk from reader to free buffer space */
d163679c 675unsigned comedi_buf_read_free(struct comedi_async *async, unsigned int nbytes)
ed9eccbe 676{
ac4898a0
ZR
677 /* barrier insures data has been read out of
678 * buffer before read count is incremented */
ed9eccbe
DS
679 smp_mb();
680 if ((int)(async->buf_read_count + nbytes -
0a85b6f0
MT
681 async->buf_read_alloc_count) > 0) {
682 printk
683 ("comedi: attempted to read-free more bytes than have been read-allocated.\n");
ed9eccbe
DS
684 nbytes = async->buf_read_alloc_count - async->buf_read_count;
685 }
686 async->buf_read_count += nbytes;
687 async->buf_read_ptr += nbytes;
688 async->buf_read_ptr %= async->prealloc_bufsz;
689 return nbytes;
690}
d58214b0 691EXPORT_SYMBOL(comedi_buf_read_free);
ed9eccbe 692
d163679c 693void comedi_buf_memcpy_to(struct comedi_async *async, unsigned int offset,
0a85b6f0 694 const void *data, unsigned int num_bytes)
ed9eccbe
DS
695{
696 unsigned int write_ptr = async->buf_write_ptr + offset;
697
698 if (write_ptr >= async->prealloc_bufsz)
699 write_ptr %= async->prealloc_bufsz;
700
701 while (num_bytes) {
702 unsigned int block_size;
703
704 if (write_ptr + num_bytes > async->prealloc_bufsz)
705 block_size = async->prealloc_bufsz - write_ptr;
706 else
707 block_size = num_bytes;
708
709 memcpy(async->prealloc_buf + write_ptr, data, block_size);
710
711 data += block_size;
712 num_bytes -= block_size;
713
714 write_ptr = 0;
715 }
716}
d58214b0 717EXPORT_SYMBOL(comedi_buf_memcpy_to);
ed9eccbe 718
d163679c 719void comedi_buf_memcpy_from(struct comedi_async *async, unsigned int offset,
0a85b6f0 720 void *dest, unsigned int nbytes)
ed9eccbe
DS
721{
722 void *src;
723 unsigned int read_ptr = async->buf_read_ptr + offset;
724
725 if (read_ptr >= async->prealloc_bufsz)
726 read_ptr %= async->prealloc_bufsz;
727
728 while (nbytes) {
729 unsigned int block_size;
730
731 src = async->prealloc_buf + read_ptr;
732
733 if (nbytes >= async->prealloc_bufsz - read_ptr)
734 block_size = async->prealloc_bufsz - read_ptr;
735 else
736 block_size = nbytes;
737
738 memcpy(dest, src, block_size);
739 nbytes -= block_size;
740 dest += block_size;
741 read_ptr = 0;
742 }
743}
d58214b0 744EXPORT_SYMBOL(comedi_buf_memcpy_from);
ed9eccbe 745
d163679c 746unsigned int comedi_buf_read_n_available(struct comedi_async *async)
ed9eccbe
DS
747{
748 unsigned num_bytes;
749
750 if (async == NULL)
751 return 0;
752 num_bytes = async->munge_count - async->buf_read_count;
753 /* barrier insures the read of munge_count in this
754 query occurs before any following reads of the buffer which
755 might be based on the return value from this query.
756 */
757 smp_rmb();
758 return num_bytes;
759}
d58214b0 760EXPORT_SYMBOL(comedi_buf_read_n_available);
ed9eccbe 761
d163679c 762int comedi_buf_get(struct comedi_async *async, short *x)
ed9eccbe
DS
763{
764 unsigned int n = comedi_buf_read_n_available(async);
765
790c5541 766 if (n < sizeof(short))
ed9eccbe 767 return 0;
790c5541 768 comedi_buf_read_alloc(async, sizeof(short));
0a85b6f0 769 *x = *(short *)(async->prealloc_buf + async->buf_read_ptr);
790c5541 770 comedi_buf_read_free(async, sizeof(short));
ed9eccbe
DS
771 return 1;
772}
d58214b0 773EXPORT_SYMBOL(comedi_buf_get);
ed9eccbe 774
d163679c 775int comedi_buf_put(struct comedi_async *async, short x)
ed9eccbe 776{
790c5541 777 unsigned int n = comedi_buf_write_alloc_strict(async, sizeof(short));
ed9eccbe 778
790c5541 779 if (n < sizeof(short)) {
ed9eccbe
DS
780 async->events |= COMEDI_CB_ERROR;
781 return 0;
782 }
0a85b6f0 783 *(short *)(async->prealloc_buf + async->buf_write_ptr) = x;
790c5541 784 comedi_buf_write_free(async, sizeof(short));
ed9eccbe
DS
785 return 1;
786}
d58214b0 787EXPORT_SYMBOL(comedi_buf_put);
ed9eccbe 788
d163679c 789void comedi_reset_async_buf(struct comedi_async *async)
ed9eccbe
DS
790{
791 async->buf_write_alloc_count = 0;
792 async->buf_write_count = 0;
793 async->buf_read_alloc_count = 0;
794 async->buf_read_count = 0;
795
796 async->buf_write_ptr = 0;
797 async->buf_read_ptr = 0;
798
799 async->cur_chan = 0;
800 async->scan_progress = 0;
801 async->munge_chan = 0;
802 async->munge_count = 0;
803 async->munge_ptr = 0;
804
805 async->events = 0;
806}
807
7029a874
GKH
808static int comedi_auto_config(struct device *hardware_device,
809 const char *board_name, const int *options,
810 unsigned num_options)
ed9eccbe 811{
0707bb04 812 struct comedi_devconfig it;
ed9eccbe
DS
813 int minor;
814 struct comedi_device_file_info *dev_file_info;
815 int retval;
c28264da 816 unsigned *private_data = NULL;
ed9eccbe 817
719548ef
IA
818 if (!comedi_autoconfig) {
819 dev_set_drvdata(hardware_device, NULL);
820 return 0;
821 }
6a9d7a21 822
ed9eccbe 823 minor = comedi_alloc_board_minor(hardware_device);
0a85b6f0
MT
824 if (minor < 0)
825 return minor;
c28264da
BP
826
827 private_data = kmalloc(sizeof(unsigned), GFP_KERNEL);
828 if (private_data == NULL) {
829 retval = -ENOMEM;
830 goto cleanup;
831 }
832 *private_data = minor;
833 dev_set_drvdata(hardware_device, private_data);
ed9eccbe
DS
834
835 dev_file_info = comedi_get_device_file_info(minor);
836
837 memset(&it, 0, sizeof(it));
838 strncpy(it.board_name, board_name, COMEDI_NAMELEN);
839 it.board_name[COMEDI_NAMELEN - 1] = '\0';
840 BUG_ON(num_options > COMEDI_NDEVCONFOPTS);
841 memcpy(it.options, options, num_options * sizeof(int));
842
843 mutex_lock(&dev_file_info->device->mutex);
844 retval = comedi_device_attach(dev_file_info->device, &it);
845 mutex_unlock(&dev_file_info->device->mutex);
c28264da
BP
846
847cleanup:
0a85b6f0 848 if (retval < 0) {
c28264da 849 kfree(private_data);
ed9eccbe
DS
850 comedi_free_board_minor(minor);
851 }
852 return retval;
853}
854
7029a874 855static void comedi_auto_unconfig(struct device *hardware_device)
ed9eccbe 856{
c28264da 857 unsigned *minor = (unsigned *)dev_get_drvdata(hardware_device);
0a85b6f0
MT
858 if (minor == NULL)
859 return;
ed9eccbe 860
c28264da 861 BUG_ON(*minor >= COMEDI_NUM_BOARD_MINORS);
ed9eccbe 862
c28264da
BP
863 comedi_free_board_minor(*minor);
864 dev_set_drvdata(hardware_device, NULL);
865 kfree(minor);
ed9eccbe
DS
866}
867
868int comedi_pci_auto_config(struct pci_dev *pcidev, const char *board_name)
869{
870 int options[2];
871
b6c77757 872 /* pci bus */
ed9eccbe 873 options[0] = pcidev->bus->number;
b6c77757 874 /* pci slot */
ed9eccbe
DS
875 options[1] = PCI_SLOT(pcidev->devfn);
876
8629efa4
BP
877 return comedi_auto_config(&pcidev->dev, board_name,
878 options, ARRAY_SIZE(options));
ed9eccbe 879}
4bf93559 880EXPORT_SYMBOL_GPL(comedi_pci_auto_config);
ed9eccbe
DS
881
882void comedi_pci_auto_unconfig(struct pci_dev *pcidev)
883{
884 comedi_auto_unconfig(&pcidev->dev);
885}
4bf93559 886EXPORT_SYMBOL_GPL(comedi_pci_auto_unconfig);
c28264da 887
0a85b6f0 888int comedi_usb_auto_config(struct usb_device *usbdev, const char *board_name)
c28264da
BP
889{
890 BUG_ON(usbdev == NULL);
891 return comedi_auto_config(&usbdev->dev, board_name, NULL, 0);
892}
4bf93559 893EXPORT_SYMBOL_GPL(comedi_usb_auto_config);
c28264da
BP
894
895void comedi_usb_auto_unconfig(struct usb_device *usbdev)
896{
897 BUG_ON(usbdev == NULL);
898 comedi_auto_unconfig(&usbdev->dev);
899}
4bf93559 900EXPORT_SYMBOL_GPL(comedi_usb_auto_unconfig);
This page took 0.215074 seconds and 5 git commands to generate.