xfs_itable.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706
  1. /*
  2. * Copyright (c) 2000-2002,2005 Silicon Graphics, Inc.
  3. * All Rights Reserved.
  4. *
  5. * This program is free software; you can redistribute it and/or
  6. * modify it under the terms of the GNU General Public License as
  7. * published by the Free Software Foundation.
  8. *
  9. * This program is distributed in the hope that it would be useful,
  10. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. * GNU General Public License for more details.
  13. *
  14. * You should have received a copy of the GNU General Public License
  15. * along with this program; if not, write the Free Software Foundation,
  16. * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  17. */
  18. #include "xfs.h"
  19. #include "xfs_fs.h"
  20. #include "xfs_shared.h"
  21. #include "xfs_format.h"
  22. #include "xfs_log_format.h"
  23. #include "xfs_trans_resv.h"
  24. #include "xfs_inum.h"
  25. #include "xfs_sb.h"
  26. #include "xfs_ag.h"
  27. #include "xfs_mount.h"
  28. #include "xfs_inode.h"
  29. #include "xfs_btree.h"
  30. #include "xfs_ialloc.h"
  31. #include "xfs_ialloc_btree.h"
  32. #include "xfs_itable.h"
  33. #include "xfs_error.h"
  34. #include "xfs_trace.h"
  35. #include "xfs_icache.h"
  36. #include "xfs_dinode.h"
  37. STATIC int
  38. xfs_internal_inum(
  39. xfs_mount_t *mp,
  40. xfs_ino_t ino)
  41. {
  42. return (ino == mp->m_sb.sb_rbmino || ino == mp->m_sb.sb_rsumino ||
  43. (xfs_sb_version_hasquota(&mp->m_sb) &&
  44. xfs_is_quota_inode(&mp->m_sb, ino)));
  45. }
  46. /*
  47. * Return stat information for one inode.
  48. * Return 0 if ok, else errno.
  49. */
  50. int
  51. xfs_bulkstat_one_int(
  52. struct xfs_mount *mp, /* mount point for filesystem */
  53. xfs_ino_t ino, /* inode to get data for */
  54. void __user *buffer, /* buffer to place output in */
  55. int ubsize, /* size of buffer */
  56. bulkstat_one_fmt_pf formatter, /* formatter, copy to user */
  57. int *ubused, /* bytes used by me */
  58. int *stat) /* BULKSTAT_RV_... */
  59. {
  60. struct xfs_icdinode *dic; /* dinode core info pointer */
  61. struct xfs_inode *ip; /* incore inode pointer */
  62. struct xfs_bstat *buf; /* return buffer */
  63. int error = 0; /* error value */
  64. *stat = BULKSTAT_RV_NOTHING;
  65. if (!buffer || xfs_internal_inum(mp, ino))
  66. return XFS_ERROR(EINVAL);
  67. buf = kmem_alloc(sizeof(*buf), KM_SLEEP | KM_MAYFAIL);
  68. if (!buf)
  69. return XFS_ERROR(ENOMEM);
  70. error = xfs_iget(mp, NULL, ino,
  71. (XFS_IGET_DONTCACHE | XFS_IGET_UNTRUSTED),
  72. XFS_ILOCK_SHARED, &ip);
  73. if (error) {
  74. *stat = BULKSTAT_RV_NOTHING;
  75. goto out_free;
  76. }
  77. ASSERT(ip != NULL);
  78. ASSERT(ip->i_imap.im_blkno != 0);
  79. dic = &ip->i_d;
  80. /* xfs_iget returns the following without needing
  81. * further change.
  82. */
  83. buf->bs_nlink = dic->di_nlink;
  84. buf->bs_projid_lo = dic->di_projid_lo;
  85. buf->bs_projid_hi = dic->di_projid_hi;
  86. buf->bs_ino = ino;
  87. buf->bs_mode = dic->di_mode;
  88. buf->bs_uid = dic->di_uid;
  89. buf->bs_gid = dic->di_gid;
  90. buf->bs_size = dic->di_size;
  91. buf->bs_atime.tv_sec = dic->di_atime.t_sec;
  92. buf->bs_atime.tv_nsec = dic->di_atime.t_nsec;
  93. buf->bs_mtime.tv_sec = dic->di_mtime.t_sec;
  94. buf->bs_mtime.tv_nsec = dic->di_mtime.t_nsec;
  95. buf->bs_ctime.tv_sec = dic->di_ctime.t_sec;
  96. buf->bs_ctime.tv_nsec = dic->di_ctime.t_nsec;
  97. buf->bs_xflags = xfs_ip2xflags(ip);
  98. buf->bs_extsize = dic->di_extsize << mp->m_sb.sb_blocklog;
  99. buf->bs_extents = dic->di_nextents;
  100. buf->bs_gen = dic->di_gen;
  101. memset(buf->bs_pad, 0, sizeof(buf->bs_pad));
  102. buf->bs_dmevmask = dic->di_dmevmask;
  103. buf->bs_dmstate = dic->di_dmstate;
  104. buf->bs_aextents = dic->di_anextents;
  105. buf->bs_forkoff = XFS_IFORK_BOFF(ip);
  106. switch (dic->di_format) {
  107. case XFS_DINODE_FMT_DEV:
  108. buf->bs_rdev = ip->i_df.if_u2.if_rdev;
  109. buf->bs_blksize = BLKDEV_IOSIZE;
  110. buf->bs_blocks = 0;
  111. break;
  112. case XFS_DINODE_FMT_LOCAL:
  113. case XFS_DINODE_FMT_UUID:
  114. buf->bs_rdev = 0;
  115. buf->bs_blksize = mp->m_sb.sb_blocksize;
  116. buf->bs_blocks = 0;
  117. break;
  118. case XFS_DINODE_FMT_EXTENTS:
  119. case XFS_DINODE_FMT_BTREE:
  120. buf->bs_rdev = 0;
  121. buf->bs_blksize = mp->m_sb.sb_blocksize;
  122. buf->bs_blocks = dic->di_nblocks + ip->i_delayed_blks;
  123. break;
  124. }
  125. xfs_iunlock(ip, XFS_ILOCK_SHARED);
  126. IRELE(ip);
  127. error = formatter(buffer, ubsize, ubused, buf);
  128. if (!error)
  129. *stat = BULKSTAT_RV_DIDONE;
  130. out_free:
  131. kmem_free(buf);
  132. return error;
  133. }
  134. /* Return 0 on success or positive error */
  135. STATIC int
  136. xfs_bulkstat_one_fmt(
  137. void __user *ubuffer,
  138. int ubsize,
  139. int *ubused,
  140. const xfs_bstat_t *buffer)
  141. {
  142. if (ubsize < sizeof(*buffer))
  143. return XFS_ERROR(ENOMEM);
  144. if (copy_to_user(ubuffer, buffer, sizeof(*buffer)))
  145. return XFS_ERROR(EFAULT);
  146. if (ubused)
  147. *ubused = sizeof(*buffer);
  148. return 0;
  149. }
  150. int
  151. xfs_bulkstat_one(
  152. xfs_mount_t *mp, /* mount point for filesystem */
  153. xfs_ino_t ino, /* inode number to get data for */
  154. void __user *buffer, /* buffer to place output in */
  155. int ubsize, /* size of buffer */
  156. int *ubused, /* bytes used by me */
  157. int *stat) /* BULKSTAT_RV_... */
  158. {
  159. return xfs_bulkstat_one_int(mp, ino, buffer, ubsize,
  160. xfs_bulkstat_one_fmt, ubused, stat);
  161. }
  162. #define XFS_BULKSTAT_UBLEFT(ubleft) ((ubleft) >= statstruct_size)
  163. /*
  164. * Return stat information in bulk (by-inode) for the filesystem.
  165. */
  166. int /* error status */
  167. xfs_bulkstat(
  168. xfs_mount_t *mp, /* mount point for filesystem */
  169. xfs_ino_t *lastinop, /* last inode returned */
  170. int *ubcountp, /* size of buffer/count returned */
  171. bulkstat_one_pf formatter, /* func that'd fill a single buf */
  172. size_t statstruct_size, /* sizeof struct filling */
  173. char __user *ubuffer, /* buffer with inode stats */
  174. int *done) /* 1 if there are more stats to get */
  175. {
  176. xfs_agblock_t agbno=0;/* allocation group block number */
  177. xfs_buf_t *agbp; /* agi header buffer */
  178. xfs_agi_t *agi; /* agi header data */
  179. xfs_agino_t agino; /* inode # in allocation group */
  180. xfs_agnumber_t agno; /* allocation group number */
  181. int chunkidx; /* current index into inode chunk */
  182. int clustidx; /* current index into inode cluster */
  183. xfs_btree_cur_t *cur; /* btree cursor for ialloc btree */
  184. int end_of_ag; /* set if we've seen the ag end */
  185. int error; /* error code */
  186. int fmterror;/* bulkstat formatter result */
  187. int i; /* loop index */
  188. int icount; /* count of inodes good in irbuf */
  189. size_t irbsize; /* size of irec buffer in bytes */
  190. xfs_ino_t ino; /* inode number (filesystem) */
  191. xfs_inobt_rec_incore_t *irbp; /* current irec buffer pointer */
  192. xfs_inobt_rec_incore_t *irbuf; /* start of irec buffer */
  193. xfs_inobt_rec_incore_t *irbufend; /* end of good irec buffer entries */
  194. xfs_ino_t lastino; /* last inode number returned */
  195. int nbcluster; /* # of blocks in a cluster */
  196. int nicluster; /* # of inodes in a cluster */
  197. int nimask; /* mask for inode clusters */
  198. int nirbuf; /* size of irbuf */
  199. int rval; /* return value error code */
  200. int tmp; /* result value from btree calls */
  201. int ubcount; /* size of user's buffer */
  202. int ubleft; /* bytes left in user's buffer */
  203. char __user *ubufp; /* pointer into user's buffer */
  204. int ubelem; /* spaces used in user's buffer */
  205. int ubused; /* bytes used by formatter */
  206. /*
  207. * Get the last inode value, see if there's nothing to do.
  208. */
  209. ino = (xfs_ino_t)*lastinop;
  210. lastino = ino;
  211. agno = XFS_INO_TO_AGNO(mp, ino);
  212. agino = XFS_INO_TO_AGINO(mp, ino);
  213. if (agno >= mp->m_sb.sb_agcount ||
  214. ino != XFS_AGINO_TO_INO(mp, agno, agino)) {
  215. *done = 1;
  216. *ubcountp = 0;
  217. return 0;
  218. }
  219. if (!ubcountp || *ubcountp <= 0) {
  220. return EINVAL;
  221. }
  222. ubcount = *ubcountp; /* statstruct's */
  223. ubleft = ubcount * statstruct_size; /* bytes */
  224. *ubcountp = ubelem = 0;
  225. *done = 0;
  226. fmterror = 0;
  227. ubufp = ubuffer;
  228. nicluster = mp->m_sb.sb_blocksize >= XFS_INODE_CLUSTER_SIZE(mp) ?
  229. mp->m_sb.sb_inopblock :
  230. (XFS_INODE_CLUSTER_SIZE(mp) >> mp->m_sb.sb_inodelog);
  231. nimask = ~(nicluster - 1);
  232. nbcluster = nicluster >> mp->m_sb.sb_inopblog;
  233. irbuf = kmem_zalloc_greedy(&irbsize, PAGE_SIZE, PAGE_SIZE * 4);
  234. if (!irbuf)
  235. return ENOMEM;
  236. nirbuf = irbsize / sizeof(*irbuf);
  237. /*
  238. * Loop over the allocation groups, starting from the last
  239. * inode returned; 0 means start of the allocation group.
  240. */
  241. rval = 0;
  242. while (XFS_BULKSTAT_UBLEFT(ubleft) && agno < mp->m_sb.sb_agcount) {
  243. cond_resched();
  244. error = xfs_ialloc_read_agi(mp, NULL, agno, &agbp);
  245. if (error) {
  246. /*
  247. * Skip this allocation group and go to the next one.
  248. */
  249. agno++;
  250. agino = 0;
  251. continue;
  252. }
  253. agi = XFS_BUF_TO_AGI(agbp);
  254. /*
  255. * Allocate and initialize a btree cursor for ialloc btree.
  256. */
  257. cur = xfs_inobt_init_cursor(mp, NULL, agbp, agno);
  258. irbp = irbuf;
  259. irbufend = irbuf + nirbuf;
  260. end_of_ag = 0;
  261. /*
  262. * If we're returning in the middle of an allocation group,
  263. * we need to get the remainder of the chunk we're in.
  264. */
  265. if (agino > 0) {
  266. xfs_inobt_rec_incore_t r;
  267. /*
  268. * Lookup the inode chunk that this inode lives in.
  269. */
  270. error = xfs_inobt_lookup(cur, agino, XFS_LOOKUP_LE,
  271. &tmp);
  272. if (!error && /* no I/O error */
  273. tmp && /* lookup succeeded */
  274. /* got the record, should always work */
  275. !(error = xfs_inobt_get_rec(cur, &r, &i)) &&
  276. i == 1 &&
  277. /* this is the right chunk */
  278. agino < r.ir_startino + XFS_INODES_PER_CHUNK &&
  279. /* lastino was not last in chunk */
  280. (chunkidx = agino - r.ir_startino + 1) <
  281. XFS_INODES_PER_CHUNK &&
  282. /* there are some left allocated */
  283. xfs_inobt_maskn(chunkidx,
  284. XFS_INODES_PER_CHUNK - chunkidx) &
  285. ~r.ir_free) {
  286. /*
  287. * Grab the chunk record. Mark all the
  288. * uninteresting inodes (because they're
  289. * before our start point) free.
  290. */
  291. for (i = 0; i < chunkidx; i++) {
  292. if (XFS_INOBT_MASK(i) & ~r.ir_free)
  293. r.ir_freecount++;
  294. }
  295. r.ir_free |= xfs_inobt_maskn(0, chunkidx);
  296. irbp->ir_startino = r.ir_startino;
  297. irbp->ir_freecount = r.ir_freecount;
  298. irbp->ir_free = r.ir_free;
  299. irbp++;
  300. agino = r.ir_startino + XFS_INODES_PER_CHUNK;
  301. icount = XFS_INODES_PER_CHUNK - r.ir_freecount;
  302. } else {
  303. /*
  304. * If any of those tests failed, bump the
  305. * inode number (just in case).
  306. */
  307. agino++;
  308. icount = 0;
  309. }
  310. /*
  311. * In any case, increment to the next record.
  312. */
  313. if (!error)
  314. error = xfs_btree_increment(cur, 0, &tmp);
  315. } else {
  316. /*
  317. * Start of ag. Lookup the first inode chunk.
  318. */
  319. error = xfs_inobt_lookup(cur, 0, XFS_LOOKUP_GE, &tmp);
  320. icount = 0;
  321. }
  322. /*
  323. * Loop through inode btree records in this ag,
  324. * until we run out of inodes or space in the buffer.
  325. */
  326. while (irbp < irbufend && icount < ubcount) {
  327. xfs_inobt_rec_incore_t r;
  328. /*
  329. * Loop as long as we're unable to read the
  330. * inode btree.
  331. */
  332. while (error) {
  333. agino += XFS_INODES_PER_CHUNK;
  334. if (XFS_AGINO_TO_AGBNO(mp, agino) >=
  335. be32_to_cpu(agi->agi_length))
  336. break;
  337. error = xfs_inobt_lookup(cur, agino,
  338. XFS_LOOKUP_GE, &tmp);
  339. cond_resched();
  340. }
  341. /*
  342. * If ran off the end of the ag either with an error,
  343. * or the normal way, set end and stop collecting.
  344. */
  345. if (error) {
  346. end_of_ag = 1;
  347. break;
  348. }
  349. error = xfs_inobt_get_rec(cur, &r, &i);
  350. if (error || i == 0) {
  351. end_of_ag = 1;
  352. break;
  353. }
  354. /*
  355. * If this chunk has any allocated inodes, save it.
  356. * Also start read-ahead now for this chunk.
  357. */
  358. if (r.ir_freecount < XFS_INODES_PER_CHUNK) {
  359. struct blk_plug plug;
  360. /*
  361. * Loop over all clusters in the next chunk.
  362. * Do a readahead if there are any allocated
  363. * inodes in that cluster.
  364. */
  365. blk_start_plug(&plug);
  366. agbno = XFS_AGINO_TO_AGBNO(mp, r.ir_startino);
  367. for (chunkidx = 0;
  368. chunkidx < XFS_INODES_PER_CHUNK;
  369. chunkidx += nicluster,
  370. agbno += nbcluster) {
  371. if (xfs_inobt_maskn(chunkidx, nicluster)
  372. & ~r.ir_free)
  373. xfs_btree_reada_bufs(mp, agno,
  374. agbno, nbcluster,
  375. &xfs_inode_buf_ops);
  376. }
  377. blk_finish_plug(&plug);
  378. irbp->ir_startino = r.ir_startino;
  379. irbp->ir_freecount = r.ir_freecount;
  380. irbp->ir_free = r.ir_free;
  381. irbp++;
  382. icount += XFS_INODES_PER_CHUNK - r.ir_freecount;
  383. }
  384. /*
  385. * Set agino to after this chunk and bump the cursor.
  386. */
  387. agino = r.ir_startino + XFS_INODES_PER_CHUNK;
  388. error = xfs_btree_increment(cur, 0, &tmp);
  389. cond_resched();
  390. }
  391. /*
  392. * Drop the btree buffers and the agi buffer.
  393. * We can't hold any of the locks these represent
  394. * when calling iget.
  395. */
  396. xfs_btree_del_cursor(cur, XFS_BTREE_NOERROR);
  397. xfs_buf_relse(agbp);
  398. /*
  399. * Now format all the good inodes into the user's buffer.
  400. */
  401. irbufend = irbp;
  402. for (irbp = irbuf;
  403. irbp < irbufend && XFS_BULKSTAT_UBLEFT(ubleft); irbp++) {
  404. /*
  405. * Now process this chunk of inodes.
  406. */
  407. for (agino = irbp->ir_startino, chunkidx = clustidx = 0;
  408. XFS_BULKSTAT_UBLEFT(ubleft) &&
  409. irbp->ir_freecount < XFS_INODES_PER_CHUNK;
  410. chunkidx++, clustidx++, agino++) {
  411. ASSERT(chunkidx < XFS_INODES_PER_CHUNK);
  412. ino = XFS_AGINO_TO_INO(mp, agno, agino);
  413. /*
  414. * Skip if this inode is free.
  415. */
  416. if (XFS_INOBT_MASK(chunkidx) & irbp->ir_free) {
  417. lastino = ino;
  418. continue;
  419. }
  420. /*
  421. * Count used inodes as free so we can tell
  422. * when the chunk is used up.
  423. */
  424. irbp->ir_freecount++;
  425. /*
  426. * Get the inode and fill in a single buffer.
  427. */
  428. ubused = statstruct_size;
  429. error = formatter(mp, ino, ubufp, ubleft,
  430. &ubused, &fmterror);
  431. if (fmterror == BULKSTAT_RV_NOTHING) {
  432. if (error && error != ENOENT &&
  433. error != EINVAL) {
  434. ubleft = 0;
  435. rval = error;
  436. break;
  437. }
  438. lastino = ino;
  439. continue;
  440. }
  441. if (fmterror == BULKSTAT_RV_GIVEUP) {
  442. ubleft = 0;
  443. ASSERT(error);
  444. rval = error;
  445. break;
  446. }
  447. if (ubufp)
  448. ubufp += ubused;
  449. ubleft -= ubused;
  450. ubelem++;
  451. lastino = ino;
  452. }
  453. cond_resched();
  454. }
  455. /*
  456. * Set up for the next loop iteration.
  457. */
  458. if (XFS_BULKSTAT_UBLEFT(ubleft)) {
  459. if (end_of_ag) {
  460. agno++;
  461. agino = 0;
  462. } else
  463. agino = XFS_INO_TO_AGINO(mp, lastino);
  464. } else
  465. break;
  466. }
  467. /*
  468. * Done, we're either out of filesystem or space to put the data.
  469. */
  470. kmem_free(irbuf);
  471. *ubcountp = ubelem;
  472. /*
  473. * Found some inodes, return them now and return the error next time.
  474. */
  475. if (ubelem)
  476. rval = 0;
  477. if (agno >= mp->m_sb.sb_agcount) {
  478. /*
  479. * If we ran out of filesystem, mark lastino as off
  480. * the end of the filesystem, so the next call
  481. * will return immediately.
  482. */
  483. *lastinop = (xfs_ino_t)XFS_AGINO_TO_INO(mp, agno, 0);
  484. *done = 1;
  485. } else
  486. *lastinop = (xfs_ino_t)lastino;
  487. return rval;
  488. }
  489. /*
  490. * Return stat information in bulk (by-inode) for the filesystem.
  491. * Special case for non-sequential one inode bulkstat.
  492. */
  493. int /* error status */
  494. xfs_bulkstat_single(
  495. xfs_mount_t *mp, /* mount point for filesystem */
  496. xfs_ino_t *lastinop, /* inode to return */
  497. char __user *buffer, /* buffer with inode stats */
  498. int *done) /* 1 if there are more stats to get */
  499. {
  500. int count; /* count value for bulkstat call */
  501. int error; /* return value */
  502. xfs_ino_t ino; /* filesystem inode number */
  503. int res; /* result from bs1 */
  504. /*
  505. * note that requesting valid inode numbers which are not allocated
  506. * to inodes will most likely cause xfs_imap_to_bp to generate warning
  507. * messages about bad magic numbers. This is ok. The fact that
  508. * the inode isn't actually an inode is handled by the
  509. * error check below. Done this way to make the usual case faster
  510. * at the expense of the error case.
  511. */
  512. ino = *lastinop;
  513. error = xfs_bulkstat_one(mp, ino, buffer, sizeof(xfs_bstat_t),
  514. NULL, &res);
  515. if (error) {
  516. /*
  517. * Special case way failed, do it the "long" way
  518. * to see if that works.
  519. */
  520. (*lastinop)--;
  521. count = 1;
  522. if (xfs_bulkstat(mp, lastinop, &count, xfs_bulkstat_one,
  523. sizeof(xfs_bstat_t), buffer, done))
  524. return error;
  525. if (count == 0 || (xfs_ino_t)*lastinop != ino)
  526. return error == EFSCORRUPTED ?
  527. XFS_ERROR(EINVAL) : error;
  528. else
  529. return 0;
  530. }
  531. *done = 0;
  532. return 0;
  533. }
  534. int
  535. xfs_inumbers_fmt(
  536. void __user *ubuffer, /* buffer to write to */
  537. const xfs_inogrp_t *buffer, /* buffer to read from */
  538. long count, /* # of elements to read */
  539. long *written) /* # of bytes written */
  540. {
  541. if (copy_to_user(ubuffer, buffer, count * sizeof(*buffer)))
  542. return -EFAULT;
  543. *written = count * sizeof(*buffer);
  544. return 0;
  545. }
  546. /*
  547. * Return inode number table for the filesystem.
  548. */
  549. int /* error status */
  550. xfs_inumbers(
  551. xfs_mount_t *mp, /* mount point for filesystem */
  552. xfs_ino_t *lastino, /* last inode returned */
  553. int *count, /* size of buffer/count returned */
  554. void __user *ubuffer,/* buffer with inode descriptions */
  555. inumbers_fmt_pf formatter)
  556. {
  557. xfs_buf_t *agbp;
  558. xfs_agino_t agino;
  559. xfs_agnumber_t agno;
  560. int bcount;
  561. xfs_inogrp_t *buffer;
  562. int bufidx;
  563. xfs_btree_cur_t *cur;
  564. int error;
  565. xfs_inobt_rec_incore_t r;
  566. int i;
  567. xfs_ino_t ino;
  568. int left;
  569. int tmp;
  570. ino = (xfs_ino_t)*lastino;
  571. agno = XFS_INO_TO_AGNO(mp, ino);
  572. agino = XFS_INO_TO_AGINO(mp, ino);
  573. left = *count;
  574. *count = 0;
  575. bcount = MIN(left, (int)(PAGE_SIZE / sizeof(*buffer)));
  576. buffer = kmem_alloc(bcount * sizeof(*buffer), KM_SLEEP);
  577. error = bufidx = 0;
  578. cur = NULL;
  579. agbp = NULL;
  580. while (left > 0 && agno < mp->m_sb.sb_agcount) {
  581. if (agbp == NULL) {
  582. error = xfs_ialloc_read_agi(mp, NULL, agno, &agbp);
  583. if (error) {
  584. /*
  585. * If we can't read the AGI of this ag,
  586. * then just skip to the next one.
  587. */
  588. ASSERT(cur == NULL);
  589. agbp = NULL;
  590. agno++;
  591. agino = 0;
  592. continue;
  593. }
  594. cur = xfs_inobt_init_cursor(mp, NULL, agbp, agno);
  595. error = xfs_inobt_lookup(cur, agino, XFS_LOOKUP_GE,
  596. &tmp);
  597. if (error) {
  598. xfs_btree_del_cursor(cur, XFS_BTREE_ERROR);
  599. cur = NULL;
  600. xfs_buf_relse(agbp);
  601. agbp = NULL;
  602. /*
  603. * Move up the last inode in the current
  604. * chunk. The lookup_ge will always get
  605. * us the first inode in the next chunk.
  606. */
  607. agino += XFS_INODES_PER_CHUNK - 1;
  608. continue;
  609. }
  610. }
  611. error = xfs_inobt_get_rec(cur, &r, &i);
  612. if (error || i == 0) {
  613. xfs_buf_relse(agbp);
  614. agbp = NULL;
  615. xfs_btree_del_cursor(cur, XFS_BTREE_NOERROR);
  616. cur = NULL;
  617. agno++;
  618. agino = 0;
  619. continue;
  620. }
  621. agino = r.ir_startino + XFS_INODES_PER_CHUNK - 1;
  622. buffer[bufidx].xi_startino =
  623. XFS_AGINO_TO_INO(mp, agno, r.ir_startino);
  624. buffer[bufidx].xi_alloccount =
  625. XFS_INODES_PER_CHUNK - r.ir_freecount;
  626. buffer[bufidx].xi_allocmask = ~r.ir_free;
  627. bufidx++;
  628. left--;
  629. if (bufidx == bcount) {
  630. long written;
  631. if (formatter(ubuffer, buffer, bufidx, &written)) {
  632. error = XFS_ERROR(EFAULT);
  633. break;
  634. }
  635. ubuffer += written;
  636. *count += bufidx;
  637. bufidx = 0;
  638. }
  639. if (left) {
  640. error = xfs_btree_increment(cur, 0, &tmp);
  641. if (error) {
  642. xfs_btree_del_cursor(cur, XFS_BTREE_ERROR);
  643. cur = NULL;
  644. xfs_buf_relse(agbp);
  645. agbp = NULL;
  646. /*
  647. * The agino value has already been bumped.
  648. * Just try to skip up to it.
  649. */
  650. agino += XFS_INODES_PER_CHUNK;
  651. continue;
  652. }
  653. }
  654. }
  655. if (!error) {
  656. if (bufidx) {
  657. long written;
  658. if (formatter(ubuffer, buffer, bufidx, &written))
  659. error = XFS_ERROR(EFAULT);
  660. else
  661. *count += bufidx;
  662. }
  663. *lastino = XFS_AGINO_TO_INO(mp, agno, agino);
  664. }
  665. kmem_free(buffer);
  666. if (cur)
  667. xfs_btree_del_cursor(cur, (error ? XFS_BTREE_ERROR :
  668. XFS_BTREE_NOERROR));
  669. if (agbp)
  670. xfs_buf_relse(agbp);
  671. return error;
  672. }