X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lustre%2Fquota%2Fqsd_lib.c;h=a9307b7e03eecd5558e6e76f81b77604bdf6b27b;hp=9d9887c908825969e2a381618be75765c9318adf;hb=0ad4f8a4227ed7dd93fec99d33c6bb25056473fc;hpb=c4beaea00ab812cf526c119ee0df35779d2bb470 diff --git a/lustre/quota/qsd_lib.c b/lustre/quota/qsd_lib.c index 9d9887c..a9307b7 100644 --- a/lustre/quota/qsd_lib.c +++ b/lustre/quota/qsd_lib.c @@ -207,11 +207,15 @@ qsd_timeout_seq_write(struct file *file, const char *buffer, } LPROC_SEQ_FOPS(qsd_timeout); -static struct lprocfs_seq_vars lprocfs_quota_qsd_vars[] = { - { "info", &qsd_state_fops }, - { "enabled", &qsd_enabled_fops }, - { "force_reint", &qsd_force_reint_fops }, - { "timeout", &qsd_timeout_fops }, +static struct lprocfs_vars lprocfs_quota_qsd_vars[] = { + { .name = "info", + .fops = &qsd_state_fops }, + { .name = "enabled", + .fops = &qsd_enabled_fops }, + { .name = "force_reint", + .fops = &qsd_force_reint_fops }, + { .name = "timeout", + .fops = &qsd_timeout_fops }, { NULL } }; @@ -277,8 +281,8 @@ static void qsd_qtype_fini(const struct lu_env *env, struct qsd_instance *qsd, qsd->qsd_type_array[qtype] = NULL; /* all deferred work lists should be empty */ - LASSERT(cfs_list_empty(&qqi->qqi_deferred_glb)); - LASSERT(cfs_list_empty(&qqi->qqi_deferred_slv)); + LASSERT(list_empty(&qqi->qqi_deferred_glb)); + LASSERT(list_empty(&qqi->qqi_deferred_slv)); /* shutdown lquota site */ if (qqi->qqi_site != NULL && !IS_ERR(qqi->qqi_site)) { @@ -301,16 +305,16 @@ static void qsd_qtype_fini(const struct lu_env *env, struct qsd_instance *qsd, * qsd_glb_blocking_ast() might haven't been called yet when we * get here. */ - while (cfs_atomic_read(&qqi->qqi_ref) > 1) { + while (atomic_read(&qqi->qqi_ref) > 1) { CDEBUG(D_QUOTA, "qqi reference count %u, repeat: %d\n", - cfs_atomic_read(&qqi->qqi_ref), repeat); + atomic_read(&qqi->qqi_ref), repeat); repeat++; schedule_timeout_and_set_state(TASK_INTERRUPTIBLE, cfs_time_seconds(1)); } /* by now, all qqi users should have gone away */ - LASSERT(cfs_atomic_read(&qqi->qqi_ref) == 1); + LASSERT(atomic_read(&qqi->qqi_ref) == 1); lu_ref_fini(&qqi->qqi_reference); /* release accounting object */ @@ -366,7 +370,7 @@ static int qsd_qtype_init(const struct lu_env *env, struct qsd_instance *qsd, if (qqi == NULL) RETURN(-ENOMEM); qsd->qsd_type_array[qtype] = qqi; - cfs_atomic_set(&qqi->qqi_ref, 1); /* referenced from qsd */ + atomic_set(&qqi->qqi_ref, 1); /* referenced from qsd */ /* set backpointer and other parameters */ qqi->qqi_qsd = qsd; @@ -379,8 +383,8 @@ static int qsd_qtype_init(const struct lu_env *env, struct qsd_instance *qsd, qqi->qqi_reint = false; init_waitqueue_head(&qqi->qqi_reint_thread.t_ctl_waitq); thread_set_flags(&qqi->qqi_reint_thread, SVC_STOPPED); - CFS_INIT_LIST_HEAD(&qqi->qqi_deferred_glb); - CFS_INIT_LIST_HEAD(&qqi->qqi_deferred_slv); + INIT_LIST_HEAD(&qqi->qqi_deferred_glb); + INIT_LIST_HEAD(&qqi->qqi_deferred_slv); /* open accounting object */ LASSERT(qqi->qqi_acct_obj == NULL); @@ -508,10 +512,10 @@ void qsd_fini(const struct lu_env *env, struct qsd_instance *qsd) /* release per-filesystem information */ if (qsd->qsd_fsinfo != NULL) { - down(&qsd->qsd_fsinfo->qfs_sem); + mutex_lock(&qsd->qsd_fsinfo->qfs_mutex); /* remove from the list of fsinfo */ - cfs_list_del_init(&qsd->qsd_link); - up(&qsd->qsd_fsinfo->qfs_sem); + list_del_init(&qsd->qsd_link); + mutex_unlock(&qsd->qsd_fsinfo->qfs_mutex); qsd_put_fsinfo(qsd->qsd_fsinfo); qsd->qsd_fsinfo = NULL; } @@ -550,7 +554,7 @@ EXPORT_SYMBOL(qsd_fini); */ struct qsd_instance *qsd_init(const struct lu_env *env, char *svname, struct dt_device *dev, - cfs_proc_dir_entry_t *osd_proc) + struct proc_dir_entry *osd_proc) { struct qsd_thread_info *qti = qsd_info(env); struct qsd_instance *qsd; @@ -569,12 +573,12 @@ struct qsd_instance *qsd_init(const struct lu_env *env, char *svname, /* generic initializations */ rwlock_init(&qsd->qsd_lock); - CFS_INIT_LIST_HEAD(&qsd->qsd_link); + INIT_LIST_HEAD(&qsd->qsd_link); thread_set_flags(&qsd->qsd_upd_thread, SVC_STOPPED); init_waitqueue_head(&qsd->qsd_upd_thread.t_ctl_waitq); - CFS_INIT_LIST_HEAD(&qsd->qsd_upd_list); + INIT_LIST_HEAD(&qsd->qsd_upd_list); spin_lock_init(&qsd->qsd_adjust_lock); - CFS_INIT_LIST_HEAD(&qsd->qsd_adjust_list); + INIT_LIST_HEAD(&qsd->qsd_adjust_list); qsd->qsd_prepared = false; qsd->qsd_started = false; @@ -608,13 +612,13 @@ struct qsd_instance *qsd_init(const struct lu_env *env, char *svname, } /* add in the list of lquota_fsinfo */ - down(&qsd->qsd_fsinfo->qfs_sem); + mutex_lock(&qsd->qsd_fsinfo->qfs_mutex); list_add_tail(&qsd->qsd_link, &qsd->qsd_fsinfo->qfs_qsd_list); - up(&qsd->qsd_fsinfo->qfs_sem); + mutex_unlock(&qsd->qsd_fsinfo->qfs_mutex); /* register procfs directory */ - qsd->qsd_proc = lprocfs_seq_register(QSD_DIR, osd_proc, - lprocfs_quota_qsd_vars, qsd); + qsd->qsd_proc = lprocfs_register(QSD_DIR, osd_proc, + lprocfs_quota_qsd_vars, qsd); if (IS_ERR(qsd->qsd_proc)) { rc = PTR_ERR(qsd->qsd_proc); qsd->qsd_proc = NULL; @@ -728,7 +732,8 @@ int qsd_prepare(const struct lu_env *env, struct qsd_instance *qsd) } /* generate osp name */ - rc = tgt_name2lwpname((char *)qsd->qsd_svname, qti->qti_buf); + rc = tgt_name2lwp_name(qsd->qsd_svname, qti->qti_buf, + MTI_NAME_MAXLEN, 0); if (rc) { CERROR("%s: failed to generate ospname (%d)\n", qsd->qsd_svname, rc);