main.c
上传用户:wudi5211
上传日期:2010-01-21
资源大小:607k
文件大小:15k
源码类别:

嵌入式Linux

开发平台:

C/C++

  1. /* -*- C -*-
  2.  * main.c -- the bare scullp char module
  3.  *
  4.  * Copyright (C) 2001 Alessandro Rubini and Jonathan Corbet
  5.  * Copyright (C) 2001 O'Reilly & Associates
  6.  *
  7.  * The source code in this file can be freely used, adapted,
  8.  * and redistributed in source or binary form, so long as an
  9.  * acknowledgment appears in derived source files.  The citation
  10.  * should list that the code comes from the book "Linux Device
  11.  * Drivers" by Alessandro Rubini and Jonathan Corbet, published
  12.  * by O'Reilly & Associates.   No warranty is attached;
  13.  * we cannot take responsibility for errors or fitness for use.
  14.  *
  15.  * $Id: _main.c.in,v 1.19 2001/07/18 22:28:18 rubini Exp $
  16.  */
  17. #ifndef __KERNEL__
  18. #  define __KERNEL__
  19. #endif
  20. #ifndef MODULE
  21. #  define MODULE
  22. #endif
  23. #include <linux/config.h>
  24. #include <linux/module.h>
  25. /* modversion stuff: no #ifdef needed if 2.0 support is not needed */
  26. #ifdef CONFIG_MODVERSIONS
  27. #  include <linux/modversions.h>
  28. #endif
  29. #include <linux/kernel.h> /* printk() */
  30. #include <linux/malloc.h> /* kmalloc() */
  31. #include <linux/fs.h>     /* everything... */
  32. #include <linux/errno.h>  /* error codes */
  33. #include <linux/types.h>  /* size_t */
  34. #include <linux/proc_fs.h>
  35. #include <linux/fcntl.h>        /* O_ACCMODE */
  36. #include <asm/system.h>   /* cli(), *_flags */
  37. #include "scullp.h"        /* local definitions */
  38. /*
  39.  * I don't use static symbols here, because register_symtab is called
  40.  */
  41. int scullp_major =   SCULLP_MAJOR;
  42. int scullp_devs =    SCULLP_DEVS;    /* number of bare scullp devices */
  43. int scullp_qset =    SCULLP_QSET;
  44. int scullp_order =   SCULLP_ORDER;
  45. MODULE_PARM(scullp_major, "i");
  46. MODULE_PARM(scullp_devs, "i");
  47. MODULE_PARM(scullp_qset, "i");
  48. MODULE_PARM(scullp_order, "i");
  49. MODULE_AUTHOR("Alessandro Rubini");
  50. ScullP_Dev *scullp_devices; /* allocated in scullp_init */
  51. int scullp_trim(ScullP_Dev *dev);
  52. #ifdef SCULLP_USE_PROC /* don't waste space if unused */
  53. /*
  54.  * The proc filesystem: function to read and entry
  55.  */
  56. void scullp_proc_offset(char *buf, char **start, off_t *offset, int *len)
  57. {
  58.     if (*offset == 0)
  59.         return;
  60.     if (*offset >= *len) {      /* Not there yet */
  61.         *offset -= *len;
  62.         *len = 0;
  63.     }
  64.     else {                      /* We're into the interesting stuff now */
  65.         *start = buf + *offset;
  66.         *offset = 0;
  67.     }
  68. }
  69. int scullp_read_procmem(char *buf, char **start, off_t offset,
  70.                    int count, int *eof, void *data)
  71. {
  72.     int i, j, order, qset, len = 0;
  73.     int limit = count - 80; /* Don't print more than this */
  74.     ScullP_Dev *d;
  75.     *start = buf;
  76.     for(i=0; i<scullp_devs; i++) {
  77.         d=&scullp_devices[i];
  78.         if (down_interruptible (&d->sem))
  79.                 return -ERESTARTSYS;
  80.         qset=d->qset;  /* retrieve the features of each device */
  81.         order=d->order;
  82.         len += sprintf(buf+len,"nDevice %i: qset %i, order %i, sz %lin",
  83.                        i, qset, order, (long)(d->size));
  84.         for (; d; d=d->next) { /* scan the list */
  85.             len += sprintf(buf+len,"  item at %p, qset at %pn",d,d->data);
  86.             scullp_proc_offset (buf, start, &offset, &len);
  87.             if (len > limit)
  88.                 goto out;
  89.             if (d->data && !d->next) /* dump only the last item - save space */
  90.                 for (j=0; j<qset; j++) {
  91.                     if (d->data[j])
  92.                         len += sprintf(buf+len,"    % 4i:%8pn",j,d->data[j]);
  93.                     scullp_proc_offset (buf, start, &offset, &len);
  94.                     if (len > limit)
  95.                         goto out;
  96. }
  97.         }
  98.     out:
  99.         up (&scullp_devices[i].sem);
  100. if (len > limit)
  101.     break;
  102.     }
  103.     *eof = 1;
  104.     return len;
  105. }
  106. #ifdef USE_PROC_REGISTER
  107. static int scullp_get_info (char *buf, char **start, off_t offset,
  108.                 int len, int unused)
  109. {
  110.     int eof = 0;
  111.     return scullp_read_procmem(buf, start, offset, len, &eof, NULL);
  112. }
  113. struct proc_dir_entry scullp_proc_entry = {
  114.         0,                 /* low_ino: the inode -- dynamic */
  115.         9, "scullpmem",     /* len of name and name */
  116.         S_IFREG | S_IRUGO, /* mode */
  117.         1, 0, 0,           /* nlinks, owner, group */
  118.         0, NULL,           /* size - unused; operations -- use default */
  119.         scullp_get_info,   /* function used to read data */
  120.         /* nothing more */
  121.     };
  122. static inline void create_proc_read_entry (const char *name, mode_t mode,
  123.                 struct proc_dir_entry *base, void *read_func, void *data)
  124. {
  125.     proc_register_dynamic (&proc_root, &scullp_proc_entry);
  126. }
  127. static inline void remove_proc_entry (char *name, void *parent)
  128. {
  129.     proc_unregister (&proc_root, scullp_proc_entry.low_ino);
  130. }
  131. #endif /* USE_PROC_REGISTER */
  132. #endif /* SCULLP_USE_PROC */
  133. /*
  134.  * Open and close
  135.  */
  136. int scullp_open (struct inode *inode, struct file *filp)
  137. {
  138.     int num = MINOR(inode->i_rdev);
  139.     ScullP_Dev *dev; /* device information */
  140.     /*  check the device number */
  141.     if (num >= scullp_devs) return -ENODEV;
  142.     dev = &scullp_devices[num];
  143.     /* now trim to 0 the length of the device if open was write-only */
  144.      if ( (filp->f_flags & O_ACCMODE) == O_WRONLY) {
  145.         if (down_interruptible (&dev->sem))
  146.             return -ERESTARTSYS;
  147.         scullp_trim(dev); /* ignore errors */
  148.         up (&dev->sem);
  149.     }
  150.     /* and use filp->private_data to point to the device data */
  151.     filp->private_data = dev;
  152.     MOD_INC_USE_COUNT;
  153.     return 0;          /* success */
  154. }
  155. int scullp_release (struct inode *inode, struct file *filp)
  156. {
  157.     MOD_DEC_USE_COUNT;
  158.     return 0;
  159. }
  160. /*
  161.  * Follow the list 
  162.  */
  163. ScullP_Dev *scullp_follow(ScullP_Dev *dev, int n)
  164. {
  165.     while (n--) {
  166.         if (!dev->next) {
  167.             dev->next = kmalloc(sizeof(ScullP_Dev), GFP_KERNEL);
  168.             memset(dev->next, 0, sizeof(ScullP_Dev));
  169.         }
  170.         dev = dev->next;
  171.         continue;
  172.     }
  173.     return dev;
  174. }
  175. /*
  176.  * Data management: read and write
  177.  */
  178. ssize_t scullp_read (struct file *filp, char *buf, size_t count,
  179.                 loff_t *f_pos)
  180. {
  181.     ScullP_Dev *dev = filp->private_data; /* the first listitem */
  182.     ScullP_Dev *dptr;
  183.     int quantum = PAGE_SIZE << dev->order;
  184.     int qset = dev->qset;
  185.     int itemsize = quantum * qset; /* how many bytes in the listitem */
  186.     int item, s_pos, q_pos, rest;
  187.     ssize_t retval = 0;
  188.     if (down_interruptible (&dev->sem))
  189.             return -ERESTARTSYS;
  190.     if (*f_pos > dev->size) 
  191.         goto nothing;
  192.     if (*f_pos + count > dev->size)
  193.         count = dev->size - *f_pos;
  194.     /* find listitem, qset index, and offset in the quantum */
  195.     item = ((long) *f_pos) / itemsize;
  196.     rest = ((long) *f_pos) % itemsize;
  197.     s_pos = rest / quantum; q_pos = rest % quantum;
  198.     /* follow the list up to the right position (defined elsewhere) */
  199.     dptr = scullp_follow(dev, item);
  200.     if (!dptr->data)
  201.         goto nothing; /* don't fill holes */
  202.     if (!dptr->data[s_pos])
  203.         goto nothing;
  204.     if (count > quantum - q_pos)
  205.         count = quantum - q_pos; /* read only up to the end of this quantum */
  206.     if (copy_to_user (buf, dptr->data[s_pos]+q_pos, count)) {
  207.         retval = -EFAULT;
  208.         goto nothing;
  209.     }
  210.     up (&dev->sem);
  211.     *f_pos += count;
  212.     return count;
  213.   nothing:
  214.     up (&dev->sem);
  215.     return retval;
  216. }
  217. ssize_t scullp_write (struct file *filp, const char *buf, size_t count,
  218.                 loff_t *f_pos)
  219. {
  220.     ScullP_Dev *dev = filp->private_data;
  221.     ScullP_Dev *dptr;
  222.     int quantum = PAGE_SIZE << dev->order;
  223.     int qset = dev->qset;
  224.     int itemsize = quantum * qset;
  225.     int item, s_pos, q_pos, rest;
  226.     ssize_t retval = -ENOMEM; /* our most likely error */
  227.     if (down_interruptible (&dev->sem))
  228.             return -ERESTARTSYS;
  229.     /* find listitem, qset index and offset in the quantum */
  230.     item = ((long) *f_pos) / itemsize;
  231.     rest = ((long) *f_pos) % itemsize;
  232.     s_pos = rest / quantum; q_pos = rest % quantum;
  233.     /* follow the list up to the right position */
  234.     dptr = scullp_follow(dev, item);
  235.     if (!dptr->data) {
  236.         dptr->data = kmalloc(qset * sizeof(void *), GFP_KERNEL);
  237.         if (!dptr->data)
  238.             goto nomem;
  239.         memset(dptr->data, 0, qset * sizeof(char *));
  240.     }
  241.     /* Here's the allocation of a single quantum */
  242.     if (!dptr->data[s_pos]) {
  243.         dptr->data[s_pos] =
  244.   (void *)__get_free_pages(GFP_KERNEL, dptr->order);
  245.         if (!dptr->data[s_pos])
  246.             goto nomem;
  247.         memset(dptr->data[s_pos], 0, PAGE_SIZE << dptr->order);
  248.     }
  249.     if (count > quantum - q_pos)
  250.         count = quantum - q_pos; /* write only up to the end of this quantum */
  251.     if (copy_from_user (dptr->data[s_pos]+q_pos, buf, count)) {
  252.         retval = -EFAULT;
  253.         goto nomem;
  254.     }
  255.     *f_pos += count;
  256.  
  257.     /* update the size */
  258.     if (dev->size < *f_pos)
  259.         dev->size = *f_pos;
  260.     up (&dev->sem);
  261.     return count;
  262.   nomem:
  263.     up (&dev->sem);
  264.     return retval;
  265. }
  266. /*
  267.  * The ioctl() implementation
  268.  */
  269. int scullp_ioctl (struct inode *inode, struct file *filp,
  270.                  unsigned int cmd, unsigned long arg)
  271. {
  272.     int err= 0, ret = 0, tmp;
  273.     /* don't even decode wrong cmds: better returning  ENOTTY than EFAULT */
  274.     if (_IOC_TYPE(cmd) != SCULLP_IOC_MAGIC) return -ENOTTY;
  275.     if (_IOC_NR(cmd) > SCULLP_IOC_MAXNR) return -ENOTTY;
  276.     /*
  277.      * the type is a bitmask, and VERIFY_WRITE catches R/W
  278.      * transfers. Note that the type is user-oriented, while
  279.      * verify_area is kernel-oriented, so the concept of "read" and
  280.      * "write" is reversed
  281.      */
  282.     if (_IOC_DIR(cmd) & _IOC_READ)
  283.         err = !access_ok(VERIFY_WRITE, (void *)arg, _IOC_SIZE(cmd));
  284.     else if (_IOC_DIR(cmd) & _IOC_WRITE)
  285.         err =  !access_ok(VERIFY_READ, (void *)arg, _IOC_SIZE(cmd));
  286.     if (err) return -EFAULT;
  287.     switch(cmd) {
  288.       case SCULLP_IOCRESET:
  289.         scullp_qset = SCULLP_QSET;
  290.         scullp_order = SCULLP_ORDER;
  291.         break;
  292.         
  293.       case SCULLP_IOCSORDER: /* Set: arg points to the value */
  294.         ret = __GET_USER(scullp_order, (int *) arg);
  295.         break;
  296.       case SCULLP_IOCTORDER: /* Tell: arg is the value */
  297.         scullp_order = arg;
  298.         break;
  299.       case SCULLP_IOCGORDER: /* Get: arg is pointer to result */
  300.         ret = __PUT_USER (scullp_order, (int *) arg);
  301.         break;
  302.       case SCULLP_IOCQORDER: /* Query: return it (it's positive) */
  303.         return scullp_order;
  304.       case SCULLP_IOCXORDER: /* eXchange: use arg as pointer */
  305.         tmp = scullp_order;
  306.         ret = __GET_USER(scullp_order, (int *) arg);
  307.         if (ret == 0)
  308.             ret = __PUT_USER(tmp, (int *) arg);
  309.         break;
  310.       case SCULLP_IOCHORDER: /* sHift: like Tell + Query */
  311.         tmp = scullp_order;
  312.         scullp_order = arg;
  313.         return tmp;
  314.         
  315.       case SCULLP_IOCSQSET:
  316.         ret = __GET_USER(scullp_qset, (int *) arg);
  317.         break;
  318.       case SCULLP_IOCTQSET:
  319.         scullp_qset = arg;
  320.         break;
  321.       case SCULLP_IOCGQSET:
  322.         ret = __PUT_USER(scullp_qset, (int *)arg);
  323.         break;
  324.       case SCULLP_IOCQQSET:
  325.         return scullp_qset;
  326.       case SCULLP_IOCXQSET:
  327.         tmp = scullp_qset;
  328.         ret = __GET_USER(scullp_qset, (int *) arg);
  329.         if (ret == 0)
  330.             ret = __PUT_USER(tmp, (int *)arg);
  331.         break;
  332.       case SCULLP_IOCHQSET:
  333.         tmp = scullp_qset;
  334.         scullp_qset = arg;
  335.         return tmp;
  336.       default:  /* redundant, as cmd was checked against MAXNR */
  337.         return -ENOTTY;
  338.     }
  339.     return ret;
  340. }
  341. /*
  342.  * The "extended" operations
  343.  */
  344. loff_t scullp_llseek (struct file *filp, loff_t off, int whence)
  345. {
  346.     ScullP_Dev *dev = filp->private_data;
  347.     long newpos;
  348.     switch(whence) {
  349.       case 0: /* SEEK_SET */
  350.         newpos = off;
  351.         break;
  352.       case 1: /* SEEK_CUR */
  353.         newpos = filp->f_pos + off;
  354.         break;
  355.       case 2: /* SEEK_END */
  356.         newpos = dev->size + off;
  357.         break;
  358.       default: /* can't happen */
  359.         return -EINVAL;
  360.     }
  361.     if (newpos<0) return -EINVAL;
  362.     filp->f_pos = newpos;
  363.     return newpos;
  364. }
  365.  
  366. /*
  367.  * Mmap *is* available, but confined in a different file
  368.  */
  369. #ifndef LINUX_20
  370. extern int scullp_mmap(struct file *filp, struct vm_area_struct *vma);
  371. #else
  372. extern int scullp_mmap(struct inode *inode, struct file *filp,
  373. struct vm_area_struct *vma);
  374. #endif
  375. /*
  376.  * The 2.0 wrappers
  377.  */
  378. #ifdef LINUX_20
  379. int scullp_lseek_20 (struct inode *ino, struct file *f,
  380.                 off_t offset, int whence)
  381. {
  382.     return (int)scullp_llseek(f, offset, whence);
  383. }
  384. int scullp_read_20 (struct inode *ino, struct file *f, char *buf, int count)
  385. {
  386.     return (int)scullp_read(f, buf, count, &f->f_pos);
  387. }
  388. int scullp_write_20 (struct inode *ino, struct file *f, const char *b, int c)
  389. {
  390.     return (int)scullp_write(f, b, c, &f->f_pos);
  391. }
  392. void scullp_release_20 (struct inode *ino, struct file *f)
  393. {
  394.     scullp_release(ino, f);
  395. }
  396. #define scullp_llseek scullp_lseek_20
  397. #define scullp_read scullp_read_20
  398. #define scullp_write scullp_write_20
  399. #define scullp_release scullp_release_20
  400. #define llseek lseek
  401. #endif /* LINUX_20 */
  402. /*
  403.  * The fops
  404.  */
  405. struct file_operations scullp_fops = {
  406.     llseek: scullp_llseek,
  407.     read: scullp_read,
  408.     write: scullp_write,
  409.     ioctl: scullp_ioctl,
  410.     mmap: scullp_mmap,
  411.     open: scullp_open,
  412.     release: scullp_release,
  413. };
  414. int scullp_trim(ScullP_Dev *dev)
  415. {
  416.     ScullP_Dev *next, *dptr;
  417.     int qset = dev->qset;   /* "dev" is not-null */
  418.     int i;
  419.     if (dev->vmas) /* don't trim: there are active mappings */
  420.         return -EBUSY;
  421.     for (dptr = dev; dptr; dptr = next) { /* all the list items */
  422.         if (dptr->data) {
  423.             /* This code frees a whole quantum-set */
  424.             for (i = 0; i < qset; i++)
  425.                 if (dptr->data[i])
  426.                     free_pages((unsigned long)(dptr->data[i]),
  427.                                dptr->order);
  428.             kfree(dptr->data);
  429.             dptr->data=NULL;
  430.         }
  431.         next=dptr->next;
  432.         if (dptr != dev) kfree(dptr); /* all of them but the first */
  433.     }
  434.     dev->size = 0;
  435.     dev->qset = scullp_qset;
  436.     dev->order = scullp_order;
  437.     dev->next = NULL;
  438.     return 0;
  439. }
  440. /*
  441.  * Finally, the module stuff
  442.  */
  443. int scullp_init(void)
  444. {
  445.     int result, i;
  446.     SET_MODULE_OWNER(&scullp_fops);
  447.     /*
  448.      * Register your major, and accept a dynamic number
  449.      */
  450.     result = register_chrdev(scullp_major, "scullp", &scullp_fops);
  451.     if (result < 0) return result;
  452.     if (scullp_major == 0) scullp_major = result; /* dynamic */
  453.     /* 
  454.      * allocate the devices -- we can't have them static, as the number
  455.      * can be specified at load time
  456.      */
  457.     scullp_devices = kmalloc(scullp_devs * sizeof (ScullP_Dev), GFP_KERNEL);
  458.     if (!scullp_devices) {
  459.         result = -ENOMEM;
  460.         goto fail_malloc;
  461.     }
  462.     memset(scullp_devices, 0, scullp_devs * sizeof (ScullP_Dev));
  463.     for (i=0; i < scullp_devs; i++) {
  464.         scullp_devices[i].order = scullp_order;
  465.         scullp_devices[i].qset = scullp_qset;
  466.         sema_init (&scullp_devices[i].sem, 1);
  467.     }
  468. #ifdef SCULLP_USE_PROC /* only when available */
  469.     create_proc_read_entry("scullpmem", 0, NULL, scullp_read_procmem, NULL);
  470. #endif
  471.     return 0; /* succeed */
  472.   fail_malloc:
  473.     unregister_chrdev(scullp_major, "scullp");
  474.     return result;
  475. }
  476. void scullp_cleanup(void)
  477. {
  478.     int i;
  479.     unregister_chrdev(scullp_major, "scullp");
  480. #ifdef SCULLP_USE_PROC
  481.     remove_proc_entry("scullpmem", 0);
  482. #endif
  483.     for (i=0; i<scullp_devs; i++)
  484.         scullp_trim(scullp_devices+i);
  485.     kfree(scullp_devices);
  486. }
  487. module_init(scullp_init);
  488. module_exit(scullp_cleanup);