struct qsd_type_info;
struct qsd_fsinfo;
+extern struct kmem_cache *upd_kmem;
+
/*
* A QSD instance implements quota enforcement support for a given OSD.
* The instance can be created via qsd_init() and then freed with qsd_fini().
/* name of service which created this qsd instance */
char qsd_svname[MAX_OBD_NAME];
- /* pool ID is always 0 for now */
- int qsd_pool_id;
-
/* dt_device associated with this qsd instance */
struct dt_device *qsd_dev;
*
* This will have to be revisited if new quota types are added in the
* future. For the time being, we can just use an array. */
- struct qsd_qtype_info *qsd_type_array[MAXQUOTAS];
+ struct qsd_qtype_info *qsd_type_array[LL_MAXQUOTAS];
/* per-filesystem quota information */
struct qsd_fsinfo *qsd_fsinfo;
spinlock_t qsd_adjust_lock;
/* dedicated thread for updating slave index files. */
- struct ptlrpc_thread qsd_upd_thread;
+ struct task_struct *qsd_upd_task;
/* list of update tasks */
struct list_head qsd_upd_list;
* enforced here (via procfs) */
int qsd_timeout;
- unsigned long qsd_is_md:1, /* managing quota for mdt */
- qsd_started:1, /* instance is now started */
- qsd_prepared:1, /* qsd_prepare() successfully
+ unsigned long qsd_is_md:1, /* managing quota for mdt */
+ qsd_started:1, /* instance is now started */
+ qsd_prepared:1, /* qsd_prepare() successfully
* called */
- qsd_exp_valid:1,/* qsd_exp is now valid */
- qsd_stopping:1, /* qsd_instance is stopping */
- qsd_acct_failed:1; /* failed to set up acct
- * for one quota type */
+ qsd_exp_valid:1,/* qsd_exp is now valid */
+ qsd_stopping:1; /* qsd_instance is stopping */
+
};
/*
struct lquota_site *qqi_site;
/* Reintegration thread */
- struct ptlrpc_thread qqi_reint_thread;
+ struct task_struct *qqi_reint_task;
/* statistics on operations performed by this slave */
struct lprocfs_stats *qqi_stats;
/* Various flags representing the current state of the slave for this
* quota type. */
- unsigned long qqi_glb_uptodate:1, /* global index uptodate
+ unsigned long qqi_glb_uptodate:1, /* global index uptodate
with master */
- qqi_slv_uptodate:1, /* slave index uptodate
+ qqi_slv_uptodate:1, /* slave index uptodate
with master */
- qqi_reint:1; /* in reintegration or not */
+ qqi_reint:1, /* in reintegration or not */
+ qqi_acct_failed:1; /* failed to setup acct */
/* A list of references to this instance, for debugging */
- struct lu_ref qqi_reference;
+ struct lu_ref qqi_reference;
+
+ /* default quota setting*/
+ __u64 qqi_default_hardlimit;
+ __u64 qqi_default_softlimit;
+ __u64 qqi_default_gracetime;
};
/*
static inline
struct qsd_thread_info *qsd_info(const struct lu_env *env)
{
- struct qsd_thread_info *info;
-
- info = lu_context_key_get(&env->le_ctx, &qsd_thread_key);
- if (info == NULL) {
- lu_env_refill((struct lu_env *)env);
- info = lu_context_key_get(&env->le_ctx, &qsd_thread_key);
- }
- LASSERT(info);
- return info;
+ return lu_env_info(env, &qsd_thread_key);
}
/* helper function to check whether a given quota type is enabled */
int enabled, pool;
LASSERT(qsd != NULL);
- LASSERT(type < MAXQUOTAS);
+ LASSERT(type < LL_MAXQUOTAS);
if (qsd->qsd_fsinfo == NULL)
return 0;
pool = qsd->qsd_is_md ? LQUOTA_RES_MD : LQUOTA_RES_DT;
enabled = qsd->qsd_fsinfo->qfs_enabled[pool - LQUOTA_FIRST_RES];
- return enabled & (1 << type);
+ return enabled & BIT(type);
}
/* helper function to set new qunit and compute associated qtune value */
{
lqe->lqe_edquot = edquot;
if (edquot)
- lqe->lqe_edquot_time = cfs_time_current_64();
+ lqe->lqe_edquot_time = ktime_get_seconds();
}
#define QSD_WB_INTERVAL 60 /* 60 seconds */
/* qsd_lock.c */
extern struct ldlm_enqueue_info qsd_glb_einfo;
extern struct ldlm_enqueue_info qsd_id_einfo;
+void qsd_update_default_quota(struct qsd_qtype_info *qqi, __u64 hardlimit,
+ __u64 softlimit, __u64 gracetime);
int qsd_id_lock_match(struct lustre_handle *, struct lustre_handle *);
int qsd_id_lock_cancel(const struct lu_env *, struct lquota_entry *);
/* qsd_config.c */
struct qsd_fsinfo *qsd_get_fsinfo(char *, bool);
void qsd_put_fsinfo(struct qsd_fsinfo *);
+int qsd_config(char *valstr, char *fsname, int pool);
int qsd_process_config(struct lustre_cfg *);
/* qsd_handler.c */