Whamcloud - gitweb
LU-6158 mdt: always shrink_capsule in getxattr_all
[fs/lustre-release.git] / lustre / mdt / mdt_xattr.c
index 9678397..a7c69cf 100644 (file)
@@ -27,7 +27,7 @@
  * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
  * Use is subject to license terms.
  *
- * Copyright (c) 2011, 2013, Intel Corporation.
+ * Copyright (c) 2011, 2014, Intel Corporation.
  */
 /*
  * This file is part of Lustre, http://www.lustre.org/
@@ -46,6 +46,8 @@
 #define DEBUG_SUBSYSTEM S_MDS
 
 #include <linux/xattr.h>
+#include <obd_class.h>
+#include <lustre_nodemap.h>
 #include <lustre_acl.h>
 #include "mdt_internal.h"
 
@@ -180,10 +182,11 @@ static int mdt_getxattr_all(struct mdt_thread_info *info,
        eadatahead = buf->lb_buf;
 
        /* Fill out EADATA first */
-       eadatasize = mo_xattr_list(env, next, buf);
-       if (eadatasize < 0)
-               GOTO(out, rc = eadatasize);
+       rc = mo_xattr_list(env, next, buf);
+       if (rc < 0)
+               GOTO(out_shrink, rc);
 
+       eadatasize = rc;
        eadatatail = eadatahead + eadatasize;
 
        v = req_capsule_server_get(info->mti_pill, &RMF_EAVALS);
@@ -195,13 +198,19 @@ static int mdt_getxattr_all(struct mdt_thread_info *info,
                buf->lb_len = reqbody->mbo_eadatasize - eavallen;
                rc = mdt_getxattr_one(info, b, next, buf, med, uc);
                if (rc < 0)
-                       GOTO(out, rc);
+                       GOTO(out_shrink, rc);
 
                sizes[eavallens] = rc;
                eavallens++;
                eavallen += rc;
        }
 
+out_shrink:
+       if (rc < 0) {
+               eadatasize = 0;
+               eavallens = 0;
+               eavallen = 0;
+       }
        repbody->mbo_aclsize = eavallen;
        repbody->mbo_max_mdsize = eavallens;
 
@@ -210,8 +219,8 @@ static int mdt_getxattr_all(struct mdt_thread_info *info,
                           eavallens * sizeof(__u32), RCL_SERVER);
        req_capsule_shrink(info->mti_pill, &RMF_EADATA, eadatasize, RCL_SERVER);
 
-       GOTO(out, rc = eadatasize);
-out:
+       if (rc >= 0)
+               RETURN(eadatasize);
        return rc;
 }
 
@@ -227,7 +236,7 @@ int mdt_getxattr(struct mdt_thread_info *info)
         __u32                   remote = exp_connect_rmtclient(info->mti_exp);
         __u32                   perm;
         int                     easize, rc;
-       obd_valid               valid;
+       u64                     valid;
         ENTRY;
 
         LASSERT(info->mti_object != NULL);
