123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858 |
- #include <drm/drmP.h>
- #include <drm/i915_drm.h>
- #include "i915_drv.h"
- #include "i915_trace.h"
- #include "intel_drv.h"
- #include <linux/mmu_context.h>
- #include <linux/mmu_notifier.h>
- #include <linux/mempolicy.h>
- #include <linux/swap.h>
- struct i915_mm_struct {
- struct mm_struct *mm;
- struct drm_device *dev;
- struct i915_mmu_notifier *mn;
- struct hlist_node node;
- struct kref kref;
- struct work_struct work;
- };
- #if defined(CONFIG_MMU_NOTIFIER)
- #include <linux/interval_tree.h>
- struct i915_mmu_notifier {
- spinlock_t lock;
- struct hlist_node node;
- struct mmu_notifier mn;
- struct rb_root objects;
- struct list_head linear;
- unsigned long serial;
- bool has_linear;
- };
- struct i915_mmu_object {
- struct i915_mmu_notifier *mn;
- struct interval_tree_node it;
- struct list_head link;
- struct drm_i915_gem_object *obj;
- bool is_linear;
- };
- static unsigned long cancel_userptr(struct drm_i915_gem_object *obj)
- {
- struct drm_device *dev = obj->base.dev;
- unsigned long end;
- mutex_lock(&dev->struct_mutex);
-
- obj->userptr.work = NULL;
- if (obj->pages != NULL) {
- struct drm_i915_private *dev_priv = to_i915(dev);
- struct i915_vma *vma, *tmp;
- bool was_interruptible;
- was_interruptible = dev_priv->mm.interruptible;
- dev_priv->mm.interruptible = false;
- list_for_each_entry_safe(vma, tmp, &obj->vma_list, vma_link) {
- int ret = i915_vma_unbind(vma);
- WARN_ON(ret && ret != -EIO);
- }
- WARN_ON(i915_gem_object_put_pages(obj));
- dev_priv->mm.interruptible = was_interruptible;
- }
- end = obj->userptr.ptr + obj->base.size;
- drm_gem_object_unreference(&obj->base);
- mutex_unlock(&dev->struct_mutex);
- return end;
- }
- static void *invalidate_range__linear(struct i915_mmu_notifier *mn,
- struct mm_struct *mm,
- unsigned long start,
- unsigned long end)
- {
- struct i915_mmu_object *mo;
- unsigned long serial;
- restart:
- serial = mn->serial;
- list_for_each_entry(mo, &mn->linear, link) {
- struct drm_i915_gem_object *obj;
- if (mo->it.last < start || mo->it.start > end)
- continue;
- obj = mo->obj;
- if (!kref_get_unless_zero(&obj->base.refcount))
- continue;
- spin_unlock(&mn->lock);
- cancel_userptr(obj);
- spin_lock(&mn->lock);
- if (serial != mn->serial)
- goto restart;
- }
- return NULL;
- }
- static void i915_gem_userptr_mn_invalidate_range_start(struct mmu_notifier *_mn,
- struct mm_struct *mm,
- unsigned long start,
- unsigned long end)
- {
- struct i915_mmu_notifier *mn = container_of(_mn, struct i915_mmu_notifier, mn);
- struct interval_tree_node *it = NULL;
- unsigned long next = start;
- unsigned long serial = 0;
- end--;
- while (next < end) {
- struct drm_i915_gem_object *obj = NULL;
- spin_lock(&mn->lock);
- if (mn->has_linear)
- it = invalidate_range__linear(mn, mm, start, end);
- else if (serial == mn->serial)
- it = interval_tree_iter_next(it, next, end);
- else
- it = interval_tree_iter_first(&mn->objects, start, end);
- if (it != NULL) {
- obj = container_of(it, struct i915_mmu_object, it)->obj;
-
- if (!kref_get_unless_zero(&obj->base.refcount)) {
- spin_unlock(&mn->lock);
- serial = 0;
- continue;
- }
- serial = mn->serial;
- }
- spin_unlock(&mn->lock);
- if (obj == NULL)
- return;
- next = cancel_userptr(obj);
- }
- }
- static const struct mmu_notifier_ops i915_gem_userptr_notifier = {
- .invalidate_range_start = i915_gem_userptr_mn_invalidate_range_start,
- };
- static struct i915_mmu_notifier *
- i915_mmu_notifier_create(struct mm_struct *mm)
- {
- struct i915_mmu_notifier *mn;
- int ret;
- mn = kmalloc(sizeof(*mn), GFP_KERNEL);
- if (mn == NULL)
- return ERR_PTR(-ENOMEM);
- spin_lock_init(&mn->lock);
- mn->mn.ops = &i915_gem_userptr_notifier;
- mn->objects = RB_ROOT;
- mn->serial = 1;
- INIT_LIST_HEAD(&mn->linear);
- mn->has_linear = false;
-
- ret = __mmu_notifier_register(&mn->mn, mm);
- if (ret) {
- kfree(mn);
- return ERR_PTR(ret);
- }
- return mn;
- }
- static void __i915_mmu_notifier_update_serial(struct i915_mmu_notifier *mn)
- {
- if (++mn->serial == 0)
- mn->serial = 1;
- }
- static int
- i915_mmu_notifier_add(struct drm_device *dev,
- struct i915_mmu_notifier *mn,
- struct i915_mmu_object *mo)
- {
- struct interval_tree_node *it;
- int ret = 0;
-
- mutex_lock(&dev->struct_mutex);
-
- i915_gem_retire_requests(dev);
- spin_lock(&mn->lock);
- it = interval_tree_iter_first(&mn->objects,
- mo->it.start, mo->it.last);
- if (it) {
- struct drm_i915_gem_object *obj;
-
- obj = container_of(it, struct i915_mmu_object, it)->obj;
- if (!obj->userptr.workers)
- mn->has_linear = mo->is_linear = true;
- else
- ret = -EAGAIN;
- } else
- interval_tree_insert(&mo->it, &mn->objects);
- if (ret == 0) {
- list_add(&mo->link, &mn->linear);
- __i915_mmu_notifier_update_serial(mn);
- }
- spin_unlock(&mn->lock);
- mutex_unlock(&dev->struct_mutex);
- return ret;
- }
- static bool i915_mmu_notifier_has_linear(struct i915_mmu_notifier *mn)
- {
- struct i915_mmu_object *mo;
- list_for_each_entry(mo, &mn->linear, link)
- if (mo->is_linear)
- return true;
- return false;
- }
- static void
- i915_mmu_notifier_del(struct i915_mmu_notifier *mn,
- struct i915_mmu_object *mo)
- {
- spin_lock(&mn->lock);
- list_del(&mo->link);
- if (mo->is_linear)
- mn->has_linear = i915_mmu_notifier_has_linear(mn);
- else
- interval_tree_remove(&mo->it, &mn->objects);
- __i915_mmu_notifier_update_serial(mn);
- spin_unlock(&mn->lock);
- }
- static void
- i915_gem_userptr_release__mmu_notifier(struct drm_i915_gem_object *obj)
- {
- struct i915_mmu_object *mo;
- mo = obj->userptr.mmu_object;
- if (mo == NULL)
- return;
- i915_mmu_notifier_del(mo->mn, mo);
- kfree(mo);
- obj->userptr.mmu_object = NULL;
- }
- static struct i915_mmu_notifier *
- i915_mmu_notifier_find(struct i915_mm_struct *mm)
- {
- struct i915_mmu_notifier *mn = mm->mn;
- mn = mm->mn;
- if (mn)
- return mn;
- down_write(&mm->mm->mmap_sem);
- mutex_lock(&to_i915(mm->dev)->mm_lock);
- if ((mn = mm->mn) == NULL) {
- mn = i915_mmu_notifier_create(mm->mm);
- if (!IS_ERR(mn))
- mm->mn = mn;
- }
- mutex_unlock(&to_i915(mm->dev)->mm_lock);
- up_write(&mm->mm->mmap_sem);
- return mn;
- }
- static int
- i915_gem_userptr_init__mmu_notifier(struct drm_i915_gem_object *obj,
- unsigned flags)
- {
- struct i915_mmu_notifier *mn;
- struct i915_mmu_object *mo;
- int ret;
- if (flags & I915_USERPTR_UNSYNCHRONIZED)
- return capable(CAP_SYS_ADMIN) ? 0 : -EPERM;
- if (WARN_ON(obj->userptr.mm == NULL))
- return -EINVAL;
- mn = i915_mmu_notifier_find(obj->userptr.mm);
- if (IS_ERR(mn))
- return PTR_ERR(mn);
- mo = kzalloc(sizeof(*mo), GFP_KERNEL);
- if (mo == NULL)
- return -ENOMEM;
- mo->mn = mn;
- mo->it.start = obj->userptr.ptr;
- mo->it.last = mo->it.start + obj->base.size - 1;
- mo->obj = obj;
- ret = i915_mmu_notifier_add(obj->base.dev, mn, mo);
- if (ret) {
- kfree(mo);
- return ret;
- }
- obj->userptr.mmu_object = mo;
- return 0;
- }
- static void
- i915_mmu_notifier_free(struct i915_mmu_notifier *mn,
- struct mm_struct *mm)
- {
- if (mn == NULL)
- return;
- mmu_notifier_unregister(&mn->mn, mm);
- kfree(mn);
- }
- #else
- static void
- i915_gem_userptr_release__mmu_notifier(struct drm_i915_gem_object *obj)
- {
- }
- static int
- i915_gem_userptr_init__mmu_notifier(struct drm_i915_gem_object *obj,
- unsigned flags)
- {
- if ((flags & I915_USERPTR_UNSYNCHRONIZED) == 0)
- return -ENODEV;
- if (!capable(CAP_SYS_ADMIN))
- return -EPERM;
- return 0;
- }
- static void
- i915_mmu_notifier_free(struct i915_mmu_notifier *mn,
- struct mm_struct *mm)
- {
- }
- #endif
- static struct i915_mm_struct *
- __i915_mm_struct_find(struct drm_i915_private *dev_priv, struct mm_struct *real)
- {
- struct i915_mm_struct *mm;
-
- hash_for_each_possible(dev_priv->mm_structs, mm, node, (unsigned long)real)
- if (mm->mm == real)
- return mm;
- return NULL;
- }
- static int
- i915_gem_userptr_init__mm_struct(struct drm_i915_gem_object *obj)
- {
- struct drm_i915_private *dev_priv = to_i915(obj->base.dev);
- struct i915_mm_struct *mm;
- int ret = 0;
-
- mutex_lock(&dev_priv->mm_lock);
- mm = __i915_mm_struct_find(dev_priv, current->mm);
- if (mm == NULL) {
- mm = kmalloc(sizeof(*mm), GFP_KERNEL);
- if (mm == NULL) {
- ret = -ENOMEM;
- goto out;
- }
- kref_init(&mm->kref);
- mm->dev = obj->base.dev;
- mm->mm = current->mm;
- atomic_inc(¤t->mm->mm_count);
- mm->mn = NULL;
-
- hash_add(dev_priv->mm_structs,
- &mm->node, (unsigned long)mm->mm);
- } else
- kref_get(&mm->kref);
- obj->userptr.mm = mm;
- out:
- mutex_unlock(&dev_priv->mm_lock);
- return ret;
- }
- static void
- __i915_mm_struct_free__worker(struct work_struct *work)
- {
- struct i915_mm_struct *mm = container_of(work, typeof(*mm), work);
- i915_mmu_notifier_free(mm->mn, mm->mm);
- mmdrop(mm->mm);
- kfree(mm);
- }
- static void
- __i915_mm_struct_free(struct kref *kref)
- {
- struct i915_mm_struct *mm = container_of(kref, typeof(*mm), kref);
-
- hash_del(&mm->node);
- mutex_unlock(&to_i915(mm->dev)->mm_lock);
- INIT_WORK(&mm->work, __i915_mm_struct_free__worker);
- schedule_work(&mm->work);
- }
- static void
- i915_gem_userptr_release__mm_struct(struct drm_i915_gem_object *obj)
- {
- if (obj->userptr.mm == NULL)
- return;
- kref_put_mutex(&obj->userptr.mm->kref,
- __i915_mm_struct_free,
- &to_i915(obj->base.dev)->mm_lock);
- obj->userptr.mm = NULL;
- }
- struct get_pages_work {
- struct work_struct work;
- struct drm_i915_gem_object *obj;
- struct task_struct *task;
- };
- #if IS_ENABLED(CONFIG_SWIOTLB)
- #define swiotlb_active() swiotlb_nr_tbl()
- #else
- #define swiotlb_active() 0
- #endif
- static int
- st_set_pages(struct sg_table **st, struct page **pvec, int num_pages)
- {
- struct scatterlist *sg;
- int ret, n;
- *st = kmalloc(sizeof(**st), GFP_KERNEL);
- if (*st == NULL)
- return -ENOMEM;
- if (swiotlb_active()) {
- ret = sg_alloc_table(*st, num_pages, GFP_KERNEL);
- if (ret)
- goto err;
- for_each_sg((*st)->sgl, sg, num_pages, n)
- sg_set_page(sg, pvec[n], PAGE_SIZE, 0);
- } else {
- ret = sg_alloc_table_from_pages(*st, pvec, num_pages,
- 0, num_pages << PAGE_SHIFT,
- GFP_KERNEL);
- if (ret)
- goto err;
- }
- return 0;
- err:
- kfree(*st);
- *st = NULL;
- return ret;
- }
- static void
- __i915_gem_userptr_get_pages_worker(struct work_struct *_work)
- {
- struct get_pages_work *work = container_of(_work, typeof(*work), work);
- struct drm_i915_gem_object *obj = work->obj;
- struct drm_device *dev = obj->base.dev;
- const int num_pages = obj->base.size >> PAGE_SHIFT;
- struct page **pvec;
- int pinned, ret;
- ret = -ENOMEM;
- pinned = 0;
- pvec = kmalloc(num_pages*sizeof(struct page *),
- GFP_TEMPORARY | __GFP_NOWARN | __GFP_NORETRY);
- if (pvec == NULL)
- pvec = drm_malloc_ab(num_pages, sizeof(struct page *));
- if (pvec != NULL) {
- struct mm_struct *mm = obj->userptr.mm->mm;
- down_read(&mm->mmap_sem);
- while (pinned < num_pages) {
- ret = get_user_pages(work->task, mm,
- obj->userptr.ptr + pinned * PAGE_SIZE,
- num_pages - pinned,
- !obj->userptr.read_only, 0,
- pvec + pinned, NULL);
- if (ret < 0)
- break;
- pinned += ret;
- }
- up_read(&mm->mmap_sem);
- }
- mutex_lock(&dev->struct_mutex);
- if (obj->userptr.work != &work->work) {
- ret = 0;
- } else if (pinned == num_pages) {
- ret = st_set_pages(&obj->pages, pvec, num_pages);
- if (ret == 0) {
- list_add_tail(&obj->global_list, &to_i915(dev)->mm.unbound_list);
- pinned = 0;
- }
- }
- obj->userptr.work = ERR_PTR(ret);
- obj->userptr.workers--;
- drm_gem_object_unreference(&obj->base);
- mutex_unlock(&dev->struct_mutex);
- release_pages(pvec, pinned, 0);
- drm_free_large(pvec);
- put_task_struct(work->task);
- kfree(work);
- }
- static int
- i915_gem_userptr_get_pages(struct drm_i915_gem_object *obj)
- {
- const int num_pages = obj->base.size >> PAGE_SHIFT;
- struct page **pvec;
- int pinned, ret;
-
- pvec = NULL;
- pinned = 0;
- if (obj->userptr.mm->mm == current->mm) {
- pvec = kmalloc(num_pages*sizeof(struct page *),
- GFP_TEMPORARY | __GFP_NOWARN | __GFP_NORETRY);
- if (pvec == NULL) {
- pvec = drm_malloc_ab(num_pages, sizeof(struct page *));
- if (pvec == NULL)
- return -ENOMEM;
- }
- pinned = __get_user_pages_fast(obj->userptr.ptr, num_pages,
- !obj->userptr.read_only, pvec);
- }
- if (pinned < num_pages) {
- if (pinned < 0) {
- ret = pinned;
- pinned = 0;
- } else {
-
- ret = -EAGAIN;
- if (obj->userptr.work == NULL &&
- obj->userptr.workers < I915_GEM_USERPTR_MAX_WORKERS) {
- struct get_pages_work *work;
- work = kmalloc(sizeof(*work), GFP_KERNEL);
- if (work != NULL) {
- obj->userptr.work = &work->work;
- obj->userptr.workers++;
- work->obj = obj;
- drm_gem_object_reference(&obj->base);
- work->task = current;
- get_task_struct(work->task);
- INIT_WORK(&work->work, __i915_gem_userptr_get_pages_worker);
- schedule_work(&work->work);
- } else
- ret = -ENOMEM;
- } else {
- if (IS_ERR(obj->userptr.work)) {
- ret = PTR_ERR(obj->userptr.work);
- obj->userptr.work = NULL;
- }
- }
- }
- } else {
- ret = st_set_pages(&obj->pages, pvec, num_pages);
- if (ret == 0) {
- obj->userptr.work = NULL;
- pinned = 0;
- }
- }
- release_pages(pvec, pinned, 0);
- drm_free_large(pvec);
- return ret;
- }
- static void
- i915_gem_userptr_put_pages(struct drm_i915_gem_object *obj)
- {
- struct sg_page_iter sg_iter;
- BUG_ON(obj->userptr.work != NULL);
- if (obj->madv != I915_MADV_WILLNEED)
- obj->dirty = 0;
- for_each_sg_page(obj->pages->sgl, &sg_iter, obj->pages->nents, 0) {
- struct page *page = sg_page_iter_page(&sg_iter);
- if (obj->dirty)
- set_page_dirty(page);
- mark_page_accessed(page);
- page_cache_release(page);
- }
- obj->dirty = 0;
- sg_free_table(obj->pages);
- kfree(obj->pages);
- }
- static void
- i915_gem_userptr_release(struct drm_i915_gem_object *obj)
- {
- i915_gem_userptr_release__mmu_notifier(obj);
- i915_gem_userptr_release__mm_struct(obj);
- }
- static int
- i915_gem_userptr_dmabuf_export(struct drm_i915_gem_object *obj)
- {
- if (obj->userptr.mmu_object)
- return 0;
- return i915_gem_userptr_init__mmu_notifier(obj, 0);
- }
- static const struct drm_i915_gem_object_ops i915_gem_userptr_ops = {
- .dmabuf_export = i915_gem_userptr_dmabuf_export,
- .get_pages = i915_gem_userptr_get_pages,
- .put_pages = i915_gem_userptr_put_pages,
- .release = i915_gem_userptr_release,
- };
- int
- i915_gem_userptr_ioctl(struct drm_device *dev, void *data, struct drm_file *file)
- {
- struct drm_i915_private *dev_priv = dev->dev_private;
- struct drm_i915_gem_userptr *args = data;
- struct drm_i915_gem_object *obj;
- int ret;
- u32 handle;
- if (args->flags & ~(I915_USERPTR_READ_ONLY |
- I915_USERPTR_UNSYNCHRONIZED))
- return -EINVAL;
- if (offset_in_page(args->user_ptr | args->user_size))
- return -EINVAL;
- if (args->user_size > dev_priv->gtt.base.total)
- return -E2BIG;
- if (!access_ok(args->flags & I915_USERPTR_READ_ONLY ? VERIFY_READ : VERIFY_WRITE,
- (char __user *)(unsigned long)args->user_ptr, args->user_size))
- return -EFAULT;
- if (args->flags & I915_USERPTR_READ_ONLY) {
-
- return -ENODEV;
- }
- obj = i915_gem_object_alloc(dev);
- if (obj == NULL)
- return -ENOMEM;
- drm_gem_private_object_init(dev, &obj->base, args->user_size);
- i915_gem_object_init(obj, &i915_gem_userptr_ops);
- obj->cache_level = I915_CACHE_LLC;
- obj->base.write_domain = I915_GEM_DOMAIN_CPU;
- obj->base.read_domains = I915_GEM_DOMAIN_CPU;
- obj->userptr.ptr = args->user_ptr;
- obj->userptr.read_only = !!(args->flags & I915_USERPTR_READ_ONLY);
-
- ret = i915_gem_userptr_init__mm_struct(obj);
- if (ret == 0)
- ret = i915_gem_userptr_init__mmu_notifier(obj, args->flags);
- if (ret == 0)
- ret = drm_gem_handle_create(file, &obj->base, &handle);
-
- drm_gem_object_unreference_unlocked(&obj->base);
- if (ret)
- return ret;
- args->handle = handle;
- return 0;
- }
- int
- i915_gem_init_userptr(struct drm_device *dev)
- {
- struct drm_i915_private *dev_priv = to_i915(dev);
- mutex_init(&dev_priv->mm_lock);
- hash_init(dev_priv->mm_structs);
- return 0;
- }
|