Commit f96051e5 authored by David Vrabel's avatar David Vrabel Committed by Ben Hutchings

xen/gntdev: convert priv->lock to a mutex

commit 1401c00e upstream.

Unmapping may require sleeping and we unmap while holding priv->lock, so
convert it to a mutex.
Signed-off-by: default avatarDavid Vrabel <david.vrabel@citrix.com>
Reviewed-by: default avatarStefano Stabellini <stefano.stabellini@eu.citrix.com>
[bwh: Backported to 3.2:
 - Adjust context
 - Drop changes to functions we don't have]
Signed-off-by: default avatarBen Hutchings <ben@decadent.org.uk>
parent 7f63bfd0
...@@ -60,7 +60,7 @@ static int use_ptemod; ...@@ -60,7 +60,7 @@ static int use_ptemod;
struct gntdev_priv { struct gntdev_priv {
struct list_head maps; struct list_head maps;
/* lock protects maps from concurrent changes */ /* lock protects maps from concurrent changes */
spinlock_t lock; struct mutex lock;
struct mm_struct *mm; struct mm_struct *mm;
struct mmu_notifier mn; struct mmu_notifier mn;
}; };
...@@ -395,7 +395,7 @@ static void mn_invl_range_start(struct mmu_notifier *mn, ...@@ -395,7 +395,7 @@ static void mn_invl_range_start(struct mmu_notifier *mn,
unsigned long mstart, mend; unsigned long mstart, mend;
int err; int err;
spin_lock(&priv->lock); mutex_lock(&priv->lock);
list_for_each_entry(map, &priv->maps, next) { list_for_each_entry(map, &priv->maps, next) {
if (!map->vma) if (!map->vma)
continue; continue;
...@@ -414,7 +414,7 @@ static void mn_invl_range_start(struct mmu_notifier *mn, ...@@ -414,7 +414,7 @@ static void mn_invl_range_start(struct mmu_notifier *mn,
(mend - mstart) >> PAGE_SHIFT); (mend - mstart) >> PAGE_SHIFT);
WARN_ON(err); WARN_ON(err);
} }
spin_unlock(&priv->lock); mutex_unlock(&priv->lock);
} }
static void mn_invl_page(struct mmu_notifier *mn, static void mn_invl_page(struct mmu_notifier *mn,
...@@ -431,7 +431,7 @@ static void mn_release(struct mmu_notifier *mn, ...@@ -431,7 +431,7 @@ static void mn_release(struct mmu_notifier *mn,
struct grant_map *map; struct grant_map *map;
int err; int err;
spin_lock(&priv->lock); mutex_lock(&priv->lock);
list_for_each_entry(map, &priv->maps, next) { list_for_each_entry(map, &priv->maps, next) {
if (!map->vma) if (!map->vma)
continue; continue;
...@@ -441,7 +441,7 @@ static void mn_release(struct mmu_notifier *mn, ...@@ -441,7 +441,7 @@ static void mn_release(struct mmu_notifier *mn,
err = unmap_grant_pages(map, /* offset */ 0, map->count); err = unmap_grant_pages(map, /* offset */ 0, map->count);
WARN_ON(err); WARN_ON(err);
} }
spin_unlock(&priv->lock); mutex_unlock(&priv->lock);
} }
struct mmu_notifier_ops gntdev_mmu_ops = { struct mmu_notifier_ops gntdev_mmu_ops = {
...@@ -462,7 +462,7 @@ static int gntdev_open(struct inode *inode, struct file *flip) ...@@ -462,7 +462,7 @@ static int gntdev_open(struct inode *inode, struct file *flip)
return -ENOMEM; return -ENOMEM;
INIT_LIST_HEAD(&priv->maps); INIT_LIST_HEAD(&priv->maps);
spin_lock_init(&priv->lock); mutex_init(&priv->lock);
if (use_ptemod) { if (use_ptemod) {
priv->mm = get_task_mm(current); priv->mm = get_task_mm(current);
...@@ -535,10 +535,10 @@ static long gntdev_ioctl_map_grant_ref(struct gntdev_priv *priv, ...@@ -535,10 +535,10 @@ static long gntdev_ioctl_map_grant_ref(struct gntdev_priv *priv,
return err; return err;
} }
spin_lock(&priv->lock); mutex_lock(&priv->lock);
gntdev_add_map(priv, map); gntdev_add_map(priv, map);
op.index = map->index << PAGE_SHIFT; op.index = map->index << PAGE_SHIFT;
spin_unlock(&priv->lock); mutex_unlock(&priv->lock);
if (copy_to_user(u, &op, sizeof(op)) != 0) if (copy_to_user(u, &op, sizeof(op)) != 0)
return -EFAULT; return -EFAULT;
...@@ -557,13 +557,13 @@ static long gntdev_ioctl_unmap_grant_ref(struct gntdev_priv *priv, ...@@ -557,13 +557,13 @@ static long gntdev_ioctl_unmap_grant_ref(struct gntdev_priv *priv,
return -EFAULT; return -EFAULT;
pr_debug("priv %p, del %d+%d\n", priv, (int)op.index, (int)op.count); pr_debug("priv %p, del %d+%d\n", priv, (int)op.index, (int)op.count);
spin_lock(&priv->lock); mutex_lock(&priv->lock);
map = gntdev_find_map_index(priv, op.index >> PAGE_SHIFT, op.count); map = gntdev_find_map_index(priv, op.index >> PAGE_SHIFT, op.count);
if (map) { if (map) {
list_del(&map->next); list_del(&map->next);
err = 0; err = 0;
} }
spin_unlock(&priv->lock); mutex_unlock(&priv->lock);
if (map) if (map)
gntdev_put_map(map); gntdev_put_map(map);
return err; return err;
...@@ -608,7 +608,7 @@ static long gntdev_ioctl_notify(struct gntdev_priv *priv, void __user *u) ...@@ -608,7 +608,7 @@ static long gntdev_ioctl_notify(struct gntdev_priv *priv, void __user *u)
if (op.action & ~(UNMAP_NOTIFY_CLEAR_BYTE|UNMAP_NOTIFY_SEND_EVENT)) if (op.action & ~(UNMAP_NOTIFY_CLEAR_BYTE|UNMAP_NOTIFY_SEND_EVENT))
return -EINVAL; return -EINVAL;
spin_lock(&priv->lock); mutex_lock(&priv->lock);
list_for_each_entry(map, &priv->maps, next) { list_for_each_entry(map, &priv->maps, next) {
uint64_t begin = map->index << PAGE_SHIFT; uint64_t begin = map->index << PAGE_SHIFT;
...@@ -631,7 +631,7 @@ static long gntdev_ioctl_notify(struct gntdev_priv *priv, void __user *u) ...@@ -631,7 +631,7 @@ static long gntdev_ioctl_notify(struct gntdev_priv *priv, void __user *u)
map->notify.event = op.event_channel_port; map->notify.event = op.event_channel_port;
rc = 0; rc = 0;
unlock_out: unlock_out:
spin_unlock(&priv->lock); mutex_unlock(&priv->lock);
return rc; return rc;
} }
...@@ -676,7 +676,7 @@ static int gntdev_mmap(struct file *flip, struct vm_area_struct *vma) ...@@ -676,7 +676,7 @@ static int gntdev_mmap(struct file *flip, struct vm_area_struct *vma)
pr_debug("map %d+%d at %lx (pgoff %lx)\n", pr_debug("map %d+%d at %lx (pgoff %lx)\n",
index, count, vma->vm_start, vma->vm_pgoff); index, count, vma->vm_start, vma->vm_pgoff);
spin_lock(&priv->lock); mutex_lock(&priv->lock);
map = gntdev_find_map_index(priv, index, count); map = gntdev_find_map_index(priv, index, count);
if (!map) if (!map)
goto unlock_out; goto unlock_out;
...@@ -711,7 +711,7 @@ static int gntdev_mmap(struct file *flip, struct vm_area_struct *vma) ...@@ -711,7 +711,7 @@ static int gntdev_mmap(struct file *flip, struct vm_area_struct *vma)
map->flags |= GNTMAP_readonly; map->flags |= GNTMAP_readonly;
} }
spin_unlock(&priv->lock); mutex_unlock(&priv->lock);
if (use_ptemod) { if (use_ptemod) {
err = apply_to_page_range(vma->vm_mm, vma->vm_start, err = apply_to_page_range(vma->vm_mm, vma->vm_start,
...@@ -739,11 +739,11 @@ static int gntdev_mmap(struct file *flip, struct vm_area_struct *vma) ...@@ -739,11 +739,11 @@ static int gntdev_mmap(struct file *flip, struct vm_area_struct *vma)
return 0; return 0;
unlock_out: unlock_out:
spin_unlock(&priv->lock); mutex_unlock(&priv->lock);
return err; return err;
out_unlock_put: out_unlock_put:
spin_unlock(&priv->lock); mutex_unlock(&priv->lock);
out_put_map: out_put_map:
if (use_ptemod) if (use_ptemod)
map->vma = NULL; map->vma = NULL;
......
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