@@ -354,27 +363,30 @@ _out:
 int mdt_reint_setxattr(struct mdt_thread_info *info,
                        struct mdt_lock_handle *unused)
 {
-       struct ptlrpc_request   *req = mdt_info_req(info);
-       struct lu_ucred         *uc  = lu_ucred(info->mti_env);
-        struct mdt_lock_handle  *lh;
-        const struct lu_env     *env  = info->mti_env;
-        struct lu_buf           *buf  = &info->mti_buf;
-        struct mdt_reint_record *rr   = &info->mti_rr;
-        struct md_attr          *ma = &info->mti_attr;
-        struct lu_attr          *attr = &info->mti_attr.ma_attr;
-        struct mdt_object       *obj;
-        struct md_object        *child;
-        __u64                    valid = attr->la_valid;
+       struct ptlrpc_request   *req = mdt_info_req(info);
+       struct lu_ucred         *uc  = lu_ucred(info->mti_env);
+       struct mdt_lock_handle  *lh;
+       const struct lu_env     *env  = info->mti_env;
+       struct lu_buf           *buf  = &info->mti_buf;
+       struct mdt_reint_record *rr   = &info->mti_rr;
+       struct md_attr          *ma = &info->mti_attr;
+       struct lu_attr          *attr = &info->mti_attr.ma_attr;
+       struct mdt_object       *obj;
+       struct md_object        *child;
+       struct obd_export       *exp = info->mti_exp;
+       struct lu_nodemap       *nodemap = exp->exp_target_data.ted_nodemap;
+       __u64                    valid = attr->la_valid;
        const char              *xattr_name = rr->rr_name.ln_name;
-        int                      xattr_len = rr->rr_eadatalen;
-        __u64                    lockpart;
-        int                      rc;
-        posix_acl_xattr_header  *new_xattr = NULL;
-        __u32                    remote = exp_connect_rmtclient(info->mti_exp);
-        __u32                    perm;
-        ENTRY;
+       int                      xattr_len = rr->rr_eadatalen;
+       __u64                    lockpart;
+       int                      rc;
+       posix_acl_xattr_header  *new_xattr = NULL;
+       __u32                    remote = exp_connect_rmtclient(info->mti_exp);
+       __u32                    perm;
+       ENTRY;
 
-        CDEBUG(D_INODE, "setxattr for "DFID"\n", PFID(rr->rr_fid1));
+       CDEBUG(D_INODE, "setxattr for "DFID": %s %s\n", PFID(rr->rr_fid1),
+              valid & OBD_MD_FLXATTR ? "set" : "remove", xattr_name);
 
        if (info->mti_dlm_req)
                ldlm_request_cancel(req, info->mti_dlm_req, 0, LATF_SKIP);
@@ -382,9 +394,6 @@ int mdt_reint_setxattr(struct mdt_thread_info *info,
         if (OBD_FAIL_CHECK(OBD_FAIL_MDS_SETXATTR))
                 RETURN(err_serious(-ENOMEM));
 
-        CDEBUG(D_INODE, "%s xattr %s\n",
-               valid & OBD_MD_FLXATTR ? "set" : "remove", xattr_name);
-
        rc = mdt_init_ucred_reint(info);
         if (rc != 0)
                 RETURN(rc);
@@ -419,12 +428,27 @@ int mdt_reint_setxattr(struct mdt_thread_info *info,
                    strcmp(xattr_name, XATTR_NAME_HSM) == 0 ||
                    strcmp(xattr_name, XATTR_NAME_LFSCK_NAMESPACE) == 0)
                        GOTO(out, rc = 0);
+
+#if LUSTRE_VERSION_CODE < OBD_OCD_VERSION(2, 8, 53, 0)
+               if (strcmp(xattr_name, XATTR_NAME_LFSCK_NAMESPACE_OLD) == 0)
+                       GOTO(out, rc = 0);
+#endif
        } else if ((valid & OBD_MD_FLXATTR) &&
                   (strcmp(xattr_name, XATTR_NAME_ACL_ACCESS) == 0 ||
                    strcmp(xattr_name, XATTR_NAME_ACL_DEFAULT) == 0)) {
+
                /* currently lustre limit acl access size */
                if (xattr_len > LUSTRE_POSIX_ACL_MAX_SIZE)
                        GOTO(out, rc = -ERANGE);
+
+               rc = nodemap_map_acl(nodemap, rr->rr_eadata, xattr_len,
+                                    NODEMAP_CLIENT_TO_FS);
+               if (rc < 0)
+                       GOTO(out, rc);
+
+               /* ACLs were mapped out, return an error so the user knows */
+               if (rc != xattr_len)
+                       GOTO(out, rc = -EPERM);
        }
 
         lockpart = MDS_INODELOCK_UPDATE;
@@ -447,8 +471,8 @@ int mdt_reint_setxattr(struct mdt_thread_info *info,
          * to cancel them. */
         mdt_lock_reg_init(lh, LCK_EX);
         obj = mdt_object_find_lock(info, rr->rr_fid1, lh, lockpart);
-        if (IS_ERR(obj))
-                GOTO(out, rc =  PTR_ERR(obj));
+       if (IS_ERR(obj))
+               GOTO(out, rc = PTR_ERR(obj));
 
        tgt_vbr_obj_set(env, mdt_obj2dt(obj));
        rc = mdt_version_get_check_save(info, obj, 0);
@@ -464,46 +488,41 @@ int mdt_reint_setxattr(struct mdt_thread_info *info,
                      PFID(rr->rr_fid1), valid);
                attr->la_ctime = cfs_time_current_sec();
        }
-        attr->la_valid = LA_CTIME;
-        child = mdt_object_child(obj);
-        if (valid & OBD_MD_FLXATTR) {
-                char *xattr = (void *)rr->rr_eadata;
-
-                if (xattr_len > 0) {
-                        int flags = 0;
-
-                        if (valid & OBD_MD_FLRMTLSETFACL) {
-                                if (unlikely(!remote))
-                                        GOTO(out_unlock, rc = -EINVAL);
-
-                                xattr_len = mdt_rmtlsetfacl(info, child,
-                                                xattr_name,
-                                                (ext_acl_xattr_header *)xattr,
-                                                &new_xattr);
-                                if (xattr_len < 0)
-                                        GOTO(out_unlock, rc = xattr_len);
-
-                                xattr = (char *)new_xattr;
-                        }
-
-                        if (attr->la_flags & XATTR_REPLACE)
-                                flags |= LU_XATTR_REPLACE;
-
-                        if (attr->la_flags & XATTR_CREATE)
-                                flags |= LU_XATTR_CREATE;
-
-                        mdt_fail_write(env, info->mti_mdt->mdt_bottom,
-                                       OBD_FAIL_MDS_SETXATTR_WRITE);
-
-                        buf->lb_buf = xattr;
-                        buf->lb_len = xattr_len;
-                        rc = mo_xattr_set(env, child, buf, xattr_name, flags);
-                        /* update ctime after xattr changed */
-                        if (rc == 0) {
-                                ma->ma_attr_flags |= MDS_PERM_BYPASS;
-                                mo_attr_set(env, child, ma);
-                        }
-                }
+       attr->la_valid = LA_CTIME;
+       child = mdt_object_child(obj);
+       if (valid & OBD_MD_FLXATTR) {
+               void   *xattr = rr->rr_eadata;
+               int     flags = 0;
+
+               if (valid & OBD_MD_FLRMTLSETFACL) {
+                       if (unlikely(!remote))
+                               GOTO(out_unlock, rc = -EINVAL);
+
+                       xattr_len = mdt_rmtlsetfacl(info, child, xattr_name,
+                                                   xattr, &new_xattr);
+                       if (xattr_len < 0)
+                               GOTO(out_unlock, rc = xattr_len);
+
+                       xattr = new_xattr;
+               }
+
+               if (attr->la_flags & XATTR_REPLACE)
+                       flags |= LU_XATTR_REPLACE;
+
+               if (attr->la_flags & XATTR_CREATE)
+                       flags |= LU_XATTR_CREATE;
+
+               mdt_fail_write(env, info->mti_mdt->mdt_bottom,
+                              OBD_FAIL_MDS_SETXATTR_WRITE);
+
+               buf->lb_buf = xattr;
+               buf->lb_len = xattr_len;
+               rc = mo_xattr_set(env, child, buf, xattr_name, flags);
+               /* update ctime after xattr changed */
+               if (rc == 0) {
+                       ma->ma_attr_flags |= MDS_PERM_BYPASS;
+                       mo_attr_set(env, child, ma);
+               }
         } else if (valid & OBD_MD_FLXATTRRM) {
                 rc = mo_xattr_del(env, child, xattr_name);
                 /* update ctime after xattr changed */