Whamcloud - gitweb
git://git.whamcloud.com
/
fs
/
lustre-release.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
LU-4629 utils: fix rsources leak
[fs/lustre-release.git]
/
lustre
/
quota
/
qmt_lock.c
diff --git
a/lustre/quota/qmt_lock.c
b/lustre/quota/qmt_lock.c
index
635a314
..
f722617
100644
(file)
--- a/
lustre/quota/qmt_lock.c
+++ b/
lustre/quota/qmt_lock.c
@@
-688,7
+688,7
@@
void qmt_id_lock_notify(struct qmt_device *qmt, struct lquota_entry *lqe)
spin_unlock(&qmt->qmt_reba_lock);
if (added)
spin_unlock(&qmt->qmt_reba_lock);
if (added)
-
cfs_waitq_signal
(&qmt->qmt_reba_thread.t_ctl_waitq);
+
wake_up
(&qmt->qmt_reba_thread.t_ctl_waitq);
else
lqe_putref(lqe);
EXIT;
else
lqe_putref(lqe);
EXIT;
@@
-726,7
+726,7
@@
static int qmt_reba_thread(void *arg)
}
thread_set_flags(thread, SVC_RUNNING);
}
thread_set_flags(thread, SVC_RUNNING);
-
cfs_waitq_signal
(&thread->t_ctl_waitq);
+
wake_up
(&thread->t_ctl_waitq);
while (1) {
l_wait_event(thread->t_ctl_waitq,
while (1) {
l_wait_event(thread->t_ctl_waitq,
@@
-753,7
+753,7
@@
static int qmt_reba_thread(void *arg)
lu_env_fini(env);
OBD_FREE_PTR(env);
thread_set_flags(thread, SVC_STOPPED);
lu_env_fini(env);
OBD_FREE_PTR(env);
thread_set_flags(thread, SVC_STOPPED);
-
cfs_waitq_signal
(&thread->t_ctl_waitq);
+
wake_up
(&thread->t_ctl_waitq);
RETURN(rc);
}
RETURN(rc);
}
@@
-764,7
+764,7
@@
int qmt_start_reba_thread(struct qmt_device *qmt)
{
struct ptlrpc_thread *thread = &qmt->qmt_reba_thread;
struct l_wait_info lwi = { 0 };
{
struct ptlrpc_thread *thread = &qmt->qmt_reba_thread;
struct l_wait_info lwi = { 0 };
-
cfs_task_
t *task;
+
struct task_struc
t *task;
ENTRY;
task = kthread_run(qmt_reba_thread, (void *)qmt,
ENTRY;
task = kthread_run(qmt_reba_thread, (void *)qmt,
@@
-794,7
+794,7
@@
void qmt_stop_reba_thread(struct qmt_device *qmt)
struct l_wait_info lwi = { 0 };
thread_set_flags(thread, SVC_STOPPING);
struct l_wait_info lwi = { 0 };
thread_set_flags(thread, SVC_STOPPING);
-
cfs_waitq_signal
(&thread->t_ctl_waitq);
+
wake_up
(&thread->t_ctl_waitq);
l_wait_event(thread->t_ctl_waitq, thread_is_stopped(thread),
&lwi);
l_wait_event(thread->t_ctl_waitq, thread_is_stopped(thread),
&lwi);