jfs_metapage.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865
  1. /*
  2. * Copyright (C) International Business Machines Corp., 2000-2005
  3. * Portions Copyright (C) Christoph Hellwig, 2001-2002
  4. *
  5. * This program is free software; you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation; either version 2 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See
  13. * the GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program; if not, write to the Free Software
  17. * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  18. */
  19. #include <linux/fs.h>
  20. #include <linux/mm.h>
  21. #include <linux/bio.h>
  22. #include <linux/init.h>
  23. #include <linux/buffer_head.h>
  24. #include <linux/mempool.h>
  25. #include "jfs_incore.h"
  26. #include "jfs_superblock.h"
  27. #include "jfs_filsys.h"
  28. #include "jfs_metapage.h"
  29. #include "jfs_txnmgr.h"
  30. #include "jfs_debug.h"
  31. #ifdef CONFIG_JFS_STATISTICS
  32. static struct {
  33. uint pagealloc; /* # of page allocations */
  34. uint pagefree; /* # of page frees */
  35. uint lockwait; /* # of sleeping lock_metapage() calls */
  36. } mpStat;
  37. #endif
  38. #define metapage_locked(mp) test_bit(META_locked, &(mp)->flag)
  39. #define trylock_metapage(mp) test_and_set_bit(META_locked, &(mp)->flag)
  40. static inline void unlock_metapage(struct metapage *mp)
  41. {
  42. clear_bit(META_locked, &mp->flag);
  43. wake_up(&mp->wait);
  44. }
  45. static inline void __lock_metapage(struct metapage *mp)
  46. {
  47. DECLARE_WAITQUEUE(wait, current);
  48. INCREMENT(mpStat.lockwait);
  49. add_wait_queue_exclusive(&mp->wait, &wait);
  50. do {
  51. set_current_state(TASK_UNINTERRUPTIBLE);
  52. if (metapage_locked(mp)) {
  53. unlock_page(mp->page);
  54. schedule();
  55. lock_page(mp->page);
  56. }
  57. } while (trylock_metapage(mp));
  58. __set_current_state(TASK_RUNNING);
  59. remove_wait_queue(&mp->wait, &wait);
  60. }
  61. /*
  62. * Must have mp->page locked
  63. */
  64. static inline void lock_metapage(struct metapage *mp)
  65. {
  66. if (trylock_metapage(mp))
  67. __lock_metapage(mp);
  68. }
  69. #define METAPOOL_MIN_PAGES 32
  70. static kmem_cache_t *metapage_cache;
  71. static mempool_t *metapage_mempool;
  72. #define MPS_PER_PAGE (PAGE_CACHE_SIZE >> L2PSIZE)
  73. #if MPS_PER_PAGE > 1
  74. struct meta_anchor {
  75. int mp_count;
  76. atomic_t io_count;
  77. struct metapage *mp[MPS_PER_PAGE];
  78. };
  79. #define mp_anchor(page) ((struct meta_anchor *)page->private)
  80. static inline struct metapage *page_to_mp(struct page *page, uint offset)
  81. {
  82. if (!PagePrivate(page))
  83. return NULL;
  84. return mp_anchor(page)->mp[offset >> L2PSIZE];
  85. }
  86. static inline int insert_metapage(struct page *page, struct metapage *mp)
  87. {
  88. struct meta_anchor *a;
  89. int index;
  90. int l2mp_blocks; /* log2 blocks per metapage */
  91. if (PagePrivate(page))
  92. a = mp_anchor(page);
  93. else {
  94. a = kmalloc(sizeof(struct meta_anchor), GFP_NOFS);
  95. if (!a)
  96. return -ENOMEM;
  97. memset(a, 0, sizeof(struct meta_anchor));
  98. page->private = (unsigned long)a;
  99. SetPagePrivate(page);
  100. kmap(page);
  101. }
  102. if (mp) {
  103. l2mp_blocks = L2PSIZE - page->mapping->host->i_blkbits;
  104. index = (mp->index >> l2mp_blocks) & (MPS_PER_PAGE - 1);
  105. a->mp_count++;
  106. a->mp[index] = mp;
  107. }
  108. return 0;
  109. }
  110. static inline void remove_metapage(struct page *page, struct metapage *mp)
  111. {
  112. struct meta_anchor *a = mp_anchor(page);
  113. int l2mp_blocks = L2PSIZE - page->mapping->host->i_blkbits;
  114. int index;
  115. index = (mp->index >> l2mp_blocks) & (MPS_PER_PAGE - 1);
  116. BUG_ON(a->mp[index] != mp);
  117. a->mp[index] = NULL;
  118. if (--a->mp_count == 0) {
  119. kfree(a);
  120. page->private = 0;
  121. ClearPagePrivate(page);
  122. kunmap(page);
  123. }
  124. }
  125. static inline void inc_io(struct page *page)
  126. {
  127. atomic_inc(&mp_anchor(page)->io_count);
  128. }
  129. static inline void dec_io(struct page *page, void (*handler) (struct page *))
  130. {
  131. if (atomic_dec_and_test(&mp_anchor(page)->io_count))
  132. handler(page);
  133. }
  134. #else
  135. static inline struct metapage *page_to_mp(struct page *page, uint offset)
  136. {
  137. return PagePrivate(page) ? (struct metapage *)page->private : NULL;
  138. }
  139. static inline int insert_metapage(struct page *page, struct metapage *mp)
  140. {
  141. if (mp) {
  142. page->private = (unsigned long)mp;
  143. SetPagePrivate(page);
  144. kmap(page);
  145. }
  146. return 0;
  147. }
  148. static inline void remove_metapage(struct page *page, struct metapage *mp)
  149. {
  150. page->private = 0;
  151. ClearPagePrivate(page);
  152. kunmap(page);
  153. }
  154. #define inc_io(page) do {} while(0)
  155. #define dec_io(page, handler) handler(page)
  156. #endif
  157. static void init_once(void *foo, kmem_cache_t *cachep, unsigned long flags)
  158. {
  159. struct metapage *mp = (struct metapage *)foo;
  160. if ((flags & (SLAB_CTOR_VERIFY|SLAB_CTOR_CONSTRUCTOR)) ==
  161. SLAB_CTOR_CONSTRUCTOR) {
  162. mp->lid = 0;
  163. mp->lsn = 0;
  164. mp->flag = 0;
  165. mp->data = NULL;
  166. mp->clsn = 0;
  167. mp->log = NULL;
  168. set_bit(META_free, &mp->flag);
  169. init_waitqueue_head(&mp->wait);
  170. }
  171. }
  172. static inline struct metapage *alloc_metapage(unsigned int gfp_mask)
  173. {
  174. return mempool_alloc(metapage_mempool, gfp_mask);
  175. }
  176. static inline void free_metapage(struct metapage *mp)
  177. {
  178. mp->flag = 0;
  179. set_bit(META_free, &mp->flag);
  180. mempool_free(mp, metapage_mempool);
  181. }
  182. int __init metapage_init(void)
  183. {
  184. /*
  185. * Allocate the metapage structures
  186. */
  187. metapage_cache = kmem_cache_create("jfs_mp", sizeof(struct metapage),
  188. 0, 0, init_once, NULL);
  189. if (metapage_cache == NULL)
  190. return -ENOMEM;
  191. metapage_mempool = mempool_create(METAPOOL_MIN_PAGES, mempool_alloc_slab,
  192. mempool_free_slab, metapage_cache);
  193. if (metapage_mempool == NULL) {
  194. kmem_cache_destroy(metapage_cache);
  195. return -ENOMEM;
  196. }
  197. return 0;
  198. }
  199. void metapage_exit(void)
  200. {
  201. mempool_destroy(metapage_mempool);
  202. kmem_cache_destroy(metapage_cache);
  203. }
  204. static inline void drop_metapage(struct page *page, struct metapage *mp)
  205. {
  206. if (mp->count || mp->nohomeok || test_bit(META_dirty, &mp->flag) ||
  207. test_bit(META_io, &mp->flag))
  208. return;
  209. remove_metapage(page, mp);
  210. INCREMENT(mpStat.pagefree);
  211. free_metapage(mp);
  212. }
  213. /*
  214. * Metapage address space operations
  215. */
  216. static sector_t metapage_get_blocks(struct inode *inode, sector_t lblock,
  217. unsigned int *len)
  218. {
  219. int rc = 0;
  220. int xflag;
  221. s64 xaddr;
  222. sector_t file_blocks = (inode->i_size + inode->i_blksize - 1) >>
  223. inode->i_blkbits;
  224. if (lblock >= file_blocks)
  225. return 0;
  226. if (lblock + *len > file_blocks)
  227. *len = file_blocks - lblock;
  228. if (inode->i_ino) {
  229. rc = xtLookup(inode, (s64)lblock, *len, &xflag, &xaddr, len, 0);
  230. if ((rc == 0) && *len)
  231. lblock = (sector_t)xaddr;
  232. else
  233. lblock = 0;
  234. } /* else no mapping */
  235. return lblock;
  236. }
  237. static void last_read_complete(struct page *page)
  238. {
  239. if (!PageError(page))
  240. SetPageUptodate(page);
  241. unlock_page(page);
  242. }
  243. static int metapage_read_end_io(struct bio *bio, unsigned int bytes_done,
  244. int err)
  245. {
  246. struct page *page = bio->bi_private;
  247. if (bio->bi_size)
  248. return 1;
  249. if (!test_bit(BIO_UPTODATE, &bio->bi_flags)) {
  250. printk(KERN_ERR "metapage_read_end_io: I/O error\n");
  251. SetPageError(page);
  252. }
  253. dec_io(page, last_read_complete);
  254. bio_put(bio);
  255. return 0;
  256. }
  257. static void remove_from_logsync(struct metapage *mp)
  258. {
  259. struct jfs_log *log = mp->log;
  260. unsigned long flags;
  261. /*
  262. * This can race. Recheck that log hasn't been set to null, and after
  263. * acquiring logsync lock, recheck lsn
  264. */
  265. if (!log)
  266. return;
  267. LOGSYNC_LOCK(log, flags);
  268. if (mp->lsn) {
  269. mp->log = NULL;
  270. mp->lsn = 0;
  271. mp->clsn = 0;
  272. log->count--;
  273. list_del(&mp->synclist);
  274. }
  275. LOGSYNC_UNLOCK(log, flags);
  276. }
  277. static void last_write_complete(struct page *page)
  278. {
  279. struct metapage *mp;
  280. unsigned int offset;
  281. for (offset = 0; offset < PAGE_CACHE_SIZE; offset += PSIZE) {
  282. mp = page_to_mp(page, offset);
  283. if (mp && test_bit(META_io, &mp->flag)) {
  284. if (mp->lsn)
  285. remove_from_logsync(mp);
  286. clear_bit(META_io, &mp->flag);
  287. }
  288. /*
  289. * I'd like to call drop_metapage here, but I don't think it's
  290. * safe unless I have the page locked
  291. */
  292. }
  293. end_page_writeback(page);
  294. }
  295. static int metapage_write_end_io(struct bio *bio, unsigned int bytes_done,
  296. int err)
  297. {
  298. struct page *page = bio->bi_private;
  299. BUG_ON(!PagePrivate(page));
  300. if (bio->bi_size)
  301. return 1;
  302. if (! test_bit(BIO_UPTODATE, &bio->bi_flags)) {
  303. printk(KERN_ERR "metapage_write_end_io: I/O error\n");
  304. SetPageError(page);
  305. }
  306. dec_io(page, last_write_complete);
  307. bio_put(bio);
  308. return 0;
  309. }
  310. static int metapage_writepage(struct page *page, struct writeback_control *wbc)
  311. {
  312. struct bio *bio = NULL;
  313. unsigned int block_offset; /* block offset of mp within page */
  314. struct inode *inode = page->mapping->host;
  315. unsigned int blocks_per_mp = JFS_SBI(inode->i_sb)->nbperpage;
  316. unsigned int len;
  317. unsigned int xlen;
  318. struct metapage *mp;
  319. int redirty = 0;
  320. sector_t lblock;
  321. sector_t pblock;
  322. sector_t next_block = 0;
  323. sector_t page_start;
  324. unsigned long bio_bytes = 0;
  325. unsigned long bio_offset = 0;
  326. unsigned int offset;
  327. page_start = (sector_t)page->index <<
  328. (PAGE_CACHE_SHIFT - inode->i_blkbits);
  329. BUG_ON(!PageLocked(page));
  330. BUG_ON(PageWriteback(page));
  331. for (offset = 0; offset < PAGE_CACHE_SIZE; offset += PSIZE) {
  332. mp = page_to_mp(page, offset);
  333. if (!mp || !test_bit(META_dirty, &mp->flag))
  334. continue;
  335. if (mp->nohomeok && !test_bit(META_forcewrite, &mp->flag)) {
  336. redirty = 1;
  337. continue;
  338. }
  339. clear_bit(META_dirty, &mp->flag);
  340. block_offset = offset >> inode->i_blkbits;
  341. lblock = page_start + block_offset;
  342. if (bio) {
  343. if (xlen && lblock == next_block) {
  344. /* Contiguous, in memory & on disk */
  345. len = min(xlen, blocks_per_mp);
  346. xlen -= len;
  347. bio_bytes += len << inode->i_blkbits;
  348. set_bit(META_io, &mp->flag);
  349. continue;
  350. }
  351. /* Not contiguous */
  352. if (bio_add_page(bio, page, bio_bytes, bio_offset) <
  353. bio_bytes)
  354. goto add_failed;
  355. /*
  356. * Increment counter before submitting i/o to keep
  357. * count from hitting zero before we're through
  358. */
  359. inc_io(page);
  360. if (!bio->bi_size)
  361. goto dump_bio;
  362. submit_bio(WRITE, bio);
  363. bio = NULL;
  364. } else {
  365. set_page_writeback(page);
  366. inc_io(page);
  367. }
  368. xlen = (PAGE_CACHE_SIZE - offset) >> inode->i_blkbits;
  369. pblock = metapage_get_blocks(inode, lblock, &xlen);
  370. if (!pblock) {
  371. /* Need better error handling */
  372. printk(KERN_ERR "JFS: metapage_get_blocks failed\n");
  373. dec_io(page, last_write_complete);
  374. continue;
  375. }
  376. set_bit(META_io, &mp->flag);
  377. len = min(xlen, (uint) JFS_SBI(inode->i_sb)->nbperpage);
  378. bio = bio_alloc(GFP_NOFS, 1);
  379. bio->bi_bdev = inode->i_sb->s_bdev;
  380. bio->bi_sector = pblock << (inode->i_blkbits - 9);
  381. bio->bi_end_io = metapage_write_end_io;
  382. bio->bi_private = page;
  383. /* Don't call bio_add_page yet, we may add to this vec */
  384. bio_offset = offset;
  385. bio_bytes = len << inode->i_blkbits;
  386. xlen -= len;
  387. next_block = lblock + len;
  388. }
  389. if (bio) {
  390. if (bio_add_page(bio, page, bio_bytes, bio_offset) < bio_bytes)
  391. goto add_failed;
  392. if (!bio->bi_size)
  393. goto dump_bio;
  394. submit_bio(WRITE, bio);
  395. }
  396. if (redirty)
  397. redirty_page_for_writepage(wbc, page);
  398. unlock_page(page);
  399. return 0;
  400. add_failed:
  401. /* We should never reach here, since we're only adding one vec */
  402. printk(KERN_ERR "JFS: bio_add_page failed unexpectedly\n");
  403. goto skip;
  404. dump_bio:
  405. dump_mem("bio", bio, sizeof(*bio));
  406. skip:
  407. bio_put(bio);
  408. unlock_page(page);
  409. dec_io(page, last_write_complete);
  410. return -EIO;
  411. }
  412. static int metapage_readpage(struct file *fp, struct page *page)
  413. {
  414. struct inode *inode = page->mapping->host;
  415. struct bio *bio = NULL;
  416. unsigned int block_offset;
  417. unsigned int blocks_per_page = PAGE_CACHE_SIZE >> inode->i_blkbits;
  418. sector_t page_start; /* address of page in fs blocks */
  419. sector_t pblock;
  420. unsigned int xlen;
  421. unsigned int len;
  422. unsigned int offset;
  423. BUG_ON(!PageLocked(page));
  424. page_start = (sector_t)page->index <<
  425. (PAGE_CACHE_SHIFT - inode->i_blkbits);
  426. block_offset = 0;
  427. while (block_offset < blocks_per_page) {
  428. xlen = blocks_per_page - block_offset;
  429. pblock = metapage_get_blocks(inode, page_start + block_offset,
  430. &xlen);
  431. if (pblock) {
  432. if (!PagePrivate(page))
  433. insert_metapage(page, NULL);
  434. inc_io(page);
  435. if (bio)
  436. submit_bio(READ, bio);
  437. bio = bio_alloc(GFP_NOFS, 1);
  438. bio->bi_bdev = inode->i_sb->s_bdev;
  439. bio->bi_sector = pblock << (inode->i_blkbits - 9);
  440. bio->bi_end_io = metapage_read_end_io;
  441. bio->bi_private = page;
  442. len = xlen << inode->i_blkbits;
  443. offset = block_offset << inode->i_blkbits;
  444. if (bio_add_page(bio, page, len, offset) < len)
  445. goto add_failed;
  446. block_offset += xlen;
  447. } else
  448. block_offset++;
  449. }
  450. if (bio)
  451. submit_bio(READ, bio);
  452. else
  453. unlock_page(page);
  454. return 0;
  455. add_failed:
  456. printk(KERN_ERR "JFS: bio_add_page failed unexpectedly\n");
  457. bio_put(bio);
  458. dec_io(page, last_read_complete);
  459. return -EIO;
  460. }
  461. static int metapage_releasepage(struct page *page, int gfp_mask)
  462. {
  463. struct metapage *mp;
  464. int busy = 0;
  465. unsigned int offset;
  466. for (offset = 0; offset < PAGE_CACHE_SIZE; offset += PSIZE) {
  467. mp = page_to_mp(page, offset);
  468. if (!mp)
  469. continue;
  470. jfs_info("metapage_releasepage: mp = 0x%p", mp);
  471. if (mp->count || mp->nohomeok) {
  472. jfs_info("count = %ld, nohomeok = %d", mp->count,
  473. mp->nohomeok);
  474. busy = 1;
  475. continue;
  476. }
  477. wait_on_page_writeback(page);
  478. //WARN_ON(test_bit(META_dirty, &mp->flag));
  479. if (test_bit(META_dirty, &mp->flag)) {
  480. dump_mem("dirty mp in metapage_releasepage", mp,
  481. sizeof(struct metapage));
  482. dump_mem("page", page, sizeof(struct page));
  483. dump_stack();
  484. }
  485. if (mp->lsn)
  486. remove_from_logsync(mp);
  487. remove_metapage(page, mp);
  488. INCREMENT(mpStat.pagefree);
  489. free_metapage(mp);
  490. }
  491. if (busy)
  492. return -1;
  493. return 0;
  494. }
  495. static int metapage_invalidatepage(struct page *page, unsigned long offset)
  496. {
  497. BUG_ON(offset);
  498. if (PageWriteback(page))
  499. return 0;
  500. return metapage_releasepage(page, 0);
  501. }
  502. struct address_space_operations jfs_metapage_aops = {
  503. .readpage = metapage_readpage,
  504. .writepage = metapage_writepage,
  505. .sync_page = block_sync_page,
  506. .releasepage = metapage_releasepage,
  507. .invalidatepage = metapage_invalidatepage,
  508. .set_page_dirty = __set_page_dirty_nobuffers,
  509. };
  510. struct metapage *__get_metapage(struct inode *inode, unsigned long lblock,
  511. unsigned int size, int absolute,
  512. unsigned long new)
  513. {
  514. int l2BlocksPerPage;
  515. int l2bsize;
  516. struct address_space *mapping;
  517. struct metapage *mp = NULL;
  518. struct page *page;
  519. unsigned long page_index;
  520. unsigned long page_offset;
  521. jfs_info("__get_metapage: ino = %ld, lblock = 0x%lx, abs=%d",
  522. inode->i_ino, lblock, absolute);
  523. l2bsize = inode->i_blkbits;
  524. l2BlocksPerPage = PAGE_CACHE_SHIFT - l2bsize;
  525. page_index = lblock >> l2BlocksPerPage;
  526. page_offset = (lblock - (page_index << l2BlocksPerPage)) << l2bsize;
  527. if ((page_offset + size) > PAGE_CACHE_SIZE) {
  528. jfs_err("MetaData crosses page boundary!!");
  529. jfs_err("lblock = %lx, size = %d", lblock, size);
  530. dump_stack();
  531. return NULL;
  532. }
  533. if (absolute)
  534. mapping = JFS_SBI(inode->i_sb)->direct_inode->i_mapping;
  535. else {
  536. /*
  537. * If an nfs client tries to read an inode that is larger
  538. * than any existing inodes, we may try to read past the
  539. * end of the inode map
  540. */
  541. if ((lblock << inode->i_blkbits) >= inode->i_size)
  542. return NULL;
  543. mapping = inode->i_mapping;
  544. }
  545. if (new && (PSIZE == PAGE_CACHE_SIZE)) {
  546. page = grab_cache_page(mapping, page_index);
  547. if (!page) {
  548. jfs_err("grab_cache_page failed!");
  549. return NULL;
  550. }
  551. SetPageUptodate(page);
  552. } else {
  553. page = read_cache_page(mapping, page_index,
  554. (filler_t *)mapping->a_ops->readpage, NULL);
  555. if (IS_ERR(page) || !PageUptodate(page)) {
  556. jfs_err("read_cache_page failed!");
  557. return NULL;
  558. }
  559. lock_page(page);
  560. }
  561. mp = page_to_mp(page, page_offset);
  562. if (mp) {
  563. if (mp->logical_size != size) {
  564. jfs_error(inode->i_sb,
  565. "__get_metapage: mp->logical_size != size");
  566. jfs_err("logical_size = %d, size = %d",
  567. mp->logical_size, size);
  568. dump_stack();
  569. goto unlock;
  570. }
  571. mp->count++;
  572. lock_metapage(mp);
  573. if (test_bit(META_discard, &mp->flag)) {
  574. if (!new) {
  575. jfs_error(inode->i_sb,
  576. "__get_metapage: using a "
  577. "discarded metapage");
  578. discard_metapage(mp);
  579. goto unlock;
  580. }
  581. clear_bit(META_discard, &mp->flag);
  582. }
  583. } else {
  584. INCREMENT(mpStat.pagealloc);
  585. mp = alloc_metapage(GFP_NOFS);
  586. mp->page = page;
  587. mp->flag = 0;
  588. mp->xflag = COMMIT_PAGE;
  589. mp->count = 1;
  590. mp->nohomeok = 0;
  591. mp->logical_size = size;
  592. mp->data = page_address(page) + page_offset;
  593. mp->index = lblock;
  594. if (unlikely(insert_metapage(page, mp))) {
  595. free_metapage(mp);
  596. goto unlock;
  597. }
  598. lock_metapage(mp);
  599. }
  600. if (new) {
  601. jfs_info("zeroing mp = 0x%p", mp);
  602. memset(mp->data, 0, PSIZE);
  603. }
  604. unlock_page(page);
  605. jfs_info("__get_metapage: returning = 0x%p data = 0x%p", mp, mp->data);
  606. return mp;
  607. unlock:
  608. unlock_page(page);
  609. return NULL;
  610. }
  611. void grab_metapage(struct metapage * mp)
  612. {
  613. jfs_info("grab_metapage: mp = 0x%p", mp);
  614. page_cache_get(mp->page);
  615. lock_page(mp->page);
  616. mp->count++;
  617. lock_metapage(mp);
  618. unlock_page(mp->page);
  619. }
  620. void force_metapage(struct metapage *mp)
  621. {
  622. struct page *page = mp->page;
  623. jfs_info("force_metapage: mp = 0x%p", mp);
  624. set_bit(META_forcewrite, &mp->flag);
  625. clear_bit(META_sync, &mp->flag);
  626. page_cache_get(page);
  627. lock_page(page);
  628. set_page_dirty(page);
  629. write_one_page(page, 1);
  630. clear_bit(META_forcewrite, &mp->flag);
  631. page_cache_release(page);
  632. }
  633. void hold_metapage(struct metapage *mp)
  634. {
  635. lock_page(mp->page);
  636. }
  637. void put_metapage(struct metapage *mp)
  638. {
  639. if (mp->count || mp->nohomeok) {
  640. /* Someone else will release this */
  641. unlock_page(mp->page);
  642. return;
  643. }
  644. page_cache_get(mp->page);
  645. mp->count++;
  646. lock_metapage(mp);
  647. unlock_page(mp->page);
  648. release_metapage(mp);
  649. }
  650. void release_metapage(struct metapage * mp)
  651. {
  652. struct page *page = mp->page;
  653. jfs_info("release_metapage: mp = 0x%p, flag = 0x%lx", mp, mp->flag);
  654. BUG_ON(!page);
  655. lock_page(page);
  656. unlock_metapage(mp);
  657. assert(mp->count);
  658. if (--mp->count || mp->nohomeok) {
  659. unlock_page(page);
  660. page_cache_release(page);
  661. return;
  662. }
  663. if (test_bit(META_dirty, &mp->flag)) {
  664. set_page_dirty(page);
  665. if (test_bit(META_sync, &mp->flag)) {
  666. clear_bit(META_sync, &mp->flag);
  667. write_one_page(page, 1);
  668. lock_page(page); /* write_one_page unlocks the page */
  669. }
  670. } else if (mp->lsn) /* discard_metapage doesn't remove it */
  671. remove_from_logsync(mp);
  672. #if MPS_PER_PAGE == 1
  673. /*
  674. * If we know this is the only thing in the page, we can throw
  675. * the page out of the page cache. If pages are larger, we
  676. * don't want to do this.
  677. */
  678. /* Retest mp->count since we may have released page lock */
  679. if (test_bit(META_discard, &mp->flag) && !mp->count) {
  680. clear_page_dirty(page);
  681. ClearPageUptodate(page);
  682. }
  683. #else
  684. /* Try to keep metapages from using up too much memory */
  685. drop_metapage(page, mp);
  686. #endif
  687. unlock_page(page);
  688. page_cache_release(page);
  689. }
  690. void __invalidate_metapages(struct inode *ip, s64 addr, int len)
  691. {
  692. sector_t lblock;
  693. int l2BlocksPerPage = PAGE_CACHE_SHIFT - ip->i_blkbits;
  694. int BlocksPerPage = 1 << l2BlocksPerPage;
  695. /* All callers are interested in block device's mapping */
  696. struct address_space *mapping =
  697. JFS_SBI(ip->i_sb)->direct_inode->i_mapping;
  698. struct metapage *mp;
  699. struct page *page;
  700. unsigned int offset;
  701. /*
  702. * Mark metapages to discard. They will eventually be
  703. * released, but should not be written.
  704. */
  705. for (lblock = addr & ~(BlocksPerPage - 1); lblock < addr + len;
  706. lblock += BlocksPerPage) {
  707. page = find_lock_page(mapping, lblock >> l2BlocksPerPage);
  708. if (!page)
  709. continue;
  710. for (offset = 0; offset < PAGE_CACHE_SIZE; offset += PSIZE) {
  711. mp = page_to_mp(page, offset);
  712. if (!mp)
  713. continue;
  714. if (mp->index < addr)
  715. continue;
  716. if (mp->index >= addr + len)
  717. break;
  718. clear_bit(META_dirty, &mp->flag);
  719. set_bit(META_discard, &mp->flag);
  720. if (mp->lsn)
  721. remove_from_logsync(mp);
  722. }
  723. unlock_page(page);
  724. page_cache_release(page);
  725. }
  726. }
  727. #ifdef CONFIG_JFS_STATISTICS
  728. int jfs_mpstat_read(char *buffer, char **start, off_t offset, int length,
  729. int *eof, void *data)
  730. {
  731. int len = 0;
  732. off_t begin;
  733. len += sprintf(buffer,
  734. "JFS Metapage statistics\n"
  735. "=======================\n"
  736. "page allocations = %d\n"
  737. "page frees = %d\n"
  738. "lock waits = %d\n",
  739. mpStat.pagealloc,
  740. mpStat.pagefree,
  741. mpStat.lockwait);
  742. begin = offset;
  743. *start = buffer + begin;
  744. len -= begin;
  745. if (len > length)
  746. len = length;
  747. else
  748. *eof = 1;
  749. if (len < 0)
  750. len = 0;
  751. return len;
  752. }
  753. #endif