X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;ds=inline;f=lustre%2Fllite%2Fvvp_object.c;h=498d3b262fc2be999a3cd88087e087e72b6d69c1;hb=c9739496bb089f82b7b7d0952a3b2c1c2bcc616d;hp=412a877068cc01fd3018eb087b4c354b39ce7a99;hpb=fbf5870b9848929d352460f1f005b79c0b5ccc5a;p=fs%2Flustre-release.git

diff --git a/lustre/llite/vvp_object.c b/lustre/llite/vvp_object.c
index 412a877..498d3b2 100644
--- a/lustre/llite/vvp_object.c
+++ b/lustre/llite/vvp_object.c
@@ -1,6 +1,4 @@
-/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
- * vim:expandtab:shiftwidth=8:tabstop=8:
- *
+/*
  * GPL HEADER START
  *
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
@@ -26,8 +24,10 @@
  * GPL HEADER END
  */
 /*
- * Copyright 2008 Sun Microsystems, Inc.  All rights reserved.
+ * Copyright (c) 2008, 2010, Oracle and/or its affiliates. All rights reserved.
  * Use is subject to license terms.
+ *
+ * Copyright (c) 2012, 2013, Intel Corporation.
  */
 /*
  * This file is part of Lustre, http://www.lustre.org/
@@ -58,72 +58,118 @@
  */
 
 static int vvp_object_print(const struct lu_env *env, void *cookie,
-                            lu_printer_t p, const struct lu_object *o)
+			    lu_printer_t p, const struct lu_object *o)
 {
-        struct ccc_object    *obj   = lu2ccc(o);
-        struct inode         *inode = obj->cob_inode;
-        struct ll_inode_info *lli;
-
-        (*p)(env, cookie, "(%s %i %i) inode: %p ",
-             list_empty(&obj->cob_pending_list) ? "-" : "+",
-             obj->cob_transient_pages, atomic_read(&obj->cob_mmap_cnt), inode);
-        if (inode) {
-                lli = ll_i2info(inode);
-                (*p)(env, cookie, "%lu/%u %o %u %i %p "DFID,
-                     inode->i_ino, inode->i_generation, inode->i_mode,
-                     inode->i_nlink, atomic_read(&inode->i_count),
-                     lli->lli_clob, PFID(&lli->lli_fid));
-        }
-        return 0;
+	struct ccc_object    *obj   = lu2ccc(o);
+	struct inode         *inode = obj->cob_inode;
+	struct ll_inode_info *lli;
+
+	(*p)(env, cookie, "(%s %d %d) inode: %p ",
+	     list_empty(&obj->cob_pending_list) ? "-" : "+",
+	     obj->cob_transient_pages, atomic_read(&obj->cob_mmap_cnt),
+	     inode);
+	if (inode) {
+		lli = ll_i2info(inode);
+		(*p)(env, cookie, "%lu/%u %o %u %d %p "DFID,
+		     inode->i_ino, inode->i_generation, inode->i_mode,
+		     inode->i_nlink, atomic_read(&inode->i_count),
+		     lli->lli_clob, PFID(&lli->lli_fid));
+	}
+	return 0;
 }
 
 static int vvp_attr_get(const struct lu_env *env, struct cl_object *obj,
                         struct cl_attr *attr)
 {
-        struct inode *inode = ccc_object_inode(obj);
-
-        /*
-         * lov overwrites most of these fields in
-         * lov_attr_get()->...lov_merge_lvb_kms(), except when inode
-         * attributes are newer.
-         */
-
-        attr->cat_size = i_size_read(inode);
-        attr->cat_mtime = LTIME_S(inode->i_mtime);
-        attr->cat_atime = LTIME_S(inode->i_atime);
-        attr->cat_ctime = LTIME_S(inode->i_ctime);
-        attr->cat_blocks = inode->i_blocks;
-        attr->cat_uid = inode->i_uid;
-        attr->cat_gid = inode->i_gid;
-        /* KMS is not known by this layer */
-        return 0; /* layers below have to fill in the rest */
+	struct inode *inode = ccc_object_inode(obj);
+
+	/*
+	 * lov overwrites most of these fields in
+	 * lov_attr_get()->...lov_merge_lvb_kms(), except when inode
+	 * attributes are newer.
+	 */
+
+	attr->cat_size = i_size_read(inode);
+	attr->cat_mtime = LTIME_S(inode->i_mtime);
+	attr->cat_atime = LTIME_S(inode->i_atime);
+	attr->cat_ctime = LTIME_S(inode->i_ctime);
+	attr->cat_blocks = inode->i_blocks;
+	attr->cat_uid = from_kuid(&init_user_ns, inode->i_uid);
+	attr->cat_gid = from_kgid(&init_user_ns, inode->i_gid);
+	/* KMS is not known by this layer */
+	return 0; /* layers below have to fill in the rest */
 }
 
 static int vvp_attr_set(const struct lu_env *env, struct cl_object *obj,
                         const struct cl_attr *attr, unsigned valid)
 {
-        struct inode *inode = ccc_object_inode(obj);
-
-        if (valid & CAT_UID)
-                inode->i_uid = attr->cat_uid;
-        if (valid & CAT_GID)
-                inode->i_gid = attr->cat_gid;
-        if (0 && valid & CAT_SIZE)
-                i_size_write(inode, attr->cat_size);
-        /* not currently necessary */
-        if (0 && valid & (CAT_UID|CAT_GID|CAT_SIZE))
-                mark_inode_dirty(inode);
-        return 0;
+	struct inode *inode = ccc_object_inode(obj);
+
+	if (valid & CAT_UID)
+		inode->i_uid = make_kuid(&init_user_ns, attr->cat_uid);
+	if (valid & CAT_GID)
+		inode->i_gid = make_kgid(&init_user_ns, attr->cat_gid);
+	if (valid & CAT_ATIME)
+		LTIME_S(inode->i_atime) = attr->cat_atime;
+	if (valid & CAT_MTIME)
+		LTIME_S(inode->i_mtime) = attr->cat_mtime;
+	if (valid & CAT_CTIME)
+		LTIME_S(inode->i_ctime) = attr->cat_ctime;
+	if (0 && valid & CAT_SIZE)
+		cl_isize_write_nolock(inode, attr->cat_size);
+	/* not currently necessary */
+	if (0 && valid & (CAT_UID|CAT_GID|CAT_SIZE))
+		mark_inode_dirty(inode);
+	return 0;
+}
+
+static int vvp_conf_set(const struct lu_env *env, struct cl_object *obj,
+			const struct cl_object_conf *conf)
+{
+	struct ll_inode_info *lli = ll_i2info(conf->coc_inode);
+
+	if (conf->coc_opc == OBJECT_CONF_INVALIDATE) {
+		CDEBUG(D_VFSTRACE, DFID ": losing layout lock\n",
+		       PFID(&lli->lli_fid));
+
+		ll_layout_version_set(lli, LL_LAYOUT_GEN_NONE);
+
+		/* Clean up page mmap for this inode.
+		 * The reason for us to do this is that if the page has
+		 * already been installed into memory space, the process
+		 * can access it without interacting with lustre, so this
+		 * page may be stale due to layout change, and the process
+		 * will never be notified.
+		 * This operation is expensive but mmap processes have to pay
+		 * a price themselves. */
+		unmap_mapping_range(conf->coc_inode->i_mapping,
+				    0, OBD_OBJECT_EOF, 0);
+	}
+	return 0;
+}
+
+static int vvp_prune(const struct lu_env *env, struct cl_object *obj)
+{
+	struct inode *inode = ccc_object_inode(obj);
+	int rc;
+	ENTRY;
+
+	rc = cl_sync_file_range(inode, 0, OBD_OBJECT_EOF, CL_FSYNC_ALL, 1);
+	if (rc == 0)
+		truncate_inode_pages(inode->i_mapping, 0);
+
+	RETURN(rc);
 }
 
 static const struct cl_object_operations vvp_ops = {
-        .coo_page_init = vvp_page_init,
-        .coo_lock_init = vvp_lock_init,
-        .coo_io_init   = vvp_io_init,
-        .coo_attr_get  = vvp_attr_get,
-        .coo_attr_set  = vvp_attr_set,
-        .coo_conf_set  = ccc_conf_set,
-        .coo_glimpse   = ccc_object_glimpse
+	.coo_page_init = vvp_page_init,
+	.coo_lock_init = vvp_lock_init,
+	.coo_io_init   = vvp_io_init,
+	.coo_attr_get  = vvp_attr_get,
+	.coo_attr_set  = vvp_attr_set,
+	.coo_conf_set  = vvp_conf_set,
+	.coo_prune     = vvp_prune,
+	.coo_glimpse   = ccc_object_glimpse
 };
 
 static const struct lu_object_operations vvp_lu_obj_ops = {