|
@@ -353,7 +353,7 @@ static ssize_t dev_write(struct file *file, const char __user *u, size_t count,
|
|
{
|
|
{
|
|
struct dlm_plock_info info;
|
|
struct dlm_plock_info info;
|
|
struct plock_op *op;
|
|
struct plock_op *op;
|
|
- int found = 0;
|
|
|
|
|
|
+ int found = 0, do_callback = 0;
|
|
|
|
|
|
if (count != sizeof(info))
|
|
if (count != sizeof(info))
|
|
return -EINVAL;
|
|
return -EINVAL;
|
|
@@ -366,21 +366,24 @@ static ssize_t dev_write(struct file *file, const char __user *u, size_t count,
|
|
|
|
|
|
spin_lock(&ops_lock);
|
|
spin_lock(&ops_lock);
|
|
list_for_each_entry(op, &recv_list, list) {
|
|
list_for_each_entry(op, &recv_list, list) {
|
|
- if (op->info.fsid == info.fsid && op->info.number == info.number &&
|
|
|
|
|
|
+ if (op->info.fsid == info.fsid &&
|
|
|
|
+ op->info.number == info.number &&
|
|
op->info.owner == info.owner) {
|
|
op->info.owner == info.owner) {
|
|
|
|
+ struct plock_xop *xop = (struct plock_xop *)op;
|
|
list_del_init(&op->list);
|
|
list_del_init(&op->list);
|
|
- found = 1;
|
|
|
|
- op->done = 1;
|
|
|
|
memcpy(&op->info, &info, sizeof(info));
|
|
memcpy(&op->info, &info, sizeof(info));
|
|
|
|
+ if (xop->callback)
|
|
|
|
+ do_callback = 1;
|
|
|
|
+ else
|
|
|
|
+ op->done = 1;
|
|
|
|
+ found = 1;
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
spin_unlock(&ops_lock);
|
|
spin_unlock(&ops_lock);
|
|
|
|
|
|
if (found) {
|
|
if (found) {
|
|
- struct plock_xop *xop;
|
|
|
|
- xop = (struct plock_xop *)op;
|
|
|
|
- if (xop->callback)
|
|
|
|
|
|
+ if (do_callback)
|
|
dlm_plock_callback(op);
|
|
dlm_plock_callback(op);
|
|
else
|
|
else
|
|
wake_up(&recv_wq);
|
|
wake_up(&recv_wq);
|