[deliverable/linux.git] / fs / f2fs / inline.c

/*
 * fs/f2fs/inline.c
 * Copyright (c) 2013, Intel Corporation
 * Authors: Huajun Li <huajun.li@intel.com>
 *          Haicheng Li <haicheng.li@intel.com>
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 2 as
 * published by the Free Software Foundation.
 */

#include <linux/fs.h>
#include <linux/f2fs_fs.h>

#include "f2fs.h"

bool f2fs_may_inline(struct inode *inode)
{
	struct f2fs_sb_info *sbi = F2FS_SB(inode->i_sb);
	block_t nr_blocks;
	loff_t i_size;

	if (!test_opt(sbi, INLINE_DATA))
		return false;

	nr_blocks = F2FS_I(inode)->i_xattr_nid ? 3 : 2;
	if (inode->i_blocks > nr_blocks)
		return false;

	i_size = i_size_read(inode);
	if (i_size > MAX_INLINE_DATA)
		return false;

	return true;
}

int f2fs_read_inline_data(struct inode *inode, struct page *page)
{
	struct f2fs_sb_info *sbi = F2FS_SB(inode->i_sb);
	struct page *ipage;
	void *src_addr, *dst_addr;

	ipage = get_node_page(sbi, inode->i_ino);
	if (IS_ERR(ipage))
		return PTR_ERR(ipage);

	zero_user_segment(page, INLINE_DATA_OFFSET,
				INLINE_DATA_OFFSET + MAX_INLINE_DATA);

	/* Copy the whole inline data block */
	src_addr = inline_data_addr(ipage);
	dst_addr = kmap(page);
	memcpy(dst_addr, src_addr, MAX_INLINE_DATA);
	kunmap(page);
	f2fs_put_page(ipage, 1);

	SetPageUptodate(page);
	unlock_page(page);

	return 0;
}

static int __f2fs_convert_inline_data(struct inode *inode, struct page *page)
{
	int err;
	struct page *ipage;
	struct dnode_of_data dn;
	void *src_addr, *dst_addr;
	block_t new_blk_addr;
	struct f2fs_sb_info *sbi = F2FS_SB(inode->i_sb);
	struct f2fs_io_info fio = {
		.type = DATA,
		.rw = WRITE_SYNC | REQ_PRIO,
	};

	f2fs_lock_op(sbi);
	ipage = get_node_page(sbi, inode->i_ino);
	if (IS_ERR(ipage))
		return PTR_ERR(ipage);

	/*
	 * i_addr[0] is not used for inline data,
	 * so reserving new block will not destroy inline data
	 */
	set_new_dnode(&dn, inode, ipage, ipage, 0);
	err = f2fs_reserve_block(&dn, 0);
	if (err) {
		f2fs_put_page(ipage, 1);
		f2fs_unlock_op(sbi);
		return err;
	}

	zero_user_segment(page, 0, PAGE_CACHE_SIZE);

	/* Copy the whole inline data block */
	src_addr = inline_data_addr(ipage);
	dst_addr = kmap(page);
	memcpy(dst_addr, src_addr, MAX_INLINE_DATA);
	kunmap(page);
	SetPageUptodate(page);

	/* write data page to try to make data consistent */
	set_page_writeback(page);
	write_data_page(page, &dn, &new_blk_addr, &fio);
	update_extent_cache(new_blk_addr, &dn);
	f2fs_wait_on_page_writeback(page, DATA, true);

	/* clear inline data and flag after data writeback */
	zero_user_segment(ipage, INLINE_DATA_OFFSET,
				 INLINE_DATA_OFFSET + MAX_INLINE_DATA);
	clear_inode_flag(F2FS_I(inode), FI_INLINE_DATA);
	stat_dec_inline_inode(inode);

	sync_inode_page(&dn);
	f2fs_put_page(ipage, 1);
	f2fs_unlock_op(sbi);

	return err;
}

