aboutsummaryrefslogtreecommitdiffstats
path: root/drivers/infiniband
diff options
context:
space:
mode:
Diffstat (limited to 'drivers/infiniband')
-rw-r--r--drivers/infiniband/ulp/srp/ib_srp.c290
-rw-r--r--drivers/infiniband/ulp/srp/ib_srp.h25
2 files changed, 228 insertions, 87 deletions
diff --git a/drivers/infiniband/ulp/srp/ib_srp.c b/drivers/infiniband/ulp/srp/ib_srp.c
index 9cbdffa08dc2..9c373139ee63 100644
--- a/drivers/infiniband/ulp/srp/ib_srp.c
+++ b/drivers/infiniband/ulp/srp/ib_srp.c
@@ -105,7 +105,8 @@ static struct srp_iu *srp_alloc_iu(struct srp_host *host, size_t size,
105 if (!iu->buf) 105 if (!iu->buf)
106 goto out_free_iu; 106 goto out_free_iu;
107 107
108 iu->dma = dma_map_single(host->dev->dma_device, iu->buf, size, direction); 108 iu->dma = dma_map_single(host->dev->dev->dma_device,
109 iu->buf, size, direction);
109 if (dma_mapping_error(iu->dma)) 110 if (dma_mapping_error(iu->dma))
110 goto out_free_buf; 111 goto out_free_buf;
111 112
@@ -127,7 +128,8 @@ static void srp_free_iu(struct srp_host *host, struct srp_iu *iu)
127 if (!iu) 128 if (!iu)
128 return; 129 return;
129 130
130 dma_unmap_single(host->dev->dma_device, iu->dma, iu->size, iu->direction); 131 dma_unmap_single(host->dev->dev->dma_device,
132 iu->dma, iu->size, iu->direction);
131 kfree(iu->buf); 133 kfree(iu->buf);
132 kfree(iu); 134 kfree(iu);
133} 135}
@@ -147,7 +149,7 @@ static int srp_init_qp(struct srp_target_port *target,
147 if (!attr) 149 if (!attr)
148 return -ENOMEM; 150 return -ENOMEM;
149 151
150 ret = ib_find_cached_pkey(target->srp_host->dev, 152 ret = ib_find_cached_pkey(target->srp_host->dev->dev,
151 target->srp_host->port, 153 target->srp_host->port,
152 be16_to_cpu(target->path.pkey), 154 be16_to_cpu(target->path.pkey),
153 &attr->pkey_index); 155 &attr->pkey_index);
@@ -179,7 +181,7 @@ static int srp_create_target_ib(struct srp_target_port *target)
179 if (!init_attr) 181 if (!init_attr)
180 return -ENOMEM; 182 return -ENOMEM;
181 183
182 target->cq = ib_create_cq(target->srp_host->dev, srp_completion, 184 target->cq = ib_create_cq(target->srp_host->dev->dev, srp_completion,
183 NULL, target, SRP_CQ_SIZE); 185 NULL, target, SRP_CQ_SIZE);
184 if (IS_ERR(target->cq)) { 186 if (IS_ERR(target->cq)) {
185 ret = PTR_ERR(target->cq); 187 ret = PTR_ERR(target->cq);
@@ -198,7 +200,7 @@ static int srp_create_target_ib(struct srp_target_port *target)
198 init_attr->send_cq = target->cq; 200 init_attr->send_cq = target->cq;
199 init_attr->recv_cq = target->cq; 201 init_attr->recv_cq = target->cq;
200 202
201 target->qp = ib_create_qp(target->srp_host->pd, init_attr); 203 target->qp = ib_create_qp(target->srp_host->dev->pd, init_attr);
202 if (IS_ERR(target->qp)) { 204 if (IS_ERR(target->qp)) {
203 ret = PTR_ERR(target->qp); 205 ret = PTR_ERR(target->qp);
204 ib_destroy_cq(target->cq); 206 ib_destroy_cq(target->cq);
@@ -250,7 +252,7 @@ static int srp_lookup_path(struct srp_target_port *target)
250 252
251 init_completion(&target->done); 253 init_completion(&target->done);
252 254
253 target->path_query_id = ib_sa_path_rec_get(target->srp_host->dev, 255 target->path_query_id = ib_sa_path_rec_get(target->srp_host->dev->dev,
254 target->srp_host->port, 256 target->srp_host->port,
255 &target->path, 257 &target->path,
256 IB_SA_PATH_REC_DGID | 258 IB_SA_PATH_REC_DGID |
@@ -421,6 +423,11 @@ static void srp_unmap_data(struct scsi_cmnd *scmnd,
421 scmnd->sc_data_direction != DMA_FROM_DEVICE)) 423 scmnd->sc_data_direction != DMA_FROM_DEVICE))
422 return; 424 return;
423 425
426 if (req->fmr) {
427 ib_fmr_pool_unmap(req->fmr);
428 req->fmr = NULL;
429 }
430
424 /* 431 /*
425 * This handling of non-SG commands can be killed when the 432 * This handling of non-SG commands can be killed when the
426 * SCSI midlayer no longer generates non-SG commands. 433 * SCSI midlayer no longer generates non-SG commands.
@@ -433,7 +440,7 @@ static void srp_unmap_data(struct scsi_cmnd *scmnd,
433 scat = &req->fake_sg; 440 scat = &req->fake_sg;
434 } 441 }
435 442
436 dma_unmap_sg(target->srp_host->dev->dma_device, scat, nents, 443 dma_unmap_sg(target->srp_host->dev->dev->dma_device, scat, nents,
437 scmnd->sc_data_direction); 444 scmnd->sc_data_direction);
438} 445}
439 446
@@ -459,7 +466,7 @@ static int srp_reconnect_target(struct srp_target_port *target)
459 * Now get a new local CM ID so that we avoid confusing the 466 * Now get a new local CM ID so that we avoid confusing the
460 * target in case things are really fouled up. 467 * target in case things are really fouled up.
461 */ 468 */
462 new_cm_id = ib_create_cm_id(target->srp_host->dev, 469 new_cm_id = ib_create_cm_id(target->srp_host->dev->dev,
463 srp_cm_handler, target); 470 srp_cm_handler, target);
464 if (IS_ERR(new_cm_id)) { 471 if (IS_ERR(new_cm_id)) {
465 ret = PTR_ERR(new_cm_id); 472 ret = PTR_ERR(new_cm_id);
@@ -528,14 +535,79 @@ err:
528 return ret; 535 return ret;
529} 536}
530 537
538static int srp_map_fmr(struct srp_device *dev, struct scatterlist *scat,
539 int sg_cnt, struct srp_request *req,
540 struct srp_direct_buf *buf)
541{
542 u64 io_addr = 0;
543 u64 *dma_pages;
544 u32 len;
545 int page_cnt;
546 int i, j;
547 int ret;
548
549 if (!dev->fmr_pool)
550 return -ENODEV;
551
552 len = page_cnt = 0;
553 for (i = 0; i < sg_cnt; ++i) {
554 if (sg_dma_address(&scat[i]) & ~dev->fmr_page_mask) {
555 if (i > 0)
556 return -EINVAL;
557 else
558 ++page_cnt;
559 }
560 if ((sg_dma_address(&scat[i]) + sg_dma_len(&scat[i])) &
561 ~dev->fmr_page_mask) {
562 if (i < sg_cnt - 1)
563 return -EINVAL;
564 else
565 ++page_cnt;
566 }
567
568 len += sg_dma_len(&scat[i]);
569 }
570
571 page_cnt += len >> dev->fmr_page_shift;
572 if (page_cnt > SRP_FMR_SIZE)
573 return -ENOMEM;
574
575 dma_pages = kmalloc(sizeof (u64) * page_cnt, GFP_ATOMIC);
576 if (!dma_pages)
577 return -ENOMEM;
578
579 page_cnt = 0;
580 for (i = 0; i < sg_cnt; ++i)
581 for (j = 0; j < sg_dma_len(&scat[i]); j += dev->fmr_page_size)
582 dma_pages[page_cnt++] =
583 (sg_dma_address(&scat[i]) & dev->fmr_page_mask) + j;
584
585 req->fmr = ib_fmr_pool_map_phys(dev->fmr_pool,
586 dma_pages, page_cnt, &io_addr);
587 if (IS_ERR(req->fmr)) {
588 ret = PTR_ERR(req->fmr);
589 goto out;
590 }
591
592 buf->va = cpu_to_be64(sg_dma_address(&scat[0]) & ~dev->fmr_page_mask);
593 buf->key = cpu_to_be32(req->fmr->fmr->rkey);
594 buf->len = cpu_to_be32(len);
595
596 ret = 0;
597
598out:
599 kfree(dma_pages);
600
601 return ret;
602}
603
531static int srp_map_data(struct scsi_cmnd *scmnd, struct srp_target_port *target, 604static int srp_map_data(struct scsi_cmnd *scmnd, struct srp_target_port *target,
532 struct srp_request *req) 605 struct srp_request *req)
533{ 606{
534 struct scatterlist *scat; 607 struct scatterlist *scat;
535 struct srp_cmd *cmd = req->cmd->buf; 608 struct srp_cmd *cmd = req->cmd->buf;
536 int len, nents, count; 609 int len, nents, count;
537 int i; 610 u8 fmt = SRP_DATA_DESC_DIRECT;
538 u8 fmt;
539 611
540 if (!scmnd->request_buffer || scmnd->sc_data_direction == DMA_NONE) 612 if (!scmnd->request_buffer || scmnd->sc_data_direction == DMA_NONE)
541 return sizeof (struct srp_cmd); 613 return sizeof (struct srp_cmd);
@@ -560,53 +632,63 @@ static int srp_map_data(struct scsi_cmnd *scmnd, struct srp_target_port *target,
560 sg_init_one(scat, scmnd->request_buffer, scmnd->request_bufflen); 632 sg_init_one(scat, scmnd->request_buffer, scmnd->request_bufflen);
561 } 633 }
562 634
563 count = dma_map_sg(target->srp_host->dev->dma_device, scat, nents, 635 count = dma_map_sg(target->srp_host->dev->dev->dma_device,
564 scmnd->sc_data_direction); 636 scat, nents, scmnd->sc_data_direction);
637
638 fmt = SRP_DATA_DESC_DIRECT;
639 len = sizeof (struct srp_cmd) + sizeof (struct srp_direct_buf);
565 640
566 if (count == 1) { 641 if (count == 1) {
642 /*
643 * The midlayer only generated a single gather/scatter
644 * entry, or DMA mapping coalesced everything to a
645 * single entry. So a direct descriptor along with
646 * the DMA MR suffices.
647 */
567 struct srp_direct_buf *buf = (void *) cmd->add_data; 648 struct srp_direct_buf *buf = (void *) cmd->add_data;
568 649
569 fmt = SRP_DATA_DESC_DIRECT;
570
571 buf->va = cpu_to_be64(sg_dma_address(scat)); 650 buf->va = cpu_to_be64(sg_dma_address(scat));
572 buf->key = cpu_to_be32(target->srp_host->mr->rkey); 651 buf->key = cpu_to_be32(target->srp_host->dev->mr->rkey);
573 buf->len = cpu_to_be32(sg_dma_len(scat)); 652 buf->len = cpu_to_be32(sg_dma_len(scat));
574 653 } else if (srp_map_fmr(target->srp_host->dev, scat, count, req,
575 len = sizeof (struct srp_cmd) + 654 (void *) cmd->add_data)) {
576 sizeof (struct srp_direct_buf); 655 /*
577 } else { 656 * FMR mapping failed, and the scatterlist has more
657 * than one entry. Generate an indirect memory
658 * descriptor.
659 */
578 struct srp_indirect_buf *buf = (void *) cmd->add_data; 660 struct srp_indirect_buf *buf = (void *) cmd->add_data;
579 u32 datalen = 0; 661 u32 datalen = 0;
662 int i;
580 663
581 fmt = SRP_DATA_DESC_INDIRECT; 664 fmt = SRP_DATA_DESC_INDIRECT;
665 len = sizeof (struct srp_cmd) +
666 sizeof (struct srp_indirect_buf) +
667 count * sizeof (struct srp_direct_buf);
668
669 for (i = 0; i < count; ++i) {
670 buf->desc_list[i].va =
671 cpu_to_be64(sg_dma_address(&scat[i]));
672 buf->desc_list[i].key =
673 cpu_to_be32(target->srp_host->dev->mr->rkey);
674 buf->desc_list[i].len =
675 cpu_to_be32(sg_dma_len(&scat[i]));
676 datalen += sg_dma_len(&scat[i]);
677 }
582 678
583 if (scmnd->sc_data_direction == DMA_TO_DEVICE) 679 if (scmnd->sc_data_direction == DMA_TO_DEVICE)
584 cmd->data_out_desc_cnt = count; 680 cmd->data_out_desc_cnt = count;
585 else 681 else
586 cmd->data_in_desc_cnt = count; 682 cmd->data_in_desc_cnt = count;
587 683
588 buf->table_desc.va = cpu_to_be64(req->cmd->dma + 684 buf->table_desc.va =
589 sizeof *cmd + 685 cpu_to_be64(req->cmd->dma + sizeof *cmd + sizeof *buf);
590 sizeof *buf);
591 buf->table_desc.key = 686 buf->table_desc.key =
592 cpu_to_be32(target->srp_host->mr->rkey); 687 cpu_to_be32(target->srp_host->dev->mr->rkey);
593 buf->table_desc.len = 688 buf->table_desc.len =
594 cpu_to_be32(count * sizeof (struct srp_direct_buf)); 689 cpu_to_be32(count * sizeof (struct srp_direct_buf));
595 690
596 for (i = 0; i < count; ++i) {
597 buf->desc_list[i].va = cpu_to_be64(sg_dma_address(&scat[i]));
598 buf->desc_list[i].key =
599 cpu_to_be32(target->srp_host->mr->rkey);
600 buf->desc_list[i].len = cpu_to_be32(sg_dma_len(&scat[i]));
601
602 datalen += sg_dma_len(&scat[i]);
603 }
604
605 buf->len = cpu_to_be32(datalen); 691 buf->len = cpu_to_be32(datalen);
606
607 len = sizeof (struct srp_cmd) +
608 sizeof (struct srp_indirect_buf) +
609 count * sizeof (struct srp_direct_buf);
610 } 692 }
611 693
612 if (scmnd->sc_data_direction == DMA_TO_DEVICE) 694 if (scmnd->sc_data_direction == DMA_TO_DEVICE)
@@ -689,7 +771,7 @@ static void srp_handle_recv(struct srp_target_port *target, struct ib_wc *wc)
689 771
690 iu = target->rx_ring[wc->wr_id & ~SRP_OP_RECV]; 772 iu = target->rx_ring[wc->wr_id & ~SRP_OP_RECV];
691 773
692 dma_sync_single_for_cpu(target->srp_host->dev->dma_device, iu->dma, 774 dma_sync_single_for_cpu(target->srp_host->dev->dev->dma_device, iu->dma,
693 target->max_ti_iu_len, DMA_FROM_DEVICE); 775 target->max_ti_iu_len, DMA_FROM_DEVICE);
694 776
695 opcode = *(u8 *) iu->buf; 777 opcode = *(u8 *) iu->buf;
@@ -726,7 +808,7 @@ static void srp_handle_recv(struct srp_target_port *target, struct ib_wc *wc)
726 break; 808 break;
727 } 809 }
728 810
729 dma_sync_single_for_device(target->srp_host->dev->dma_device, iu->dma, 811 dma_sync_single_for_device(target->srp_host->dev->dev->dma_device, iu->dma,
730 target->max_ti_iu_len, DMA_FROM_DEVICE); 812 target->max_ti_iu_len, DMA_FROM_DEVICE);
731} 813}
732 814
@@ -770,7 +852,7 @@ static int __srp_post_recv(struct srp_target_port *target)
770 852
771 list.addr = iu->dma; 853 list.addr = iu->dma;
772 list.length = iu->size; 854 list.length = iu->size;
773 list.lkey = target->srp_host->mr->lkey; 855 list.lkey = target->srp_host->dev->mr->lkey;
774 856
775 wr.next = NULL; 857 wr.next = NULL;
776 wr.sg_list = &list; 858 wr.sg_list = &list;
@@ -828,7 +910,7 @@ static int __srp_post_send(struct srp_target_port *target,
828 910
829 list.addr = iu->dma; 911 list.addr = iu->dma;
830 list.length = len; 912 list.length = len;
831 list.lkey = target->srp_host->mr->lkey; 913 list.lkey = target->srp_host->dev->mr->lkey;
832 914
833 wr.next = NULL; 915 wr.next = NULL;
834 wr.wr_id = target->tx_head & SRP_SQ_SIZE; 916 wr.wr_id = target->tx_head & SRP_SQ_SIZE;
@@ -870,7 +952,7 @@ static int srp_queuecommand(struct scsi_cmnd *scmnd,
870 if (!iu) 952 if (!iu)
871 goto err; 953 goto err;
872 954
873 dma_sync_single_for_cpu(target->srp_host->dev->dma_device, iu->dma, 955 dma_sync_single_for_cpu(target->srp_host->dev->dev->dma_device, iu->dma,
874 SRP_MAX_IU_LEN, DMA_TO_DEVICE); 956 SRP_MAX_IU_LEN, DMA_TO_DEVICE);
875 957
876 req = list_entry(target->free_reqs.next, struct srp_request, list); 958 req = list_entry(target->free_reqs.next, struct srp_request, list);
@@ -903,7 +985,7 @@ static int srp_queuecommand(struct scsi_cmnd *scmnd,
903 goto err_unmap; 985 goto err_unmap;
904 } 986 }
905 987
906 dma_sync_single_for_device(target->srp_host->dev->dma_device, iu->dma, 988 dma_sync_single_for_device(target->srp_host->dev->dev->dma_device, iu->dma,
907 SRP_MAX_IU_LEN, DMA_TO_DEVICE); 989 SRP_MAX_IU_LEN, DMA_TO_DEVICE);
908 990
909 if (__srp_post_send(target, iu, len)) { 991 if (__srp_post_send(target, iu, len)) {
@@ -1365,7 +1447,7 @@ static int srp_add_target(struct srp_host *host, struct srp_target_port *target)
1365 sprintf(target->target_name, "SRP.T10:%016llX", 1447 sprintf(target->target_name, "SRP.T10:%016llX",
1366 (unsigned long long) be64_to_cpu(target->id_ext)); 1448 (unsigned long long) be64_to_cpu(target->id_ext));
1367 1449
1368 if (scsi_add_host(target->scsi_host, host->dev->dma_device)) 1450 if (scsi_add_host(target->scsi_host, host->dev->dev->dma_device))
1369 return -ENODEV; 1451 return -ENODEV;
1370 1452
1371 mutex_lock(&host->target_mutex); 1453 mutex_lock(&host->target_mutex);
@@ -1558,7 +1640,7 @@ static ssize_t srp_create_target(struct class_device *class_dev,
1558 if (ret) 1640 if (ret)
1559 goto err; 1641 goto err;
1560 1642
1561 ib_get_cached_gid(host->dev, host->port, 0, &target->path.sgid); 1643 ib_get_cached_gid(host->dev->dev, host->port, 0, &target->path.sgid);
1562 1644
1563 printk(KERN_DEBUG PFX "new target: id_ext %016llx ioc_guid %016llx pkey %04x " 1645 printk(KERN_DEBUG PFX "new target: id_ext %016llx ioc_guid %016llx pkey %04x "
1564 "service_id %016llx dgid %04x:%04x:%04x:%04x:%04x:%04x:%04x:%04x\n", 1646 "service_id %016llx dgid %04x:%04x:%04x:%04x:%04x:%04x:%04x:%04x\n",
@@ -1579,7 +1661,7 @@ static ssize_t srp_create_target(struct class_device *class_dev,
1579 if (ret) 1661 if (ret)
1580 goto err; 1662 goto err;
1581 1663
1582 target->cm_id = ib_create_cm_id(host->dev, srp_cm_handler, target); 1664 target->cm_id = ib_create_cm_id(host->dev->dev, srp_cm_handler, target);
1583 if (IS_ERR(target->cm_id)) { 1665 if (IS_ERR(target->cm_id)) {
1584 ret = PTR_ERR(target->cm_id); 1666 ret = PTR_ERR(target->cm_id);
1585 goto err_free; 1667 goto err_free;
@@ -1619,7 +1701,7 @@ static ssize_t show_ibdev(struct class_device *class_dev, char *buf)
1619 struct srp_host *host = 1701 struct srp_host *host =
1620 container_of(class_dev, struct srp_host, class_dev); 1702 container_of(class_dev, struct srp_host, class_dev);
1621 1703
1622 return sprintf(buf, "%s\n", host->dev->name); 1704 return sprintf(buf, "%s\n", host->dev->dev->name);
1623} 1705}
1624 1706
1625static CLASS_DEVICE_ATTR(ibdev, S_IRUGO, show_ibdev, NULL); 1707static CLASS_DEVICE_ATTR(ibdev, S_IRUGO, show_ibdev, NULL);
@@ -1634,7 +1716,7 @@ static ssize_t show_port(struct class_device *class_dev, char *buf)
1634 1716
1635static CLASS_DEVICE_ATTR(port, S_IRUGO, show_port, NULL); 1717static CLASS_DEVICE_ATTR(port, S_IRUGO, show_port, NULL);
1636 1718
1637static struct srp_host *srp_add_port(struct ib_device *device, u8 port) 1719static struct srp_host *srp_add_port(struct srp_device *device, u8 port)
1638{ 1720{
1639 struct srp_host *host; 1721 struct srp_host *host;
1640 1722
@@ -1649,26 +1731,15 @@ static struct srp_host *srp_add_port(struct ib_device *device, u8 port)
1649 host->port = port; 1731 host->port = port;
1650 1732
1651 host->initiator_port_id[7] = port; 1733 host->initiator_port_id[7] = port;
1652 memcpy(host->initiator_port_id + 8, &device->node_guid, 8); 1734 memcpy(host->initiator_port_id + 8, &device->dev->node_guid, 8);
1653
1654 host->pd = ib_alloc_pd(device);
1655 if (IS_ERR(host->pd))
1656 goto err_free;
1657
1658 host->mr = ib_get_dma_mr(host->pd,
1659 IB_ACCESS_LOCAL_WRITE |
1660 IB_ACCESS_REMOTE_READ |
1661 IB_ACCESS_REMOTE_WRITE);
1662 if (IS_ERR(host->mr))
1663 goto err_pd;
1664 1735
1665 host->class_dev.class = &srp_class; 1736 host->class_dev.class = &srp_class;
1666 host->class_dev.dev = device->dma_device; 1737 host->class_dev.dev = device->dev->dma_device;
1667 snprintf(host->class_dev.class_id, BUS_ID_SIZE, "srp-%s-%d", 1738 snprintf(host->class_dev.class_id, BUS_ID_SIZE, "srp-%s-%d",
1668 device->name, port); 1739 device->dev->name, port);
1669 1740
1670 if (class_device_register(&host->class_dev)) 1741 if (class_device_register(&host->class_dev))
1671 goto err_mr; 1742 goto free_host;
1672 if (class_device_create_file(&host->class_dev, &class_device_attr_add_target)) 1743 if (class_device_create_file(&host->class_dev, &class_device_attr_add_target))
1673 goto err_class; 1744 goto err_class;
1674 if (class_device_create_file(&host->class_dev, &class_device_attr_ibdev)) 1745 if (class_device_create_file(&host->class_dev, &class_device_attr_ibdev))
@@ -1681,13 +1752,7 @@ static struct srp_host *srp_add_port(struct ib_device *device, u8 port)
1681err_class: 1752err_class:
1682 class_device_unregister(&host->class_dev); 1753 class_device_unregister(&host->class_dev);
1683 1754
1684err_mr: 1755free_host:
1685 ib_dereg_mr(host->mr);
1686
1687err_pd:
1688 ib_dealloc_pd(host->pd);
1689
1690err_free:
1691 kfree(host); 1756 kfree(host);
1692 1757
1693 return NULL; 1758 return NULL;
@@ -1695,15 +1760,62 @@ err_free:
1695 1760
1696static void srp_add_one(struct ib_device *device) 1761static void srp_add_one(struct ib_device *device)
1697{ 1762{
1698 struct list_head *dev_list; 1763 struct srp_device *srp_dev;
1764 struct ib_device_attr *dev_attr;
1765 struct ib_fmr_pool_param fmr_param;
1699 struct srp_host *host; 1766 struct srp_host *host;
1700 int s, e, p; 1767 int s, e, p;
1701 1768
1702 dev_list = kmalloc(sizeof *dev_list, GFP_KERNEL); 1769 dev_attr = kmalloc(sizeof *dev_attr, GFP_KERNEL);
1703 if (!dev_list) 1770 if (!dev_attr)
1704 return; 1771 return;
1705 1772
1706 INIT_LIST_HEAD(dev_list); 1773 if (ib_query_device(device, dev_attr)) {
1774 printk(KERN_WARNING PFX "Query device failed for %s\n",
1775 device->name);
1776 goto free_attr;
1777 }
1778
1779 srp_dev = kmalloc(sizeof *srp_dev, GFP_KERNEL);
1780 if (!srp_dev)
1781 goto free_attr;
1782
1783 /*
1784 * Use the smallest page size supported by the HCA, down to a
1785 * minimum of 512 bytes (which is the smallest sector that a
1786 * SCSI command will ever carry).
1787 */
1788 srp_dev->fmr_page_shift = max(9, ffs(dev_attr->page_size_cap) - 1);
1789 srp_dev->fmr_page_size = 1 << srp_dev->fmr_page_shift;
1790 srp_dev->fmr_page_mask = ~((unsigned long) srp_dev->fmr_page_size - 1);
1791
1792 INIT_LIST_HEAD(&srp_dev->dev_list);
1793
1794 srp_dev->dev = device;
1795 srp_dev->pd = ib_alloc_pd(device);
1796 if (IS_ERR(srp_dev->pd))
1797 goto free_dev;
1798
1799 srp_dev->mr = ib_get_dma_mr(srp_dev->pd,
1800 IB_ACCESS_LOCAL_WRITE |
1801 IB_ACCESS_REMOTE_READ |
1802 IB_ACCESS_REMOTE_WRITE);
1803 if (IS_ERR(srp_dev->mr))
1804 goto err_pd;
1805
1806 memset(&fmr_param, 0, sizeof fmr_param);
1807 fmr_param.pool_size = SRP_FMR_POOL_SIZE;
1808 fmr_param.dirty_watermark = SRP_FMR_DIRTY_SIZE;
1809 fmr_param.cache = 1;
1810 fmr_param.max_pages_per_fmr = SRP_FMR_SIZE;
1811 fmr_param.page_shift = srp_dev->fmr_page_shift;
1812 fmr_param.access = (IB_ACCESS_LOCAL_WRITE |
1813 IB_ACCESS_REMOTE_WRITE |
1814 IB_ACCESS_REMOTE_READ);
1815
1816 srp_dev->fmr_pool = ib_create_fmr_pool(srp_dev->pd, &fmr_param);
1817 if (IS_ERR(srp_dev->fmr_pool))
1818 srp_dev->fmr_pool = NULL;
1707 1819
1708 if (device->node_type == IB_NODE_SWITCH) { 1820 if (device->node_type == IB_NODE_SWITCH) {
1709 s = 0; 1821 s = 0;
@@ -1714,25 +1826,36 @@ static void srp_add_one(struct ib_device *device)
1714 } 1826 }
1715 1827
1716 for (p = s; p <= e; ++p) { 1828 for (p = s; p <= e; ++p) {
1717 host = srp_add_port(device, p); 1829 host = srp_add_port(srp_dev, p);
1718 if (host) 1830 if (host)
1719 list_add_tail(&host->list, dev_list); 1831 list_add_tail(&host->list, &srp_dev->dev_list);
1720 } 1832 }
1721 1833
1722 ib_set_client_data(device, &srp_client, dev_list); 1834 ib_set_client_data(device, &srp_client, srp_dev);
1835
1836 goto free_attr;
1837
1838err_pd:
1839 ib_dealloc_pd(srp_dev->pd);
1840
1841free_dev:
1842 kfree(srp_dev);
1843
1844free_attr:
1845 kfree(dev_attr);
1723} 1846}
1724 1847
1725static void srp_remove_one(struct ib_device *device) 1848static void srp_remove_one(struct ib_device *device)
1726{ 1849{
1727 struct list_head *dev_list; 1850 struct srp_device *srp_dev;
1728 struct srp_host *host, *tmp_host; 1851 struct srp_host *host, *tmp_host;
1729 LIST_HEAD(target_list); 1852 LIST_HEAD(target_list);
1730 struct srp_target_port *target, *tmp_target; 1853 struct srp_target_port *target, *tmp_target;
1731 unsigned long flags; 1854 unsigned long flags;
1732 1855
1733 dev_list = ib_get_client_data(device, &srp_client); 1856 srp_dev = ib_get_client_data(device, &srp_client);
1734 1857
1735 list_for_each_entry_safe(host, tmp_host, dev_list, list) { 1858 list_for_each_entry_safe(host, tmp_host, &srp_dev->dev_list, list) {
1736 class_device_unregister(&host->class_dev); 1859 class_device_unregister(&host->class_dev);
1737 /* 1860 /*
1738 * Wait for the sysfs entry to go away, so that no new 1861 * Wait for the sysfs entry to go away, so that no new
@@ -1770,12 +1893,15 @@ static void srp_remove_one(struct ib_device *device)
1770 scsi_host_put(target->scsi_host); 1893 scsi_host_put(target->scsi_host);
1771 } 1894 }
1772 1895
1773 ib_dereg_mr(host->mr);
1774 ib_dealloc_pd(host->pd);
1775 kfree(host); 1896 kfree(host);
1776 } 1897 }
1777 1898
1778 kfree(dev_list); 1899 if (srp_dev->fmr_pool)
1900 ib_destroy_fmr_pool(srp_dev->fmr_pool);
1901 ib_dereg_mr(srp_dev->mr);
1902 ib_dealloc_pd(srp_dev->pd);
1903
1904 kfree(srp_dev);
1779} 1905}
1780 1906
1781static int __init srp_init_module(void) 1907static int __init srp_init_module(void)
diff --git a/drivers/infiniband/ulp/srp/ib_srp.h b/drivers/infiniband/ulp/srp/ib_srp.h
index c5cd43aae860..5ecda4ad8906 100644
--- a/drivers/infiniband/ulp/srp/ib_srp.h
+++ b/drivers/infiniband/ulp/srp/ib_srp.h
@@ -46,6 +46,7 @@
46#include <rdma/ib_verbs.h> 46#include <rdma/ib_verbs.h>
47#include <rdma/ib_sa.h> 47#include <rdma/ib_sa.h>
48#include <rdma/ib_cm.h> 48#include <rdma/ib_cm.h>
49#include <rdma/ib_fmr_pool.h>
49 50
50enum { 51enum {
51 SRP_PATH_REC_TIMEOUT_MS = 1000, 52 SRP_PATH_REC_TIMEOUT_MS = 1000,
@@ -62,7 +63,11 @@ enum {
62 SRP_SQ_SIZE = SRP_RQ_SIZE - 1, 63 SRP_SQ_SIZE = SRP_RQ_SIZE - 1,
63 SRP_CQ_SIZE = SRP_SQ_SIZE + SRP_RQ_SIZE, 64 SRP_CQ_SIZE = SRP_SQ_SIZE + SRP_RQ_SIZE,
64 65
65 SRP_TAG_TSK_MGMT = 1 << (SRP_RQ_SHIFT + 1) 66 SRP_TAG_TSK_MGMT = 1 << (SRP_RQ_SHIFT + 1),
67
68 SRP_FMR_SIZE = 256,
69 SRP_FMR_POOL_SIZE = 1024,
70 SRP_FMR_DIRTY_SIZE = SRP_FMR_POOL_SIZE / 4
66}; 71};
67 72
68#define SRP_OP_RECV (1 << 31) 73#define SRP_OP_RECV (1 << 31)
@@ -77,15 +82,24 @@ enum srp_target_state {
77 SRP_TARGET_REMOVED 82 SRP_TARGET_REMOVED
78}; 83};
79 84
80struct srp_host { 85struct srp_device {
81 u8 initiator_port_id[16]; 86 struct list_head dev_list;
82 struct ib_device *dev; 87 struct ib_device *dev;
83 u8 port;
84 struct ib_pd *pd; 88 struct ib_pd *pd;
85 struct ib_mr *mr; 89 struct ib_mr *mr;
90 struct ib_fmr_pool *fmr_pool;
91 int fmr_page_shift;
92 int fmr_page_size;
93 unsigned long fmr_page_mask;
94};
95
96struct srp_host {
97 u8 initiator_port_id[16];
98 struct srp_device *dev;
99 u8 port;
86 struct class_device class_dev; 100 struct class_device class_dev;
87 struct list_head target_list; 101 struct list_head target_list;
88 struct mutex target_mutex; 102 struct mutex target_mutex;
89 struct completion released; 103 struct completion released;
90 struct list_head list; 104 struct list_head list;
91}; 105};
@@ -95,6 +109,7 @@ struct srp_request {
95 struct scsi_cmnd *scmnd; 109 struct scsi_cmnd *scmnd;
96 struct srp_iu *cmd; 110 struct srp_iu *cmd;
97 struct srp_iu *tsk_mgmt; 111 struct srp_iu *tsk_mgmt;
112 struct ib_pool_fmr *fmr;
98 /* 113 /*
99 * Fake scatterlist used when scmnd->use_sg==0. Can be killed 114 * Fake scatterlist used when scmnd->use_sg==0. Can be killed
100 * when the SCSI midlayer no longer generates non-SG commands. 115 * when the SCSI midlayer no longer generates non-SG commands.