[Xen-devel] [PATCH 4/6] xen-gntdev: Add reference counting to maps

[Daniel De Graaf <dgdegra@xxxxxxxxxxxxx>]

This allows userspace to perform mmap() on the gntdev device and then
immediately close the filehandle or remove the mapping using the
remove ioctl, with the mapped area remaining valid until unmapped.
This also fixes an infinite loop when a gntdev device is closed
without first unmapping all areas.

Signed-off-by: Daniel De Graaf <dgdegra@xxxxxxxxxxxxx>
---
 drivers/xen/gntdev.c |   56 +++++++++++++++++++------------------------------
 1 files changed, 22 insertions(+), 34 deletions(-)

diff --git a/drivers/xen/gntdev.c b/drivers/xen/gntdev.c
index 4f7eb3a..8a12857 100644
--- a/drivers/xen/gntdev.c
+++ b/drivers/xen/gntdev.c
@@ -70,16 +70,18 @@ struct granted_page {
 
 struct grant_map {
        struct list_head next;
-       struct gntdev_priv *priv;
        struct vm_area_struct *vma;
        int index;
        int count;
+       atomic_t users;
        int is_mapped:1;
        int is_ro:1;
        struct page **pages;
        struct granted_page pginfo[0];
 };
 
+static void unmap_grant_pages(struct grant_map *map, int offset, int pages);
+
 /* ------------------------------------------------------------------ */
 
 static void gntdev_print_maps(struct gntdev_priv *priv,
@@ -118,6 +120,7 @@ static struct grant_map *gntdev_alloc_map(int count,
        }
 
        add->index = 0;
+       atomic_set(&add->users, 1);
        add->count = count;
        for(i = 0; i < count; i++)
                add->pginfo[i].target = grants[i];
@@ -150,7 +153,6 @@ static void gntdev_add_map(struct gntdev_priv *priv, struct 
grant_map *add)
        list_add_tail(&add->next, &priv->maps);
 
 done:
-       add->priv = priv;
        gntdev_print_maps(priv, "[new]", add->index);
        spin_unlock(&priv->lock);
 }
@@ -170,29 +172,18 @@ static struct grant_map *gntdev_find_map_index(struct 
gntdev_priv *priv,
        return NULL;
 }
 
-static int gntdev_del_map(struct grant_map *map)
-{
-       int i;
-
-       if (map->vma)
-               return -EBUSY;
-       if (map->is_mapped)
-               for (i = 0; i < map->count; i++)
-                       if (map->pginfo[i].handle)
-                               return -EBUSY;
-
-       atomic_sub(map->count, &pages_mapped);
-       list_del(&map->next);
-       return 0;
-}
-
-static void gntdev_free_map(struct grant_map *map)
+static void gntdev_put_map(struct grant_map *map)
 {
        int i;
 
        if (!map)
                return;
 
+       if (!atomic_dec_and_test(&map->users))
+               return;
+
+       atomic_sub(map->count, &pages_mapped);
+
        for (i = 0; i < map->count; i++) {
                if (map->pages[i])
                        __free_page(map->pages[i]);
@@ -313,6 +304,7 @@ static void gntdev_vma_close(struct vm_area_struct *vma)
        map->is_mapped = 0;
        map->vma = NULL;
        vma->vm_private_data = NULL;
+       gntdev_put_map(map);
 }
 
 static int gntdev_vma_fault(struct vm_area_struct *vma, struct vm_fault *vmf)
@@ -430,17 +422,14 @@ static int gntdev_release(struct inode *inode, struct 
file *flip)
 {
        struct gntdev_priv *priv = flip->private_data;
        struct grant_map *map;
-       int err;
 
        pr_debug("priv %p\n", priv);
 
        spin_lock(&priv->lock);
        while (!list_empty(&priv->maps)) {
                map = list_entry(priv->maps.next, struct grant_map, next);
-               err = gntdev_del_map(map);
-               if (WARN_ON(err))
-                       gntdev_free_map(map);
-
+               list_del(&map->next);
+               gntdev_put_map(map);
        }
        spin_unlock(&priv->lock);
 
@@ -488,18 +477,14 @@ static long gntdev_ioctl_map_grant_ref(struct gntdev_priv 
*priv,
 
        if (copy_to_user(u, &op, sizeof(op))) {
                err = -EFAULT;
-               goto out_remove;
+               goto out_free;
        }
        err = 0;
 out_free:
        kfree(grants);
        return err;
-out_remove:
-       spin_lock(&priv->lock);
-       gntdev_del_map(map);
-       spin_unlock(&priv->lock);
 out_free_map:
-       gntdev_free_map(map);
+       gntdev_put_map(map);
        goto out_free;
 }
 
@@ -516,11 +501,12 @@ static long gntdev_ioctl_unmap_grant_ref(struct 
gntdev_priv *priv,
 
        spin_lock(&priv->lock);
        map = gntdev_find_map_index(priv, op.index >> PAGE_SHIFT, op.count);
-       if (map)
-               err = gntdev_del_map(map);
+       if (map) {
+               list_del(&map->next);
+               gntdev_put_map(map);
+               err = 0;
+       }
        spin_unlock(&priv->lock);
-       if (!err)
-               gntdev_free_map(map);
        return err;
 }
 
@@ -600,6 +586,8 @@ static int gntdev_mmap(struct file *flip, struct 
vm_area_struct *vma)
                goto unlock_out;
        }
 
+       atomic_inc(&map->users);
+
        vma->vm_ops = &gntdev_vmops;
 
        vma->vm_flags |= VM_RESERVED|VM_DONTCOPY|VM_DONTEXPAND|VM_PFNMAP;
-- 
1.7.3.4


_______________________________________________
Xen-devel mailing list
Xen-devel@xxxxxxxxxxxxxxxxxxx
http://lists.xensource.com/xen-devel