sufile.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752
  1. /*
  2. * sufile.c - NILFS segment usage file.
  3. *
  4. * Copyright (C) 2006-2008 Nippon Telegraph and Telephone Corporation.
  5. *
  6. * This program is free software; you can redistribute it and/or modify
  7. * it under the terms of the GNU General Public License as published by
  8. * the Free Software Foundation; either version 2 of the License, or
  9. * (at your option) any later version.
  10. *
  11. * This program is distributed in the hope that it will be useful,
  12. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14. * GNU General Public License for more details.
  15. *
  16. * You should have received a copy of the GNU General Public License
  17. * along with this program; if not, write to the Free Software
  18. * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  19. *
  20. * Written by Koji Sato <koji@osrg.net>.
  21. * Rivised by Ryusuke Konishi <ryusuke@osrg.net>.
  22. */
  23. #include <linux/kernel.h>
  24. #include <linux/fs.h>
  25. #include <linux/string.h>
  26. #include <linux/buffer_head.h>
  27. #include <linux/errno.h>
  28. #include <linux/nilfs2_fs.h>
  29. #include "mdt.h"
  30. #include "sufile.h"
  31. struct nilfs_sufile_info {
  32. struct nilfs_mdt_info mi;
  33. unsigned long ncleansegs;
  34. };
  35. static inline struct nilfs_sufile_info *NILFS_SUI(struct inode *sufile)
  36. {
  37. return (struct nilfs_sufile_info *)NILFS_MDT(sufile);
  38. }
  39. static inline unsigned long
  40. nilfs_sufile_segment_usages_per_block(const struct inode *sufile)
  41. {
  42. return NILFS_MDT(sufile)->mi_entries_per_block;
  43. }
  44. static unsigned long
  45. nilfs_sufile_get_blkoff(const struct inode *sufile, __u64 segnum)
  46. {
  47. __u64 t = segnum + NILFS_MDT(sufile)->mi_first_entry_offset;
  48. do_div(t, nilfs_sufile_segment_usages_per_block(sufile));
  49. return (unsigned long)t;
  50. }
  51. static unsigned long
  52. nilfs_sufile_get_offset(const struct inode *sufile, __u64 segnum)
  53. {
  54. __u64 t = segnum + NILFS_MDT(sufile)->mi_first_entry_offset;
  55. return do_div(t, nilfs_sufile_segment_usages_per_block(sufile));
  56. }
  57. static unsigned long
  58. nilfs_sufile_segment_usages_in_block(const struct inode *sufile, __u64 curr,
  59. __u64 max)
  60. {
  61. return min_t(unsigned long,
  62. nilfs_sufile_segment_usages_per_block(sufile) -
  63. nilfs_sufile_get_offset(sufile, curr),
  64. max - curr + 1);
  65. }
  66. static struct nilfs_segment_usage *
  67. nilfs_sufile_block_get_segment_usage(const struct inode *sufile, __u64 segnum,
  68. struct buffer_head *bh, void *kaddr)
  69. {
  70. return kaddr + bh_offset(bh) +
  71. nilfs_sufile_get_offset(sufile, segnum) *
  72. NILFS_MDT(sufile)->mi_entry_size;
  73. }
  74. static inline int nilfs_sufile_get_header_block(struct inode *sufile,
  75. struct buffer_head **bhp)
  76. {
  77. return nilfs_mdt_get_block(sufile, 0, 0, NULL, bhp);
  78. }
  79. static inline int
  80. nilfs_sufile_get_segment_usage_block(struct inode *sufile, __u64 segnum,
  81. int create, struct buffer_head **bhp)
  82. {
  83. return nilfs_mdt_get_block(sufile,
  84. nilfs_sufile_get_blkoff(sufile, segnum),
  85. create, NULL, bhp);
  86. }
  87. static void nilfs_sufile_mod_counter(struct buffer_head *header_bh,
  88. u64 ncleanadd, u64 ndirtyadd)
  89. {
  90. struct nilfs_sufile_header *header;
  91. void *kaddr;
  92. kaddr = kmap_atomic(header_bh->b_page, KM_USER0);
  93. header = kaddr + bh_offset(header_bh);
  94. le64_add_cpu(&header->sh_ncleansegs, ncleanadd);
  95. le64_add_cpu(&header->sh_ndirtysegs, ndirtyadd);
  96. kunmap_atomic(kaddr, KM_USER0);
  97. nilfs_mdt_mark_buffer_dirty(header_bh);
  98. }
  99. /**
  100. * nilfs_sufile_get_ncleansegs - return the number of clean segments
  101. * @sufile: inode of segment usage file
  102. */
  103. unsigned long nilfs_sufile_get_ncleansegs(struct inode *sufile)
  104. {
  105. return NILFS_SUI(sufile)->ncleansegs;
  106. }
  107. /**
  108. * nilfs_sufile_updatev - modify multiple segment usages at a time
  109. * @sufile: inode of segment usage file
  110. * @segnumv: array of segment numbers
  111. * @nsegs: size of @segnumv array
  112. * @create: creation flag
  113. * @ndone: place to store number of modified segments on @segnumv
  114. * @dofunc: primitive operation for the update
  115. *
  116. * Description: nilfs_sufile_updatev() repeatedly calls @dofunc
  117. * against the given array of segments. The @dofunc is called with
  118. * buffers of a header block and the sufile block in which the target
  119. * segment usage entry is contained. If @ndone is given, the number
  120. * of successfully modified segments from the head is stored in the
  121. * place @ndone points to.
  122. *
  123. * Return Value: On success, zero is returned. On error, one of the
  124. * following negative error codes is returned.
  125. *
  126. * %-EIO - I/O error.
  127. *
  128. * %-ENOMEM - Insufficient amount of memory available.
  129. *
  130. * %-ENOENT - Given segment usage is in hole block (may be returned if
  131. * @create is zero)
  132. *
  133. * %-EINVAL - Invalid segment usage number
  134. */
  135. int nilfs_sufile_updatev(struct inode *sufile, __u64 *segnumv, size_t nsegs,
  136. int create, size_t *ndone,
  137. void (*dofunc)(struct inode *, __u64,
  138. struct buffer_head *,
  139. struct buffer_head *))
  140. {
  141. struct buffer_head *header_bh, *bh;
  142. unsigned long blkoff, prev_blkoff;
  143. __u64 *seg;
  144. size_t nerr = 0, n = 0;
  145. int ret = 0;
  146. if (unlikely(nsegs == 0))
  147. goto out;
  148. down_write(&NILFS_MDT(sufile)->mi_sem);
  149. for (seg = segnumv; seg < segnumv + nsegs; seg++) {
  150. if (unlikely(*seg >= nilfs_sufile_get_nsegments(sufile))) {
  151. printk(KERN_WARNING
  152. "%s: invalid segment number: %llu\n", __func__,
  153. (unsigned long long)*seg);
  154. nerr++;
  155. }
  156. }
  157. if (nerr > 0) {
  158. ret = -EINVAL;
  159. goto out_sem;
  160. }
  161. ret = nilfs_sufile_get_header_block(sufile, &header_bh);
  162. if (ret < 0)
  163. goto out_sem;
  164. seg = segnumv;
  165. blkoff = nilfs_sufile_get_blkoff(sufile, *seg);
  166. ret = nilfs_mdt_get_block(sufile, blkoff, create, NULL, &bh);
  167. if (ret < 0)
  168. goto out_header;
  169. for (;;) {
  170. dofunc(sufile, *seg, header_bh, bh);
  171. if (++seg >= segnumv + nsegs)
  172. break;
  173. prev_blkoff = blkoff;
  174. blkoff = nilfs_sufile_get_blkoff(sufile, *seg);
  175. if (blkoff == prev_blkoff)
  176. continue;
  177. /* get different block */
  178. brelse(bh);
  179. ret = nilfs_mdt_get_block(sufile, blkoff, create, NULL, &bh);
  180. if (unlikely(ret < 0))
  181. goto out_header;
  182. }
  183. brelse(bh);
  184. out_header:
  185. n = seg - segnumv;
  186. brelse(header_bh);
  187. out_sem:
  188. up_write(&NILFS_MDT(sufile)->mi_sem);
  189. out:
  190. if (ndone)
  191. *ndone = n;
  192. return ret;
  193. }
  194. int nilfs_sufile_update(struct inode *sufile, __u64 segnum, int create,
  195. void (*dofunc)(struct inode *, __u64,
  196. struct buffer_head *,
  197. struct buffer_head *))
  198. {
  199. struct buffer_head *header_bh, *bh;
  200. int ret;
  201. if (unlikely(segnum >= nilfs_sufile_get_nsegments(sufile))) {
  202. printk(KERN_WARNING "%s: invalid segment number: %llu\n",
  203. __func__, (unsigned long long)segnum);
  204. return -EINVAL;
  205. }
  206. down_write(&NILFS_MDT(sufile)->mi_sem);
  207. ret = nilfs_sufile_get_header_block(sufile, &header_bh);
  208. if (ret < 0)
  209. goto out_sem;
  210. ret = nilfs_sufile_get_segment_usage_block(sufile, segnum, create, &bh);
  211. if (!ret) {
  212. dofunc(sufile, segnum, header_bh, bh);
  213. brelse(bh);
  214. }
  215. brelse(header_bh);
  216. out_sem:
  217. up_write(&NILFS_MDT(sufile)->mi_sem);
  218. return ret;
  219. }
  220. /**
  221. * nilfs_sufile_alloc - allocate a segment
  222. * @sufile: inode of segment usage file
  223. * @segnump: pointer to segment number
  224. *
  225. * Description: nilfs_sufile_alloc() allocates a clean segment.
  226. *
  227. * Return Value: On success, 0 is returned and the segment number of the
  228. * allocated segment is stored in the place pointed by @segnump. On error, one
  229. * of the following negative error codes is returned.
  230. *
  231. * %-EIO - I/O error.
  232. *
  233. * %-ENOMEM - Insufficient amount of memory available.
  234. *
  235. * %-ENOSPC - No clean segment left.
  236. */
  237. int nilfs_sufile_alloc(struct inode *sufile, __u64 *segnump)
  238. {
  239. struct buffer_head *header_bh, *su_bh;
  240. struct nilfs_sufile_header *header;
  241. struct nilfs_segment_usage *su;
  242. size_t susz = NILFS_MDT(sufile)->mi_entry_size;
  243. __u64 segnum, maxsegnum, last_alloc;
  244. void *kaddr;
  245. unsigned long nsegments, ncleansegs, nsus;
  246. int ret, i, j;
  247. down_write(&NILFS_MDT(sufile)->mi_sem);
  248. ret = nilfs_sufile_get_header_block(sufile, &header_bh);
  249. if (ret < 0)
  250. goto out_sem;
  251. kaddr = kmap_atomic(header_bh->b_page, KM_USER0);
  252. header = kaddr + bh_offset(header_bh);
  253. ncleansegs = le64_to_cpu(header->sh_ncleansegs);
  254. last_alloc = le64_to_cpu(header->sh_last_alloc);
  255. kunmap_atomic(kaddr, KM_USER0);
  256. nsegments = nilfs_sufile_get_nsegments(sufile);
  257. segnum = last_alloc + 1;
  258. maxsegnum = nsegments - 1;
  259. for (i = 0; i < nsegments; i += nsus) {
  260. if (segnum >= nsegments) {
  261. /* wrap around */
  262. segnum = 0;
  263. maxsegnum = last_alloc;
  264. }
  265. ret = nilfs_sufile_get_segment_usage_block(sufile, segnum, 1,
  266. &su_bh);
  267. if (ret < 0)
  268. goto out_header;
  269. kaddr = kmap_atomic(su_bh->b_page, KM_USER0);
  270. su = nilfs_sufile_block_get_segment_usage(
  271. sufile, segnum, su_bh, kaddr);
  272. nsus = nilfs_sufile_segment_usages_in_block(
  273. sufile, segnum, maxsegnum);
  274. for (j = 0; j < nsus; j++, su = (void *)su + susz, segnum++) {
  275. if (!nilfs_segment_usage_clean(su))
  276. continue;
  277. /* found a clean segment */
  278. nilfs_segment_usage_set_dirty(su);
  279. kunmap_atomic(kaddr, KM_USER0);
  280. kaddr = kmap_atomic(header_bh->b_page, KM_USER0);
  281. header = kaddr + bh_offset(header_bh);
  282. le64_add_cpu(&header->sh_ncleansegs, -1);
  283. le64_add_cpu(&header->sh_ndirtysegs, 1);
  284. header->sh_last_alloc = cpu_to_le64(segnum);
  285. kunmap_atomic(kaddr, KM_USER0);
  286. NILFS_SUI(sufile)->ncleansegs--;
  287. nilfs_mdt_mark_buffer_dirty(header_bh);
  288. nilfs_mdt_mark_buffer_dirty(su_bh);
  289. nilfs_mdt_mark_dirty(sufile);
  290. brelse(su_bh);
  291. *segnump = segnum;
  292. goto out_header;
  293. }
  294. kunmap_atomic(kaddr, KM_USER0);
  295. brelse(su_bh);
  296. }
  297. /* no segments left */
  298. ret = -ENOSPC;
  299. out_header:
  300. brelse(header_bh);
  301. out_sem:
  302. up_write(&NILFS_MDT(sufile)->mi_sem);
  303. return ret;
  304. }
  305. void nilfs_sufile_do_cancel_free(struct inode *sufile, __u64 segnum,
  306. struct buffer_head *header_bh,
  307. struct buffer_head *su_bh)
  308. {
  309. struct nilfs_segment_usage *su;
  310. void *kaddr;
  311. kaddr = kmap_atomic(su_bh->b_page, KM_USER0);
  312. su = nilfs_sufile_block_get_segment_usage(sufile, segnum, su_bh, kaddr);
  313. if (unlikely(!nilfs_segment_usage_clean(su))) {
  314. printk(KERN_WARNING "%s: segment %llu must be clean\n",
  315. __func__, (unsigned long long)segnum);
  316. kunmap_atomic(kaddr, KM_USER0);
  317. return;
  318. }
  319. nilfs_segment_usage_set_dirty(su);
  320. kunmap_atomic(kaddr, KM_USER0);
  321. nilfs_sufile_mod_counter(header_bh, -1, 1);
  322. NILFS_SUI(sufile)->ncleansegs--;
  323. nilfs_mdt_mark_buffer_dirty(su_bh);
  324. nilfs_mdt_mark_dirty(sufile);
  325. }
  326. void nilfs_sufile_do_scrap(struct inode *sufile, __u64 segnum,
  327. struct buffer_head *header_bh,
  328. struct buffer_head *su_bh)
  329. {
  330. struct nilfs_segment_usage *su;
  331. void *kaddr;
  332. int clean, dirty;
  333. kaddr = kmap_atomic(su_bh->b_page, KM_USER0);
  334. su = nilfs_sufile_block_get_segment_usage(sufile, segnum, su_bh, kaddr);
  335. if (su->su_flags == cpu_to_le32(1UL << NILFS_SEGMENT_USAGE_DIRTY) &&
  336. su->su_nblocks == cpu_to_le32(0)) {
  337. kunmap_atomic(kaddr, KM_USER0);
  338. return;
  339. }
  340. clean = nilfs_segment_usage_clean(su);
  341. dirty = nilfs_segment_usage_dirty(su);
  342. /* make the segment garbage */
  343. su->su_lastmod = cpu_to_le64(0);
  344. su->su_nblocks = cpu_to_le32(0);
  345. su->su_flags = cpu_to_le32(1UL << NILFS_SEGMENT_USAGE_DIRTY);
  346. kunmap_atomic(kaddr, KM_USER0);
  347. nilfs_sufile_mod_counter(header_bh, clean ? (u64)-1 : 0, dirty ? 0 : 1);
  348. NILFS_SUI(sufile)->ncleansegs -= clean;
  349. nilfs_mdt_mark_buffer_dirty(su_bh);
  350. nilfs_mdt_mark_dirty(sufile);
  351. }
  352. void nilfs_sufile_do_free(struct inode *sufile, __u64 segnum,
  353. struct buffer_head *header_bh,
  354. struct buffer_head *su_bh)
  355. {
  356. struct nilfs_segment_usage *su;
  357. void *kaddr;
  358. int sudirty;
  359. kaddr = kmap_atomic(su_bh->b_page, KM_USER0);
  360. su = nilfs_sufile_block_get_segment_usage(sufile, segnum, su_bh, kaddr);
  361. if (nilfs_segment_usage_clean(su)) {
  362. printk(KERN_WARNING "%s: segment %llu is already clean\n",
  363. __func__, (unsigned long long)segnum);
  364. kunmap_atomic(kaddr, KM_USER0);
  365. return;
  366. }
  367. WARN_ON(nilfs_segment_usage_error(su));
  368. WARN_ON(!nilfs_segment_usage_dirty(su));
  369. sudirty = nilfs_segment_usage_dirty(su);
  370. nilfs_segment_usage_set_clean(su);
  371. kunmap_atomic(kaddr, KM_USER0);
  372. nilfs_mdt_mark_buffer_dirty(su_bh);
  373. nilfs_sufile_mod_counter(header_bh, 1, sudirty ? (u64)-1 : 0);
  374. NILFS_SUI(sufile)->ncleansegs++;
  375. nilfs_mdt_mark_dirty(sufile);
  376. }
  377. /**
  378. * nilfs_sufile_get_segment_usage - get a segment usage
  379. * @sufile: inode of segment usage file
  380. * @segnum: segment number
  381. * @sup: pointer to segment usage
  382. * @bhp: pointer to buffer head
  383. *
  384. * Description: nilfs_sufile_get_segment_usage() acquires the segment usage
  385. * specified by @segnum.
  386. *
  387. * Return Value: On success, 0 is returned, and the segment usage and the
  388. * buffer head of the buffer on which the segment usage is located are stored
  389. * in the place pointed by @sup and @bhp, respectively. On error, one of the
  390. * following negative error codes is returned.
  391. *
  392. * %-EIO - I/O error.
  393. *
  394. * %-ENOMEM - Insufficient amount of memory available.
  395. *
  396. * %-EINVAL - Invalid segment usage number.
  397. */
  398. int nilfs_sufile_get_segment_usage(struct inode *sufile, __u64 segnum,
  399. struct nilfs_segment_usage **sup,
  400. struct buffer_head **bhp)
  401. {
  402. struct buffer_head *bh;
  403. struct nilfs_segment_usage *su;
  404. void *kaddr;
  405. int ret;
  406. /* segnum is 0 origin */
  407. if (segnum >= nilfs_sufile_get_nsegments(sufile))
  408. return -EINVAL;
  409. down_write(&NILFS_MDT(sufile)->mi_sem);
  410. ret = nilfs_sufile_get_segment_usage_block(sufile, segnum, 1, &bh);
  411. if (ret < 0)
  412. goto out_sem;
  413. kaddr = kmap(bh->b_page);
  414. su = nilfs_sufile_block_get_segment_usage(sufile, segnum, bh, kaddr);
  415. if (nilfs_segment_usage_error(su)) {
  416. kunmap(bh->b_page);
  417. brelse(bh);
  418. ret = -EINVAL;
  419. goto out_sem;
  420. }
  421. if (sup != NULL)
  422. *sup = su;
  423. *bhp = bh;
  424. out_sem:
  425. up_write(&NILFS_MDT(sufile)->mi_sem);
  426. return ret;
  427. }
  428. /**
  429. * nilfs_sufile_put_segment_usage - put a segment usage
  430. * @sufile: inode of segment usage file
  431. * @segnum: segment number
  432. * @bh: buffer head
  433. *
  434. * Description: nilfs_sufile_put_segment_usage() releases the segment usage
  435. * specified by @segnum. @bh must be the buffer head which have been returned
  436. * by a previous call to nilfs_sufile_get_segment_usage() with @segnum.
  437. */
  438. void nilfs_sufile_put_segment_usage(struct inode *sufile, __u64 segnum,
  439. struct buffer_head *bh)
  440. {
  441. kunmap(bh->b_page);
  442. brelse(bh);
  443. }
  444. /**
  445. * nilfs_sufile_mark_dirty - mark the buffer having a segment usage dirty
  446. * @sufile: inode of segment usage file
  447. * @segnum: segment number
  448. */
  449. int nilfs_sufile_mark_dirty(struct inode *sufile, __u64 segnum)
  450. {
  451. struct buffer_head *bh;
  452. int ret;
  453. ret = nilfs_sufile_get_segment_usage_block(sufile, segnum, 0, &bh);
  454. if (!ret) {
  455. nilfs_mdt_mark_buffer_dirty(bh);
  456. nilfs_mdt_mark_dirty(sufile);
  457. brelse(bh);
  458. }
  459. return ret;
  460. }
  461. /**
  462. * nilfs_sufile_set_segment_usage - set usage of a segment
  463. * @sufile: inode of segment usage file
  464. * @segnum: segment number
  465. * @nblocks: number of live blocks in the segment
  466. * @modtime: modification time (option)
  467. */
  468. int nilfs_sufile_set_segment_usage(struct inode *sufile, __u64 segnum,
  469. unsigned long nblocks, time_t modtime)
  470. {
  471. struct buffer_head *bh;
  472. struct nilfs_segment_usage *su;
  473. void *kaddr;
  474. int ret;
  475. down_write(&NILFS_MDT(sufile)->mi_sem);
  476. ret = nilfs_sufile_get_segment_usage_block(sufile, segnum, 0, &bh);
  477. if (ret < 0)
  478. goto out_sem;
  479. kaddr = kmap_atomic(bh->b_page, KM_USER0);
  480. su = nilfs_sufile_block_get_segment_usage(sufile, segnum, bh, kaddr);
  481. WARN_ON(nilfs_segment_usage_error(su));
  482. if (modtime)
  483. su->su_lastmod = cpu_to_le64(modtime);
  484. su->su_nblocks = cpu_to_le32(nblocks);
  485. kunmap_atomic(kaddr, KM_USER0);
  486. nilfs_mdt_mark_buffer_dirty(bh);
  487. nilfs_mdt_mark_dirty(sufile);
  488. brelse(bh);
  489. out_sem:
  490. up_write(&NILFS_MDT(sufile)->mi_sem);
  491. return ret;
  492. }
  493. /**
  494. * nilfs_sufile_get_stat - get segment usage statistics
  495. * @sufile: inode of segment usage file
  496. * @stat: pointer to a structure of segment usage statistics
  497. *
  498. * Description: nilfs_sufile_get_stat() returns information about segment
  499. * usage.
  500. *
  501. * Return Value: On success, 0 is returned, and segment usage information is
  502. * stored in the place pointed by @stat. On error, one of the following
  503. * negative error codes is returned.
  504. *
  505. * %-EIO - I/O error.
  506. *
  507. * %-ENOMEM - Insufficient amount of memory available.
  508. */
  509. int nilfs_sufile_get_stat(struct inode *sufile, struct nilfs_sustat *sustat)
  510. {
  511. struct buffer_head *header_bh;
  512. struct nilfs_sufile_header *header;
  513. struct the_nilfs *nilfs = NILFS_MDT(sufile)->mi_nilfs;
  514. void *kaddr;
  515. int ret;
  516. down_read(&NILFS_MDT(sufile)->mi_sem);
  517. ret = nilfs_sufile_get_header_block(sufile, &header_bh);
  518. if (ret < 0)
  519. goto out_sem;
  520. kaddr = kmap_atomic(header_bh->b_page, KM_USER0);
  521. header = kaddr + bh_offset(header_bh);
  522. sustat->ss_nsegs = nilfs_sufile_get_nsegments(sufile);
  523. sustat->ss_ncleansegs = le64_to_cpu(header->sh_ncleansegs);
  524. sustat->ss_ndirtysegs = le64_to_cpu(header->sh_ndirtysegs);
  525. sustat->ss_ctime = nilfs->ns_ctime;
  526. sustat->ss_nongc_ctime = nilfs->ns_nongc_ctime;
  527. spin_lock(&nilfs->ns_last_segment_lock);
  528. sustat->ss_prot_seq = nilfs->ns_prot_seq;
  529. spin_unlock(&nilfs->ns_last_segment_lock);
  530. kunmap_atomic(kaddr, KM_USER0);
  531. brelse(header_bh);
  532. out_sem:
  533. up_read(&NILFS_MDT(sufile)->mi_sem);
  534. return ret;
  535. }
  536. void nilfs_sufile_do_set_error(struct inode *sufile, __u64 segnum,
  537. struct buffer_head *header_bh,
  538. struct buffer_head *su_bh)
  539. {
  540. struct nilfs_segment_usage *su;
  541. void *kaddr;
  542. int suclean;
  543. kaddr = kmap_atomic(su_bh->b_page, KM_USER0);
  544. su = nilfs_sufile_block_get_segment_usage(sufile, segnum, su_bh, kaddr);
  545. if (nilfs_segment_usage_error(su)) {
  546. kunmap_atomic(kaddr, KM_USER0);
  547. return;
  548. }
  549. suclean = nilfs_segment_usage_clean(su);
  550. nilfs_segment_usage_set_error(su);
  551. kunmap_atomic(kaddr, KM_USER0);
  552. if (suclean) {
  553. nilfs_sufile_mod_counter(header_bh, -1, 0);
  554. NILFS_SUI(sufile)->ncleansegs--;
  555. }
  556. nilfs_mdt_mark_buffer_dirty(su_bh);
  557. nilfs_mdt_mark_dirty(sufile);
  558. }
  559. /**
  560. * nilfs_sufile_get_suinfo -
  561. * @sufile: inode of segment usage file
  562. * @segnum: segment number to start looking
  563. * @buf: array of suinfo
  564. * @sisz: byte size of suinfo
  565. * @nsi: size of suinfo array
  566. *
  567. * Description:
  568. *
  569. * Return Value: On success, 0 is returned and .... On error, one of the
  570. * following negative error codes is returned.
  571. *
  572. * %-EIO - I/O error.
  573. *
  574. * %-ENOMEM - Insufficient amount of memory available.
  575. */
  576. ssize_t nilfs_sufile_get_suinfo(struct inode *sufile, __u64 segnum, void *buf,
  577. unsigned sisz, size_t nsi)
  578. {
  579. struct buffer_head *su_bh;
  580. struct nilfs_segment_usage *su;
  581. struct nilfs_suinfo *si = buf;
  582. size_t susz = NILFS_MDT(sufile)->mi_entry_size;
  583. struct the_nilfs *nilfs = NILFS_MDT(sufile)->mi_nilfs;
  584. void *kaddr;
  585. unsigned long nsegs, segusages_per_block;
  586. ssize_t n;
  587. int ret, i, j;
  588. down_read(&NILFS_MDT(sufile)->mi_sem);
  589. segusages_per_block = nilfs_sufile_segment_usages_per_block(sufile);
  590. nsegs = min_t(unsigned long,
  591. nilfs_sufile_get_nsegments(sufile) - segnum,
  592. nsi);
  593. for (i = 0; i < nsegs; i += n, segnum += n) {
  594. n = min_t(unsigned long,
  595. segusages_per_block -
  596. nilfs_sufile_get_offset(sufile, segnum),
  597. nsegs - i);
  598. ret = nilfs_sufile_get_segment_usage_block(sufile, segnum, 0,
  599. &su_bh);
  600. if (ret < 0) {
  601. if (ret != -ENOENT)
  602. goto out;
  603. /* hole */
  604. memset(si, 0, sisz * n);
  605. si = (void *)si + sisz * n;
  606. continue;
  607. }
  608. kaddr = kmap_atomic(su_bh->b_page, KM_USER0);
  609. su = nilfs_sufile_block_get_segment_usage(
  610. sufile, segnum, su_bh, kaddr);
  611. for (j = 0; j < n;
  612. j++, su = (void *)su + susz, si = (void *)si + sisz) {
  613. si->sui_lastmod = le64_to_cpu(su->su_lastmod);
  614. si->sui_nblocks = le32_to_cpu(su->su_nblocks);
  615. si->sui_flags = le32_to_cpu(su->su_flags) &
  616. ~(1UL << NILFS_SEGMENT_USAGE_ACTIVE);
  617. if (nilfs_segment_is_active(nilfs, segnum + j))
  618. si->sui_flags |=
  619. (1UL << NILFS_SEGMENT_USAGE_ACTIVE);
  620. }
  621. kunmap_atomic(kaddr, KM_USER0);
  622. brelse(su_bh);
  623. }
  624. ret = nsegs;
  625. out:
  626. up_read(&NILFS_MDT(sufile)->mi_sem);
  627. return ret;
  628. }
  629. /**
  630. * nilfs_sufile_read - read sufile inode
  631. * @sufile: sufile inode
  632. * @raw_inode: on-disk sufile inode
  633. */
  634. int nilfs_sufile_read(struct inode *sufile, struct nilfs_inode *raw_inode)
  635. {
  636. struct nilfs_sufile_info *sui = NILFS_SUI(sufile);
  637. struct buffer_head *header_bh;
  638. struct nilfs_sufile_header *header;
  639. void *kaddr;
  640. int ret;
  641. ret = nilfs_read_inode_common(sufile, raw_inode);
  642. if (ret < 0)
  643. return ret;
  644. ret = nilfs_sufile_get_header_block(sufile, &header_bh);
  645. if (!ret) {
  646. kaddr = kmap_atomic(header_bh->b_page, KM_USER0);
  647. header = kaddr + bh_offset(header_bh);
  648. sui->ncleansegs = le64_to_cpu(header->sh_ncleansegs);
  649. kunmap_atomic(kaddr, KM_USER0);
  650. brelse(header_bh);
  651. }
  652. return ret;
  653. }
  654. /**
  655. * nilfs_sufile_new - create sufile
  656. * @nilfs: nilfs object
  657. * @susize: size of a segment usage entry
  658. */
  659. struct inode *nilfs_sufile_new(struct the_nilfs *nilfs, size_t susize)
  660. {
  661. struct inode *sufile;
  662. sufile = nilfs_mdt_new(nilfs, NULL, NILFS_SUFILE_INO,
  663. sizeof(struct nilfs_sufile_info));
  664. if (sufile)
  665. nilfs_mdt_set_entry_size(sufile, susize,
  666. sizeof(struct nilfs_sufile_header));
  667. return sufile;
  668. }