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

Linux/Unix编程

开发平台:

Unix_Linux

  1. /*
  2.  *  linux/fs/file.c
  3.  *
  4.  *  Copyright (C) 1998-1999, Stephen Tweedie and Bill Hawes
  5.  *
  6.  *  Manage the dynamic fd arrays in the process files_struct.
  7.  */
  8. #include <linux/fs.h>
  9. #include <linux/mm.h>
  10. #include <linux/sched.h>
  11. #include <linux/slab.h>
  12. #include <linux/vmalloc.h>
  13. #include <asm/bitops.h>
  14. /*
  15.  * Allocate an fd array, using kmalloc or vmalloc.
  16.  * Note: the array isn't cleared at allocation time.
  17.  */
  18. struct file ** alloc_fd_array(int num)
  19. {
  20. struct file **new_fds;
  21. int size = num * sizeof(struct file *);
  22. if (size <= PAGE_SIZE)
  23. new_fds = (struct file **) kmalloc(size, GFP_KERNEL);
  24. else 
  25. new_fds = (struct file **) vmalloc(size);
  26. return new_fds;
  27. }
  28. void free_fd_array(struct file **array, int num)
  29. {
  30. int size = num * sizeof(struct file *);
  31. if (!array) {
  32. printk(KERN_ERR "%s array = 0 (num = %d)n",
  33. __FUNCTION__, num);
  34. return;
  35. }
  36. if (num <= NR_OPEN_DEFAULT) /* Don't free the embedded fd array! */
  37. return;
  38. else if (size <= PAGE_SIZE)
  39. kfree(array);
  40. else
  41. vfree(array);
  42. }
  43. /*
  44.  * Expand the fd array in the files_struct.  Called with the files
  45.  * spinlock held for write.
  46.  */
  47. int expand_fd_array(struct files_struct *files, int nr)
  48. {
  49. struct file **new_fds;
  50. int error, nfds;
  51. error = -EMFILE;
  52. if (files->max_fds >= NR_OPEN || nr >= NR_OPEN)
  53. goto out;
  54. nfds = files->max_fds;
  55. write_unlock(&files->file_lock);
  56. /* 
  57.  * Expand to the max in easy steps, and keep expanding it until
  58.  * we have enough for the requested fd array size. 
  59.  */
  60. do {
  61. #if NR_OPEN_DEFAULT < 256
  62. if (nfds < 256)
  63. nfds = 256;
  64. else 
  65. #endif
  66. if (nfds < (PAGE_SIZE / sizeof(struct file *)))
  67. nfds = PAGE_SIZE / sizeof(struct file *);
  68. else {
  69. nfds = nfds * 2;
  70. if (nfds > NR_OPEN)
  71. nfds = NR_OPEN;
  72. }
  73. } while (nfds <= nr);
  74. error = -ENOMEM;
  75. new_fds = alloc_fd_array(nfds);
  76. write_lock(&files->file_lock);
  77. if (!new_fds)
  78. goto out;
  79. /* Copy the existing array and install the new pointer */
  80. if (nfds > files->max_fds) {
  81. struct file **old_fds;
  82. int i;
  83. old_fds = xchg(&files->fd, new_fds);
  84. i = xchg(&files->max_fds, nfds);
  85. /* Don't copy/clear the array if we are creating a new
  86.    fd array for fork() */
  87. if (i) {
  88. memcpy(new_fds, old_fds, i * sizeof(struct file *));
  89. /* clear the remainder of the array */
  90. memset(&new_fds[i], 0,
  91.        (nfds-i) * sizeof(struct file *)); 
  92. write_unlock(&files->file_lock);
  93. free_fd_array(old_fds, i);
  94. write_lock(&files->file_lock);
  95. }
  96. } else {
  97. /* Somebody expanded the array while we slept ... */
  98. write_unlock(&files->file_lock);
  99. free_fd_array(new_fds, nfds);
  100. write_lock(&files->file_lock);
  101. }
  102. error = 0;
  103. out:
  104. return error;
  105. }
  106. /*
  107.  * Allocate an fdset array, using kmalloc or vmalloc.
  108.  * Note: the array isn't cleared at allocation time.
  109.  */
  110. fd_set * alloc_fdset(int num)
  111. {
  112. fd_set *new_fdset;
  113. int size = num / 8;
  114. if (size <= PAGE_SIZE)
  115. new_fdset = (fd_set *) kmalloc(size, GFP_KERNEL);
  116. else
  117. new_fdset = (fd_set *) vmalloc(size);
  118. return new_fdset;
  119. }
  120. void free_fdset(fd_set *array, int num)
  121. {
  122. int size = num / 8;
  123. if (!array) {
  124. printk(KERN_ERR "%s array = 0 (num = %d)n",
  125. __FUNCTION__, num);
  126. return;
  127. }
  128. if (num <= __FD_SETSIZE) /* Don't free an embedded fdset */
  129. return;
  130. else if (size <= PAGE_SIZE)
  131. kfree(array);
  132. else
  133. vfree(array);
  134. }
  135. /*
  136.  * Expand the fdset in the files_struct.  Called with the files spinlock
  137.  * held for write.
  138.  */
  139. int expand_fdset(struct files_struct *files, int nr)
  140. {
  141. fd_set *new_openset = 0, *new_execset = 0;
  142. int error, nfds = 0;
  143. error = -EMFILE;
  144. if (files->max_fdset >= NR_OPEN || nr >= NR_OPEN)
  145. goto out;
  146. nfds = files->max_fdset;
  147. write_unlock(&files->file_lock);
  148. /* Expand to the max in easy steps */
  149. do {
  150. if (nfds < (PAGE_SIZE * 8))
  151. nfds = PAGE_SIZE * 8;
  152. else {
  153. nfds = nfds * 2;
  154. if (nfds > NR_OPEN)
  155. nfds = NR_OPEN;
  156. }
  157. } while (nfds <= nr);
  158. error = -ENOMEM;
  159. new_openset = alloc_fdset(nfds);
  160. new_execset = alloc_fdset(nfds);
  161. write_lock(&files->file_lock);
  162. if (!new_openset || !new_execset)
  163. goto out;
  164. error = 0;
  165. /* Copy the existing tables and install the new pointers */
  166. if (nfds > files->max_fdset) {
  167. int i = files->max_fdset / (sizeof(unsigned long) * 8);
  168. int count = (nfds - files->max_fdset) / 8;
  169. /* 
  170.  * Don't copy the entire array if the current fdset is
  171.  * not yet initialised.  
  172.  */
  173. if (i) {
  174. memcpy (new_openset, files->open_fds, files->max_fdset/8);
  175. memcpy (new_execset, files->close_on_exec, files->max_fdset/8);
  176. memset (&new_openset->fds_bits[i], 0, count);
  177. memset (&new_execset->fds_bits[i], 0, count);
  178. }
  179. nfds = xchg(&files->max_fdset, nfds);
  180. new_openset = xchg(&files->open_fds, new_openset);
  181. new_execset = xchg(&files->close_on_exec, new_execset);
  182. write_unlock(&files->file_lock);
  183. free_fdset (new_openset, nfds);
  184. free_fdset (new_execset, nfds);
  185. write_lock(&files->file_lock);
  186. return 0;
  187. /* Somebody expanded the array while we slept ... */
  188. out:
  189. write_unlock(&files->file_lock);
  190. if (new_openset)
  191. free_fdset(new_openset, nfds);
  192. if (new_execset)
  193. free_fdset(new_execset, nfds);
  194. write_lock(&files->file_lock);
  195. return error;
  196. }