From patchwork Mon May 9 16:41:21 2011 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: "Amir G." X-Patchwork-Id: 94795 X-Patchwork-Delegate: tytso@mit.edu Return-Path: X-Original-To: patchwork-incoming@ozlabs.org Delivered-To: patchwork-incoming@ozlabs.org Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by ozlabs.org (Postfix) with ESMTP id 4FB8EB6F29 for ; Tue, 10 May 2011 02:42:49 +1000 (EST) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1753105Ab1EIQms (ORCPT ); Mon, 9 May 2011 12:42:48 -0400 Received: from mail-ww0-f44.google.com ([74.125.82.44]:59790 "EHLO mail-ww0-f44.google.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1753444Ab1EIQmr (ORCPT ); Mon, 9 May 2011 12:42:47 -0400 Received: by wwa36 with SMTP id 36so5954969wwa.1 for ; Mon, 09 May 2011 09:42:45 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:sender:from:to:cc:subject:date:message-id :x-mailer:in-reply-to:references; bh=5dJ2/tKolxJuu4msf8CMDNVMQ9TTvH7PhZsJhJXBzLs=; b=U0W9PEVqhdbqaU1gv7le8oibIf+bd3wgsrkcsq1go2aYdnN3Tt9L397ZxEAumxIcLc nXspnomd1UPjM+UNpuf7+QiDrVXLMQzzaJ+st1DqysKoiEv9eRNHyLTnR1jUNpqC0yTi NIO34lXb6DixfcGYa+ESpO2jvJdi/pIHhN090= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=sender:from:to:cc:subject:date:message-id:x-mailer:in-reply-to :references; b=WAltfpcyrc/d/M7Fv6HDkl7iFMh7cpbF2vrYsXUj+t91OjVeyNKQ8/ClZ0FG153CrQ qKbBIeuO0l5zM9/3FmfQ/63tLRIkSl+iq9tPhXQM5M7p5hOQgq5hdB3PJ4gg19akMVjN 5xZ76eWe0nnsyP+KIFC6zQ+CHuAPSIb9mjQRk= Received: by 10.227.172.7 with SMTP id j7mr922106wbz.60.1304959365769; Mon, 09 May 2011 09:42:45 -0700 (PDT) Received: from localhost.localdomain (bzq-79-179-43-50.red.bezeqint.net [79.179.43.50]) by mx.google.com with ESMTPS id o23sm2034877wbc.27.2011.05.09.09.42.43 (version=TLSv1/SSLv3 cipher=OTHER); Mon, 09 May 2011 09:42:44 -0700 (PDT) From: amir73il@users.sourceforge.net To: linux-ext4@vger.kernel.org Cc: tytso@mit.edu, Amir Goldstein , Yongqiang Yang Subject: [PATCH RFC 03/30] ext4: snapshot hooks - inside JBD hooks Date: Mon, 9 May 2011 19:41:21 +0300 Message-Id: <1304959308-11122-4-git-send-email-amir73il@users.sourceforge.net> X-Mailer: git-send-email 1.7.0.4 In-Reply-To: <1304959308-11122-1-git-send-email-amir73il@users.sourceforge.net> References: <1304959308-11122-1-git-send-email-amir73il@users.sourceforge.net> Sender: linux-ext4-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: linux-ext4@vger.kernel.org From: Amir Goldstein Before every metadata buffer write, the journal API is called, namely, one of the ext4_journal_get_XXX_access() functions. We use these journal hooks to call the snapshot API, namely ext4_snapshot_get_XXX_access(), to COW the metadata buffer before it is modified for the first time. Signed-off-by: Amir Goldstein Signed-off-by: Yongqiang Yang --- fs/ext4/ext4_jbd2.c | 9 +++++++-- fs/ext4/ext4_jbd2.h | 15 +++++++++++---- fs/ext4/extents.c | 3 ++- fs/ext4/inode.c | 22 +++++++++++++++------- fs/ext4/move_extent.c | 3 ++- 5 files changed, 37 insertions(+), 15 deletions(-) diff --git a/fs/ext4/ext4_jbd2.c b/fs/ext4/ext4_jbd2.c index 560020d..833969b 100644 --- a/fs/ext4/ext4_jbd2.c +++ b/fs/ext4/ext4_jbd2.c @@ -23,13 +23,16 @@ int __ext4_journal_get_undo_access(const char *where, unsigned int line, return err; } -int __ext4_journal_get_write_access(const char *where, unsigned int line, - handle_t *handle, struct buffer_head *bh) +int __ext4_journal_get_write_access_inode(const char *where, unsigned int line, + handle_t *handle, struct inode *inode, + struct buffer_head *bh, int exclude) { int err = 0; if (ext4_handle_valid(handle)) { err = jbd2_journal_get_write_access(handle, bh); + if (!err && !exclude) + err = ext4_snapshot_get_write_access(handle, inode, bh); if (err) ext4_journal_abort_handle(where, line, __func__, bh, handle, err); @@ -111,6 +114,8 @@ int __ext4_journal_get_create_access(const char *where, unsigned int line, if (ext4_handle_valid(handle)) { err = jbd2_journal_get_create_access(handle, bh); + if (!err) + err = ext4_snapshot_get_create_access(handle, bh); if (err) ext4_journal_abort_handle(where, line, __func__, bh, handle, err); diff --git a/fs/ext4/ext4_jbd2.h b/fs/ext4/ext4_jbd2.h index 8ffffb1..75662f7 100644 --- a/fs/ext4/ext4_jbd2.h +++ b/fs/ext4/ext4_jbd2.h @@ -132,9 +132,9 @@ void ext4_journal_abort_handle(const char *caller, unsigned int line, int __ext4_journal_get_undo_access(const char *where, unsigned int line, handle_t *handle, struct buffer_head *bh); -int __ext4_journal_get_write_access(const char *where, unsigned int line, - handle_t *handle, struct buffer_head *bh); - +int __ext4_journal_get_write_access_inode(const char *where, unsigned int line, + handle_t *handle, struct inode *inode, + struct buffer_head *bh, int exclude); int __ext4_forget(const char *where, unsigned int line, handle_t *handle, int is_metadata, struct inode *inode, struct buffer_head *bh, ext4_fsblk_t blocknr); @@ -151,8 +151,15 @@ int __ext4_handle_dirty_super(const char *where, unsigned int line, #define ext4_journal_get_undo_access(handle, bh) \ __ext4_journal_get_undo_access(__func__, __LINE__, (handle), (bh)) +#define ext4_journal_get_write_access_exclude(handle, bh) \ + __ext4_journal_get_write_access_inode(__func__, __LINE__, \ + (handle), NULL, (bh), 1) #define ext4_journal_get_write_access(handle, bh) \ - __ext4_journal_get_write_access(__func__, __LINE__, (handle), (bh)) + __ext4_journal_get_write_access_inode(__func__, __LINE__, \ + (handle), NULL, (bh), 0) +#define ext4_journal_get_write_access_inode(handle, inode, bh) \ + __ext4_journal_get_write_access_inode(__func__, __LINE__, \ + (handle), (inode), (bh), 0) #define ext4_forget(handle, is_metadata, inode, bh, block_nr) \ __ext4_forget(__func__, __LINE__, (handle), (is_metadata), (inode), \ (bh), (block_nr)) diff --git a/fs/ext4/extents.c b/fs/ext4/extents.c index 0c3ea93..c8cab3d 100644 --- a/fs/ext4/extents.c +++ b/fs/ext4/extents.c @@ -77,7 +77,8 @@ static int ext4_ext_get_access(handle_t *handle, struct inode *inode, { if (path->p_bh) { /* path points to block */ - return ext4_journal_get_write_access(handle, path->p_bh); + return ext4_journal_get_write_access_inode(handle, + inode, path->p_bh); } /* path points to leaf/index in inode body */ /* we use in-core data, no need to protect them */ diff --git a/fs/ext4/inode.c b/fs/ext4/inode.c index a597ff1..b848072 100644 --- a/fs/ext4/inode.c +++ b/fs/ext4/inode.c @@ -874,7 +874,8 @@ static int ext4_splice_branch(handle_t *handle, struct inode *inode, */ if (where->bh) { BUFFER_TRACE(where->bh, "get_write_access"); - err = ext4_journal_get_write_access(handle, where->bh); + err = ext4_journal_get_write_access_inode(handle, inode, + where->bh); if (err) goto err_out; } @@ -4172,7 +4173,8 @@ static int ext4_clear_blocks(handle_t *handle, struct inode *inode, goto out_err; if (bh) { BUFFER_TRACE(bh, "retaking write access"); - err = ext4_journal_get_write_access(handle, bh); + err = ext4_journal_get_write_access_inode(handle, + inode, bh); if (unlikely(err)) goto out_err; } @@ -4223,7 +4225,8 @@ static void ext4_free_data(handle_t *handle, struct inode *inode, if (this_bh) { /* For indirect block */ BUFFER_TRACE(this_bh, "get_write_access"); - err = ext4_journal_get_write_access(handle, this_bh); + err = ext4_journal_get_write_access_inode(handle, inode, + this_bh); /* Important: if we can't update the indirect pointers * to the blocks, we can't free them. */ if (err) @@ -4386,8 +4389,8 @@ static void ext4_free_branches(handle_t *handle, struct inode *inode, * pointed to by an indirect block: journal it */ BUFFER_TRACE(parent_bh, "get_write_access"); - if (!ext4_journal_get_write_access(handle, - parent_bh)){ + if (!ext4_journal_get_write_access_inode( + handle, inode, parent_bh)){ *p = 0; BUFFER_TRACE(parent_bh, "call ext4_handle_dirty_metadata"); @@ -4759,9 +4762,14 @@ has_buffer: int ext4_get_inode_loc(struct inode *inode, struct ext4_iloc *iloc) { - /* We have all inode data except xattrs in memory here. */ - return __ext4_get_inode_loc(inode, iloc, + int in_mem = (!EXT4_SNAPSHOTS(inode->i_sb) && !ext4_test_inode_state(inode, EXT4_STATE_XATTR)); + + /* + * We have all inode's data except xattrs in memory here, + * but we must always read-in the entire inode block for COW. + */ + return __ext4_get_inode_loc(inode, iloc, in_mem); } void ext4_set_inode_flags(struct inode *inode) diff --git a/fs/ext4/move_extent.c b/fs/ext4/move_extent.c index b9f3e78..ad5409a 100644 --- a/fs/ext4/move_extent.c +++ b/fs/ext4/move_extent.c @@ -421,7 +421,8 @@ mext_insert_extents(handle_t *handle, struct inode *orig_inode, if (depth) { /* Register to journal */ - ret = ext4_journal_get_write_access(handle, orig_path->p_bh); + ret = ext4_journal_get_write_access_inode(handle, + orig_inode, orig_path->p_bh); if (ret) return ret; }