Commit 11975e01 authored by Christoph Hellwig's avatar Christoph Hellwig Committed by Doug Ledford

nvme-rdma: use IB_PD_UNSAFE_GLOBAL_RKEY

Signed-off-by: default avatarChristoph Hellwig <hch@lst.de>
Reviewed-by: default avatarSagi Grimberg <sagi@grimberg.me>
Reviewed-by: default avatarJason Gunthorpe <jgunthorpe@obsidianresearch.com>
Reviewed-by: default avatarSteve Wise <swise@opengridcomputing.com>
Signed-off-by: default avatarDoug Ledford <dledford@redhat.com>
parent 5f071777
...@@ -58,7 +58,6 @@ ...@@ -58,7 +58,6 @@
struct nvme_rdma_device { struct nvme_rdma_device {
struct ib_device *dev; struct ib_device *dev;
struct ib_pd *pd; struct ib_pd *pd;
struct ib_mr *mr;
struct kref ref; struct kref ref;
struct list_head entry; struct list_head entry;
}; };
...@@ -410,10 +409,7 @@ static void nvme_rdma_free_dev(struct kref *ref) ...@@ -410,10 +409,7 @@ static void nvme_rdma_free_dev(struct kref *ref)
list_del(&ndev->entry); list_del(&ndev->entry);
mutex_unlock(&device_list_mutex); mutex_unlock(&device_list_mutex);
if (!register_always)
ib_dereg_mr(ndev->mr);
ib_dealloc_pd(ndev->pd); ib_dealloc_pd(ndev->pd);
kfree(ndev); kfree(ndev);
} }
...@@ -446,24 +442,16 @@ nvme_rdma_find_get_device(struct rdma_cm_id *cm_id) ...@@ -446,24 +442,16 @@ nvme_rdma_find_get_device(struct rdma_cm_id *cm_id)
ndev->dev = cm_id->device; ndev->dev = cm_id->device;
kref_init(&ndev->ref); kref_init(&ndev->ref);
ndev->pd = ib_alloc_pd(ndev->dev, 0); ndev->pd = ib_alloc_pd(ndev->dev,
register_always ? 0 : IB_PD_UNSAFE_GLOBAL_RKEY);
if (IS_ERR(ndev->pd)) if (IS_ERR(ndev->pd))
goto out_free_dev; goto out_free_dev;
if (!register_always) {
ndev->mr = ib_get_dma_mr(ndev->pd,
IB_ACCESS_LOCAL_WRITE |
IB_ACCESS_REMOTE_READ |
IB_ACCESS_REMOTE_WRITE);
if (IS_ERR(ndev->mr))
goto out_free_pd;
}
if (!(ndev->dev->attrs.device_cap_flags & if (!(ndev->dev->attrs.device_cap_flags &
IB_DEVICE_MEM_MGT_EXTENSIONS)) { IB_DEVICE_MEM_MGT_EXTENSIONS)) {
dev_err(&ndev->dev->dev, dev_err(&ndev->dev->dev,
"Memory registrations not supported.\n"); "Memory registrations not supported.\n");
goto out_free_mr; goto out_free_pd;
} }
list_add(&ndev->entry, &device_list); list_add(&ndev->entry, &device_list);
...@@ -471,9 +459,6 @@ nvme_rdma_find_get_device(struct rdma_cm_id *cm_id) ...@@ -471,9 +459,6 @@ nvme_rdma_find_get_device(struct rdma_cm_id *cm_id)
mutex_unlock(&device_list_mutex); mutex_unlock(&device_list_mutex);
return ndev; return ndev;
out_free_mr:
if (!register_always)
ib_dereg_mr(ndev->mr);
out_free_pd: out_free_pd:
ib_dealloc_pd(ndev->pd); ib_dealloc_pd(ndev->pd);
out_free_dev: out_free_dev:
...@@ -903,7 +888,7 @@ static int nvme_rdma_map_sg_single(struct nvme_rdma_queue *queue, ...@@ -903,7 +888,7 @@ static int nvme_rdma_map_sg_single(struct nvme_rdma_queue *queue,
sg->addr = cpu_to_le64(sg_dma_address(req->sg_table.sgl)); sg->addr = cpu_to_le64(sg_dma_address(req->sg_table.sgl));
put_unaligned_le24(sg_dma_len(req->sg_table.sgl), sg->length); put_unaligned_le24(sg_dma_len(req->sg_table.sgl), sg->length);
put_unaligned_le32(queue->device->mr->rkey, sg->key); put_unaligned_le32(queue->device->pd->unsafe_global_rkey, sg->key);
sg->type = NVME_KEY_SGL_FMT_DATA_DESC << 4; sg->type = NVME_KEY_SGL_FMT_DATA_DESC << 4;
return 0; return 0;
} }
...@@ -988,7 +973,7 @@ static int nvme_rdma_map_data(struct nvme_rdma_queue *queue, ...@@ -988,7 +973,7 @@ static int nvme_rdma_map_data(struct nvme_rdma_queue *queue,
nvme_rdma_queue_idx(queue)) nvme_rdma_queue_idx(queue))
return nvme_rdma_map_sg_inline(queue, req, c); return nvme_rdma_map_sg_inline(queue, req, c);
if (!register_always) if (dev->pd->flags & IB_PD_UNSAFE_GLOBAL_RKEY)
return nvme_rdma_map_sg_single(queue, req, c); return nvme_rdma_map_sg_single(queue, req, c);
} }
......
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