int f2fs_convert_inline_data(struct inode *inode, pgoff_t to_size)
{
	struct page *page;
	int err;

	if (!f2fs_has_inline_data(inode))
		return 0;
	else if (to_size <= MAX_INLINE_DATA)
		return 0;

	page = grab_cache_page_write_begin(inode->i_mapping, 0, AOP_FLAG_NOFS);
	if (!page)
		return -ENOMEM;

	err = __f2fs_convert_inline_data(inode, page);
	f2fs_put_page(page, 1);
	return err;
}

int f2fs_write_inline_data(struct inode *inode,
			   struct page *page, unsigned size)
{
	void *src_addr, *dst_addr;
	struct page *ipage;
	struct dnode_of_data dn;
	int err;

	set_new_dnode(&dn, inode, NULL, NULL, 0);
	err = get_dnode_of_data(&dn, 0, LOOKUP_NODE);
	if (err)
		return err;
	ipage = dn.inode_page;

	zero_user_segment(ipage, INLINE_DATA_OFFSET,
				 INLINE_DATA_OFFSET + MAX_INLINE_DATA);
	src_addr = kmap(page);
	dst_addr = inline_data_addr(ipage);
	memcpy(dst_addr, src_addr, size);
	kunmap(page);

	/* Release the first data block if it is allocated */
	if (!f2fs_has_inline_data(inode)) {
		truncate_data_blocks_range(&dn, 1);
		set_inode_flag(F2FS_I(inode), FI_INLINE_DATA);
		stat_inc_inline_inode(inode);
	}

	sync_inode_page(&dn);
	f2fs_put_dnode(&dn);

	return 0;
}
Commit	Line	Data
e18c65b2 HL	1	/*
	2	* fs/f2fs/inline.c
	3	* Copyright (c) 2013, Intel Corporation
	4	* Authors: Huajun Li <huajun.li@intel.com>
	5	* Haicheng Li <haicheng.li@intel.com>
	6	* This program is free software; you can redistribute it and/or modify
	7	* it under the terms of the GNU General Public License version 2 as
	8	* published by the Free Software Foundation.
	9	*/
	10
	11	#include <linux/fs.h>
	12	#include <linux/f2fs_fs.h>
	13
	14	#include "f2fs.h"
	15
e18c65b2 HL	16	bool f2fs_may_inline(struct inode *inode)
	17	{
	18	struct f2fs_sb_info *sbi = F2FS_SB(inode->i_sb);
	19	block_t nr_blocks;
	20	loff_t i_size;
	21
	22	if (!test_opt(sbi, INLINE_DATA))
	23	return false;
	24
	25	nr_blocks = F2FS_I(inode)->i_xattr_nid ? 3 : 2;
	26	if (inode->i_blocks > nr_blocks)
	27	return false;
	28
	29	i_size = i_size_read(inode);
	30	if (i_size > MAX_INLINE_DATA)
	31	return false;
	32
	33	return true;
	34	}
	35
	36	int f2fs_read_inline_data(struct inode inode, struct page page)
	37	{
	38	struct f2fs_sb_info *sbi = F2FS_SB(inode->i_sb);
	39	struct page *ipage;
	40	void src_addr, dst_addr;
	41
	42	ipage = get_node_page(sbi, inode->i_ino);
	43	if (IS_ERR(ipage))
	44	return PTR_ERR(ipage);
	45
	46	zero_user_segment(page, INLINE_DATA_OFFSET,
	47	INLINE_DATA_OFFSET + MAX_INLINE_DATA);
	48
	49	/* Copy the whole inline data block */
	50	src_addr = inline_data_addr(ipage);
	51	dst_addr = kmap(page);
	52	memcpy(dst_addr, src_addr, MAX_INLINE_DATA);
	53	kunmap(page);
	54	f2fs_put_page(ipage, 1);
	55
	56	SetPageUptodate(page);
	57	unlock_page(page);
	58
	59	return 0;
	60	}
	61
	62	static int __f2fs_convert_inline_data(struct inode inode, struct page page)
	63	{
	64	int err;
	65	struct page *ipage;
	66	struct dnode_of_data dn;
	67	void src_addr, dst_addr;
	68	block_t new_blk_addr;
	69	struct f2fs_sb_info *sbi = F2FS_SB(inode->i_sb);
	70	struct f2fs_io_info fio = {
	71	.type = DATA,
	72	.rw = WRITE_SYNC \| REQ_PRIO,
	73	};
	74
	75	f2fs_lock_op(sbi);
	76	ipage = get_node_page(sbi, inode->i_ino);
	77	if (IS_ERR(ipage))
	78	return PTR_ERR(ipage);
	79
80	/*
81	* i_addr[0] is not used for inline data,
82	* so reserving new block will not destroy inline data
83	*/
84	set_new_dnode(&dn, inode, ipage, ipage, 0);
85	err = f2fs_reserve_block(&dn, 0);
86	if (err) {
87	f2fs_put_page(ipage, 1);
88	f2fs_unlock_op(sbi);
89	return err;
90	}
91
92	zero_user_segment(page, 0, PAGE_CACHE_SIZE);
93
94	/* Copy the whole inline data block */
95	src_addr = inline_data_addr(ipage);
96	dst_addr = kmap(page);
97	memcpy(dst_addr, src_addr, MAX_INLINE_DATA);
98	kunmap(page);
9e09fc85	99	SetPageUptodate(page);
e18c65b2 HL	100
	101	/* write data page to try to make data consistent */
	102	set_page_writeback(page);
	103	write_data_page(page, &dn, &new_blk_addr, &fio);
	104	update_extent_cache(new_blk_addr, &dn);
	105	f2fs_wait_on_page_writeback(page, DATA, true);
	106
	107	/* clear inline data and flag after data writeback */
	108	zero_user_segment(ipage, INLINE_DATA_OFFSET,
	109	INLINE_DATA_OFFSET + MAX_INLINE_DATA);
	110	clear_inode_flag(F2FS_I(inode), FI_INLINE_DATA);
0dbdc2ae	111	stat_dec_inline_inode(inode);
e18c65b2 HL	112
	113	sync_inode_page(&dn);
	114	f2fs_put_page(ipage, 1);
	115	f2fs_unlock_op(sbi);
	116
	117	return err;
	118	}
	119
