#define DEBUG_SUBSYSTEM S_MDS
#include <linux/module.h>
+#include <linux/pagemap.h>
#include <dt_object.h>
#include <lustre_acl.h>
nodemap_fileset = nodemap_get_fileset(exp->exp_target_data.ted_nodemap);
if (nodemap_fileset && nodemap_fileset[0]) {
+ CDEBUG(D_INFO, "nodemap fileset is %s\n", nodemap_fileset);
if (fileset) {
/* consider fileset from client as a sub-fileset
* of the nodemap one */
}
if (fileset) {
+ CDEBUG(D_INFO, "Getting fileset %s\n", fileset);
rc = mdt_lookup_fileset(info, fileset, &repbody->mbo_fid1);
if (rc < 0)
GOTO(out, rc = err_serious(rc));
rc = next->md_ops->mdo_statfs(info->mti_env, next, osfs);
if (rc)
GOTO(out, rc);
- spin_lock(&info->mti_mdt->mdt_osfs_lock);
+ spin_lock(&info->mti_mdt->mdt_lock);
info->mti_mdt->mdt_osfs = *osfs;
info->mti_mdt->mdt_osfs_age = cfs_time_current_64();
- spin_unlock(&info->mti_mdt->mdt_osfs_lock);
+ spin_unlock(&info->mti_mdt->mdt_lock);
} else {
/** use cached statfs data */
- spin_lock(&info->mti_mdt->mdt_osfs_lock);
+ spin_lock(&info->mti_mdt->mdt_lock);
*osfs = info->mti_mdt->mdt_osfs;
- spin_unlock(&info->mti_mdt->mdt_osfs_lock);
+ spin_unlock(&info->mti_mdt->mdt_lock);
}
if (rc == 0)
PFID(fid), b->mbo_nlink, b->mbo_mode, b->mbo_valid);
}
- if (info != NULL)
- mdt_body_reverse_idmap(info, b);
-
if (!(attr->la_valid & LA_TYPE))
return;
rc = mdt_attr_get_complex(info, o, ma);
if (unlikely(rc)) {
- CERROR("%s: getattr error for "DFID": rc = %d\n",
+ CDEBUG(rc == -ENOENT ? D_OTHER : D_ERROR,
+ "%s: getattr error for "DFID": rc = %d\n",
mdt_obd_name(info->mti_mdt),
PFID(mdt_object_fid(o)), rc);
RETURN(rc);
repbody->mbo_max_mdsize);
}
- if (exp_connect_rmtclient(info->mti_exp) &&
- reqbody->mbo_valid & OBD_MD_FLRMTPERM) {
- void *buf = req_capsule_server_get(pill, &RMF_ACL);
-
- /* mdt_getattr_lock only */
- rc = mdt_pack_remote_perm(info, o, buf);
- if (rc) {
- repbody->mbo_valid &= ~OBD_MD_FLRMTPERM;
- repbody->mbo_aclsize = 0;
- RETURN(rc);
- } else {
- repbody->mbo_valid |= OBD_MD_FLRMTPERM;
- repbody->mbo_aclsize = sizeof(struct mdt_remote_perm);
- }
- }
#ifdef CONFIG_FS_POSIX_ACL
- else if ((exp_connect_flags(req->rq_export) & OBD_CONNECT_ACL) &&
+ if ((exp_connect_flags(req->rq_export) & OBD_CONNECT_ACL) &&
(reqbody->mbo_valid & OBD_MD_FLACL)) {
struct lu_nodemap *nodemap = nodemap_get_from_exp(exp);
if (IS_ERR(nodemap))
repbody->mbo_eadatasize = 0;
repbody->mbo_aclsize = 0;
- if (reqbody->mbo_valid & OBD_MD_FLRMTPERM)
- rc = mdt_init_ucred(info, reqbody);
- else
- rc = mdt_check_ucred(info);
+ rc = mdt_check_ucred(info);
if (unlikely(rc))
GOTO(out_shrink, rc);
info->mti_cross_ref = !!(reqbody->mbo_valid & OBD_MD_FLCROSSREF);
rc = mdt_getattr_internal(info, obj, 0);
- if (reqbody->mbo_valid & OBD_MD_FLRMTPERM)
- mdt_exit_ucred(info);
EXIT;
out_shrink:
mdt_client_compatibility(info);
*/
static void mdt_swap_lov_flag(struct mdt_object *o1, struct mdt_object *o2)
{
- __u64 o1_flags;
+ unsigned int o1_lov_created = o1->mot_lov_created;
mutex_lock(&o1->mot_lov_mutex);
mutex_lock(&o2->mot_lov_mutex);
- o1_flags = o1->mot_flags;
- o1->mot_flags = (o1->mot_flags & ~MOF_LOV_CREATED) |
- (o2->mot_flags & MOF_LOV_CREATED);
-
- o2->mot_flags = (o2->mot_flags & ~MOF_LOV_CREATED) |
- (o1_flags & MOF_LOV_CREATED);
+ o1->mot_lov_created = o2->mot_lov_created;
+ o2->mot_lov_created = o1_lov_created;
mutex_unlock(&o2->mot_lov_mutex);
mutex_unlock(&o1->mot_lov_mutex);
return rc;
}
+static int mdt_fix_attr_ucred(struct mdt_thread_info *info, __u32 op)
+{
+ struct lu_ucred *uc = mdt_ucred_check(info);
+ struct lu_attr *attr = &info->mti_attr.ma_attr;
+
+ if (uc == NULL)
+ return -EINVAL;
+
+ if (op != REINT_SETATTR) {
+ if ((attr->la_valid & LA_UID) && (attr->la_uid != -1))
+ attr->la_uid = uc->uc_fsuid;
+ /* for S_ISGID, inherit gid from his parent, such work will be
+ * done in cmm/mdd layer, here set all cases as uc->uc_fsgid. */
+ if ((attr->la_valid & LA_GID) && (attr->la_gid != -1))
+ attr->la_gid = uc->uc_fsgid;
+ }
+
+ return 0;
+}
+
static int mdt_reint_internal(struct mdt_thread_info *info,
struct mdt_lock_handle *lhc,
__u32 op)
GOTO(out_nodemap, rc = -EFAULT);
}
- /* map uid/gid for remote client */
id = oqctl->qc_id;
- if (exp_connect_rmtclient(exp)) {
- struct lustre_idmap_table *idmap;
-
- idmap = exp->exp_mdt_data.med_idmap;
-
- if (unlikely(oqctl->qc_cmd != Q_GETQUOTA &&
- oqctl->qc_cmd != Q_GETINFO))
- GOTO(out_nodemap, rc = -EPERM);
-
- if (oqctl->qc_type == USRQUOTA)
- id = lustre_idmap_lookup_uid(NULL, idmap, 0,
- oqctl->qc_id);
- else if (oqctl->qc_type == GRPQUOTA)
- id = lustre_idmap_lookup_gid(NULL, idmap, 0,
- oqctl->qc_id);
- else
- GOTO(out_nodemap, rc = -EINVAL);
-
- if (id == CFS_IDMAP_NOTFOUND) {
- CDEBUG(D_QUOTA, "no mapping for id %u\n", oqctl->qc_id);
- GOTO(out_nodemap, rc = -EACCES);
- }
- }
-
if (oqctl->qc_type == USRQUOTA)
id = nodemap_map_id(nodemap, NODEMAP_UID,
NODEMAP_CLIENT_TO_FS, id);
*/
static int mdt_sec_ctx_handle(struct tgt_session_info *tsi)
{
- int rc;
-
- rc = mdt_handle_idmap(tsi);
- if (unlikely(rc)) {
- struct ptlrpc_request *req = tgt_ses_req(tsi);
- __u32 opc;
-
- opc = lustre_msg_get_opc(req->rq_reqmsg);
- if (opc == SEC_CTX_INIT || opc == SEC_CTX_INIT_CONT)
- sptlrpc_svc_ctx_invalidate(req);
- }
-
CFS_FAIL_TIMEOUT(OBD_FAIL_SEC_CTX_HDL_PAUSE, cfs_fail_val);
- return rc;
+ return 0;
}
/*
int mdt_remote_blocking_ast(struct ldlm_lock *lock, struct ldlm_lock_desc *desc,
void *data, int flag)
{
- struct lustre_handle lockh;
- int rc;
+ int rc = 0;
ENTRY;
switch (flag) {
- case LDLM_CB_BLOCKING:
+ case LDLM_CB_BLOCKING: {
+ struct lustre_handle lockh;
+
ldlm_lock2handle(lock, &lockh);
rc = ldlm_cli_cancel(&lockh,
ldlm_is_atomic_cb(lock) ? 0 : LCF_ASYNC);
RETURN(rc);
}
break;
- case LDLM_CB_CANCELING:
- LDLM_DEBUG(lock, "Revoke remote lock");
+ }
+ case LDLM_CB_CANCELING: {
+ LDLM_DEBUG(lock, "Revoke remote lock\n");
+
/* discard slc lock here so that it can be cleaned anytime,
* especially for cleanup_resource() */
tgt_discard_slc_lock(lock);
+
+ /* once we cache lock, l_ast_data is set to mdt_object */
+ if (lock->l_ast_data != NULL) {
+ struct mdt_object *mo = lock->l_ast_data;
+ struct lu_env env;
+
+ rc = lu_env_init(&env, LCT_MD_THREAD);
+ if (unlikely(rc != 0)) {
+ struct obd_device *obd;
+
+ obd = ldlm_lock_to_ns(lock)->ns_obd;
+ CWARN("%s: lu_env initialization failed, object"
+ "%p "DFID" is leaked!\n",
+ obd->obd_name, mo,
+ PFID(mdt_object_fid(mo)));
+ RETURN(rc);
+ }
+
+ if (lock->l_policy_data.l_inodebits.bits &
+ (MDS_INODELOCK_XATTR | MDS_INODELOCK_UPDATE)) {
+ rc = mo_invalidate(&env, mdt_object_child(mo));
+ mo->mot_cache_attr = 0;
+ }
+ mdt_object_put(&env, mo);
+ lu_env_fini(&env);
+ }
break;
+ }
default:
LBUG();
}
- RETURN(0);
+ RETURN(rc);
}
int mdt_check_resent_lock(struct mdt_thread_info *info,
int mdt_remote_object_lock(struct mdt_thread_info *mti, struct mdt_object *o,
const struct lu_fid *fid, struct lustre_handle *lh,
- enum ldlm_mode mode, __u64 ibits, bool nonblock)
+ enum ldlm_mode mode, __u64 ibits, bool nonblock,
+ bool cache)
{
struct ldlm_enqueue_info *einfo = &mti->mti_einfo;
union ldlm_policy_data *policy = &mti->mti_policy;
einfo->ei_res_id = res_id;
if (nonblock)
einfo->ei_nonblock = 1;
+ if (cache) {
+ /*
+ * if we cache lock, couple lock with mdt_object, so that object
+ * can be easily found in lock ASTs.
+ */
+ mdt_object_get(mti->mti_env, o);
+ einfo->ei_cbdata = o;
+ }
memset(policy, 0, sizeof(*policy));
policy->l_inodebits.bits = ibits;
rc = mo_object_lock(mti->mti_env, mdt_object_child(o), lh, einfo,
policy);
+ if (rc < 0 && cache) {
+ mdt_object_put(mti->mti_env, o);
+ einfo->ei_cbdata = NULL;
+ }
RETURN(rc);
}
rc = mdt_remote_object_lock(info, o, mdt_object_fid(o),
&lh->mlh_rreg_lh,
lh->mlh_rreg_mode,
- MDS_INODELOCK_UPDATE, nonblock);
+ MDS_INODELOCK_UPDATE, nonblock,
+ false);
if (rc != ELDLM_OK) {
if (local_lh != NULL)
mdt_object_unlock(info, o, local_lh, rc);
* \param decref force immediate lock releasing
*/
static void mdt_save_remote_lock(struct mdt_thread_info *info,
- struct lustre_handle *h, enum ldlm_mode mode,
- int decref)
+ struct mdt_object *o, struct lustre_handle *h,
+ enum ldlm_mode mode, int decref)
{
ENTRY;
if (lustre_handle_is_used(h)) {
+ struct ldlm_lock *lock = ldlm_handle2lock(h);
+
+ if (o != NULL &&
+ (lock->l_policy_data.l_inodebits.bits &
+ (MDS_INODELOCK_XATTR | MDS_INODELOCK_UPDATE)))
+ mo_invalidate(info->mti_env, mdt_object_child(o));
+
if (decref || !info->mti_has_trans ||
!(mode & (LCK_PW | LCK_EX))) {
ldlm_lock_decref_and_cancel(h, mode);
+ LDLM_LOCK_PUT(lock);
} else {
- struct ldlm_lock *lock = ldlm_handle2lock(h);
struct ptlrpc_request *req = mdt_info_req(info);
LASSERT(req != NULL);
mdt_save_lock(info, &lh->mlh_pdo_lh, lh->mlh_pdo_mode, decref);
mdt_save_lock(info, &lh->mlh_reg_lh, lh->mlh_reg_mode, decref);
- mdt_save_remote_lock(info, &lh->mlh_rreg_lh, lh->mlh_rreg_mode, decref);
+ mdt_save_remote_lock(info, o, &lh->mlh_rreg_lh, lh->mlh_rreg_mode,
+ decref);
EXIT;
}
static int mdt_tgt_connect(struct tgt_session_info *tsi)
{
- struct ptlrpc_request *req = tgt_ses_req(tsi);
- int rc;
-
- ENTRY;
-
if (OBD_FAIL_CHECK(OBD_FAIL_TGT_DELAY_CONDITIONAL) &&
cfs_fail_val ==
tsi2mdt_info(tsi)->mti_mdt->mdt_seq_site.ss_node_id) {
schedule_timeout(msecs_to_jiffies(3 * MSEC_PER_SEC));
}
- rc = tgt_connect(tsi);
- if (rc != 0)
- RETURN(rc);
-
- rc = mdt_init_idmap(tsi);
- if (rc != 0)
- GOTO(err, rc);
- RETURN(0);
-err:
- obd_disconnect(class_export_get(req->rq_export));
- return rc;
+ return tgt_connect(tsi);
}
enum mdt_it_code {
struct lfsck_stop stop;
ENTRY;
+ if (m->mdt_md_root != NULL) {
+ mdt_object_put(env, m->mdt_md_root);
+ m->mdt_md_root = NULL;
+ }
+
stop.ls_status = LS_PAUSED;
stop.ls_flags = 0;
next->md_ops->mdo_iocontrol(env, next, OBD_IOC_STOP_LFSCK, 0, &stop);
m->mdt_squash.rsi_gid = 0;
INIT_LIST_HEAD(&m->mdt_squash.rsi_nosquash_nids);
init_rwsem(&m->mdt_squash.rsi_sem);
- spin_lock_init(&m->mdt_osfs_lock);
+ spin_lock_init(&m->mdt_lock);
m->mdt_osfs_age = cfs_time_shift_64(-1000);
m->mdt_enable_remote_dir = 0;
m->mdt_enable_remote_dir_gid = 0;
struct mdt_object *mdto = mdt_obj((struct lu_object *)o);
return (*p)(env, cookie,
- LUSTRE_MDT_NAME"-object@%p(flags=%d, writecount=%d)",
- mdto, mdto->mot_flags, mdto->mot_write_count);
+ LUSTRE_MDT_NAME"-object@%p(%s %s, writecount=%d)",
+ mdto, mdto->mot_lov_created ? "lov_created" : "",
+ mdto->mot_cache_attr ? "cache_attr" : "",
+ mdto->mot_write_count);
}
static int mdt_prepare(const struct lu_env *env,
ENTRY;
LASSERT(env != NULL);
+ LASSERT(data != NULL);
+
if (!exp || !obd || !cluuid)
RETURN(-EINVAL);
* XXX: probably not very appropriate method is used now
* at some point we should find a better one
*/
- if (!test_bit(MDT_FL_SYNCED, &mdt->mdt_state) && data != NULL &&
+ if (!test_bit(MDT_FL_SYNCED, &mdt->mdt_state) &&
!(data->ocd_connect_flags & OBD_CONNECT_LIGHTWEIGHT) &&
!(data->ocd_connect_flags & OBD_CONNECT_MDS_MDS)) {
rc = obd_get_info(env, mdt->mdt_child_exp,
INIT_LIST_HEAD(&med->med_open_head);
spin_lock_init(&med->med_open_lock);
- mutex_init(&med->med_idmap_mutex);
- med->med_idmap = NULL;
spin_lock(&exp->exp_lock);
exp->exp_connecting = 1;
spin_unlock(&exp->exp_lock);
{
ENTRY;
- if (exp_connect_rmtclient(exp))
- mdt_cleanup_idmap(&exp->exp_mdt_data);
-
target_destroy_export(exp);
/* destroy can be called from failed obd_setup, so
* checking uuid is safer than obd_self_export */