X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fquota%2Fqsd_entry.c;h=f4e26a02b87739869bbf143694568867780358c2;hb=25670bb8c21deb64cfbb277bdeeab6e7ee39aa0e;hp=b27d329c38514ff118c806433cb4bb7bdaa44be2;hpb=d943c6afe74f6e0d371120ade8bed55c5d60b67a;p=fs%2Flustre-release.git diff --git a/lustre/quota/qsd_entry.c b/lustre/quota/qsd_entry.c index b27d329..f4e26a0 100644 --- a/lustre/quota/qsd_entry.c +++ b/lustre/quota/qsd_entry.c @@ -21,17 +21,13 @@ * GPL HEADER END */ /* - * Copyright (c) 2011, 2012, Intel, Inc. + * Copyright (c) 2012, Intel Corporation. * Use is subject to license terms. * - * Author: Johann Lombardi - * Author: Niu Yawei + * Author: Johann Lombardi + * Author: Niu Yawei */ -#ifndef EXPORT_SYMTAB -# define EXPORT_SYMTAB -#endif - #define DEBUG_SUBSYSTEM S_LQUOTA #include "qsd_internal.h" @@ -47,11 +43,11 @@ static void qsd_lqe_init(struct lquota_entry *lqe, void *arg) LASSERT(!lqe_is_master(lqe)); /* initialize slave parameters */ - cfs_rwlock_init(&lqe->lqe_lock); + rwlock_init(&lqe->lqe_lock); memset(&lqe->lqe_lockh, 0, sizeof(lqe->lqe_lockh)); lqe->lqe_pending_write = 0; lqe->lqe_pending_req = 0; - cfs_waitq_init(&lqe->lqe_waiters); + init_waitqueue_head(&lqe->lqe_waiters); lqe->lqe_usage = 0; lqe->lqe_nopreacq = false; } @@ -93,8 +89,8 @@ static int qsd_lqe_read(const struct lu_env *env, struct lquota_entry *lqe, lqe->lqe_enforced = true; break; default: - LQUOTA_ERROR(lqe, "failed to read quota entry from global index" - "copy, rc:%d", rc); + LQUOTA_ERROR(lqe, "failed to read quota entry from global " + "index copy, rc:%d", rc); return rc; } @@ -110,8 +106,8 @@ static int qsd_lqe_read(const struct lu_env *env, struct lquota_entry *lqe, lqe->lqe_granted = qti->qti_slv_rec.qsr_granted; break; default: - LQUOTA_ERROR(lqe, "failed to read quota entry from slave index" - "copy, rc:%d", rc); + LQUOTA_ERROR(lqe, "failed to read quota entry from slave " + "index copy, rc:%d", rc); return rc; } @@ -261,7 +257,6 @@ int qsd_update_index(const struct lu_env *env, struct qsd_qtype_info *qqi, if (rc) GOTO(out, rc); - /* write lock lquota entry */ if (global) { /* Update record in global index copy */ struct lquota_glb_rec *glb_rec = (struct lquota_glb_rec *)rec; @@ -314,14 +309,11 @@ out: int qsd_update_lqe(const struct lu_env *env, struct lquota_entry *lqe, bool global, void *rec) { - struct qsd_qtype_info *qqi; ENTRY; LASSERT(lqe != NULL); LASSERT(!lqe_is_master(lqe)); - qqi = lqe2qqi(lqe); - /* updating lqe is always serialized, no locking needed. */ if (global) { struct lquota_glb_rec *glb_rec = (struct lquota_glb_rec *)rec; @@ -331,7 +323,7 @@ int qsd_update_lqe(const struct lu_env *env, struct lquota_entry *lqe, glb_rec->qbr_softlimit) ? true : false; LQUOTA_DEBUG(lqe, "updating global index hardlimit: "LPU64", " - "softlimit: "LPU64"\n", glb_rec->qbr_hardlimit, + "softlimit: "LPU64, glb_rec->qbr_hardlimit, glb_rec->qbr_softlimit); } else { struct lquota_slv_rec *slv_rec = (struct lquota_slv_rec *)rec;