Commit 8aef7340 authored by Björn Töpel's avatar Björn Töpel Committed by Daniel Borkmann

xsk: introduce xdp_umem_page

The xdp_umem_page holds the address for a page. Trade memory for
faster lookup. Later, we'll add DMA address here as well.
Signed-off-by: default avatarBjörn Töpel <bjorn.topel@intel.com>
Signed-off-by: default avatarDaniel Borkmann <daniel@iogearbox.net>
parent e61e62b9
...@@ -20,10 +20,14 @@ struct xdp_umem_props { ...@@ -20,10 +20,14 @@ struct xdp_umem_props {
u64 size; u64 size;
}; };
struct xdp_umem_page {
void *addr;
};
struct xdp_umem { struct xdp_umem {
struct xsk_queue *fq; struct xsk_queue *fq;
struct xsk_queue *cq; struct xsk_queue *cq;
struct page **pgs; struct xdp_umem_page *pages;
struct xdp_umem_props props; struct xdp_umem_props props;
u32 headroom; u32 headroom;
u32 chunk_size_nohr; u32 chunk_size_nohr;
...@@ -32,6 +36,7 @@ struct xdp_umem { ...@@ -32,6 +36,7 @@ struct xdp_umem {
unsigned long address; unsigned long address;
refcount_t users; refcount_t users;
struct work_struct work; struct work_struct work;
struct page **pgs;
u32 npgs; u32 npgs;
}; };
......
...@@ -65,6 +65,9 @@ static void xdp_umem_release(struct xdp_umem *umem) ...@@ -65,6 +65,9 @@ static void xdp_umem_release(struct xdp_umem *umem)
goto out; goto out;
mmput(mm); mmput(mm);
kfree(umem->pages);
umem->pages = NULL;
xdp_umem_unaccount_pages(umem); xdp_umem_unaccount_pages(umem);
out: out:
kfree(umem); kfree(umem);
...@@ -155,7 +158,7 @@ static int xdp_umem_reg(struct xdp_umem *umem, struct xdp_umem_reg *mr) ...@@ -155,7 +158,7 @@ static int xdp_umem_reg(struct xdp_umem *umem, struct xdp_umem_reg *mr)
u32 chunk_size = mr->chunk_size, headroom = mr->headroom; u32 chunk_size = mr->chunk_size, headroom = mr->headroom;
unsigned int chunks, chunks_per_page; unsigned int chunks, chunks_per_page;
u64 addr = mr->addr, size = mr->len; u64 addr = mr->addr, size = mr->len;
int size_chk, err; int size_chk, err, i;
if (chunk_size < XDP_UMEM_MIN_CHUNK_SIZE || chunk_size > PAGE_SIZE) { if (chunk_size < XDP_UMEM_MIN_CHUNK_SIZE || chunk_size > PAGE_SIZE) {
/* Strictly speaking we could support this, if: /* Strictly speaking we could support this, if:
...@@ -213,6 +216,16 @@ static int xdp_umem_reg(struct xdp_umem *umem, struct xdp_umem_reg *mr) ...@@ -213,6 +216,16 @@ static int xdp_umem_reg(struct xdp_umem *umem, struct xdp_umem_reg *mr)
err = xdp_umem_pin_pages(umem); err = xdp_umem_pin_pages(umem);
if (err) if (err)
goto out_account; goto out_account;
umem->pages = kcalloc(umem->npgs, sizeof(*umem->pages), GFP_KERNEL);
if (!umem->pages) {
err = -ENOMEM;
goto out_account;
}
for (i = 0; i < umem->npgs; i++)
umem->pages[i].addr = page_address(umem->pgs[i]);
return 0; return 0;
out_account: out_account:
......
...@@ -10,8 +10,7 @@ ...@@ -10,8 +10,7 @@
static inline char *xdp_umem_get_data(struct xdp_umem *umem, u64 addr) static inline char *xdp_umem_get_data(struct xdp_umem *umem, u64 addr)
{ {
return page_address(umem->pgs[addr >> PAGE_SHIFT]) + return umem->pages[addr >> PAGE_SHIFT].addr + (addr & (PAGE_SIZE - 1));
(addr & (PAGE_SIZE - 1));
} }
bool xdp_umem_validate_queues(struct xdp_umem *umem); bool xdp_umem_validate_queues(struct xdp_umem *umem);
......
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