Commit 6f3bc58d authored by Linus Torvalds's avatar Linus Torvalds

Merge tag 'dlm-3.12' of git://git.kernel.org/pub/scm/linux/kernel/git/teigland/linux-dlm

Pull dlm updates from David Teigland:
 "This set includes a workqueue cleanup and the removal of incorrect and
  unneeded signal blocking"

* tag 'dlm-3.12' of git://git.kernel.org/pub/scm/linux/kernel/git/teigland/linux-dlm:
  dlm: remove signal blocking
  dlm: WQ_NON_REENTRANT is meaningless and going away
parents ae67d9a8 c6ca7bc9
...@@ -267,10 +267,7 @@ void dlm_callback_work(struct work_struct *work) ...@@ -267,10 +267,7 @@ void dlm_callback_work(struct work_struct *work)
int dlm_callback_start(struct dlm_ls *ls) int dlm_callback_start(struct dlm_ls *ls)
{ {
ls->ls_callback_wq = alloc_workqueue("dlm_callback", ls->ls_callback_wq = alloc_workqueue("dlm_callback",
WQ_UNBOUND | WQ_UNBOUND | WQ_MEM_RECLAIM, 0);
WQ_MEM_RECLAIM |
WQ_NON_REENTRANT,
0);
if (!ls->ls_callback_wq) { if (!ls->ls_callback_wq) {
log_print("can't start dlm_callback workqueue"); log_print("can't start dlm_callback workqueue");
return -ENOMEM; return -ENOMEM;
......
...@@ -493,7 +493,6 @@ static ssize_t device_write(struct file *file, const char __user *buf, ...@@ -493,7 +493,6 @@ static ssize_t device_write(struct file *file, const char __user *buf,
{ {
struct dlm_user_proc *proc = file->private_data; struct dlm_user_proc *proc = file->private_data;
struct dlm_write_request *kbuf; struct dlm_write_request *kbuf;
sigset_t tmpsig, allsigs;
int error; int error;
#ifdef CONFIG_COMPAT #ifdef CONFIG_COMPAT
...@@ -557,9 +556,6 @@ static ssize_t device_write(struct file *file, const char __user *buf, ...@@ -557,9 +556,6 @@ static ssize_t device_write(struct file *file, const char __user *buf,
goto out_free; goto out_free;
} }
sigfillset(&allsigs);
sigprocmask(SIG_BLOCK, &allsigs, &tmpsig);
error = -EINVAL; error = -EINVAL;
switch (kbuf->cmd) switch (kbuf->cmd)
...@@ -567,7 +563,7 @@ static ssize_t device_write(struct file *file, const char __user *buf, ...@@ -567,7 +563,7 @@ static ssize_t device_write(struct file *file, const char __user *buf,
case DLM_USER_LOCK: case DLM_USER_LOCK:
if (!proc) { if (!proc) {
log_print("no locking on control device"); log_print("no locking on control device");
goto out_sig; goto out_free;
} }
error = device_user_lock(proc, &kbuf->i.lock); error = device_user_lock(proc, &kbuf->i.lock);
break; break;
...@@ -575,7 +571,7 @@ static ssize_t device_write(struct file *file, const char __user *buf, ...@@ -575,7 +571,7 @@ static ssize_t device_write(struct file *file, const char __user *buf,
case DLM_USER_UNLOCK: case DLM_USER_UNLOCK:
if (!proc) { if (!proc) {
log_print("no locking on control device"); log_print("no locking on control device");
goto out_sig; goto out_free;
} }
error = device_user_unlock(proc, &kbuf->i.lock); error = device_user_unlock(proc, &kbuf->i.lock);
break; break;
...@@ -583,7 +579,7 @@ static ssize_t device_write(struct file *file, const char __user *buf, ...@@ -583,7 +579,7 @@ static ssize_t device_write(struct file *file, const char __user *buf,
case DLM_USER_DEADLOCK: case DLM_USER_DEADLOCK:
if (!proc) { if (!proc) {
log_print("no locking on control device"); log_print("no locking on control device");
goto out_sig; goto out_free;
} }
error = device_user_deadlock(proc, &kbuf->i.lock); error = device_user_deadlock(proc, &kbuf->i.lock);
break; break;
...@@ -591,7 +587,7 @@ static ssize_t device_write(struct file *file, const char __user *buf, ...@@ -591,7 +587,7 @@ static ssize_t device_write(struct file *file, const char __user *buf,
case DLM_USER_CREATE_LOCKSPACE: case DLM_USER_CREATE_LOCKSPACE:
if (proc) { if (proc) {
log_print("create/remove only on control device"); log_print("create/remove only on control device");
goto out_sig; goto out_free;
} }
error = device_create_lockspace(&kbuf->i.lspace); error = device_create_lockspace(&kbuf->i.lspace);
break; break;
...@@ -599,7 +595,7 @@ static ssize_t device_write(struct file *file, const char __user *buf, ...@@ -599,7 +595,7 @@ static ssize_t device_write(struct file *file, const char __user *buf,
case DLM_USER_REMOVE_LOCKSPACE: case DLM_USER_REMOVE_LOCKSPACE:
if (proc) { if (proc) {
log_print("create/remove only on control device"); log_print("create/remove only on control device");
goto out_sig; goto out_free;
} }
error = device_remove_lockspace(&kbuf->i.lspace); error = device_remove_lockspace(&kbuf->i.lspace);
break; break;
...@@ -607,7 +603,7 @@ static ssize_t device_write(struct file *file, const char __user *buf, ...@@ -607,7 +603,7 @@ static ssize_t device_write(struct file *file, const char __user *buf,
case DLM_USER_PURGE: case DLM_USER_PURGE:
if (!proc) { if (!proc) {
log_print("no locking on control device"); log_print("no locking on control device");
goto out_sig; goto out_free;
} }
error = device_user_purge(proc, &kbuf->i.purge); error = device_user_purge(proc, &kbuf->i.purge);
break; break;
...@@ -617,8 +613,6 @@ static ssize_t device_write(struct file *file, const char __user *buf, ...@@ -617,8 +613,6 @@ static ssize_t device_write(struct file *file, const char __user *buf,
kbuf->cmd); kbuf->cmd);
} }
out_sig:
sigprocmask(SIG_SETMASK, &tmpsig, NULL);
out_free: out_free:
kfree(kbuf); kfree(kbuf);
return error; return error;
...@@ -659,15 +653,11 @@ static int device_close(struct inode *inode, struct file *file) ...@@ -659,15 +653,11 @@ static int device_close(struct inode *inode, struct file *file)
{ {
struct dlm_user_proc *proc = file->private_data; struct dlm_user_proc *proc = file->private_data;
struct dlm_ls *ls; struct dlm_ls *ls;
sigset_t tmpsig, allsigs;
ls = dlm_find_lockspace_local(proc->lockspace); ls = dlm_find_lockspace_local(proc->lockspace);
if (!ls) if (!ls)
return -ENOENT; return -ENOENT;
sigfillset(&allsigs);
sigprocmask(SIG_BLOCK, &allsigs, &tmpsig);
set_bit(DLM_PROC_FLAGS_CLOSING, &proc->flags); set_bit(DLM_PROC_FLAGS_CLOSING, &proc->flags);
dlm_clear_proc_locks(ls, proc); dlm_clear_proc_locks(ls, proc);
...@@ -685,8 +675,6 @@ static int device_close(struct inode *inode, struct file *file) ...@@ -685,8 +675,6 @@ static int device_close(struct inode *inode, struct file *file)
/* FIXME: AUTOFREE: if this ls is no longer used do /* FIXME: AUTOFREE: if this ls is no longer used do
device_remove_lockspace() */ device_remove_lockspace() */
sigprocmask(SIG_SETMASK, &tmpsig, NULL);
return 0; return 0;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment