X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lustre%2Fquota%2Flquota_internal.h;h=43bcb4b39d07cfd08cb22a6c57eb958aaf486662;hp=1e530540d5bed526b4e9934110749bfecf0f30d6;hb=c20b866ba374ea38237f0e0c8f5b1bc9bb370985;hpb=92c24af6c7c9d0836bf866975bc0a1d641a4a815 diff --git a/lustre/quota/lquota_internal.h b/lustre/quota/lquota_internal.h index 1e53054..43bcb4b 100644 --- a/lustre/quota/lquota_internal.h +++ b/lustre/quota/lquota_internal.h @@ -21,7 +21,7 @@ * GPL HEADER END */ /* - * Copyright (c) 2012, Intel Corporation. + * Copyright (c) 2012, 2017, Intel Corporation. * Use is subject to license terms. */ @@ -31,7 +31,6 @@ #ifndef _LQUOTA_INTERNAL_H #define _LQUOTA_INTERNAL_H -#define QTYPE_NAME(qtype) ((qtype) == USRQUOTA ? "usr" : "grp") #define RES_NAME(res) ((res) == LQUOTA_RES_MD ? "md" : "dt") #define QIF_IFLAGS (QIF_INODES | QIF_ITIME | QIF_ILIMITS) @@ -46,10 +45,26 @@ enum lquota_local_oid { LQUOTA_USR_OID = 1UL, /* slave index copy for user quota */ LQUOTA_GRP_OID = 2UL, /* slave index copy for group quota */ + LQUOTA_PRJ_OID = 3UL, /* slave index copy for project quota */ /* all OIDs after this are allocated dynamically by the QMT */ LQUOTA_GENERATED_OID = 4096UL, }; +static inline __u32 qtype2slv_oid(int qtype) +{ + switch (qtype) { + case USRQUOTA: + return LQUOTA_USR_OID; + case GRPQUOTA: + return LQUOTA_GRP_OID; + case PRJQUOTA: + return LQUOTA_PRJ_OID; + } + + /* should not come here, just make compile happy */ + return LQUOTA_USR_OID; +} + /* * lquota_entry support */ @@ -61,12 +76,12 @@ struct lquota_entry_operations { /* Read quota settings from disk and update lquota entry */ int (*lqe_read)(const struct lu_env *, struct lquota_entry *, - void *arg); + void *arg, bool find); /* Print debug information about a given lquota entry */ void (*lqe_debug)(struct lquota_entry *, void *, - struct libcfs_debug_msg_data *, const char *, - va_list); + struct libcfs_debug_msg_data *, + struct va_format *vaf); }; /* Per-ID information specific to the quota master target */ @@ -81,7 +96,7 @@ struct lquota_mst_entry { __u64 lme_gracetime; /* last time we glimpsed */ - __u64 lme_revoke_time; + time64_t lme_revoke_time; /* r/w semaphore used to protect concurrent access to the quota * parameters which are stored on disk */ @@ -116,26 +131,29 @@ struct lquota_slv_entry { rwlock_t lse_lock; /* waiter for pending request done */ - cfs_waitq_t lse_waiters; + wait_queue_head_t lse_waiters; /* hint on current on-disk usage, in inodes or kbytes */ __u64 lse_usage; /* time to trigger quota adjust */ - __u64 lse_adjust_time; + time64_t lse_adjust_time; /* return code of latest acquire RPC */ int lse_acq_rc; /* when latest acquire RPC completed */ - __u64 lse_acq_time; + time64_t lse_acq_time; + + /* when latest edquot set */ + time64_t lse_edquot_time; }; /* In-memory entry for each enforced quota id * A lquota_entry structure belong to a single lquota_site */ struct lquota_entry { /* link to site hash table */ - cfs_hlist_node_t lqe_hash; + struct hlist_node lqe_hash; /* quota identifier associated with this entry */ union lquota_id lqe_id; @@ -144,15 +162,17 @@ struct lquota_entry { struct lquota_site *lqe_site; /* reference counter */ - cfs_atomic_t lqe_ref; + atomic_t lqe_ref; /* linked to list of lqes which: * - need quota space adjustment on slave * - need glimpse to be sent on master */ - cfs_list_t lqe_link; + struct list_head lqe_link; /* current quota settings/usage of this ID */ __u64 lqe_granted; /* granted limit, inodes or kbytes */ + /* used in quota pool recalc process (only on QMT) */ + __u64 lqe_recalc_granted; __u64 lqe_qunit; /* [ib]unit size, inodes or kbytes */ union { struct lquota_mst_entry me; /* params specific to QMT */ @@ -160,11 +180,37 @@ struct lquota_entry { } u; /* flags describing the state of the lquota_entry */ - unsigned long lqe_enforced:1,/* quota enforced or not */ - lqe_uptodate:1,/* successfully read from disk */ - lqe_edquot:1, /* id out of quota space on QMT */ - lqe_gl:1, /* glimpse is in progress */ - lqe_nopreacq:1;/* pre-acquire disabled */ + unsigned long lqe_enforced:1, /* quota enforced or not */ + lqe_uptodate:1, /* successfully read from disk */ + lqe_edquot:1, /* id out of quota space on QMT */ + lqe_gl:1, /* glimpse is in progress */ + lqe_nopreacq:1, /* pre-acquire disabled */ + lqe_is_default:1, /* the default quota is used */ + lqe_is_global:1; /* lqe belongs to global pool "0x0"*/ + + struct lqe_glbl_data *lqe_glbl_data; +}; + +#define lqe_qtype(lqe) (lqe->lqe_site->lqs_qtype) +#define lqe_rtype(lqe) (lqe2qpi(lqe)->qpi_rtype) + +struct lqe_glbl_entry { + __u64 lge_qunit; + unsigned long lge_edquot:1, + /* true when minimum qunit is set */ + lge_qunit_set:1, + /* qunit or edquot is changed - need + * to send glimpse to appropriate slave */ + lge_qunit_nu:1, + lge_edquot_nu:1; +}; + +struct lqe_glbl_data { + struct lqe_glbl_entry *lqeg_arr; + /* number of initialised entries */ + int lqeg_num_used; + /* number of allocated entries */ + int lqeg_num_alloc; }; /* Compartment within which lquota_entry are unique. @@ -172,7 +218,7 @@ struct lquota_entry { * present. */ struct lquota_site { /* Hash table storing lquota_entry structures */ - cfs_hash_t *lqs_hash; + struct cfs_hash *lqs_hash; /* Quota type, either user or group. */ int lqs_qtype; @@ -182,7 +228,7 @@ struct lquota_site { /* Vector of operations which can be done on lquota entry belonging to * this quota site */ - struct lquota_entry_operations *lqs_ops; + const struct lquota_entry_operations *lqs_ops; /* Backpointer to parent structure, either QMT pool info for master or * QSD for slave */ @@ -208,15 +254,18 @@ struct lquota_site { #define lqe_lockh u.se.lse_lockh #define lqe_acq_rc u.se.lse_acq_rc #define lqe_acq_time u.se.lse_acq_time +#define lqe_edquot_time u.se.lse_edquot_time #define LQUOTA_BUMP_VER 0x1 #define LQUOTA_SET_VER 0x2 +extern struct kmem_cache *lqe_kmem; + /* helper routine to get/put reference on lquota_entry */ static inline void lqe_getref(struct lquota_entry *lqe) { LASSERT(lqe != NULL); - cfs_atomic_inc(&lqe->lqe_ref); + atomic_inc(&lqe->lqe_ref); } static inline void lqe_putref(struct lquota_entry *lqe) @@ -224,7 +273,7 @@ static inline void lqe_putref(struct lquota_entry *lqe) LASSERT(lqe != NULL); LASSERT(atomic_read(&lqe->lqe_ref) > 0); if (atomic_dec_and_test(&lqe->lqe_ref)) - OBD_FREE_PTR(lqe); + OBD_SLAB_FREE_PTR(lqe, lqe_kmem); } static inline int lqe_is_master(struct lquota_entry *lqe) @@ -273,8 +322,20 @@ static inline void lqe_read_unlock(struct lquota_entry *lqe) #define LQUOTA_LEAST_QUNIT(type) \ (type == LQUOTA_RES_MD ? (1 << 10) : toqb(OFD_MAX_BRW_SIZE)) -#define LQUOTA_OVER_FL(type) \ - (type == USRQUOTA ? QUOTA_FL_OVER_USRQUOTA : QUOTA_FL_OVER_GRPQUOTA) +static inline enum osd_quota_local_flags lquota_over_fl(int qtype) +{ + switch (qtype) { + case USRQUOTA: + return QUOTA_FL_OVER_USRQUOTA; + case GRPQUOTA: + return QUOTA_FL_OVER_GRPQUOTA; + case PRJQUOTA: + return QUOTA_FL_OVER_PRJQUOTA; + } + + /* should not come here, just make compile happy */ + return QUOTA_FL_OVER_USRQUOTA; +} /* Common data shared by quota-level handlers. This is allocated per-thread to * reduce stack consumption */ @@ -283,7 +344,6 @@ struct lquota_thread_info { struct lu_buf qti_lb; struct lu_attr qti_attr; struct dt_object_format qti_dof; - struct lustre_mdt_attrs qti_lma; struct lu_fid qti_fid; char qti_buf[LQUOTA_NAME_MAX]; }; @@ -301,15 +361,7 @@ extern struct lu_context_key lquota_thread_key; static inline struct lquota_thread_info *lquota_info(const struct lu_env *env) { - struct lquota_thread_info *info; - - info = lu_context_key_get(&env->le_ctx, &lquota_thread_key); - if (info == NULL) { - lu_env_refill((struct lu_env *)env); - info = lu_context_key_get(&env->le_ctx, &lquota_thread_key); - } - LASSERT(info); - return info; + return lu_env_info(env, &lquota_thread_key); } #define req_is_acq(flags) ((flags & QUOTA_DQACQ_FL_ACQ) != 0) @@ -333,7 +385,7 @@ void lquota_lqe_debug0(struct lquota_entry *lqe, __attribute__ ((format (printf, 3, 4))); #define LQUOTA_DEBUG_LIMIT(mask, lqe, fmt, a...) do { \ - static cfs_debug_limit_state_t _lquota_cdls; \ + static struct cfs_debug_limit_state _lquota_cdls; \ LIBCFS_DEBUG_MSG_DATA_DECL(msgdata, mask, &_lquota_cdls); \ lquota_lqe_debug(&msgdata, mask, &_lquota_cdls, lqe, "$$$ "fmt" ", \ ##a); \ @@ -345,11 +397,37 @@ void lquota_lqe_debug0(struct lquota_entry *lqe, #define LQUOTA_CONSOLE(lqe, fmt, a...) \ LQUOTA_DEBUG_LIMIT(D_CONSOLE, lqe, fmt, ## a) -#define LQUOTA_DEBUG(lock, fmt, a...) do { \ +#define LQUOTA_ELEVEL_LQES(level, env, fmt, a...) do { \ + int i; \ + for (i = 0; i < qti_lqes_cnt(env); i++) { \ + LQUOTA_##level(qti_lqes(env)[i], fmt, ##a); \ + } \ +} while (0) +#define LQUOTA_WARN_LQES(lqe, fmt, a...) \ + LQUOTA_ELEVEL_LQES(WARN, env, fmt, ##a) +#define LQUOTA_CONSOLE_LQES(lqe, fmt, a...) \ + LQUOTA_ELEVEL_LQES(CONSOLE, env, fmt, ##a) +#define LQUOTA_ERROR_LQES(lqe, fmt, a...) \ + LQUOTA_ELEVEL_LQES(ERROR, env, fmt, ##a) + +#define LQUOTA_DEBUG(lqe, fmt, a...) do { \ LIBCFS_DEBUG_MSG_DATA_DECL(msgdata, D_QUOTA, NULL); \ lquota_lqe_debug(&msgdata, D_QUOTA, NULL, lqe, "$$$ "fmt" ", ##a); \ } while (0) + +#define LQUOTA_DEBUG_LQES(env, fmt, a...) do { \ + int i; \ + for (i = 0; i < qti_lqes_cnt(env); i++) { \ + LQUOTA_DEBUG(qti_lqes(env)[i], fmt, ##a); \ + } \ +} while (0) + + #else /* !LIBCFS_DEBUG */ +# define LQUOTA_DEBUG_LQES(lqe, fmt, a...) ((void)0) +# define LQUOTA_ERROR_LQES(lqe, fmt, a...) ((void)0) +# define LQUOTA_WARN_LQES(lqe, fmt, a...) ((void)0) +# define LQUOTA_CONSOLE_LQES(lqe, fmt, a...) ((void)0) # define LQUOTA_DEBUG(lqe, fmt, a...) ((void)0) # define LQUOTA_ERROR(lqe, fmt, a...) ((void)0) # define LQUOTA_WARN(lqe, fmt, a...) ((void)0) @@ -361,19 +439,22 @@ void lquota_lqe_debug0(struct lquota_entry *lqe, /* lquota_lib.c */ struct dt_object *acct_obj_lookup(const struct lu_env *, struct dt_device *, int); -void lquota_generate_fid(struct lu_fid *, int, int, int); -int lquota_extract_fid(const struct lu_fid *, int *, int *, int *); +void lquota_generate_fid(struct lu_fid *, int, int); +int lquota_extract_fid(const struct lu_fid *, int *, int *); const struct dt_index_features *glb_idx_feature(struct lu_fid *); -extern cfs_mem_cache_t *lqe_kmem; /* lquota_entry.c */ /* site create/destroy */ -struct lquota_site *lquota_site_alloc(const struct lu_env *, void *, bool, - short, struct lquota_entry_operations *); +struct lquota_site *lquota_site_alloc(const struct lu_env *env, void *parent, + bool master, short qtype, + const struct lquota_entry_operations *op); void lquota_site_free(const struct lu_env *, struct lquota_site *); /* quota entry operations */ -struct lquota_entry *lqe_locate(const struct lu_env *, struct lquota_site *, - union lquota_id *); +#define lqe_locate(env, site, id) lqe_locate_find(env, site, id, false) +#define lqe_find(env, site, id) lqe_locate_find(env, site, id, true) +struct lquota_entry *lqe_locate_find(const struct lu_env *, + struct lquota_site *, + union lquota_id *, bool); /* lquota_disk.c */ struct dt_object *lquota_disk_dir_find_create(const struct lu_env *, @@ -405,13 +486,15 @@ int lquota_disk_write(const struct lu_env *, struct thandle *, __u32, __u64 *); int lquota_disk_update_ver(const struct lu_env *, struct dt_device *, struct dt_object *, __u64); +int lquota_disk_write_glb(const struct lu_env *, struct dt_object *, __u64, + struct lquota_glb_rec *); /* qmt_dev.c */ int qmt_glb_init(void); void qmt_glb_fini(void); /* lproc_quota.c */ -extern struct file_operations lprocfs_quota_seq_fops; +extern const struct file_operations lprocfs_quota_seq_fops; /* qsd_lib.c */ int qsd_glb_init(void);