Blame view
lib/flex_array.c
10.9 KB
534acc057 lib: flexible arr... |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
/* * Flexible array managed in PAGE_SIZE parts * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * * Copyright IBM Corporation, 2009 * * Author: Dave Hansen <dave@linux.vnet.ibm.com> */ #include <linux/flex_array.h> #include <linux/slab.h> #include <linux/stddef.h> |
78c377d1b flex_array: expor... |
26 |
#include <linux/module.h> |
704f15ddb flex_array: avoid... |
27 |
#include <linux/reciprocal_div.h> |
534acc057 lib: flexible arr... |
28 29 30 31 |
struct flex_array_part { char elements[FLEX_ARRAY_PART_SIZE]; }; |
534acc057 lib: flexible arr... |
32 33 34 35 36 37 38 39 40 |
/* * If a user requests an allocation which is small * enough, we may simply use the space in the * flex_array->parts[] array to store the user * data. */ static inline int elements_fit_in_base(struct flex_array *fa) { int data_size = fa->element_size * fa->total_nr_elements; |
45b588d6e flex_array: intro... |
41 |
if (data_size <= FLEX_ARRAY_BASE_BYTES_LEFT) |
534acc057 lib: flexible arr... |
42 43 44 45 46 47 48 49 |
return 1; return 0; } /** * flex_array_alloc - allocate a new flexible array * @element_size: the size of individual elements in the array * @total: total number of elements that this should hold |
fc0d8d944 flex_array: add m... |
50 |
* @flags: page allocation flags to use for base array |
534acc057 lib: flexible arr... |
51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 |
* * Note: all locking must be provided by the caller. * * @total is used to size internal structures. If the user ever * accesses any array indexes >=@total, it will produce errors. * * The maximum number of elements is defined as: the number of * elements that can be stored in a page times the number of * page pointers that we can fit in the base structure or (using * integer math): * * (PAGE_SIZE/element_size) * (PAGE_SIZE-8)/sizeof(void *) * * Here's a table showing example capacities. Note that the maximum * index that the get/put() functions is just nr_objects-1. This * basically means that you get 4MB of storage on 32-bit and 2MB on * 64-bit. * * * Element size | Objects | Objects | * PAGE_SIZE=4k | 32-bit | 64-bit | * ---------------------------------| |
704f15ddb flex_array: avoid... |
73 74 75 76 77 78 79 80 81 |
* 1 bytes | 4177920 | 2088960 | * 2 bytes | 2088960 | 1044480 | * 3 bytes | 1392300 | 696150 | * 4 bytes | 1044480 | 522240 | * 32 bytes | 130560 | 65408 | * 33 bytes | 126480 | 63240 | * 2048 bytes | 2040 | 1020 | * 2049 bytes | 1020 | 510 | * void * | 1044480 | 261120 | |
534acc057 lib: flexible arr... |
82 83 84 85 86 |
* * Since 64-bit pointers are twice the size, we lose half the * capacity in the base structure. Also note that no effort is made * to efficiently pack objects across page boundaries. */ |
b62e408c0 flex_array: conve... |
87 88 |
struct flex_array *flex_array_alloc(int element_size, unsigned int total, gfp_t flags) |
534acc057 lib: flexible arr... |
89 90 |
{ struct flex_array *ret; |
704f15ddb flex_array: avoid... |
91 92 |
int elems_per_part = 0; int reciprocal_elems = 0; |
a8d05c81f flex_array: allow... |
93 |
int max_size = 0; |
704f15ddb flex_array: avoid... |
94 95 96 97 98 |
if (element_size) { elems_per_part = FLEX_ARRAY_ELEMENTS_PER_PART(element_size); reciprocal_elems = reciprocal_value(elems_per_part); max_size = FLEX_ARRAY_NR_BASE_PTRS * elems_per_part; } |
534acc057 lib: flexible arr... |
99 100 101 102 103 104 105 106 107 |
/* max_size will end up 0 if element_size > PAGE_SIZE */ if (total > max_size) return NULL; ret = kzalloc(sizeof(struct flex_array), flags); if (!ret) return NULL; ret->element_size = element_size; ret->total_nr_elements = total; |
704f15ddb flex_array: avoid... |
108 109 |
ret->elems_per_part = elems_per_part; ret->reciprocal_elems = reciprocal_elems; |
19da3dd15 flex_array: poiso... |
110 |
if (elements_fit_in_base(ret) && !(flags & __GFP_ZERO)) |
e59464c73 flex_array: fix t... |
111 |
memset(&ret->parts[0], FLEX_ARRAY_FREE, |
45b588d6e flex_array: intro... |
112 |
FLEX_ARRAY_BASE_BYTES_LEFT); |
534acc057 lib: flexible arr... |
113 114 |
return ret; } |
78c377d1b flex_array: expor... |
115 |
EXPORT_SYMBOL(flex_array_alloc); |
534acc057 lib: flexible arr... |
116 |
|
b62e408c0 flex_array: conve... |
117 118 |
static int fa_element_to_part_nr(struct flex_array *fa, unsigned int element_nr) |
534acc057 lib: flexible arr... |
119 |
{ |
704f15ddb flex_array: avoid... |
120 |
return reciprocal_divide(element_nr, fa->reciprocal_elems); |
534acc057 lib: flexible arr... |
121 122 123 124 |
} /** * flex_array_free_parts - just free the second-level pages |
fc0d8d944 flex_array: add m... |
125 |
* @fa: the flex array from which to free parts |
534acc057 lib: flexible arr... |
126 127 128 129 130 131 132 |
* * This is to be used in cases where the base 'struct flex_array' * has been statically allocated and should not be free. */ void flex_array_free_parts(struct flex_array *fa) { int part_nr; |
534acc057 lib: flexible arr... |
133 134 135 |
if (elements_fit_in_base(fa)) return; |
45b588d6e flex_array: intro... |
136 |
for (part_nr = 0; part_nr < FLEX_ARRAY_NR_BASE_PTRS; part_nr++) |
534acc057 lib: flexible arr... |
137 138 |
kfree(fa->parts[part_nr]); } |
78c377d1b flex_array: expor... |
139 |
EXPORT_SYMBOL(flex_array_free_parts); |
534acc057 lib: flexible arr... |
140 141 142 143 144 145 |
void flex_array_free(struct flex_array *fa) { flex_array_free_parts(fa); kfree(fa); } |
78c377d1b flex_array: expor... |
146 |
EXPORT_SYMBOL(flex_array_free); |
534acc057 lib: flexible arr... |
147 |
|
b62e408c0 flex_array: conve... |
148 |
static unsigned int index_inside_part(struct flex_array *fa, |
704f15ddb flex_array: avoid... |
149 150 |
unsigned int element_nr, unsigned int part_nr) |
534acc057 lib: flexible arr... |
151 |
{ |
b62e408c0 flex_array: conve... |
152 |
unsigned int part_offset; |
534acc057 lib: flexible arr... |
153 |
|
704f15ddb flex_array: avoid... |
154 |
part_offset = element_nr - part_nr * fa->elems_per_part; |
534acc057 lib: flexible arr... |
155 156 157 158 159 160 161 162 |
return part_offset * fa->element_size; } static struct flex_array_part * __fa_get_part(struct flex_array *fa, int part_nr, gfp_t flags) { struct flex_array_part *part = fa->parts[part_nr]; if (!part) { |
19da3dd15 flex_array: poiso... |
163 |
part = kmalloc(sizeof(struct flex_array_part), flags); |
534acc057 lib: flexible arr... |
164 165 |
if (!part) return NULL; |
19da3dd15 flex_array: poiso... |
166 167 168 |
if (!(flags & __GFP_ZERO)) memset(part, FLEX_ARRAY_FREE, sizeof(struct flex_array_part)); |
534acc057 lib: flexible arr... |
169 170 171 172 173 174 175 |
fa->parts[part_nr] = part; } return part; } /** * flex_array_put - copy data into the array at @element_nr |
fc0d8d944 flex_array: add m... |
176 |
* @fa: the flex array to copy data into |
534acc057 lib: flexible arr... |
177 178 |
* @element_nr: index of the position in which to insert * the new element. |
fc0d8d944 flex_array: add m... |
179 180 181 |
* @src: address of data to copy into the array * @flags: page allocation flags to use for array expansion * |
534acc057 lib: flexible arr... |
182 183 184 185 |
* * Note that this *copies* the contents of @src into * the array. If you are trying to store an array of * pointers, make sure to pass in &ptr instead of ptr. |
ea98eed9b flex_array: add h... |
186 187 |
* You may instead wish to use the flex_array_put_ptr() * helper function. |
534acc057 lib: flexible arr... |
188 189 190 |
* * Locking must be provided by the caller. */ |
b62e408c0 flex_array: conve... |
191 192 |
int flex_array_put(struct flex_array *fa, unsigned int element_nr, void *src, gfp_t flags) |
534acc057 lib: flexible arr... |
193 |
{ |
704f15ddb flex_array: avoid... |
194 |
int part_nr = 0; |
534acc057 lib: flexible arr... |
195 196 197 198 199 |
struct flex_array_part *part; void *dst; if (element_nr >= fa->total_nr_elements) return -ENOSPC; |
a8d05c81f flex_array: allow... |
200 201 |
if (!fa->element_size) return 0; |
534acc057 lib: flexible arr... |
202 203 |
if (elements_fit_in_base(fa)) part = (struct flex_array_part *)&fa->parts[0]; |
a30b595d2 flex_array: fix g... |
204 |
else { |
a8d05c81f flex_array: allow... |
205 |
part_nr = fa_element_to_part_nr(fa, element_nr); |
534acc057 lib: flexible arr... |
206 |
part = __fa_get_part(fa, part_nr, flags); |
a30b595d2 flex_array: fix g... |
207 208 209 |
if (!part) return -ENOMEM; } |
704f15ddb flex_array: avoid... |
210 |
dst = &part->elements[index_inside_part(fa, element_nr, part_nr)]; |
534acc057 lib: flexible arr... |
211 212 213 |
memcpy(dst, src, fa->element_size); return 0; } |
78c377d1b flex_array: expor... |
214 |
EXPORT_SYMBOL(flex_array_put); |
534acc057 lib: flexible arr... |
215 216 |
/** |
e6de3988a flex_array: add f... |
217 |
* flex_array_clear - clear element in array at @element_nr |
fc0d8d944 flex_array: add m... |
218 |
* @fa: the flex array of the element. |
e6de3988a flex_array: add f... |
219 220 221 222 223 224 |
* @element_nr: index of the position to clear. * * Locking must be provided by the caller. */ int flex_array_clear(struct flex_array *fa, unsigned int element_nr) { |
704f15ddb flex_array: avoid... |
225 |
int part_nr = 0; |
e6de3988a flex_array: add f... |
226 227 228 229 230 |
struct flex_array_part *part; void *dst; if (element_nr >= fa->total_nr_elements) return -ENOSPC; |
a8d05c81f flex_array: allow... |
231 232 |
if (!fa->element_size) return 0; |
e6de3988a flex_array: add f... |
233 234 235 |
if (elements_fit_in_base(fa)) part = (struct flex_array_part *)&fa->parts[0]; else { |
a8d05c81f flex_array: allow... |
236 |
part_nr = fa_element_to_part_nr(fa, element_nr); |
e6de3988a flex_array: add f... |
237 238 239 240 |
part = fa->parts[part_nr]; if (!part) return -EINVAL; } |
704f15ddb flex_array: avoid... |
241 |
dst = &part->elements[index_inside_part(fa, element_nr, part_nr)]; |
19da3dd15 flex_array: poiso... |
242 |
memset(dst, FLEX_ARRAY_FREE, fa->element_size); |
e6de3988a flex_array: add f... |
243 244 |
return 0; } |
78c377d1b flex_array: expor... |
245 |
EXPORT_SYMBOL(flex_array_clear); |
e6de3988a flex_array: add f... |
246 247 |
/** |
534acc057 lib: flexible arr... |
248 |
* flex_array_prealloc - guarantee that array space exists |
5a3ea8782 flex_array: flex_... |
249 250 251 252 |
* @fa: the flex array for which to preallocate parts * @start: index of first array element for which space is allocated * @nr_elements: number of elements for which space is allocated * @flags: page allocation flags |
534acc057 lib: flexible arr... |
253 254 255 256 257 258 259 260 |
* * This will guarantee that no future calls to flex_array_put() * will allocate memory. It can be used if you are expecting to * be holding a lock or in some atomic context while writing * data into the array. * * Locking must be provided by the caller. */ |
b62e408c0 flex_array: conve... |
261 |
int flex_array_prealloc(struct flex_array *fa, unsigned int start, |
5a3ea8782 flex_array: flex_... |
262 |
unsigned int nr_elements, gfp_t flags) |
534acc057 lib: flexible arr... |
263 264 265 266 |
{ int start_part; int end_part; int part_nr; |
5a3ea8782 flex_array: flex_... |
267 |
unsigned int end; |
534acc057 lib: flexible arr... |
268 |
struct flex_array_part *part; |
150cdf6ec flex_arrays: allo... |
269 270 271 272 273 274 |
if (!start && !nr_elements) return 0; if (start >= fa->total_nr_elements) return -ENOSPC; if (!nr_elements) return 0; |
5a3ea8782 flex_array: flex_... |
275 |
end = start + nr_elements - 1; |
150cdf6ec flex_arrays: allo... |
276 |
if (end >= fa->total_nr_elements) |
534acc057 lib: flexible arr... |
277 |
return -ENOSPC; |
a8d05c81f flex_array: allow... |
278 279 |
if (!fa->element_size) return 0; |
534acc057 lib: flexible arr... |
280 281 282 283 284 285 286 287 288 289 290 |
if (elements_fit_in_base(fa)) return 0; start_part = fa_element_to_part_nr(fa, start); end_part = fa_element_to_part_nr(fa, end); for (part_nr = start_part; part_nr <= end_part; part_nr++) { part = __fa_get_part(fa, part_nr, flags); if (!part) return -ENOMEM; } return 0; } |
78c377d1b flex_array: expor... |
291 |
EXPORT_SYMBOL(flex_array_prealloc); |
534acc057 lib: flexible arr... |
292 293 294 |
/** * flex_array_get - pull data back out of the array |
fc0d8d944 flex_array: add m... |
295 |
* @fa: the flex array from which to extract data |
534acc057 lib: flexible arr... |
296 297 298 299 |
* @element_nr: index of the element to fetch from the array * * Returns a pointer to the data at index @element_nr. Note * that this is a copy of the data that was passed in. If you |
ea98eed9b flex_array: add h... |
300 301 |
* are using this to store pointers, you'll get back &ptr. You * may instead wish to use the flex_array_get_ptr helper. |
534acc057 lib: flexible arr... |
302 303 304 |
* * Locking must be provided by the caller. */ |
b62e408c0 flex_array: conve... |
305 |
void *flex_array_get(struct flex_array *fa, unsigned int element_nr) |
534acc057 lib: flexible arr... |
306 |
{ |
704f15ddb flex_array: avoid... |
307 |
int part_nr = 0; |
534acc057 lib: flexible arr... |
308 |
struct flex_array_part *part; |
534acc057 lib: flexible arr... |
309 |
|
a8d05c81f flex_array: allow... |
310 311 |
if (!fa->element_size) return NULL; |
534acc057 lib: flexible arr... |
312 313 |
if (element_nr >= fa->total_nr_elements) return NULL; |
534acc057 lib: flexible arr... |
314 315 |
if (elements_fit_in_base(fa)) part = (struct flex_array_part *)&fa->parts[0]; |
a30b595d2 flex_array: fix g... |
316 |
else { |
a8d05c81f flex_array: allow... |
317 |
part_nr = fa_element_to_part_nr(fa, element_nr); |
534acc057 lib: flexible arr... |
318 |
part = fa->parts[part_nr]; |
a30b595d2 flex_array: fix g... |
319 320 321 |
if (!part) return NULL; } |
704f15ddb flex_array: avoid... |
322 |
return &part->elements[index_inside_part(fa, element_nr, part_nr)]; |
534acc057 lib: flexible arr... |
323 |
} |
78c377d1b flex_array: expor... |
324 |
EXPORT_SYMBOL(flex_array_get); |
4af5a2f77 flex_array: add f... |
325 |
|
ea98eed9b flex_array: add h... |
326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 |
/** * flex_array_get_ptr - pull a ptr back out of the array * @fa: the flex array from which to extract data * @element_nr: index of the element to fetch from the array * * Returns the pointer placed in the flex array at element_nr using * flex_array_put_ptr(). This function should not be called if the * element in question was not set using the _put_ptr() helper. */ void *flex_array_get_ptr(struct flex_array *fa, unsigned int element_nr) { void **tmp; tmp = flex_array_get(fa, element_nr); if (!tmp) return NULL; return *tmp; } |
78c377d1b flex_array: expor... |
345 |
EXPORT_SYMBOL(flex_array_get_ptr); |
ea98eed9b flex_array: add h... |
346 |
|
4af5a2f77 flex_array: add f... |
347 348 349 350 351 352 353 354 355 356 357 358 |
static int part_is_free(struct flex_array_part *part) { int i; for (i = 0; i < sizeof(struct flex_array_part); i++) if (part->elements[i] != FLEX_ARRAY_FREE) return 0; return 1; } /** * flex_array_shrink - free unused second-level pages |
fc0d8d944 flex_array: add m... |
359 |
* @fa: the flex array to shrink |
4af5a2f77 flex_array: add f... |
360 361 362 363 364 365 366 367 368 |
* * Frees all second-level pages that consist solely of unused * elements. Returns the number of pages freed. * * Locking must be provided by the caller. */ int flex_array_shrink(struct flex_array *fa) { struct flex_array_part *part; |
4af5a2f77 flex_array: add f... |
369 370 |
int part_nr; int ret = 0; |
a8d05c81f flex_array: allow... |
371 |
if (!fa->total_nr_elements || !fa->element_size) |
150cdf6ec flex_arrays: allo... |
372 |
return 0; |
4af5a2f77 flex_array: add f... |
373 374 |
if (elements_fit_in_base(fa)) return ret; |
45b588d6e flex_array: intro... |
375 |
for (part_nr = 0; part_nr < FLEX_ARRAY_NR_BASE_PTRS; part_nr++) { |
4af5a2f77 flex_array: add f... |
376 377 378 379 380 381 382 383 384 385 386 |
part = fa->parts[part_nr]; if (!part) continue; if (part_is_free(part)) { fa->parts[part_nr] = NULL; kfree(part); ret++; } } return ret; } |
78c377d1b flex_array: expor... |
387 |
EXPORT_SYMBOL(flex_array_shrink); |