9e09fc85	120	int f2fs_convert_inline_data(struct inode *inode, pgoff_t to_size)
e18c65b2	121	{
e18c65b2	122	struct page *page;
9e09fc85	123	int err;
e18c65b2	124
9e09fc85 JK	125	if (!f2fs_has_inline_data(inode))
	126	return 0;
	127	else if (to_size <= MAX_INLINE_DATA)
	128	return 0;
e18c65b2	129
9e09fc85 JK	130	page = grab_cache_page_write_begin(inode->i_mapping, 0, AOP_FLAG_NOFS);
	131	if (!page)
	132	return -ENOMEM;
e18c65b2	133
9e09fc85 JK	134	err = __f2fs_convert_inline_data(inode, page);
9e09fc85 JK	135	f2fs_put_page(page, 1);
e18c65b2 HL	136	return err;
	137	}
	138
	139	int f2fs_write_inline_data(struct inode *inode,
	140	struct page *page, unsigned size)
	141	{
	142	void src_addr, dst_addr;
	143	struct page *ipage;
	144	struct dnode_of_data dn;
	145	int err;
	146
	147	set_new_dnode(&dn, inode, NULL, NULL, 0);
	148	err = get_dnode_of_data(&dn, 0, LOOKUP_NODE);
	149	if (err)
	150	return err;
	151	ipage = dn.inode_page;
	152
	153	zero_user_segment(ipage, INLINE_DATA_OFFSET,
	154	INLINE_DATA_OFFSET + MAX_INLINE_DATA);
	155	src_addr = kmap(page);
	156	dst_addr = inline_data_addr(ipage);
	157	memcpy(dst_addr, src_addr, size);
	158	kunmap(page);
	159
	160	/* Release the first data block if it is allocated */
	161	if (!f2fs_has_inline_data(inode)) {
	162	truncate_data_blocks_range(&dn, 1);
	163	set_inode_flag(F2FS_I(inode), FI_INLINE_DATA);
0dbdc2ae	164	stat_inc_inline_inode(inode);
e18c65b2 HL	165	}
	166
	167	sync_inode_page(&dn);
	168	f2fs_put_dnode(&dn);
	169
	170	return 0;
	171	}