alloc.c 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875
  1. // SPDX-License-Identifier: GPL-2.0+
  2. /*
  3. * NILFS dat/inode allocator
  4. *
  5. * Copyright (C) 2006-2008 Nippon Telegraph and Telephone Corporation.
  6. *
  7. * Originally written by Koji Sato.
  8. * Two allocators were unified by Ryusuke Konishi and Amagai Yoshiji.
  9. */
  10. #include <linux/types.h>
  11. #include <linux/buffer_head.h>
  12. #include <linux/fs.h>
  13. #include <linux/bitops.h>
  14. #include <linux/slab.h>
  15. #include "mdt.h"
  16. #include "alloc.h"
  17. /**
  18. * nilfs_palloc_groups_per_desc_block - get the number of groups that a group
  19. * descriptor block can maintain
  20. * @inode: inode of metadata file using this allocator
  21. */
  22. static inline unsigned long
  23. nilfs_palloc_groups_per_desc_block(const struct inode *inode)
  24. {
  25. return i_blocksize(inode) /
  26. sizeof(struct nilfs_palloc_group_desc);
  27. }
  28. /**
  29. * nilfs_palloc_groups_count - get maximum number of groups
  30. * @inode: inode of metadata file using this allocator
  31. */
  32. static inline unsigned long
  33. nilfs_palloc_groups_count(const struct inode *inode)
  34. {
  35. return 1UL << (BITS_PER_LONG - (inode->i_blkbits + 3 /* log2(8) */));
  36. }
  37. /**
  38. * nilfs_palloc_init_blockgroup - initialize private variables for allocator
  39. * @inode: inode of metadata file using this allocator
  40. * @entry_size: size of the persistent object
  41. */
  42. int nilfs_palloc_init_blockgroup(struct inode *inode, unsigned int entry_size)
  43. {
  44. struct nilfs_mdt_info *mi = NILFS_MDT(inode);
  45. mi->mi_bgl = kmalloc(sizeof(*mi->mi_bgl), GFP_NOFS);
  46. if (!mi->mi_bgl)
  47. return -ENOMEM;
  48. bgl_lock_init(mi->mi_bgl);
  49. nilfs_mdt_set_entry_size(inode, entry_size, 0);
  50. mi->mi_blocks_per_group =
  51. DIV_ROUND_UP(nilfs_palloc_entries_per_group(inode),
  52. mi->mi_entries_per_block) + 1;
  53. /*
  54. * Number of blocks in a group including entry blocks
  55. * and a bitmap block
  56. */
  57. mi->mi_blocks_per_desc_block =
  58. nilfs_palloc_groups_per_desc_block(inode) *
  59. mi->mi_blocks_per_group + 1;
  60. /*
  61. * Number of blocks per descriptor including the
  62. * descriptor block
  63. */
  64. return 0;
  65. }
  66. /**
  67. * nilfs_palloc_group - get group number and offset from an entry number
  68. * @inode: inode of metadata file using this allocator
  69. * @nr: serial number of the entry (e.g. inode number)
  70. * @offset: pointer to store offset number in the group
  71. */
  72. static unsigned long nilfs_palloc_group(const struct inode *inode, __u64 nr,
  73. unsigned long *offset)
  74. {
  75. __u64 group = nr;
  76. *offset = do_div(group, nilfs_palloc_entries_per_group(inode));
  77. return group;
  78. }
  79. /**
  80. * nilfs_palloc_desc_blkoff - get block offset of a group descriptor block
  81. * @inode: inode of metadata file using this allocator
  82. * @group: group number
  83. *
  84. * nilfs_palloc_desc_blkoff() returns block offset of the descriptor
  85. * block which contains a descriptor of the specified group.
  86. */
  87. static unsigned long
  88. nilfs_palloc_desc_blkoff(const struct inode *inode, unsigned long group)
  89. {
  90. unsigned long desc_block =
  91. group / nilfs_palloc_groups_per_desc_block(inode);
  92. return desc_block * NILFS_MDT(inode)->mi_blocks_per_desc_block;
  93. }
  94. /**
  95. * nilfs_palloc_bitmap_blkoff - get block offset of a bitmap block
  96. * @inode: inode of metadata file using this allocator
  97. * @group: group number
  98. *
  99. * nilfs_palloc_bitmap_blkoff() returns block offset of the bitmap
  100. * block used to allocate/deallocate entries in the specified group.
  101. */
  102. static unsigned long
  103. nilfs_palloc_bitmap_blkoff(const struct inode *inode, unsigned long group)
  104. {
  105. unsigned long desc_offset =
  106. group % nilfs_palloc_groups_per_desc_block(inode);
  107. return nilfs_palloc_desc_blkoff(inode, group) + 1 +
  108. desc_offset * NILFS_MDT(inode)->mi_blocks_per_group;
  109. }
  110. /**
  111. * nilfs_palloc_group_desc_nfrees - get the number of free entries in a group
  112. * @desc: pointer to descriptor structure for the group
  113. * @lock: spin lock protecting @desc
  114. */
  115. static unsigned long
  116. nilfs_palloc_group_desc_nfrees(const struct nilfs_palloc_group_desc *desc,
  117. spinlock_t *lock)
  118. {
  119. unsigned long nfree;
  120. spin_lock(lock);
  121. nfree = le32_to_cpu(desc->pg_nfrees);
  122. spin_unlock(lock);
  123. return nfree;
  124. }
  125. /**
  126. * nilfs_palloc_group_desc_add_entries - adjust count of free entries
  127. * @desc: pointer to descriptor structure for the group
  128. * @lock: spin lock protecting @desc
  129. * @n: delta to be added
  130. */
  131. static u32
  132. nilfs_palloc_group_desc_add_entries(struct nilfs_palloc_group_desc *desc,
  133. spinlock_t *lock, u32 n)
  134. {
  135. u32 nfree;
  136. spin_lock(lock);
  137. le32_add_cpu(&desc->pg_nfrees, n);
  138. nfree = le32_to_cpu(desc->pg_nfrees);
  139. spin_unlock(lock);
  140. return nfree;
  141. }
  142. /**
  143. * nilfs_palloc_entry_blkoff - get block offset of an entry block
  144. * @inode: inode of metadata file using this allocator
  145. * @nr: serial number of the entry (e.g. inode number)
  146. */
  147. static unsigned long
  148. nilfs_palloc_entry_blkoff(const struct inode *inode, __u64 nr)
  149. {
  150. unsigned long group, group_offset;
  151. group = nilfs_palloc_group(inode, nr, &group_offset);
  152. return nilfs_palloc_bitmap_blkoff(inode, group) + 1 +
  153. group_offset / NILFS_MDT(inode)->mi_entries_per_block;
  154. }
  155. /**
  156. * nilfs_palloc_desc_block_init - initialize buffer of a group descriptor block
  157. * @inode: inode of metadata file
  158. * @bh: buffer head of the buffer to be initialized
  159. * @kaddr: kernel address mapped for the page including the buffer
  160. */
  161. static void nilfs_palloc_desc_block_init(struct inode *inode,
  162. struct buffer_head *bh, void *kaddr)
  163. {
  164. struct nilfs_palloc_group_desc *desc = kaddr + bh_offset(bh);
  165. unsigned long n = nilfs_palloc_groups_per_desc_block(inode);
  166. __le32 nfrees;
  167. nfrees = cpu_to_le32(nilfs_palloc_entries_per_group(inode));
  168. while (n-- > 0) {
  169. desc->pg_nfrees = nfrees;
  170. desc++;
  171. }
  172. }
  173. static int nilfs_palloc_get_block(struct inode *inode, unsigned long blkoff,
  174. int create,
  175. void (*init_block)(struct inode *,
  176. struct buffer_head *,
  177. void *),
  178. struct buffer_head **bhp,
  179. struct nilfs_bh_assoc *prev,
  180. spinlock_t *lock)
  181. {
  182. int ret;
  183. spin_lock(lock);
  184. if (prev->bh && blkoff == prev->blkoff &&
  185. likely(buffer_uptodate(prev->bh))) {
  186. get_bh(prev->bh);
  187. *bhp = prev->bh;
  188. spin_unlock(lock);
  189. return 0;
  190. }
  191. spin_unlock(lock);
  192. ret = nilfs_mdt_get_block(inode, blkoff, create, init_block, bhp);
  193. if (!ret) {
  194. spin_lock(lock);
  195. /*
  196. * The following code must be safe for change of the
  197. * cache contents during the get block call.
  198. */
  199. brelse(prev->bh);
  200. get_bh(*bhp);
  201. prev->bh = *bhp;
  202. prev->blkoff = blkoff;
  203. spin_unlock(lock);
  204. }
  205. return ret;
  206. }
  207. /**
  208. * nilfs_palloc_delete_block - delete a block on the persistent allocator file
  209. * @inode: inode of metadata file using this allocator
  210. * @blkoff: block offset
  211. * @prev: nilfs_bh_assoc struct of the last used buffer
  212. * @lock: spin lock protecting @prev
  213. */
  214. static int nilfs_palloc_delete_block(struct inode *inode, unsigned long blkoff,
  215. struct nilfs_bh_assoc *prev,
  216. spinlock_t *lock)
  217. {
  218. spin_lock(lock);
  219. if (prev->bh && blkoff == prev->blkoff) {
  220. brelse(prev->bh);
  221. prev->bh = NULL;
  222. }
  223. spin_unlock(lock);
  224. return nilfs_mdt_delete_block(inode, blkoff);
  225. }
  226. /**
  227. * nilfs_palloc_get_desc_block - get buffer head of a group descriptor block
  228. * @inode: inode of metadata file using this allocator
  229. * @group: group number
  230. * @create: create flag
  231. * @bhp: pointer to store the resultant buffer head
  232. */
  233. static int nilfs_palloc_get_desc_block(struct inode *inode,
  234. unsigned long group,
  235. int create, struct buffer_head **bhp)
  236. {
  237. struct nilfs_palloc_cache *cache = NILFS_MDT(inode)->mi_palloc_cache;
  238. return nilfs_palloc_get_block(inode,
  239. nilfs_palloc_desc_blkoff(inode, group),
  240. create, nilfs_palloc_desc_block_init,
  241. bhp, &cache->prev_desc, &cache->lock);
  242. }
  243. /**
  244. * nilfs_palloc_get_bitmap_block - get buffer head of a bitmap block
  245. * @inode: inode of metadata file using this allocator
  246. * @group: group number
  247. * @create: create flag
  248. * @bhp: pointer to store the resultant buffer head
  249. */
  250. static int nilfs_palloc_get_bitmap_block(struct inode *inode,
  251. unsigned long group,
  252. int create, struct buffer_head **bhp)
  253. {
  254. struct nilfs_palloc_cache *cache = NILFS_MDT(inode)->mi_palloc_cache;
  255. return nilfs_palloc_get_block(inode,
  256. nilfs_palloc_bitmap_blkoff(inode, group),
  257. create, NULL, bhp,
  258. &cache->prev_bitmap, &cache->lock);
  259. }
  260. /**
  261. * nilfs_palloc_delete_bitmap_block - delete a bitmap block
  262. * @inode: inode of metadata file using this allocator
  263. * @group: group number
  264. */
  265. static int nilfs_palloc_delete_bitmap_block(struct inode *inode,
  266. unsigned long group)
  267. {
  268. struct nilfs_palloc_cache *cache = NILFS_MDT(inode)->mi_palloc_cache;
  269. return nilfs_palloc_delete_block(inode,
  270. nilfs_palloc_bitmap_blkoff(inode,
  271. group),
  272. &cache->prev_bitmap, &cache->lock);
  273. }
  274. /**
  275. * nilfs_palloc_get_entry_block - get buffer head of an entry block
  276. * @inode: inode of metadata file using this allocator
  277. * @nr: serial number of the entry (e.g. inode number)
  278. * @create: create flag
  279. * @bhp: pointer to store the resultant buffer head
  280. */
  281. int nilfs_palloc_get_entry_block(struct inode *inode, __u64 nr,
  282. int create, struct buffer_head **bhp)
  283. {
  284. struct nilfs_palloc_cache *cache = NILFS_MDT(inode)->mi_palloc_cache;
  285. return nilfs_palloc_get_block(inode,
  286. nilfs_palloc_entry_blkoff(inode, nr),
  287. create, NULL, bhp,
  288. &cache->prev_entry, &cache->lock);
  289. }
  290. /**
  291. * nilfs_palloc_delete_entry_block - delete an entry block
  292. * @inode: inode of metadata file using this allocator
  293. * @nr: serial number of the entry
  294. */
  295. static int nilfs_palloc_delete_entry_block(struct inode *inode, __u64 nr)
  296. {
  297. struct nilfs_palloc_cache *cache = NILFS_MDT(inode)->mi_palloc_cache;
  298. return nilfs_palloc_delete_block(inode,
  299. nilfs_palloc_entry_blkoff(inode, nr),
  300. &cache->prev_entry, &cache->lock);
  301. }
  302. /**
  303. * nilfs_palloc_block_get_group_desc - get kernel address of a group descriptor
  304. * @inode: inode of metadata file using this allocator
  305. * @group: group number
  306. * @bh: buffer head of the buffer storing the group descriptor block
  307. * @kaddr: kernel address mapped for the page including the buffer
  308. */
  309. static struct nilfs_palloc_group_desc *
  310. nilfs_palloc_block_get_group_desc(const struct inode *inode,
  311. unsigned long group,
  312. const struct buffer_head *bh, void *kaddr)
  313. {
  314. return (struct nilfs_palloc_group_desc *)(kaddr + bh_offset(bh)) +
  315. group % nilfs_palloc_groups_per_desc_block(inode);
  316. }
  317. /**
  318. * nilfs_palloc_block_get_entry - get kernel address of an entry
  319. * @inode: inode of metadata file using this allocator
  320. * @nr: serial number of the entry (e.g. inode number)
  321. * @bh: buffer head of the buffer storing the entry block
  322. * @kaddr: kernel address mapped for the page including the buffer
  323. */
  324. void *nilfs_palloc_block_get_entry(const struct inode *inode, __u64 nr,
  325. const struct buffer_head *bh, void *kaddr)
  326. {
  327. unsigned long entry_offset, group_offset;
  328. nilfs_palloc_group(inode, nr, &group_offset);
  329. entry_offset = group_offset % NILFS_MDT(inode)->mi_entries_per_block;
  330. return kaddr + bh_offset(bh) +
  331. entry_offset * NILFS_MDT(inode)->mi_entry_size;
  332. }
  333. /**
  334. * nilfs_palloc_find_available_slot - find available slot in a group
  335. * @bitmap: bitmap of the group
  336. * @target: offset number of an entry in the group (start point)
  337. * @bsize: size in bits
  338. * @lock: spin lock protecting @bitmap
  339. * @wrap: whether to wrap around
  340. */
  341. static int nilfs_palloc_find_available_slot(unsigned char *bitmap,
  342. unsigned long target,
  343. unsigned int bsize,
  344. spinlock_t *lock, bool wrap)
  345. {
  346. int pos, end = bsize;
  347. if (likely(target < bsize)) {
  348. pos = target;
  349. do {
  350. pos = nilfs_find_next_zero_bit(bitmap, end, pos);
  351. if (pos >= end)
  352. break;
  353. if (!nilfs_set_bit_atomic(lock, pos, bitmap))
  354. return pos;
  355. } while (++pos < end);
  356. end = target;
  357. }
  358. if (!wrap)
  359. return -ENOSPC;
  360. /* wrap around */
  361. for (pos = 0; pos < end; pos++) {
  362. pos = nilfs_find_next_zero_bit(bitmap, end, pos);
  363. if (pos >= end)
  364. break;
  365. if (!nilfs_set_bit_atomic(lock, pos, bitmap))
  366. return pos;
  367. }
  368. return -ENOSPC;
  369. }
  370. /**
  371. * nilfs_palloc_rest_groups_in_desc_block - get the remaining number of groups
  372. * in a group descriptor block
  373. * @inode: inode of metadata file using this allocator
  374. * @curr: current group number
  375. * @max: maximum number of groups
  376. */
  377. static unsigned long
  378. nilfs_palloc_rest_groups_in_desc_block(const struct inode *inode,
  379. unsigned long curr, unsigned long max)
  380. {
  381. return min_t(unsigned long,
  382. nilfs_palloc_groups_per_desc_block(inode) -
  383. curr % nilfs_palloc_groups_per_desc_block(inode),
  384. max - curr + 1);
  385. }
  386. /**
  387. * nilfs_palloc_count_desc_blocks - count descriptor blocks number
  388. * @inode: inode of metadata file using this allocator
  389. * @desc_blocks: descriptor blocks number [out]
  390. */
  391. static int nilfs_palloc_count_desc_blocks(struct inode *inode,
  392. unsigned long *desc_blocks)
  393. {
  394. __u64 blknum;
  395. int ret;
  396. ret = nilfs_bmap_last_key(NILFS_I(inode)->i_bmap, &blknum);
  397. if (likely(!ret))
  398. *desc_blocks = DIV_ROUND_UP(
  399. (unsigned long)blknum,
  400. NILFS_MDT(inode)->mi_blocks_per_desc_block);
  401. return ret;
  402. }
  403. /**
  404. * nilfs_palloc_mdt_file_can_grow - check potential opportunity for
  405. * MDT file growing
  406. * @inode: inode of metadata file using this allocator
  407. * @desc_blocks: known current descriptor blocks count
  408. */
  409. static inline bool nilfs_palloc_mdt_file_can_grow(struct inode *inode,
  410. unsigned long desc_blocks)
  411. {
  412. return (nilfs_palloc_groups_per_desc_block(inode) * desc_blocks) <
  413. nilfs_palloc_groups_count(inode);
  414. }
  415. /**
  416. * nilfs_palloc_count_max_entries - count max number of entries that can be
  417. * described by descriptor blocks count
  418. * @inode: inode of metadata file using this allocator
  419. * @nused: current number of used entries
  420. * @nmaxp: max number of entries [out]
  421. */
  422. int nilfs_palloc_count_max_entries(struct inode *inode, u64 nused, u64 *nmaxp)
  423. {
  424. unsigned long desc_blocks = 0;
  425. u64 entries_per_desc_block, nmax;
  426. int err;
  427. err = nilfs_palloc_count_desc_blocks(inode, &desc_blocks);
  428. if (unlikely(err))
  429. return err;
  430. entries_per_desc_block = (u64)nilfs_palloc_entries_per_group(inode) *
  431. nilfs_palloc_groups_per_desc_block(inode);
  432. nmax = entries_per_desc_block * desc_blocks;
  433. if (nused == nmax &&
  434. nilfs_palloc_mdt_file_can_grow(inode, desc_blocks))
  435. nmax += entries_per_desc_block;
  436. if (nused > nmax)
  437. return -ERANGE;
  438. *nmaxp = nmax;
  439. return 0;
  440. }
  441. /**
  442. * nilfs_palloc_prepare_alloc_entry - prepare to allocate a persistent object
  443. * @inode: inode of metadata file using this allocator
  444. * @req: nilfs_palloc_req structure exchanged for the allocation
  445. * @wrap: whether to wrap around
  446. */
  447. int nilfs_palloc_prepare_alloc_entry(struct inode *inode,
  448. struct nilfs_palloc_req *req, bool wrap)
  449. {
  450. struct buffer_head *desc_bh, *bitmap_bh;
  451. struct nilfs_palloc_group_desc *desc;
  452. unsigned char *bitmap;
  453. void *desc_kaddr, *bitmap_kaddr;
  454. unsigned long group, maxgroup, ngroups;
  455. unsigned long group_offset, maxgroup_offset;
  456. unsigned long n, entries_per_group;
  457. unsigned long i, j;
  458. spinlock_t *lock;
  459. int pos, ret;
  460. ngroups = nilfs_palloc_groups_count(inode);
  461. maxgroup = ngroups - 1;
  462. group = nilfs_palloc_group(inode, req->pr_entry_nr, &group_offset);
  463. entries_per_group = nilfs_palloc_entries_per_group(inode);
  464. for (i = 0; i < ngroups; i += n) {
  465. if (group >= ngroups && wrap) {
  466. /* wrap around */
  467. group = 0;
  468. maxgroup = nilfs_palloc_group(inode, req->pr_entry_nr,
  469. &maxgroup_offset) - 1;
  470. }
  471. ret = nilfs_palloc_get_desc_block(inode, group, 1, &desc_bh);
  472. if (ret < 0)
  473. return ret;
  474. desc_kaddr = kmap_local_page(desc_bh->b_page);
  475. desc = nilfs_palloc_block_get_group_desc(
  476. inode, group, desc_bh, desc_kaddr);
  477. n = nilfs_palloc_rest_groups_in_desc_block(inode, group,
  478. maxgroup);
  479. for (j = 0; j < n; j++, desc++, group++, group_offset = 0) {
  480. lock = nilfs_mdt_bgl_lock(inode, group);
  481. if (nilfs_palloc_group_desc_nfrees(desc, lock) == 0)
  482. continue;
  483. kunmap_local(desc_kaddr);
  484. ret = nilfs_palloc_get_bitmap_block(inode, group, 1,
  485. &bitmap_bh);
  486. if (unlikely(ret < 0)) {
  487. brelse(desc_bh);
  488. return ret;
  489. }
  490. desc_kaddr = kmap_local_page(desc_bh->b_page);
  491. desc = nilfs_palloc_block_get_group_desc(
  492. inode, group, desc_bh, desc_kaddr);
  493. bitmap_kaddr = kmap_local_page(bitmap_bh->b_page);
  494. bitmap = bitmap_kaddr + bh_offset(bitmap_bh);
  495. pos = nilfs_palloc_find_available_slot(
  496. bitmap, group_offset, entries_per_group, lock,
  497. wrap);
  498. /*
  499. * Since the search for a free slot in the second and
  500. * subsequent bitmap blocks always starts from the
  501. * beginning, the wrap flag only has an effect on the
  502. * first search.
  503. */
  504. kunmap_local(bitmap_kaddr);
  505. if (pos >= 0)
  506. goto found;
  507. brelse(bitmap_bh);
  508. }
  509. kunmap_local(desc_kaddr);
  510. brelse(desc_bh);
  511. }
  512. /* no entries left */
  513. return -ENOSPC;
  514. found:
  515. /* found a free entry */
  516. nilfs_palloc_group_desc_add_entries(desc, lock, -1);
  517. req->pr_entry_nr = entries_per_group * group + pos;
  518. kunmap_local(desc_kaddr);
  519. req->pr_desc_bh = desc_bh;
  520. req->pr_bitmap_bh = bitmap_bh;
  521. return 0;
  522. }
  523. /**
  524. * nilfs_palloc_commit_alloc_entry - finish allocation of a persistent object
  525. * @inode: inode of metadata file using this allocator
  526. * @req: nilfs_palloc_req structure exchanged for the allocation
  527. */
  528. void nilfs_palloc_commit_alloc_entry(struct inode *inode,
  529. struct nilfs_palloc_req *req)
  530. {
  531. mark_buffer_dirty(req->pr_bitmap_bh);
  532. mark_buffer_dirty(req->pr_desc_bh);
  533. nilfs_mdt_mark_dirty(inode);
  534. brelse(req->pr_bitmap_bh);
  535. brelse(req->pr_desc_bh);
  536. }
  537. /**
  538. * nilfs_palloc_commit_free_entry - finish deallocating a persistent object
  539. * @inode: inode of metadata file using this allocator
  540. * @req: nilfs_palloc_req structure exchanged for the removal
  541. */
  542. void nilfs_palloc_commit_free_entry(struct inode *inode,
  543. struct nilfs_palloc_req *req)
  544. {
  545. struct nilfs_palloc_group_desc *desc;
  546. unsigned long group, group_offset;
  547. unsigned char *bitmap;
  548. void *desc_kaddr, *bitmap_kaddr;
  549. spinlock_t *lock;
  550. group = nilfs_palloc_group(inode, req->pr_entry_nr, &group_offset);
  551. desc_kaddr = kmap_local_page(req->pr_desc_bh->b_page);
  552. desc = nilfs_palloc_block_get_group_desc(inode, group,
  553. req->pr_desc_bh, desc_kaddr);
  554. bitmap_kaddr = kmap_local_page(req->pr_bitmap_bh->b_page);
  555. bitmap = bitmap_kaddr + bh_offset(req->pr_bitmap_bh);
  556. lock = nilfs_mdt_bgl_lock(inode, group);
  557. if (!nilfs_clear_bit_atomic(lock, group_offset, bitmap))
  558. nilfs_warn(inode->i_sb,
  559. "%s (ino=%lu): entry number %llu already freed",
  560. __func__, inode->i_ino,
  561. (unsigned long long)req->pr_entry_nr);
  562. else
  563. nilfs_palloc_group_desc_add_entries(desc, lock, 1);
  564. kunmap_local(bitmap_kaddr);
  565. kunmap_local(desc_kaddr);
  566. mark_buffer_dirty(req->pr_desc_bh);
  567. mark_buffer_dirty(req->pr_bitmap_bh);
  568. nilfs_mdt_mark_dirty(inode);
  569. brelse(req->pr_bitmap_bh);
  570. brelse(req->pr_desc_bh);
  571. }
  572. /**
  573. * nilfs_palloc_abort_alloc_entry - cancel allocation of a persistent object
  574. * @inode: inode of metadata file using this allocator
  575. * @req: nilfs_palloc_req structure exchanged for the allocation
  576. */
  577. void nilfs_palloc_abort_alloc_entry(struct inode *inode,
  578. struct nilfs_palloc_req *req)
  579. {
  580. struct nilfs_palloc_group_desc *desc;
  581. void *desc_kaddr, *bitmap_kaddr;
  582. unsigned char *bitmap;
  583. unsigned long group, group_offset;
  584. spinlock_t *lock;
  585. group = nilfs_palloc_group(inode, req->pr_entry_nr, &group_offset);
  586. desc_kaddr = kmap_local_page(req->pr_desc_bh->b_page);
  587. desc = nilfs_palloc_block_get_group_desc(inode, group,
  588. req->pr_desc_bh, desc_kaddr);
  589. bitmap_kaddr = kmap_local_page(req->pr_bitmap_bh->b_page);
  590. bitmap = bitmap_kaddr + bh_offset(req->pr_bitmap_bh);
  591. lock = nilfs_mdt_bgl_lock(inode, group);
  592. if (!nilfs_clear_bit_atomic(lock, group_offset, bitmap))
  593. nilfs_warn(inode->i_sb,
  594. "%s (ino=%lu): entry number %llu already freed",
  595. __func__, inode->i_ino,
  596. (unsigned long long)req->pr_entry_nr);
  597. else
  598. nilfs_palloc_group_desc_add_entries(desc, lock, 1);
  599. kunmap_local(bitmap_kaddr);
  600. kunmap_local(desc_kaddr);
  601. brelse(req->pr_bitmap_bh);
  602. brelse(req->pr_desc_bh);
  603. req->pr_entry_nr = 0;
  604. req->pr_bitmap_bh = NULL;
  605. req->pr_desc_bh = NULL;
  606. }
  607. /**
  608. * nilfs_palloc_prepare_free_entry - prepare to deallocate a persistent object
  609. * @inode: inode of metadata file using this allocator
  610. * @req: nilfs_palloc_req structure exchanged for the removal
  611. */
  612. int nilfs_palloc_prepare_free_entry(struct inode *inode,
  613. struct nilfs_palloc_req *req)
  614. {
  615. struct buffer_head *desc_bh, *bitmap_bh;
  616. unsigned long group, group_offset;
  617. int ret;
  618. group = nilfs_palloc_group(inode, req->pr_entry_nr, &group_offset);
  619. ret = nilfs_palloc_get_desc_block(inode, group, 1, &desc_bh);
  620. if (ret < 0)
  621. return ret;
  622. ret = nilfs_palloc_get_bitmap_block(inode, group, 1, &bitmap_bh);
  623. if (ret < 0) {
  624. brelse(desc_bh);
  625. return ret;
  626. }
  627. req->pr_desc_bh = desc_bh;
  628. req->pr_bitmap_bh = bitmap_bh;
  629. return 0;
  630. }
  631. /**
  632. * nilfs_palloc_abort_free_entry - cancel deallocating a persistent object
  633. * @inode: inode of metadata file using this allocator
  634. * @req: nilfs_palloc_req structure exchanged for the removal
  635. */
  636. void nilfs_palloc_abort_free_entry(struct inode *inode,
  637. struct nilfs_palloc_req *req)
  638. {
  639. brelse(req->pr_bitmap_bh);
  640. brelse(req->pr_desc_bh);
  641. req->pr_entry_nr = 0;
  642. req->pr_bitmap_bh = NULL;
  643. req->pr_desc_bh = NULL;
  644. }
  645. /**
  646. * nilfs_palloc_freev - deallocate a set of persistent objects
  647. * @inode: inode of metadata file using this allocator
  648. * @entry_nrs: array of entry numbers to be deallocated
  649. * @nitems: number of entries stored in @entry_nrs
  650. */
  651. int nilfs_palloc_freev(struct inode *inode, __u64 *entry_nrs, size_t nitems)
  652. {
  653. struct buffer_head *desc_bh, *bitmap_bh;
  654. struct nilfs_palloc_group_desc *desc;
  655. unsigned char *bitmap;
  656. void *desc_kaddr, *bitmap_kaddr;
  657. unsigned long group, group_offset;
  658. __u64 group_min_nr, last_nrs[8];
  659. const unsigned long epg = nilfs_palloc_entries_per_group(inode);
  660. const unsigned int epb = NILFS_MDT(inode)->mi_entries_per_block;
  661. unsigned int entry_start, end, pos;
  662. spinlock_t *lock;
  663. int i, j, k, ret;
  664. u32 nfree;
  665. for (i = 0; i < nitems; i = j) {
  666. int change_group = false;
  667. int nempties = 0, n = 0;
  668. group = nilfs_palloc_group(inode, entry_nrs[i], &group_offset);
  669. ret = nilfs_palloc_get_desc_block(inode, group, 0, &desc_bh);
  670. if (ret < 0)
  671. return ret;
  672. ret = nilfs_palloc_get_bitmap_block(inode, group, 0,
  673. &bitmap_bh);
  674. if (ret < 0) {
  675. brelse(desc_bh);
  676. return ret;
  677. }
  678. /* Get the first entry number of the group */
  679. group_min_nr = (__u64)group * epg;
  680. bitmap_kaddr = kmap_local_page(bitmap_bh->b_page);
  681. bitmap = bitmap_kaddr + bh_offset(bitmap_bh);
  682. lock = nilfs_mdt_bgl_lock(inode, group);
  683. j = i;
  684. entry_start = rounddown(group_offset, epb);
  685. do {
  686. if (!nilfs_clear_bit_atomic(lock, group_offset,
  687. bitmap)) {
  688. nilfs_warn(inode->i_sb,
  689. "%s (ino=%lu): entry number %llu already freed",
  690. __func__, inode->i_ino,
  691. (unsigned long long)entry_nrs[j]);
  692. } else {
  693. n++;
  694. }
  695. j++;
  696. if (j >= nitems || entry_nrs[j] < group_min_nr ||
  697. entry_nrs[j] >= group_min_nr + epg) {
  698. change_group = true;
  699. } else {
  700. group_offset = entry_nrs[j] - group_min_nr;
  701. if (group_offset >= entry_start &&
  702. group_offset < entry_start + epb) {
  703. /* This entry is in the same block */
  704. continue;
  705. }
  706. }
  707. /* Test if the entry block is empty or not */
  708. end = entry_start + epb;
  709. pos = nilfs_find_next_bit(bitmap, end, entry_start);
  710. if (pos >= end) {
  711. last_nrs[nempties++] = entry_nrs[j - 1];
  712. if (nempties >= ARRAY_SIZE(last_nrs))
  713. break;
  714. }
  715. if (change_group)
  716. break;
  717. /* Go on to the next entry block */
  718. entry_start = rounddown(group_offset, epb);
  719. } while (true);
  720. kunmap_local(bitmap_kaddr);
  721. mark_buffer_dirty(bitmap_bh);
  722. brelse(bitmap_bh);
  723. for (k = 0; k < nempties; k++) {
  724. ret = nilfs_palloc_delete_entry_block(inode,
  725. last_nrs[k]);
  726. if (ret && ret != -ENOENT)
  727. nilfs_warn(inode->i_sb,
  728. "error %d deleting block that object (entry=%llu, ino=%lu) belongs to",
  729. ret, (unsigned long long)last_nrs[k],
  730. inode->i_ino);
  731. }
  732. desc_kaddr = kmap_local_page(desc_bh->b_page);
  733. desc = nilfs_palloc_block_get_group_desc(
  734. inode, group, desc_bh, desc_kaddr);
  735. nfree = nilfs_palloc_group_desc_add_entries(desc, lock, n);
  736. kunmap_local(desc_kaddr);
  737. mark_buffer_dirty(desc_bh);
  738. nilfs_mdt_mark_dirty(inode);
  739. brelse(desc_bh);
  740. if (nfree == nilfs_palloc_entries_per_group(inode)) {
  741. ret = nilfs_palloc_delete_bitmap_block(inode, group);
  742. if (ret && ret != -ENOENT)
  743. nilfs_warn(inode->i_sb,
  744. "error %d deleting bitmap block of group=%lu, ino=%lu",
  745. ret, group, inode->i_ino);
  746. }
  747. }
  748. return 0;
  749. }
  750. void nilfs_palloc_setup_cache(struct inode *inode,
  751. struct nilfs_palloc_cache *cache)
  752. {
  753. NILFS_MDT(inode)->mi_palloc_cache = cache;
  754. spin_lock_init(&cache->lock);
  755. }
  756. void nilfs_palloc_clear_cache(struct inode *inode)
  757. {
  758. struct nilfs_palloc_cache *cache = NILFS_MDT(inode)->mi_palloc_cache;
  759. spin_lock(&cache->lock);
  760. brelse(cache->prev_desc.bh);
  761. brelse(cache->prev_bitmap.bh);
  762. brelse(cache->prev_entry.bh);
  763. cache->prev_desc.bh = NULL;
  764. cache->prev_bitmap.bh = NULL;
  765. cache->prev_entry.bh = NULL;
  766. spin_unlock(&cache->lock);
  767. }
  768. void nilfs_palloc_destroy_cache(struct inode *inode)
  769. {
  770. nilfs_palloc_clear_cache(inode);
  771. NILFS_MDT(inode)->mi_palloc_cache = NULL;
  772. }