lustre/mdt/mdt_xattr.c

   1 /*
   2  * GPL HEADER START
   3  *
   4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5  *
   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 only,
   8  * as published by the Free Software Foundation.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License version 2 for more details (a copy is included
  14  * in the LICENSE file that accompanied this code).
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * version 2 along with this program; If not, see
  18  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
  19  *
  20  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
  21  * CA 95054 USA or visit www.sun.com if you need additional information or
  22  * have any questions.
  23  *
  24  * GPL HEADER END
  25  */
  26 /*
  27  * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
  28  * Use is subject to license terms.
  29  *
  30  * Copyright (c) 2011, 2013, Intel Corporation.
  31  */
  32 /*
  33  * This file is part of Lustre, http://www.lustre.org/
  34  * Lustre is a trademark of Sun Microsystems, Inc.
  35  *
  36  * lustre/mdt/mdt_xattr.c
  37  *
  38  * Lustre Metadata Target (mdt) extended attributes management.
  39  *
  40  * Author: Peter Braam <braam@clusterfs.com>
  41  * Author: Andreas Dilger <adilger@clusterfs.com>
  42  * Author: Phil Schwan <phil@clusterfs.com>
  43  * Author: Huang Hua <huanghua@clusterfs.com>
  44  */
  45
  46 #define DEBUG_SUBSYSTEM S_MDS
  47
  48 #include <lustre_acl.h>
  49 #include "mdt_internal.h"
  50
  51
  52 /* return EADATA length to the caller. negative value means error */
  53 static int mdt_getxattr_pack_reply(struct mdt_thread_info * info)
  54 {
  55         struct req_capsule     *pill = info->mti_pill ;
  56         struct ptlrpc_request  *req = mdt_info_req(info);
  57         char                   *xattr_name;
  58         __u64                   valid;
  59         static const char       user_string[] = "user.";
  60         int                     size, rc;
  61         ENTRY;
  62
  63         if (OBD_FAIL_CHECK(OBD_FAIL_MDS_GETXATTR_PACK))
  64                 RETURN(-ENOMEM);
  65
  66         valid = info->mti_body->valid & (OBD_MD_FLXATTR | OBD_MD_FLXATTRLS);
  67
  68         /* Determine how many bytes we need */
  69         if (valid == OBD_MD_FLXATTR) {
  70                 xattr_name = req_capsule_client_get(pill, &RMF_NAME);
  71                 if (!xattr_name)
  72                         RETURN(-EFAULT);
  73
  74                 if (!(exp_connect_flags(req->rq_export) & OBD_CONNECT_XATTR) &&
  75                     !strncmp(xattr_name, user_string, sizeof(user_string) - 1))
  76                         RETURN(-EOPNOTSUPP);
  77
  78                 size = mo_xattr_get(info->mti_env,
  79                                     mdt_object_child(info->mti_object),
  80                                     &LU_BUF_NULL, xattr_name);
  81         } else if (valid == OBD_MD_FLXATTRLS) {
  82                 size = mo_xattr_list(info->mti_env,
  83                                      mdt_object_child(info->mti_object),
  84                                      &LU_BUF_NULL);
  85         } else if (valid == OBD_MD_FLXATTRALL) {
  86                 /* N.B. eadatasize = 0 is not valid for FLXATTRALL */
  87                 /* We could calculate accurate sizes, but this would
  88                  * introduce a lot of overhead, let's do it later... */
  89                 size = info->mti_body->eadatasize;
  90                 req_capsule_set_size(pill, &RMF_EAVALS, RCL_SERVER, size);
  91                 req_capsule_set_size(pill, &RMF_EAVALS_LENS, RCL_SERVER, size);
  92         } else {
  93                 CDEBUG(D_INFO, "Valid bits: "LPX64"\n", info->mti_body->valid);
  94                 RETURN(-EINVAL);
  95         }
  96
  97         if (size == -ENODATA) {
  98                 size = 0;
  99         } else if (size < 0) {
 100                 CERROR("Error geting EA size: %d\n", size);
 101                 RETURN(size);
 102         }
 103
 104         if (info->mti_body->eadatasize != 0 &&
 105             info->mti_body->eadatasize < size)
 106                 RETURN(-ERANGE);
 107
 108         req_capsule_set_size(pill, &RMF_EADATA, RCL_SERVER,
 109                              info->mti_body->eadatasize == 0 ? 0 : size);
 110         rc = req_capsule_server_pack(pill);
 111         if (rc) {
 112                 LASSERT(rc < 0);
 113                 RETURN(rc);
 114         }
 115
 116         RETURN(size);
 117 }
 118
 119 static int
 120 mdt_getxattr_one(struct mdt_thread_info *info,
 121                 char *xattr_name, struct md_object *next,
 122                 struct lu_buf *buf, struct mdt_export_data *med,
 123                 struct lu_ucred *uc)
 124 {
 125         __u32 remote = exp_connect_rmtclient(info->mti_exp);
 126         int flags = CFS_IC_NOTHING, rc;
 127
 128         ENTRY;
 129
 130         CDEBUG(D_INODE, "getxattr %s\n", xattr_name);
 131
 132         rc = mo_xattr_get(info->mti_env, next, buf, xattr_name);
 133         if (rc < 0) {
 134                 CERROR("getxattr failed: %d\n", rc);
 135                 GOTO(out, rc);
 136         }
 137
 138         if (info->mti_body->valid &
 139             (OBD_MD_FLRMTLSETFACL | OBD_MD_FLRMTLGETFACL))
 140                 flags = CFS_IC_ALL;
 141         else if (info->mti_body->valid & OBD_MD_FLRMTRGETFACL)
 142                 flags = CFS_IC_MAPPED;
 143
 144         if (rc > 0 && flags != CFS_IC_NOTHING) {
 145                 int rc1;
 146
 147                 if (unlikely(!remote))
 148                         GOTO(out, rc = -EINVAL);
 149
 150                 rc1 = lustre_posix_acl_xattr_id2client(uc,
 151                                 med->med_idmap,
 152                                 (posix_acl_xattr_header *)(buf->lb_buf),
 153                                 rc, flags);
 154                 if (unlikely(rc1 < 0))
 155                         rc = rc1;
 156         }
 157
 158 out:
 159         return rc;
 160 }
 161
 162 static int mdt_getxattr_all(struct mdt_thread_info *info,
 163                             struct mdt_body *reqbody, struct mdt_body *repbody,
 164                             struct lu_buf *buf, struct md_object *next)
 165 {
 166         const struct lu_env *env = info->mti_env;
 167         struct ptlrpc_request *req = mdt_info_req(info);
 168         struct mdt_export_data *med = mdt_req2med(req);
 169         struct lu_ucred        *uc  = mdt_ucred(info);
 170         char *v, *b, *eadatahead, *eadatatail;
 171         __u32 *sizes;
 172         int eadatasize, eavallen = 0, eavallens = 0, rc;
 173
 174         ENTRY;
 175
 176         /*
 177          * The format of the pill is the following:
 178          * EADATA:      attr1\0attr2\0...attrn\0
 179          * EAVALS:      val1val2...valn
 180          * EAVALS_LENS: 4,4,...4
 181          */
 182
 183         eadatahead = buf->lb_buf;
 184
 185         /* Fill out EADATA first */
 186         eadatasize = mo_xattr_list(env, next, buf);
 187         if (eadatasize < 0)
 188                 GOTO(out, rc = eadatasize);
 189
 190         eadatatail = eadatahead + eadatasize;
 191
 192         v = req_capsule_server_get(info->mti_pill, &RMF_EAVALS);
 193         sizes = req_capsule_server_get(info->mti_pill, &RMF_EAVALS_LENS);
 194
 195         /* Fill out EAVALS and EAVALS_LENS */
 196         for (b = eadatahead; b < eadatatail; b += strlen(b) + 1, v += rc) {
 197                 buf->lb_buf = v;
 198                 buf->lb_len = reqbody->eadatasize - eavallen;
 199                 rc = mdt_getxattr_one(info, b, next, buf, med, uc);
 200                 if (rc < 0)
 201                         GOTO(out, rc);
 202
 203                 sizes[eavallens] = rc;
 204                 eavallens++;
 205                 eavallen += rc;
 206         }
 207
 208         repbody->aclsize = eavallen;
 209         repbody->max_mdsize = eavallens;
 210
 211         req_capsule_shrink(info->mti_pill, &RMF_EAVALS, eavallen, RCL_SERVER);
 212         req_capsule_shrink(info->mti_pill, &RMF_EAVALS_LENS,
 213                            eavallens * sizeof(__u32), RCL_SERVER);
 214         req_capsule_shrink(info->mti_pill, &RMF_EADATA, eadatasize, RCL_SERVER);
 215
 216         GOTO(out, rc = eadatasize);
 217 out:
 218         return rc;
 219 }
 220
 221 int mdt_getxattr(struct mdt_thread_info *info)
 222 {
 223         struct ptlrpc_request  *req = mdt_info_req(info);
 224         struct mdt_export_data *med = mdt_req2med(req);
 225         struct lu_ucred        *uc  = mdt_ucred(info);
 226         struct mdt_body        *reqbody;
 227         struct mdt_body        *repbody = NULL;
 228         struct md_object       *next;
 229         struct lu_buf          *buf;
 230         __u32                   remote = exp_connect_rmtclient(info->mti_exp);
 231         __u32                   perm;
 232         int                     easize, rc;
 233         obd_valid               valid;
 234         ENTRY;
 235
 236         LASSERT(info->mti_object != NULL);
 237         LASSERT(lu_object_assert_exists(&info->mti_object->mot_obj));
 238
 239         CDEBUG(D_INODE, "getxattr "DFID"\n", PFID(&info->mti_body->fid1));
 240
 241         reqbody = req_capsule_client_get(info->mti_pill, &RMF_MDT_BODY);
 242         if (reqbody == NULL)
 243                 RETURN(err_serious(-EFAULT));
 244
 245         rc = mdt_init_ucred(info, reqbody);
 246         if (rc)
 247                 RETURN(err_serious(rc));
 248
 249         next = mdt_object_child(info->mti_object);
 250
 251         if (info->mti_body->valid & OBD_MD_FLRMTRGETFACL) {
 252                 if (unlikely(!remote))
 253                         GOTO(out, rc = err_serious(-EINVAL));
 254
 255                 perm = mdt_identity_get_perm(uc->uc_identity, remote,
 256                                              req->rq_peer.nid);
 257                 if (!(perm & CFS_RMTACL_PERM))
 258                         GOTO(out, rc = err_serious(-EPERM));
 259
 260                 rc = mo_permission(info->mti_env, NULL, next, NULL,
 261                                    MAY_RGETFACL);
 262                 if (rc)
 263                         GOTO(out, rc = err_serious(rc));
 264         }
 265
 266         easize = mdt_getxattr_pack_reply(info);
 267         if (easize < 0)
 268                 GOTO(out, rc = err_serious(easize));
 269
 270         repbody = req_capsule_server_get(info->mti_pill, &RMF_MDT_BODY);
 271         LASSERT(repbody != NULL);
 272
 273         /* No need further getxattr. */
 274         if (easize == 0 || reqbody->eadatasize == 0)
 275                 GOTO(out, rc = easize);
 276
 277         buf = &info->mti_buf;
 278         buf->lb_buf = req_capsule_server_get(info->mti_pill, &RMF_EADATA);
 279         buf->lb_len = easize;
 280
 281         valid = info->mti_body->valid & (OBD_MD_FLXATTR | OBD_MD_FLXATTRLS);
 282
 283         if (valid == OBD_MD_FLXATTR) {
 284                 char *xattr_name = req_capsule_client_get(info->mti_pill,
 285                                                           &RMF_NAME);
 286                 rc = mdt_getxattr_one(info, xattr_name, next, buf, med, uc);
 287         } else if (valid == OBD_MD_FLXATTRLS) {
 288                 CDEBUG(D_INODE, "listxattr\n");
 289
 290                 rc = mo_xattr_list(info->mti_env, next, buf);
 291                 if (rc < 0)
 292                         CDEBUG(D_INFO, "listxattr failed: %d\n", rc);
 293         } else if (valid == OBD_MD_FLXATTRALL) {
 294                 rc = mdt_getxattr_all(info, reqbody, repbody,
 295                                       buf, next);
 296         } else
 297                 LBUG();
 298
 299         EXIT;
 300 out:
 301         if (rc >= 0) {
 302                 mdt_counter_incr(req, LPROC_MDT_GETXATTR);
 303                 repbody->eadatasize = rc;
 304                 rc = 0;
 305         }
 306         mdt_exit_ucred(info);
 307         return rc;
 308 }
 309
 310 static int mdt_rmtlsetfacl(struct mdt_thread_info *info,
 311                            struct md_object *next,
 312                            const char *xattr_name,
 313                            ext_acl_xattr_header *header,
 314                            posix_acl_xattr_header **out)
 315 {
 316         struct ptlrpc_request  *req = mdt_info_req(info);
 317         struct mdt_export_data *med = mdt_req2med(req);
 318         struct lu_ucred        *uc = mdt_ucred(info);
 319         struct lu_buf          *buf = &info->mti_buf;
 320         int                     rc;
 321         ENTRY;
 322
 323         rc = lustre_ext_acl_xattr_id2server(uc, med->med_idmap, header);
 324         if (rc)
 325                 RETURN(rc);
 326
 327         rc = mo_xattr_get(info->mti_env, next, &LU_BUF_NULL, xattr_name);
 328         if (rc == -ENODATA)
 329                 rc = 0;
 330         else if (rc < 0)
 331                 RETURN(rc);
 332
 333         buf->lb_len = rc;
 334         if (buf->lb_len > 0) {
 335                 OBD_ALLOC_LARGE(buf->lb_buf, buf->lb_len);
 336                 if (unlikely(buf->lb_buf == NULL))
 337                         RETURN(-ENOMEM);
 338
 339                 rc = mo_xattr_get(info->mti_env, next, buf, xattr_name);
 340                 if (rc < 0) {
 341                         CERROR("getxattr failed: %d\n", rc);
 342                         GOTO(_out, rc);
 343                 }
 344         } else
 345                 buf->lb_buf = NULL;
 346
 347         rc = lustre_acl_xattr_merge2posix((posix_acl_xattr_header *)(buf->lb_buf),
 348                                           buf->lb_len, header, out);
 349         EXIT;
 350
 351 _out:
 352         if (rc <= 0 && buf->lb_buf != NULL)
 353                 OBD_FREE_LARGE(buf->lb_buf, buf->lb_len);
 354         return rc;
 355 }
 356
 357 int mdt_reint_setxattr(struct mdt_thread_info *info,
 358                        struct mdt_lock_handle *unused)
 359 {
 360         struct ptlrpc_request   *req = mdt_info_req(info);
 361         struct lu_ucred         *uc  = mdt_ucred(info);
 362         struct mdt_lock_handle  *lh;
 363         const struct lu_env     *env  = info->mti_env;
 364         struct lu_buf           *buf  = &info->mti_buf;
 365         struct mdt_reint_record *rr   = &info->mti_rr;
 366         struct md_attr          *ma = &info->mti_attr;
 367         struct lu_attr          *attr = &info->mti_attr.ma_attr;
 368         struct mdt_object       *obj;
 369         struct md_object        *child;
 370         __u64                    valid = attr->la_valid;
 371         const char              *xattr_name = rr->rr_name;
 372         int                      xattr_len = rr->rr_eadatalen;
 373         __u64                    lockpart;
 374         int                      rc;
 375         posix_acl_xattr_header  *new_xattr = NULL;
 376         __u32                    remote = exp_connect_rmtclient(info->mti_exp);
 377         __u32                    perm;
 378         ENTRY;
 379
 380         CDEBUG(D_INODE, "setxattr for "DFID"\n", PFID(rr->rr_fid1));
 381
 382         if (info->mti_dlm_req)
 383                 ldlm_request_cancel(req, info->mti_dlm_req, 0);
 384
 385         if (OBD_FAIL_CHECK(OBD_FAIL_MDS_SETXATTR))
 386                 RETURN(err_serious(-ENOMEM));
 387
 388         CDEBUG(D_INODE, "%s xattr %s\n",
 389                valid & OBD_MD_FLXATTR ? "set" : "remove", xattr_name);
 390
 391         rc = mdt_init_ucred_reint(info);
 392         if (rc != 0)
 393                 RETURN(rc);
 394
 395         if (valid & OBD_MD_FLRMTRSETFACL) {
 396                 if (unlikely(!remote))
 397                         GOTO(out, rc = err_serious(-EINVAL));
 398
 399                 perm = mdt_identity_get_perm(uc->uc_identity, remote,
 400                                              req->rq_peer.nid);
 401                 if (!(perm & CFS_RMTACL_PERM))
 402                         GOTO(out, rc = err_serious(-EPERM));
 403         }
 404
 405         if (strncmp(xattr_name, XATTR_USER_PREFIX,
 406                     sizeof(XATTR_USER_PREFIX) - 1) == 0) {
 407                 if (!(exp_connect_flags(req->rq_export) & OBD_CONNECT_XATTR))
 408                         GOTO(out, rc = -EOPNOTSUPP);
 409                 if (strcmp(xattr_name, XATTR_NAME_LOV) == 0)
 410                         GOTO(out, rc = -EACCES);
 411                 if (strcmp(xattr_name, XATTR_NAME_LMA) == 0)
 412                         GOTO(out, rc = 0);
 413                 if (strcmp(xattr_name, XATTR_NAME_LINK) == 0)
 414                         GOTO(out, rc = 0);
 415         } else if ((valid & OBD_MD_FLXATTR) &&
 416                    (strncmp(xattr_name, XATTR_NAME_ACL_ACCESS,
 417                             sizeof(XATTR_NAME_ACL_ACCESS) - 1) == 0 ||
 418                     strncmp(xattr_name, XATTR_NAME_ACL_DEFAULT,
 419                             sizeof(XATTR_NAME_ACL_DEFAULT) - 1) == 0)) {
 420                 /* currently lustre limit acl access size */
 421                 if (xattr_len > LUSTRE_POSIX_ACL_MAX_SIZE)
 422                         GOTO(out, -ERANGE);
 423         }
 424
 425         lockpart = MDS_INODELOCK_UPDATE;
 426         /* Revoke all clients' lookup lock, since the access
 427          * permissions for this inode is changed when ACL_ACCESS is
 428          * set. This isn't needed for ACL_DEFAULT, since that does
 429          * not change the access permissions of this inode, nor any
 430          * other existing inodes. It is setting the ACLs inherited
 431          * by new directories/files at create time. */
 432         /* We need revoke both LOOKUP|PERM lock here, see mdt_attr_set. */
 433         if (!strcmp(xattr_name, XATTR_NAME_ACL_ACCESS))
 434                 lockpart |= MDS_INODELOCK_PERM | MDS_INODELOCK_LOOKUP;
 435         /* We need to take the lock on behalf of old clients so that newer
 436          * clients flush their xattr caches */
 437         else
 438                 lockpart |= MDS_INODELOCK_XATTR;
 439
 440         lh = &info->mti_lh[MDT_LH_PARENT];
 441         /* ACLs were sent to clients under LCK_CR locks, so taking LCK_EX
 442          * to cancel them. */
 443         mdt_lock_reg_init(lh, LCK_EX);
 444         obj = mdt_object_find_lock(info, rr->rr_fid1, lh, lockpart);
 445         if (IS_ERR(obj))
 446                 GOTO(out, rc =  PTR_ERR(obj));
 447
 448         info->mti_mos = obj;
 449         rc = mdt_version_get_check_save(info, obj, 0);
 450         if (rc)
 451                 GOTO(out_unlock, rc);
 452
 453         if (unlikely(!(valid & OBD_MD_FLCTIME))) {
 454                 /* This isn't strictly an error, but all current clients
 455                  * should set OBD_MD_FLCTIME when setting attributes. */
 456                 CWARN("%s: client miss to set OBD_MD_FLCTIME when "
 457                       "setxattr %s: [object "DFID"] [valid "LPU64"]\n",
 458                       mdt_obd_name(info->mti_mdt), xattr_name,
 459                       PFID(rr->rr_fid1), valid);
 460                 attr->la_ctime = cfs_time_current_sec();
 461         }
 462         attr->la_valid = LA_CTIME;
 463         child = mdt_object_child(obj);
 464         if (valid & OBD_MD_FLXATTR) {
 465                 char *xattr = (void *)rr->rr_eadata;
 466
 467                 if (xattr_len > 0) {
 468                         int flags = 0;
 469
 470                         if (valid & OBD_MD_FLRMTLSETFACL) {
 471                                 if (unlikely(!remote))
 472                                         GOTO(out_unlock, rc = -EINVAL);
 473
 474                                 xattr_len = mdt_rmtlsetfacl(info, child,
 475                                                 xattr_name,
 476                                                 (ext_acl_xattr_header *)xattr,
 477                                                 &new_xattr);
 478                                 if (xattr_len < 0)
 479                                         GOTO(out_unlock, rc = xattr_len);
 480
 481                                 xattr = (char *)new_xattr;
 482                         }
 483
 484                         if (attr->la_flags & XATTR_REPLACE)
 485                                 flags |= LU_XATTR_REPLACE;
 486
 487                         if (attr->la_flags & XATTR_CREATE)
 488                                 flags |= LU_XATTR_CREATE;
 489
 490                         mdt_fail_write(env, info->mti_mdt->mdt_bottom,
 491                                        OBD_FAIL_MDS_SETXATTR_WRITE);
 492
 493                         buf->lb_buf = xattr;
 494                         buf->lb_len = xattr_len;
 495                         rc = mo_xattr_set(env, child, buf, xattr_name, flags);
 496                         /* update ctime after xattr changed */
 497                         if (rc == 0) {
 498                                 ma->ma_attr_flags |= MDS_PERM_BYPASS;
 499                                 mo_attr_set(env, child, ma);
 500                         }
 501                 }
 502         } else if (valid & OBD_MD_FLXATTRRM) {
 503                 rc = mo_xattr_del(env, child, xattr_name);
 504                 /* update ctime after xattr changed */
 505                 if (rc == 0) {
 506                         ma->ma_attr_flags |= MDS_PERM_BYPASS;
 507                         mo_attr_set(env, child, ma);
 508                 }
 509         } else {
 510                 CDEBUG(D_INFO, "valid bits: "LPX64"\n", valid);
 511                 rc = -EINVAL;
 512         }
 513         if (rc == 0)
 514                 mdt_counter_incr(req, LPROC_MDT_SETXATTR);
 515
 516         EXIT;
 517 out_unlock:
 518         mdt_object_unlock_put(info, obj, lh, rc);
 519         if (unlikely(new_xattr != NULL))
 520                 lustre_posix_acl_xattr_free(new_xattr, xattr_len);
 521 out:
 522         mdt_exit_ucred(info);
 523         return rc;
 524 }