hollalinux
/
linux-sg2042
mirror of https://github.com/sophgo/linux-riscv.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NVMe: Create nvme_map_user_pages() and nvme_unmap_user_pages() 

These are generalisations of the code that was in
nvme_submit_user_admin_command().

Signed-off-by: Matthew Wilcox <matthew.r.wilcox@intel.com>
This commit is contained in:
Matthew Wilcox 2011-01-26 17:05:50 -05:00
parent bd38c5557c
commit 7fc3cdabba
1 changed files with 54 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
drivers/block/nvme.c
View File

@ -677,17 +677,22 @@ static int __devinit nvme_configure_admin_queue(struct nvme_dev *dev)
return result; return result;
} }
static int nvme_submit_user_admin_command(struct nvme_dev *dev, unsigned long addr, static int nvme_map_user_pages(struct nvme_dev *dev, int write,
unsigned length, struct nvme_command *cmd) unsigned long addr, unsigned length,
struct scatterlist **sgp)
{ {
int i, err, count, nents, offset; int i, err, count, nents, offset;
struct scatterlist sg[2]; struct scatterlist *sg;
struct page *pages[2]; struct page **pages;
if (addr & 3) if (addr & 3)
return -EINVAL; return -EINVAL;
if (!length)
return -EINVAL;
offset = offset_in_page(addr); offset = offset_in_page(addr);
count = ((offset + length) > PAGE_SIZE) ? 2 : 1; count = DIV_ROUND_UP(offset + length, PAGE_SIZE);
pages = kcalloc(count, sizeof(*pages), GFP_KERNEL);
err = get_user_pages_fast(addr, count, 1, pages); err = get_user_pages_fast(addr, count, 1, pages);
if (err < count) { if (err < count) {
@ -695,29 +700,62 @@ static int nvme_submit_user_admin_command(struct nvme_dev *dev, unsigned long ad
err = -EFAULT; err = -EFAULT;
goto put_pages; goto put_pages;
} }
sg = kcalloc(count, sizeof(*sg), GFP_KERNEL);
sg_init_table(sg, count); sg_init_table(sg, count);
sg_set_page(&sg[0], pages[0], PAGE_SIZE - offset, offset); sg_set_page(&sg[0], pages[0], PAGE_SIZE - offset, offset);
if (count > 1) length -= (PAGE_SIZE - offset);
sg_set_page(&sg[1], pages[1], offset, 0); for (i = 1; i < count; i++) {
nents = dma_map_sg(&dev->pci_dev->dev, sg, count, DMA_FROM_DEVICE); sg_set_page(&sg[i], pages[i], min_t(int, length, PAGE_SIZE), 0);
length -= PAGE_SIZE;
}
err = -ENOMEM;
nents = dma_map_sg(&dev->pci_dev->dev, sg, count,
write ? DMA_TO_DEVICE : DMA_FROM_DEVICE);
if (!nents) if (!nents)
goto put_pages; goto put_pages;
nvme_setup_prps(&cmd->common, sg, length); kfree(pages);
*sgp = sg;
return nents;
err = nvme_submit_admin_cmd(dev, cmd, NULL);
if (err)
err = -EIO;
dma_unmap_sg(&dev->pci_dev->dev, sg, nents, DMA_FROM_DEVICE);
put_pages: put_pages:
for (i = 0; i < count; i++) for (i = 0; i < count; i++)
put_page(pages[i]); put_page(pages[i]);
kfree(pages);
return err; return err;
} }
static void nvme_unmap_user_pages(struct nvme_dev *dev, int write,
unsigned long addr, int length,
struct scatterlist *sg, int nents)
{
int i, count;
count = DIV_ROUND_UP(offset_in_page(addr) + length, PAGE_SIZE);
dma_unmap_sg(&dev->pci_dev->dev, sg, nents, DMA_FROM_DEVICE);
for (i = 0; i < count; i++)
put_page(sg_page(&sg[i]));
}
static int nvme_submit_user_admin_command(struct nvme_dev *dev,
unsigned long addr, unsigned length,
struct nvme_command *cmd)
{
int err, nents;
struct scatterlist *sg;
nents = nvme_map_user_pages(dev, 0, addr, length, &sg);
if (nents < 0)
return nents;
nvme_setup_prps(&cmd->common, sg, length);
err = nvme_submit_admin_cmd(dev, cmd, NULL);
nvme_unmap_user_pages(dev, 0, addr, length, sg, nents);
return err ? -EIO : 0;
}
static int nvme_identify(struct nvme_ns *ns, unsigned long addr, int cns) static int nvme_identify(struct nvme_ns *ns, unsigned long addr, int cns)
{ {
struct nvme_command c; struct nvme_command c;