diff options
Diffstat (limited to 'fs/mbcache.c')
-rw-r--r-- | fs/mbcache.c | 141 |
1 files changed, 40 insertions, 101 deletions
diff --git a/fs/mbcache.c b/fs/mbcache.c index e28f21b95344..8a2cbd823079 100644 --- a/fs/mbcache.c +++ b/fs/mbcache.c | |||
@@ -79,15 +79,11 @@ EXPORT_SYMBOL(mb_cache_entry_find_next); | |||
79 | struct mb_cache { | 79 | struct mb_cache { |
80 | struct list_head c_cache_list; | 80 | struct list_head c_cache_list; |
81 | const char *c_name; | 81 | const char *c_name; |
82 | struct mb_cache_op c_op; | ||
83 | atomic_t c_entry_count; | 82 | atomic_t c_entry_count; |
84 | int c_bucket_bits; | 83 | int c_bucket_bits; |
85 | #ifndef MB_CACHE_INDEXES_COUNT | 84 | struct kmem_cache *c_entry_cache; |
86 | int c_indexes_count; | ||
87 | #endif | ||
88 | struct kmem_cache *c_entry_cache; | ||
89 | struct list_head *c_block_hash; | 85 | struct list_head *c_block_hash; |
90 | struct list_head *c_indexes_hash[0]; | 86 | struct list_head *c_index_hash; |
91 | }; | 87 | }; |
92 | 88 | ||
93 | 89 | ||
@@ -101,16 +97,6 @@ static LIST_HEAD(mb_cache_list); | |||
101 | static LIST_HEAD(mb_cache_lru_list); | 97 | static LIST_HEAD(mb_cache_lru_list); |
102 | static DEFINE_SPINLOCK(mb_cache_spinlock); | 98 | static DEFINE_SPINLOCK(mb_cache_spinlock); |
103 | 99 | ||
104 | static inline int | ||
105 | mb_cache_indexes(struct mb_cache *cache) | ||
106 | { | ||
107 | #ifdef MB_CACHE_INDEXES_COUNT | ||
108 | return MB_CACHE_INDEXES_COUNT; | ||
109 | #else | ||
110 | return cache->c_indexes_count; | ||
111 | #endif | ||
112 | } | ||
113 | |||
114 | /* | 100 | /* |
115 | * What the mbcache registers as to get shrunk dynamically. | 101 | * What the mbcache registers as to get shrunk dynamically. |
116 | */ | 102 | */ |
@@ -132,12 +118,9 @@ __mb_cache_entry_is_hashed(struct mb_cache_entry *ce) | |||
132 | static void | 118 | static void |
133 | __mb_cache_entry_unhash(struct mb_cache_entry *ce) | 119 | __mb_cache_entry_unhash(struct mb_cache_entry *ce) |
134 | { | 120 | { |
135 | int n; | ||
136 | |||
137 | if (__mb_cache_entry_is_hashed(ce)) { | 121 | if (__mb_cache_entry_is_hashed(ce)) { |
138 | list_del_init(&ce->e_block_list); | 122 | list_del_init(&ce->e_block_list); |
139 | for (n=0; n<mb_cache_indexes(ce->e_cache); n++) | 123 | list_del(&ce->e_index.o_list); |
140 | list_del(&ce->e_indexes[n].o_list); | ||
141 | } | 124 | } |
142 | } | 125 | } |
143 | 126 | ||
@@ -148,16 +131,8 @@ __mb_cache_entry_forget(struct mb_cache_entry *ce, gfp_t gfp_mask) | |||
148 | struct mb_cache *cache = ce->e_cache; | 131 | struct mb_cache *cache = ce->e_cache; |
149 | 132 | ||
150 | mb_assert(!(ce->e_used || ce->e_queued)); | 133 | mb_assert(!(ce->e_used || ce->e_queued)); |
151 | if (cache->c_op.free && cache->c_op.free(ce, gfp_mask)) { | 134 | kmem_cache_free(cache->c_entry_cache, ce); |
152 | /* free failed -- put back on the lru list | 135 | atomic_dec(&cache->c_entry_count); |
153 | for freeing later. */ | ||
154 | spin_lock(&mb_cache_spinlock); | ||
155 | list_add(&ce->e_lru_list, &mb_cache_lru_list); | ||
156 | spin_unlock(&mb_cache_spinlock); | ||
157 | } else { | ||
158 | kmem_cache_free(cache->c_entry_cache, ce); | ||
159 | atomic_dec(&cache->c_entry_count); | ||
160 | } | ||
161 | } | 136 | } |
162 | 137 | ||
163 | 138 | ||
@@ -243,72 +218,49 @@ out: | |||
243 | * memory was available. | 218 | * memory was available. |
244 | * | 219 | * |
245 | * @name: name of the cache (informal) | 220 | * @name: name of the cache (informal) |
246 | * @cache_op: contains the callback called when freeing a cache entry | ||
247 | * @entry_size: The size of a cache entry, including | ||
248 | * struct mb_cache_entry | ||
249 | * @indexes_count: number of additional indexes in the cache. Must equal | ||
250 | * MB_CACHE_INDEXES_COUNT if the number of indexes is | ||
251 | * hardwired. | ||
252 | * @bucket_bits: log2(number of hash buckets) | 221 | * @bucket_bits: log2(number of hash buckets) |
253 | */ | 222 | */ |
254 | struct mb_cache * | 223 | struct mb_cache * |
255 | mb_cache_create(const char *name, struct mb_cache_op *cache_op, | 224 | mb_cache_create(const char *name, int bucket_bits) |
256 | size_t entry_size, int indexes_count, int bucket_bits) | ||
257 | { | 225 | { |
258 | int m=0, n, bucket_count = 1 << bucket_bits; | 226 | int n, bucket_count = 1 << bucket_bits; |
259 | struct mb_cache *cache = NULL; | 227 | struct mb_cache *cache = NULL; |
260 | 228 | ||
261 | if(entry_size < sizeof(struct mb_cache_entry) + | 229 | cache = kmalloc(sizeof(struct mb_cache), GFP_KERNEL); |
262 | indexes_count * sizeof(((struct mb_cache_entry *) 0)->e_indexes[0])) | ||
263 | return NULL; | ||
264 | |||
265 | cache = kmalloc(sizeof(struct mb_cache) + | ||
266 | indexes_count * sizeof(struct list_head), GFP_KERNEL); | ||
267 | if (!cache) | 230 | if (!cache) |
268 | goto fail; | 231 | return NULL; |
269 | cache->c_name = name; | 232 | cache->c_name = name; |
270 | cache->c_op.free = NULL; | ||
271 | if (cache_op) | ||
272 | cache->c_op.free = cache_op->free; | ||
273 | atomic_set(&cache->c_entry_count, 0); | 233 | atomic_set(&cache->c_entry_count, 0); |
274 | cache->c_bucket_bits = bucket_bits; | 234 | cache->c_bucket_bits = bucket_bits; |
275 | #ifdef MB_CACHE_INDEXES_COUNT | ||
276 | mb_assert(indexes_count == MB_CACHE_INDEXES_COUNT); | ||
277 | #else | ||
278 | cache->c_indexes_count = indexes_count; | ||
279 | #endif | ||
280 | cache->c_block_hash = kmalloc(bucket_count * sizeof(struct list_head), | 235 | cache->c_block_hash = kmalloc(bucket_count * sizeof(struct list_head), |
281 | GFP_KERNEL); | 236 | GFP_KERNEL); |
282 | if (!cache->c_block_hash) | 237 | if (!cache->c_block_hash) |
283 | goto fail; | 238 | goto fail; |
284 | for (n=0; n<bucket_count; n++) | 239 | for (n=0; n<bucket_count; n++) |
285 | INIT_LIST_HEAD(&cache->c_block_hash[n]); | 240 | INIT_LIST_HEAD(&cache->c_block_hash[n]); |
286 | for (m=0; m<indexes_count; m++) { | 241 | cache->c_index_hash = kmalloc(bucket_count * sizeof(struct list_head), |
287 | cache->c_indexes_hash[m] = kmalloc(bucket_count * | 242 | GFP_KERNEL); |
288 | sizeof(struct list_head), | 243 | if (!cache->c_index_hash) |
289 | GFP_KERNEL); | 244 | goto fail; |
290 | if (!cache->c_indexes_hash[m]) | 245 | for (n=0; n<bucket_count; n++) |
291 | goto fail; | 246 | INIT_LIST_HEAD(&cache->c_index_hash[n]); |
292 | for (n=0; n<bucket_count; n++) | 247 | cache->c_entry_cache = kmem_cache_create(name, |
293 | INIT_LIST_HEAD(&cache->c_indexes_hash[m][n]); | 248 | sizeof(struct mb_cache_entry), 0, |
294 | } | ||
295 | cache->c_entry_cache = kmem_cache_create(name, entry_size, 0, | ||
296 | SLAB_RECLAIM_ACCOUNT|SLAB_MEM_SPREAD, NULL); | 249 | SLAB_RECLAIM_ACCOUNT|SLAB_MEM_SPREAD, NULL); |
297 | if (!cache->c_entry_cache) | 250 | if (!cache->c_entry_cache) |
298 | goto fail; | 251 | goto fail2; |
299 | 252 | ||
300 | spin_lock(&mb_cache_spinlock); | 253 | spin_lock(&mb_cache_spinlock); |
301 | list_add(&cache->c_cache_list, &mb_cache_list); | 254 | list_add(&cache->c_cache_list, &mb_cache_list); |
302 | spin_unlock(&mb_cache_spinlock); | 255 | spin_unlock(&mb_cache_spinlock); |
303 | return cache; | 256 | return cache; |
304 | 257 | ||
258 | fail2: | ||
259 | kfree(cache->c_index_hash); | ||
260 | |||
305 | fail: | 261 | fail: |
306 | if (cache) { | 262 | kfree(cache->c_block_hash); |
307 | while (--m >= 0) | 263 | kfree(cache); |
308 | kfree(cache->c_indexes_hash[m]); | ||
309 | kfree(cache->c_block_hash); | ||
310 | kfree(cache); | ||
311 | } | ||
312 | return NULL; | 264 | return NULL; |
313 | } | 265 | } |
314 | 266 | ||
@@ -357,7 +309,6 @@ mb_cache_destroy(struct mb_cache *cache) | |||
357 | { | 309 | { |
358 | LIST_HEAD(free_list); | 310 | LIST_HEAD(free_list); |
359 | struct list_head *l, *ltmp; | 311 | struct list_head *l, *ltmp; |
360 | int n; | ||
361 | 312 | ||
362 | spin_lock(&mb_cache_spinlock); | 313 | spin_lock(&mb_cache_spinlock); |
363 | list_for_each_safe(l, ltmp, &mb_cache_lru_list) { | 314 | list_for_each_safe(l, ltmp, &mb_cache_lru_list) { |
@@ -384,8 +335,7 @@ mb_cache_destroy(struct mb_cache *cache) | |||
384 | 335 | ||
385 | kmem_cache_destroy(cache->c_entry_cache); | 336 | kmem_cache_destroy(cache->c_entry_cache); |
386 | 337 | ||
387 | for (n=0; n < mb_cache_indexes(cache); n++) | 338 | kfree(cache->c_index_hash); |
388 | kfree(cache->c_indexes_hash[n]); | ||
389 | kfree(cache->c_block_hash); | 339 | kfree(cache->c_block_hash); |
390 | kfree(cache); | 340 | kfree(cache); |
391 | } | 341 | } |
@@ -429,17 +379,16 @@ mb_cache_entry_alloc(struct mb_cache *cache, gfp_t gfp_flags) | |||
429 | * | 379 | * |
430 | * @bdev: device the cache entry belongs to | 380 | * @bdev: device the cache entry belongs to |
431 | * @block: block number | 381 | * @block: block number |
432 | * @keys: array of additional keys. There must be indexes_count entries | 382 | * @key: lookup key |
433 | * in the array (as specified when creating the cache). | ||
434 | */ | 383 | */ |
435 | int | 384 | int |
436 | mb_cache_entry_insert(struct mb_cache_entry *ce, struct block_device *bdev, | 385 | mb_cache_entry_insert(struct mb_cache_entry *ce, struct block_device *bdev, |
437 | sector_t block, unsigned int keys[]) | 386 | sector_t block, unsigned int key) |
438 | { | 387 | { |
439 | struct mb_cache *cache = ce->e_cache; | 388 | struct mb_cache *cache = ce->e_cache; |
440 | unsigned int bucket; | 389 | unsigned int bucket; |
441 | struct list_head *l; | 390 | struct list_head *l; |
442 | int error = -EBUSY, n; | 391 | int error = -EBUSY; |
443 | 392 | ||
444 | bucket = hash_long((unsigned long)bdev + (block & 0xffffffff), | 393 | bucket = hash_long((unsigned long)bdev + (block & 0xffffffff), |
445 | cache->c_bucket_bits); | 394 | cache->c_bucket_bits); |
@@ -454,12 +403,9 @@ mb_cache_entry_insert(struct mb_cache_entry *ce, struct block_device *bdev, | |||
454 | ce->e_bdev = bdev; | 403 | ce->e_bdev = bdev; |
455 | ce->e_block = block; | 404 | ce->e_block = block; |
456 | list_add(&ce->e_block_list, &cache->c_block_hash[bucket]); | 405 | list_add(&ce->e_block_list, &cache->c_block_hash[bucket]); |
457 | for (n=0; n<mb_cache_indexes(cache); n++) { | 406 | ce->e_index.o_key = key; |
458 | ce->e_indexes[n].o_key = keys[n]; | 407 | bucket = hash_long(key, cache->c_bucket_bits); |
459 | bucket = hash_long(keys[n], cache->c_bucket_bits); | 408 | list_add(&ce->e_index.o_list, &cache->c_index_hash[bucket]); |
460 | list_add(&ce->e_indexes[n].o_list, | ||
461 | &cache->c_indexes_hash[n][bucket]); | ||
462 | } | ||
463 | error = 0; | 409 | error = 0; |
464 | out: | 410 | out: |
465 | spin_unlock(&mb_cache_spinlock); | 411 | spin_unlock(&mb_cache_spinlock); |
@@ -555,13 +501,12 @@ cleanup: | |||
555 | 501 | ||
556 | static struct mb_cache_entry * | 502 | static struct mb_cache_entry * |
557 | __mb_cache_entry_find(struct list_head *l, struct list_head *head, | 503 | __mb_cache_entry_find(struct list_head *l, struct list_head *head, |
558 | int index, struct block_device *bdev, unsigned int key) | 504 | struct block_device *bdev, unsigned int key) |
559 | { | 505 | { |
560 | while (l != head) { | 506 | while (l != head) { |
561 | struct mb_cache_entry *ce = | 507 | struct mb_cache_entry *ce = |
562 | list_entry(l, struct mb_cache_entry, | 508 | list_entry(l, struct mb_cache_entry, e_index.o_list); |
563 | e_indexes[index].o_list); | 509 | if (ce->e_bdev == bdev && ce->e_index.o_key == key) { |
564 | if (ce->e_bdev == bdev && ce->e_indexes[index].o_key == key) { | ||
565 | DEFINE_WAIT(wait); | 510 | DEFINE_WAIT(wait); |
566 | 511 | ||
567 | if (!list_empty(&ce->e_lru_list)) | 512 | if (!list_empty(&ce->e_lru_list)) |
@@ -603,23 +548,20 @@ __mb_cache_entry_find(struct list_head *l, struct list_head *head, | |||
603 | * returned cache entry is locked for shared access ("multiple readers"). | 548 | * returned cache entry is locked for shared access ("multiple readers"). |
604 | * | 549 | * |
605 | * @cache: the cache to search | 550 | * @cache: the cache to search |
606 | * @index: the number of the additonal index to search (0<=index<indexes_count) | ||
607 | * @bdev: the device the cache entry should belong to | 551 | * @bdev: the device the cache entry should belong to |
608 | * @key: the key in the index | 552 | * @key: the key in the index |
609 | */ | 553 | */ |
610 | struct mb_cache_entry * | 554 | struct mb_cache_entry * |
611 | mb_cache_entry_find_first(struct mb_cache *cache, int index, | 555 | mb_cache_entry_find_first(struct mb_cache *cache, struct block_device *bdev, |
612 | struct block_device *bdev, unsigned int key) | 556 | unsigned int key) |
613 | { | 557 | { |
614 | unsigned int bucket = hash_long(key, cache->c_bucket_bits); | 558 | unsigned int bucket = hash_long(key, cache->c_bucket_bits); |
615 | struct list_head *l; | 559 | struct list_head *l; |
616 | struct mb_cache_entry *ce; | 560 | struct mb_cache_entry *ce; |
617 | 561 | ||
618 | mb_assert(index < mb_cache_indexes(cache)); | ||
619 | spin_lock(&mb_cache_spinlock); | 562 | spin_lock(&mb_cache_spinlock); |
620 | l = cache->c_indexes_hash[index][bucket].next; | 563 | l = cache->c_index_hash[bucket].next; |
621 | ce = __mb_cache_entry_find(l, &cache->c_indexes_hash[index][bucket], | 564 | ce = __mb_cache_entry_find(l, &cache->c_index_hash[bucket], bdev, key); |
622 | index, bdev, key); | ||
623 | spin_unlock(&mb_cache_spinlock); | 565 | spin_unlock(&mb_cache_spinlock); |
624 | return ce; | 566 | return ce; |
625 | } | 567 | } |
@@ -640,12 +582,11 @@ mb_cache_entry_find_first(struct mb_cache *cache, int index, | |||
640 | * } | 582 | * } |
641 | * | 583 | * |
642 | * @prev: The previous match | 584 | * @prev: The previous match |
643 | * @index: the number of the additonal index to search (0<=index<indexes_count) | ||
644 | * @bdev: the device the cache entry should belong to | 585 | * @bdev: the device the cache entry should belong to |
645 | * @key: the key in the index | 586 | * @key: the key in the index |
646 | */ | 587 | */ |
647 | struct mb_cache_entry * | 588 | struct mb_cache_entry * |
648 | mb_cache_entry_find_next(struct mb_cache_entry *prev, int index, | 589 | mb_cache_entry_find_next(struct mb_cache_entry *prev, |
649 | struct block_device *bdev, unsigned int key) | 590 | struct block_device *bdev, unsigned int key) |
650 | { | 591 | { |
651 | struct mb_cache *cache = prev->e_cache; | 592 | struct mb_cache *cache = prev->e_cache; |
@@ -653,11 +594,9 @@ mb_cache_entry_find_next(struct mb_cache_entry *prev, int index, | |||
653 | struct list_head *l; | 594 | struct list_head *l; |
654 | struct mb_cache_entry *ce; | 595 | struct mb_cache_entry *ce; |
655 | 596 | ||
656 | mb_assert(index < mb_cache_indexes(cache)); | ||
657 | spin_lock(&mb_cache_spinlock); | 597 | spin_lock(&mb_cache_spinlock); |
658 | l = prev->e_indexes[index].o_list.next; | 598 | l = prev->e_index.o_list.next; |
659 | ce = __mb_cache_entry_find(l, &cache->c_indexes_hash[index][bucket], | 599 | ce = __mb_cache_entry_find(l, &cache->c_index_hash[bucket], bdev, key); |
660 | index, bdev, key); | ||
661 | __mb_cache_entry_release_unlock(prev); | 600 | __mb_cache_entry_release_unlock(prev); |
662 | return ce; | 601 | return ce; |
663 | } | 602 | } |