Skip to content

L
linux
Commit 40eb0066 authored by Linus Torvalds's avatar Linus Torvalds
Browse files
Options

Merge branch 'for-linus' of master.kernel.org:/pub/scm/linux/kernel/git/roland/infiniband 

* 'for-linus' of master.kernel.org:/pub/scm/linux/kernel/git/roland/infiniband:
  RDMA/addr: Use client registration to fix module unload race
  IB/mthca: Fix MAD extended header format for MAD_IFC firmware command
  IB/uverbs: Return sq_draining value in query_qp response
  IB/amso1100: Fix incorrect pr_debug()
  IB/amso1100: Use dma_alloc_coherent() instead of kmalloc/dma_map_single
  IB/ehca: Fix eHCA driver compilation for uniprocessor
  RDMA/cma: rdma_bind_addr() leaks a cma_dev reference count
  IB/iser: Start connection after enabling iSER
parents e957b00a 7a118df3
Hide whitespace changes
Inline Side-by-side
Showing with 114 additions and 75 deletions
drivers/infiniband/core/addr.c
View file @ 40eb0066
...@@ -47,6 +47,7 @@ struct addr_req { ...@@ -47,6 +47,7 @@ struct addr_req {
struct sockaddr src_addr; struct sockaddr src_addr;
struct sockaddr dst_addr; struct sockaddr dst_addr;
struct rdma_dev_addr *addr; struct rdma_dev_addr *addr;
struct rdma_addr_client *client;
void *context; void *context;
void (*callback)(int status, struct sockaddr *src_addr, void (*callback)(int status, struct sockaddr *src_addr,
struct rdma_dev_addr *addr, void *context); struct rdma_dev_addr *addr, void *context);
...@@ -61,6 +62,26 @@ static LIST_HEAD(req_list); ...@@ -61,6 +62,26 @@ static LIST_HEAD(req_list);
static DECLARE_WORK(work, process_req, NULL); static DECLARE_WORK(work, process_req, NULL);
static struct workqueue_struct *addr_wq; static struct workqueue_struct *addr_wq;
void rdma_addr_register_client(struct rdma_addr_client *client)
{
atomic_set(&client->refcount, 1);
init_completion(&client->comp);
}
EXPORT_SYMBOL(rdma_addr_register_client);
static inline void put_client(struct rdma_addr_client *client)
{
if (atomic_dec_and_test(&client->refcount))
complete(&client->comp);
}
void rdma_addr_unregister_client(struct rdma_addr_client *client)
{
put_client(client);
wait_for_completion(&client->comp);
}
EXPORT_SYMBOL(rdma_addr_unregister_client);
int rdma_copy_addr(struct rdma_dev_addr *dev_addr, struct net_device *dev, int rdma_copy_addr(struct rdma_dev_addr *dev_addr, struct net_device *dev,
const unsigned char *dst_dev_addr) const unsigned char *dst_dev_addr)
{ {
...@@ -229,6 +250,7 @@ static void process_req(void *data) ...@@ -229,6 +250,7 @@ static void process_req(void *data)
list_del(&req->list); list_del(&req->list);
req->callback(req->status, &req->src_addr, req->addr, req->callback(req->status, &req->src_addr, req->addr,
req->context); req->context);
put_client(req->client);
kfree(req); kfree(req);
} }
} }
...@@ -264,7 +286,8 @@ static int addr_resolve_local(struct sockaddr_in *src_in, ...@@ -264,7 +286,8 @@ static int addr_resolve_local(struct sockaddr_in *src_in,
return ret; return ret;
} }
int rdma_resolve_ip(struct sockaddr *src_addr, struct sockaddr *dst_addr, int rdma_resolve_ip(struct rdma_addr_client *client,
struct sockaddr *src_addr, struct sockaddr *dst_addr,
struct rdma_dev_addr *addr, int timeout_ms, struct rdma_dev_addr *addr, int timeout_ms,
void (*callback)(int status, struct sockaddr *src_addr, void (*callback)(int status, struct sockaddr *src_addr,
struct rdma_dev_addr *addr, void *context), struct rdma_dev_addr *addr, void *context),
...@@ -285,6 +308,8 @@ int rdma_resolve_ip(struct sockaddr *src_addr, struct sockaddr *dst_addr, ...@@ -285,6 +308,8 @@ int rdma_resolve_ip(struct sockaddr *src_addr, struct sockaddr *dst_addr,
req->addr = addr; req->addr = addr;
req->callback = callback; req->callback = callback;
req->context = context; req->context = context;
req->client = client;
atomic_inc(&client->refcount);
src_in = (struct sockaddr_in *) &req->src_addr; src_in = (struct sockaddr_in *) &req->src_addr;
dst_in = (struct sockaddr_in *) &req->dst_addr; dst_in = (struct sockaddr_in *) &req->dst_addr;
...@@ -305,6 +330,7 @@ int rdma_resolve_ip(struct sockaddr *src_addr, struct sockaddr *dst_addr, ...@@ -305,6 +330,7 @@ int rdma_resolve_ip(struct sockaddr *src_addr, struct sockaddr *dst_addr,
break; break;
default: default:
ret = req->status; ret = req->status;
atomic_dec(&client->refcount);
kfree(req); kfree(req);
break; break;
} }
......
drivers/infiniband/core/cma.c
View file @ 40eb0066
...@@ -63,6 +63,7 @@ static struct ib_client cma_client = { ...@@ -63,6 +63,7 @@ static struct ib_client cma_client = {
}; };
static struct ib_sa_client sa_client; static struct ib_sa_client sa_client;
static struct rdma_addr_client addr_client;
static LIST_HEAD(dev_list); static LIST_HEAD(dev_list);
static LIST_HEAD(listen_any_list); static LIST_HEAD(listen_any_list);
static DEFINE_MUTEX(lock); static DEFINE_MUTEX(lock);
...@@ -1625,8 +1626,8 @@ int rdma_resolve_addr(struct rdma_cm_id *id, struct sockaddr *src_addr, ...@@ -1625,8 +1626,8 @@ int rdma_resolve_addr(struct rdma_cm_id *id, struct sockaddr *src_addr,
if (cma_any_addr(dst_addr)) if (cma_any_addr(dst_addr))
ret = cma_resolve_loopback(id_priv); ret = cma_resolve_loopback(id_priv);
else else
ret = rdma_resolve_ip(&id->route.addr.src_addr, dst_addr, ret = rdma_resolve_ip(&addr_client, &id->route.addr.src_addr,
&id->route.addr.dev_addr, dst_addr, &id->route.addr.dev_addr,
timeout_ms, addr_handler, id_priv); timeout_ms, addr_handler, id_priv);
if (ret) if (ret)
goto err; goto err;
...@@ -1762,22 +1763,29 @@ int rdma_bind_addr(struct rdma_cm_id *id, struct sockaddr *addr) ...@@ -1762,22 +1763,29 @@ int rdma_bind_addr(struct rdma_cm_id *id, struct sockaddr *addr)
if (!cma_any_addr(addr)) { if (!cma_any_addr(addr)) {
ret = rdma_translate_ip(addr, &id->route.addr.dev_addr); ret = rdma_translate_ip(addr, &id->route.addr.dev_addr);
if (!ret) {
mutex_lock(&lock);
ret = cma_acquire_dev(id_priv);
mutex_unlock(&lock);
}
if (ret) if (ret)
goto err; goto err1;
mutex_lock(&lock);
ret = cma_acquire_dev(id_priv);
mutex_unlock(&lock);
if (ret)
goto err1;
} }
memcpy(&id->route.addr.src_addr, addr, ip_addr_size(addr)); memcpy(&id->route.addr.src_addr, addr, ip_addr_size(addr));
ret = cma_get_port(id_priv); ret = cma_get_port(id_priv);
if (ret) if (ret)
goto err; goto err2;
return 0; return 0;
err: err2:
if (!cma_any_addr(addr)) {
mutex_lock(&lock);
cma_detach_from_dev(id_priv);
mutex_unlock(&lock);
}
err1:
cma_comp_exch(id_priv, CMA_ADDR_BOUND, CMA_IDLE); cma_comp_exch(id_priv, CMA_ADDR_BOUND, CMA_IDLE);
return ret; return ret;
} }
...@@ -2210,6 +2218,7 @@ static int cma_init(void) ...@@ -2210,6 +2218,7 @@ static int cma_init(void)
return -ENOMEM; return -ENOMEM;
ib_sa_register_client(&sa_client); ib_sa_register_client(&sa_client);
rdma_addr_register_client(&addr_client);
ret = ib_register_client(&cma_client); ret = ib_register_client(&cma_client);
if (ret) if (ret)
...@@ -2217,6 +2226,7 @@ static int cma_init(void) ...@@ -2217,6 +2226,7 @@ static int cma_init(void)
return 0; return 0;
err: err:
rdma_addr_unregister_client(&addr_client);
ib_sa_unregister_client(&sa_client); ib_sa_unregister_client(&sa_client);
destroy_workqueue(cma_wq); destroy_workqueue(cma_wq);
return ret; return ret;
...@@ -2225,6 +2235,7 @@ static int cma_init(void) ...@@ -2225,6 +2235,7 @@ static int cma_init(void)
static void cma_cleanup(void) static void cma_cleanup(void)
{ {
ib_unregister_client(&cma_client); ib_unregister_client(&cma_client);
rdma_addr_unregister_client(&addr_client);
ib_sa_unregister_client(&sa_client); ib_sa_unregister_client(&sa_client);
destroy_workqueue(cma_wq); destroy_workqueue(cma_wq);
idr_destroy(&sdp_ps); idr_destroy(&sdp_ps);
......
drivers/infiniband/core/uverbs_cmd.c
View file @ 40eb0066
...@@ -1214,7 +1214,7 @@ ssize_t ib_uverbs_query_qp(struct ib_uverbs_file *file, ...@@ -1214,7 +1214,7 @@ ssize_t ib_uverbs_query_qp(struct ib_uverbs_file *file,
resp.qp_access_flags = attr->qp_access_flags; resp.qp_access_flags = attr->qp_access_flags;
resp.pkey_index = attr->pkey_index; resp.pkey_index = attr->pkey_index;
resp.alt_pkey_index = attr->alt_pkey_index; resp.alt_pkey_index = attr->alt_pkey_index;
resp.en_sqd_async_notify = attr->en_sqd_async_notify; resp.sq_draining = attr->sq_draining;
resp.max_rd_atomic = attr->max_rd_atomic; resp.max_rd_atomic = attr->max_rd_atomic;
resp.max_dest_rd_atomic = attr->max_dest_rd_atomic; resp.max_dest_rd_atomic = attr->max_dest_rd_atomic;
resp.min_rnr_timer = attr->min_rnr_timer; resp.min_rnr_timer = attr->min_rnr_timer;
......
drivers/infiniband/hw/amso1100/c2_alloc.c
View file @ 40eb0066
...@@ -42,13 +42,14 @@ static int c2_alloc_mqsp_chunk(struct c2_dev *c2dev, gfp_t gfp_mask, ...@@ -42,13 +42,14 @@ static int c2_alloc_mqsp_chunk(struct c2_dev *c2dev, gfp_t gfp_mask,
{ {
int i; int i;
struct sp_chunk *new_head; struct sp_chunk *new_head;
dma_addr_t dma_addr;
new_head = (struct sp_chunk *) __get_free_page(gfp_mask); new_head = dma_alloc_coherent(&c2dev->pcidev->dev, PAGE_SIZE,
&dma_addr, gfp_mask);
if (new_head == NULL) if (new_head == NULL)
return -ENOMEM; return -ENOMEM;
new_head->dma_addr = dma_map_single(c2dev->ibdev.dma_device, new_head, new_head->dma_addr = dma_addr;
PAGE_SIZE, DMA_FROM_DEVICE);
pci_unmap_addr_set(new_head, mapping, new_head->dma_addr); pci_unmap_addr_set(new_head, mapping, new_head->dma_addr);
new_head->next = NULL; new_head->next = NULL;
...@@ -80,10 +81,8 @@ void c2_free_mqsp_pool(struct c2_dev *c2dev, struct sp_chunk *root) ...@@ -80,10 +81,8 @@ void c2_free_mqsp_pool(struct c2_dev *c2dev, struct sp_chunk *root)
while (root) { while (root) {
next = root->next; next = root->next;
dma_unmap_single(c2dev->ibdev.dma_device, dma_free_coherent(&c2dev->pcidev->dev, PAGE_SIZE, root,
pci_unmap_addr(root, mapping), PAGE_SIZE, pci_unmap_addr(root, mapping));
DMA_FROM_DEVICE);
__free_page((struct page *) root);
root = next; root = next;
} }
} }
......
drivers/infiniband/hw/amso1100/c2_cq.c
View file @ 40eb0066
...@@ -246,20 +246,17 @@ int c2_arm_cq(struct ib_cq *ibcq, enum ib_cq_notify notify) ...@@ -246,20 +246,17 @@ int c2_arm_cq(struct ib_cq *ibcq, enum ib_cq_notify notify)
static void c2_free_cq_buf(struct c2_dev *c2dev, struct c2_mq *mq) static void c2_free_cq_buf(struct c2_dev *c2dev, struct c2_mq *mq)
{ {
dma_free_coherent(&c2dev->pcidev->dev, mq->q_size * mq->msg_size,
dma_unmap_single(c2dev->ibdev.dma_device, pci_unmap_addr(mq, mapping), mq->msg_pool.host, pci_unmap_addr(mq, mapping));
mq->q_size * mq->msg_size, DMA_FROM_DEVICE);
free_pages((unsigned long) mq->msg_pool.host,
get_order(mq->q_size * mq->msg_size));
} }
static int c2_alloc_cq_buf(struct c2_dev *c2dev, struct c2_mq *mq, int q_size, static int c2_alloc_cq_buf(struct c2_dev *c2dev, struct c2_mq *mq, int q_size,
int msg_size) int msg_size)
{ {
unsigned long pool_start; u8 *pool_start;
pool_start = __get_free_pages(GFP_KERNEL, pool_start = dma_alloc_coherent(&c2dev->pcidev->dev, q_size * msg_size,
get_order(q_size * msg_size)); &mq->host_dma, GFP_KERNEL);
if (!pool_start) if (!pool_start)
return -ENOMEM; return -ENOMEM;
...@@ -267,13 +264,10 @@ static int c2_alloc_cq_buf(struct c2_dev *c2dev, struct c2_mq *mq, int q_size, ...@@ -267,13 +264,10 @@ static int c2_alloc_cq_buf(struct c2_dev *c2dev, struct c2_mq *mq, int q_size,
0, /* index (currently unknown) */ 0, /* index (currently unknown) */
q_size, q_size,
msg_size, msg_size,
(u8 *) pool_start, pool_start,
NULL, /* peer (currently unknown) */ NULL, /* peer (currently unknown) */
C2_MQ_HOST_TARGET); C2_MQ_HOST_TARGET);
mq->host_dma = dma_map_single(c2dev->ibdev.dma_device,
(void *)pool_start,
q_size * msg_size, DMA_FROM_DEVICE);
pci_unmap_addr_set(mq, mapping, mq->host_dma); pci_unmap_addr_set(mq, mapping, mq->host_dma);
return 0; return 0;
......
drivers/infiniband/hw/amso1100/c2_rnic.c
View file @ 40eb0066
...@@ -517,14 +517,12 @@ int c2_rnic_init(struct c2_dev *c2dev) ...@@ -517,14 +517,12 @@ int c2_rnic_init(struct c2_dev *c2dev)
/* Initialize the Verbs Reply Queue */ /* Initialize the Verbs Reply Queue */
qsize = be32_to_cpu(readl(mmio_regs + C2_REGS_Q1_QSIZE)); qsize = be32_to_cpu(readl(mmio_regs + C2_REGS_Q1_QSIZE));
msgsize = be32_to_cpu(readl(mmio_regs + C2_REGS_Q1_MSGSIZE)); msgsize = be32_to_cpu(readl(mmio_regs + C2_REGS_Q1_MSGSIZE));
q1_pages = kmalloc(qsize * msgsize, GFP_KERNEL); q1_pages = dma_alloc_coherent(&c2dev->pcidev->dev, qsize * msgsize,
&c2dev->rep_vq.host_dma, GFP_KERNEL);
if (!q1_pages) { if (!q1_pages) {
err = -ENOMEM; err = -ENOMEM;
goto bail1; goto bail1;
} }
c2dev->rep_vq.host_dma = dma_map_single(c2dev->ibdev.dma_device,
(void *)q1_pages, qsize * msgsize,
DMA_FROM_DEVICE);
pci_unmap_addr_set(&c2dev->rep_vq, mapping, c2dev->rep_vq.host_dma); pci_unmap_addr_set(&c2dev->rep_vq, mapping, c2dev->rep_vq.host_dma);
pr_debug("%s rep_vq va %p dma %llx\n", __FUNCTION__, q1_pages, pr_debug("%s rep_vq va %p dma %llx\n", __FUNCTION__, q1_pages,
(unsigned long long) c2dev->rep_vq.host_dma); (unsigned long long) c2dev->rep_vq.host_dma);
...@@ -540,17 +538,15 @@ int c2_rnic_init(struct c2_dev *c2dev) ...@@ -540,17 +538,15 @@ int c2_rnic_init(struct c2_dev *c2dev)
/* Initialize the Asynchronus Event Queue */ /* Initialize the Asynchronus Event Queue */
qsize = be32_to_cpu(readl(mmio_regs + C2_REGS_Q2_QSIZE)); qsize = be32_to_cpu(readl(mmio_regs + C2_REGS_Q2_QSIZE));
msgsize = be32_to_cpu(readl(mmio_regs + C2_REGS_Q2_MSGSIZE)); msgsize = be32_to_cpu(readl(mmio_regs + C2_REGS_Q2_MSGSIZE));
q2_pages = kmalloc(qsize * msgsize, GFP_KERNEL); q2_pages = dma_alloc_coherent(&c2dev->pcidev->dev, qsize * msgsize,
&c2dev->aeq.host_dma, GFP_KERNEL);
if (!q2_pages) { if (!q2_pages) {
err = -ENOMEM; err = -ENOMEM;
goto bail2; goto bail2;
} }
c2dev->aeq.host_dma = dma_map_single(c2dev->ibdev.dma_device,
(void *)q2_pages, qsize * msgsize,
DMA_FROM_DEVICE);
pci_unmap_addr_set(&c2dev->aeq, mapping, c2dev->aeq.host_dma); pci_unmap_addr_set(&c2dev->aeq, mapping, c2dev->aeq.host_dma);
pr_debug("%s aeq va %p dma %llx\n", __FUNCTION__, q1_pages, pr_debug("%s aeq va %p dma %llx\n", __FUNCTION__, q2_pages,
(unsigned long long) c2dev->rep_vq.host_dma); (unsigned long long) c2dev->aeq.host_dma);
c2_mq_rep_init(&c2dev->aeq, c2_mq_rep_init(&c2dev->aeq,
2, 2,
qsize, qsize,
...@@ -597,17 +593,13 @@ int c2_rnic_init(struct c2_dev *c2dev) ...@@ -597,17 +593,13 @@ int c2_rnic_init(struct c2_dev *c2dev)
bail4: bail4:
vq_term(c2dev); vq_term(c2dev);
bail3: bail3:
dma_unmap_single(c2dev->ibdev.dma_device, dma_free_coherent(&c2dev->pcidev->dev,
pci_unmap_addr(&c2dev->aeq, mapping), c2dev->aeq.q_size * c2dev->aeq.msg_size,
c2dev->aeq.q_size * c2dev->aeq.msg_size, q2_pages, pci_unmap_addr(&c2dev->aeq, mapping));
DMA_FROM_DEVICE);
kfree(q2_pages);
bail2: bail2:
dma_unmap_single(c2dev->ibdev.dma_device, dma_free_coherent(&c2dev->pcidev->dev,
pci_unmap_addr(&c2dev->rep_vq, mapping), c2dev->rep_vq.q_size * c2dev->rep_vq.msg_size,
c2dev->rep_vq.q_size * c2dev->rep_vq.msg_size, q1_pages, pci_unmap_addr(&c2dev->rep_vq, mapping));
DMA_FROM_DEVICE);
kfree(q1_pages);
bail1: bail1:
c2_free_mqsp_pool(c2dev, c2dev->kern_mqsp_pool); c2_free_mqsp_pool(c2dev, c2dev->kern_mqsp_pool);
bail0: bail0:
...@@ -640,19 +632,17 @@ void c2_rnic_term(struct c2_dev *c2dev) ...@@ -640,19 +632,17 @@ void c2_rnic_term(struct c2_dev *c2dev)
/* Free the verbs request allocator */ /* Free the verbs request allocator */
vq_term(c2dev); vq_term(c2dev);
/* Unmap and free the asynchronus event queue */ /* Free the asynchronus event queue */
dma_unmap_single(c2dev->ibdev.dma_device, dma_free_coherent(&c2dev->pcidev->dev,
pci_unmap_addr(&c2dev->aeq, mapping), c2dev->aeq.q_size * c2dev->aeq.msg_size,
c2dev->aeq.q_size * c2dev->aeq.msg_size, c2dev->aeq.msg_pool.host,
DMA_FROM_DEVICE); pci_unmap_addr(&c2dev->aeq, mapping));
kfree(c2dev->aeq.msg_pool.host);
/* Free the verbs reply queue */
/* Unmap and free the verbs reply queue */ dma_free_coherent(&c2dev->pcidev->dev,
dma_unmap_single(c2dev->ibdev.dma_device, c2dev->rep_vq.q_size * c2dev->rep_vq.msg_size,
pci_unmap_addr(&c2dev->rep_vq, mapping), c2dev->rep_vq.msg_pool.host,
c2dev->rep_vq.q_size * c2dev->rep_vq.msg_size, pci_unmap_addr(&c2dev->rep_vq, mapping));
DMA_FROM_DEVICE);
kfree(c2dev->rep_vq.msg_pool.host);
/* Free the MQ shared pointer pool */ /* Free the MQ shared pointer pool */
c2_free_mqsp_pool(c2dev, c2dev->kern_mqsp_pool); c2_free_mqsp_pool(c2dev, c2dev->kern_mqsp_pool);
......
drivers/infiniband/hw/ehca/ehca_tools.h
View file @ 40eb0066
...@@ -63,6 +63,7 @@ ...@@ -63,6 +63,7 @@
#include <asm/ibmebus.h> #include <asm/ibmebus.h>
#include <asm/io.h> #include <asm/io.h>
#include <asm/pgtable.h> #include <asm/pgtable.h>
#include <asm/hvcall.h>
extern int ehca_debug_level; extern int ehca_debug_level;
......
drivers/infiniband/hw/mthca/mthca_cmd.c
View file @ 40eb0066
...@@ -1820,11 +1820,11 @@ int mthca_MAD_IFC(struct mthca_dev *dev, int ignore_mkey, int ignore_bkey, ...@@ -1820,11 +1820,11 @@ int mthca_MAD_IFC(struct mthca_dev *dev, int ignore_mkey, int ignore_bkey,
#define MAD_IFC_BOX_SIZE 0x400 #define MAD_IFC_BOX_SIZE 0x400
#define MAD_IFC_MY_QPN_OFFSET 0x100 #define MAD_IFC_MY_QPN_OFFSET 0x100
#define MAD_IFC_RQPN_OFFSET 0x104 #define MAD_IFC_RQPN_OFFSET 0x108
#define MAD_IFC_SL_OFFSET 0x108 #define MAD_IFC_SL_OFFSET 0x10c
#define MAD_IFC_G_PATH_OFFSET 0x109 #define MAD_IFC_G_PATH_OFFSET 0x10d
#define MAD_IFC_RLID_OFFSET 0x10a #define MAD_IFC_RLID_OFFSET 0x10e
#define MAD_IFC_PKEY_OFFSET 0x10e #define MAD_IFC_PKEY_OFFSET 0x112
#define MAD_IFC_GRH_OFFSET 0x140 #define MAD_IFC_GRH_OFFSET 0x140
inmailbox = mthca_alloc_mailbox(dev, GFP_KERNEL); inmailbox = mthca_alloc_mailbox(dev, GFP_KERNEL);
...@@ -1862,7 +1862,7 @@ int mthca_MAD_IFC(struct mthca_dev *dev, int ignore_mkey, int ignore_bkey, ...@@ -1862,7 +1862,7 @@ int mthca_MAD_IFC(struct mthca_dev *dev, int ignore_mkey, int ignore_bkey,
val = in_wc->dlid_path_bits | val = in_wc->dlid_path_bits |
(in_wc->wc_flags & IB_WC_GRH ? 0x80 : 0); (in_wc->wc_flags & IB_WC_GRH ? 0x80 : 0);
MTHCA_PUT(inbox, val, MAD_IFC_GRH_OFFSET); MTHCA_PUT(inbox, val, MAD_IFC_G_PATH_OFFSET);
MTHCA_PUT(inbox, in_wc->slid, MAD_IFC_RLID_OFFSET); MTHCA_PUT(inbox, in_wc->slid, MAD_IFC_RLID_OFFSET);
MTHCA_PUT(inbox, in_wc->pkey_index, MAD_IFC_PKEY_OFFSET); MTHCA_PUT(inbox, in_wc->pkey_index, MAD_IFC_PKEY_OFFSET);
...@@ -1870,7 +1870,7 @@ int mthca_MAD_IFC(struct mthca_dev *dev, int ignore_mkey, int ignore_bkey, ...@@ -1870,7 +1870,7 @@ int mthca_MAD_IFC(struct mthca_dev *dev, int ignore_mkey, int ignore_bkey,
if (in_grh) if (in_grh)
memcpy(inbox + MAD_IFC_GRH_OFFSET, in_grh, 40); memcpy(inbox + MAD_IFC_GRH_OFFSET, in_grh, 40);
op_modifier |= 0x10; op_modifier |= 0x4;
in_modifier |= in_wc->slid << 16; in_modifier |= in_wc->slid << 16;
} }
......
drivers/infiniband/ulp/iser/iscsi_iser.c
View file @ 40eb0066
...@@ -363,11 +363,11 @@ iscsi_iser_conn_start(struct iscsi_cls_conn *cls_conn) ...@@ -363,11 +363,11 @@ iscsi_iser_conn_start(struct iscsi_cls_conn *cls_conn)
struct iscsi_conn *conn = cls_conn->dd_data; struct iscsi_conn *conn = cls_conn->dd_data;
int err; int err;
err = iscsi_conn_start(cls_conn); err = iser_conn_set_full_featured_mode(conn);
if (err) if (err)
return err; return err;
return iser_conn_set_full_featured_mode(conn); return iscsi_conn_start(cls_conn);
} }
static struct iscsi_transport iscsi_iser_transport; static struct iscsi_transport iscsi_iser_transport;
......
include/rdma/ib_addr.h
View file @ 40eb0066
...@@ -36,6 +36,22 @@ ...@@ -36,6 +36,22 @@
#include <linux/socket.h> #include <linux/socket.h>
#include <rdma/ib_verbs.h> #include <rdma/ib_verbs.h>
struct rdma_addr_client {
atomic_t refcount;
struct completion comp;
};
/**
* rdma_addr_register_client - Register an address client.
*/
void rdma_addr_register_client(struct rdma_addr_client *client);
/**
* rdma_addr_unregister_client - Deregister an address client.
* @client: Client object to deregister.
*/
void rdma_addr_unregister_client(struct rdma_addr_client *client);
struct rdma_dev_addr { struct rdma_dev_addr {
unsigned char src_dev_addr[MAX_ADDR_LEN]; unsigned char src_dev_addr[MAX_ADDR_LEN];
unsigned char dst_dev_addr[MAX_ADDR_LEN]; unsigned char dst_dev_addr[MAX_ADDR_LEN];
...@@ -52,6 +68,7 @@ int rdma_translate_ip(struct sockaddr *addr, struct rdma_dev_addr *dev_addr); ...@@ -52,6 +68,7 @@ int rdma_translate_ip(struct sockaddr *addr, struct rdma_dev_addr *dev_addr);
/** /**
* rdma_resolve_ip - Resolve source and destination IP addresses to * rdma_resolve_ip - Resolve source and destination IP addresses to
* RDMA hardware addresses. * RDMA hardware addresses.
* @client: Address client associated with request.
* @src_addr: An optional source address to use in the resolution. If a * @src_addr: An optional source address to use in the resolution. If a
* source address is not provided, a usable address will be returned via * source address is not provided, a usable address will be returned via
* the callback. * the callback.
...@@ -64,7 +81,8 @@ int rdma_translate_ip(struct sockaddr *addr, struct rdma_dev_addr *dev_addr); ...@@ -64,7 +81,8 @@ int rdma_translate_ip(struct sockaddr *addr, struct rdma_dev_addr *dev_addr);
* or been canceled. A status of 0 indicates success. * or been canceled. A status of 0 indicates success.
* @context: User-specified context associated with the call. * @context: User-specified context associated with the call.
*/ */
int rdma_resolve_ip(struct sockaddr *src_addr, struct sockaddr *dst_addr, int rdma_resolve_ip(struct rdma_addr_client *client,
struct sockaddr *src_addr, struct sockaddr *dst_addr,
struct rdma_dev_addr *addr, int timeout_ms, struct rdma_dev_addr *addr, int timeout_ms,
void (*callback)(int status, struct sockaddr *src_addr, void (*callback)(int status, struct sockaddr *src_addr,
struct rdma_dev_addr *addr, void *context), struct rdma_dev_addr *addr, void *context),
......
include/rdma/ib_user_verbs.h
View file @ 40eb0066
...@@ -458,7 +458,7 @@ struct ib_uverbs_query_qp_resp { ...@@ -458,7 +458,7 @@ struct ib_uverbs_query_qp_resp {
__u8 cur_qp_state; __u8 cur_qp_state;
__u8 path_mtu; __u8 path_mtu;
__u8 path_mig_state; __u8 path_mig_state;
__u8 en_sqd_async_notify; __u8 sq_draining;
__u8 max_rd_atomic; __u8 max_rd_atomic;
__u8 max_dest_rd_atomic; __u8 max_dest_rd_atomic;
__u8 min_rnr_timer; __u8 min_rnr_timer;
......
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
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7