Skip to content

Commit

Permalink
IB: Put rlimit accounting struct in struct ib_umem
Browse files Browse the repository at this point in the history
When memory pinned with ib_umem_get() is released, ib_umem_release()
needs to subtract the amount of memory being unpinned from
mm->locked_vm.  However, ib_umem_release() may be called with
mm->mmap_sem already held for writing if the memory is being released
as part of an munmap() call, so it is sometimes necessary to defer
this accounting into a workqueue.

However, the work struct used to defer this accounting is dynamically
allocated before it is queued, so there is the possibility of failing
that allocation.  If the allocation fails, then ib_umem_release has no
choice except to bail out and leave the process with a permanently
elevated locked_vm.

Fix this by allocating the structure to defer accounting as part of
the original struct ib_umem, so there's no possibility of failing a
later allocation if creating the struct ib_umem and pinning memory
succeeds.

Signed-off-by: Roland Dreier <rolandd@cisco.com>
  • Loading branch information
Roland Dreier committed May 9, 2007
1 parent f7c6a7b commit 1bf66a3
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 28 deletions.
41 changes: 13 additions & 28 deletions drivers/infiniband/core/umem.c
Original file line number Diff line number Diff line change
Expand Up @@ -39,13 +39,6 @@

#include "uverbs.h"

struct ib_umem_account_work {
struct work_struct work;
struct mm_struct *mm;
unsigned long diff;
};


static void __ib_umem_release(struct ib_device *dev, struct ib_umem *umem, int dirty)
{
struct ib_umem_chunk *chunk, *tmp;
Expand Down Expand Up @@ -192,16 +185,15 @@ struct ib_umem *ib_umem_get(struct ib_ucontext *context, unsigned long addr,
}
EXPORT_SYMBOL(ib_umem_get);

static void ib_umem_account(struct work_struct *_work)
static void ib_umem_account(struct work_struct *work)
{
struct ib_umem_account_work *work =
container_of(_work, struct ib_umem_account_work, work);

down_write(&work->mm->mmap_sem);
work->mm->locked_vm -= work->diff;
up_write(&work->mm->mmap_sem);
mmput(work->mm);
kfree(work);
struct ib_umem *umem = container_of(work, struct ib_umem, work);

down_write(&umem->mm->mmap_sem);
umem->mm->locked_vm -= umem->diff;
up_write(&umem->mm->mmap_sem);
mmput(umem->mm);
kfree(umem);
}

/**
Expand All @@ -210,7 +202,6 @@ static void ib_umem_account(struct work_struct *_work)
*/
void ib_umem_release(struct ib_umem *umem)
{
struct ib_umem_account_work *work;
struct ib_ucontext *context = umem->context;
struct mm_struct *mm;
unsigned long diff;
Expand All @@ -222,7 +213,6 @@ void ib_umem_release(struct ib_umem *umem)
return;

diff = PAGE_ALIGN(umem->length + umem->offset) >> PAGE_SHIFT;
kfree(umem);

/*
* We may be called with the mm's mmap_sem already held. This
Expand All @@ -233,24 +223,19 @@ void ib_umem_release(struct ib_umem *umem)
* we defer the vm_locked accounting to the system workqueue.
*/
if (context->closing && !down_write_trylock(&mm->mmap_sem)) {
work = kmalloc(sizeof *work, GFP_KERNEL);
if (!work) {
mmput(mm);
return;
}
INIT_WORK(&umem->work, ib_umem_account);
umem->mm = mm;
umem->diff = diff;

INIT_WORK(&work->work, ib_umem_account);
work->mm = mm;
work->diff = diff;

schedule_work(&work->work);
schedule_work(&umem->work);
return;
} else
down_write(&mm->mmap_sem);

current->mm->locked_vm -= diff;
up_write(&mm->mmap_sem);
mmput(mm);
kfree(umem);
}
EXPORT_SYMBOL(ib_umem_release);

Expand Down
3 changes: 3 additions & 0 deletions include/rdma/ib_umem.h
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,9 @@ struct ib_umem {
int page_size;
int writable;
struct list_head chunk_list;
struct work_struct work;
struct mm_struct *mm;
unsigned long diff;
};

struct ib_umem_chunk {
Expand Down

0 comments on commit 1bf66a3

Please sign in to comment.