new file mode 100644
@@ -0,0 +1,314 @@
+// SPDX-License-Identifier: GPL-2.0
+/*
+ * Authors: Cheng Xu <chengyou@linux.alibaba.com>
+ * Kai Shen <kaishen@linux.alibaba.com>
+ * Copyright (c) 2020-2021, Alibaba Group.
+ */
+#include <linux/errno.h>
+#include <linux/types.h>
+#include <linux/list.h>
+#include <linux/debugfs.h>
+
+#include <rdma/iw_cm.h>
+#include <rdma/ib_verbs.h>
+#include <rdma/ib_smi.h>
+#include <rdma/ib_user_verbs.h>
+
+#include "erdma.h"
+#include "erdma_cm.h"
+#include "erdma_debug.h"
+#include "erdma_verbs.h"
+
+char *cc_method_string[ERDMA_CC_METHODS_NUM] = {
+ [ERDMA_CC_NEWRENO] = "newreno",
+ [ERDMA_CC_CUBIC] = "cubic",
+ [ERDMA_CC_HPCC_RTT] = "hpcc_rtt",
+ [ERDMA_CC_HPCC_ECN] = "hpcc_ecn",
+ [ERDMA_CC_HPCC_INT] = "hpcc_int"
+};
+
+static struct dentry *erdma_debugfs;
+
+
+static int erdma_dbgfs_file_open(struct inode *inode, struct file *fp)
+{
+ fp->private_data = inode->i_private;
+ return nonseekable_open(inode, fp);
+}
+
+static ssize_t erdma_show_stats(struct file *fp, char __user *buf, size_t space,
+ loff_t *ppos)
+{
+ struct erdma_dev *dev = fp->private_data;
+ char *kbuf = NULL;
+ int len = 0;
+
+ if (*ppos)
+ goto out;
+
+ kbuf = kmalloc(space, GFP_KERNEL);
+ if (!kbuf)
+ goto out;
+
+ len = snprintf(kbuf, space, "Resource Summary of %s:\n"
+ "%s: %d\n%s: %d\n%s: %d\n%s: %d\n%s: %d\n%s: %d\n",
+ dev->ibdev.name,
+ "ucontext ", atomic_read(&dev->num_ctx),
+ "pd ", atomic_read(&dev->num_pd),
+ "qp ", atomic_read(&dev->num_qp),
+ "cq ", atomic_read(&dev->num_cq),
+ "mr ", atomic_read(&dev->num_mr),
+ "cep ", atomic_read(&dev->num_cep));
+ if (len > space)
+ len = space;
+out:
+ if (len)
+ len = simple_read_from_buffer(buf, len, ppos, kbuf, len);
+
+ kfree(kbuf);
+ return len;
+
+}
+
+static ssize_t erdma_show_cmdq(struct file *fp, char __user *buf, size_t space,
+ loff_t *ppos)
+{
+ struct erdma_dev *dev = fp->private_data;
+ char *kbuf = NULL;
+ int len = 0, n;
+
+ if (*ppos)
+ goto out;
+
+ kbuf = kmalloc(space, GFP_KERNEL);
+ if (!kbuf)
+ goto out;
+
+ len = snprintf(kbuf, space,
+ "CMDQ Summary:\n"
+ "submitted:%llu, completed:%llu.\n"
+ "ceq notify:%llu,,notify:%llu aeq event:%llu,,notify:%llu cq armed:%llu\n",
+ dev->cmdq.sq.total_cmds, dev->cmdq.sq.total_comp_cmds,
+ atomic64_read(&dev->cmdq.eq.event_num),
+ atomic64_read(&dev->cmdq.eq.notify_num),
+ atomic64_read(&dev->aeq.eq.event_num),
+ atomic64_read(&dev->aeq.eq.notify_num),
+ atomic64_read(&dev->cmdq.cq.cq_armed_num));
+ if (len > space) {
+ len = space;
+ goto out;
+ }
+
+ space -= len;
+ n = snprintf(kbuf + len, space,
+ "SQ-buf depth:%u, ci:0x%x, pi:0x%x\n",
+ dev->cmdq.sq.depth, dev->cmdq.sq.ci, dev->cmdq.sq.pi);
+ len += n;
+ space -= n;
+ n = snprintf(kbuf + len, space,
+ "CQ-buf depth:%u, ci:0x%x\n",
+ dev->cmdq.cq.depth, dev->cmdq.cq.ci);
+ len += n;
+ space -= n;
+ n = snprintf(kbuf + len, space,
+ "EQ-buf depth:%u, ci:0x%x\n",
+ dev->cmdq.eq.depth, dev->cmdq.eq.ci);
+ len += n;
+ space -= n;
+ n = snprintf(kbuf + len, space,
+ "AEQ-buf depth:%u, ci:0x%x\n",
+ dev->aeq.eq.depth, dev->aeq.eq.ci);
+ len += n;
+ space -= n;
+ n = snprintf(kbuf + len, space,
+ "q-flags:0x%lx\n", dev->cmdq.state);
+
+ len += n;
+ space -= n;
+
+out:
+ if (len)
+ len = simple_read_from_buffer(buf, len, ppos, kbuf, len);
+
+ kfree(kbuf);
+ return len;
+
+}
+
+static ssize_t erdma_show_ceq(struct file *fp, char __user *buf, size_t space,
+ loff_t *ppos)
+{
+
+ struct erdma_dev *dev = fp->private_data;
+ char *kbuf = NULL;
+ int len = 0, n, i;
+ struct erdma_eq_cb *eq_cb;
+
+ if (*ppos)
+ goto out;
+
+ kbuf = kmalloc(space, GFP_KERNEL);
+ if (!kbuf)
+ goto out;
+
+ len = snprintf(kbuf, space, "CEQs Summary:\n");
+ if (len > space) {
+ len = space;
+ goto out;
+ }
+
+ space -= len;
+
+ for (i = 0; i < 31; i++) {
+ eq_cb = &dev->ceqs[i];
+ n = snprintf(kbuf + len, space,
+ "%d ready:%u,event_num:%llu,notify_num:%llu,depth:%u,ci:0x%x\n",
+ i, eq_cb->ready,
+ atomic64_read(&eq_cb->eq.event_num),
+ atomic64_read(&eq_cb->eq.notify_num),
+ eq_cb->eq.depth, eq_cb->eq.ci);
+ if (n < space) {
+ len += n;
+ space -= n;
+ } else {
+ len += space;
+ break;
+ }
+ }
+
+out:
+ if (len)
+ len = simple_read_from_buffer(buf, len, ppos, kbuf, len);
+
+ kfree(kbuf);
+ return len;
+
+}
+
+static ssize_t erdma_show_cc(struct file *fp, char __user *buf, size_t space,
+ loff_t *ppos)
+{
+ struct erdma_dev *dev = fp->private_data;
+ char *kbuf = NULL;
+ int len = 0;
+
+ kbuf = kmalloc(space, GFP_KERNEL);
+ if (!kbuf)
+ goto out;
+
+ if (*ppos)
+ goto out;
+
+ if (dev->cc_method < 0 || dev->cc_method >= ERDMA_CC_METHODS_NUM)
+ goto out;
+
+ len = snprintf(kbuf, space, "%s\n", cc_method_string[dev->cc_method]);
+ if (len > space)
+ len = space;
+out:
+ if (len)
+ len = simple_read_from_buffer(buf, len, ppos, kbuf, len);
+
+ kfree(kbuf);
+ return len;
+
+}
+
+static ssize_t erdma_set_cc(struct file *fp, const char __user *buf, size_t count, loff_t *ppos)
+{
+ int bytes_not_copied;
+ struct erdma_dev *dev = fp->private_data;
+ char cmd_buf[64];
+ int i;
+
+ if (*ppos != 0)
+ return 0;
+
+ if (count >= sizeof(cmd_buf))
+ return -ENOSPC;
+
+ bytes_not_copied = copy_from_user(cmd_buf, buf, count);
+ if (bytes_not_copied < 0)
+ return bytes_not_copied;
+ if (bytes_not_copied > 0)
+ count -= bytes_not_copied;
+
+ cmd_buf[count] = '\0';
+ *ppos = 0;
+
+ for (i = 0; i < ERDMA_CC_METHODS_NUM; i++) {
+ if (strlen(cc_method_string[i]) == (count - 1) &&
+ !memcmp(cmd_buf, cc_method_string[i], count - 1)) {
+ dev->cc_method = i;
+ return count;
+ }
+ }
+
+ return -EINVAL;
+}
+
+static const struct file_operations erdma_stats_debug_fops = {
+ .owner = THIS_MODULE,
+ .open = erdma_dbgfs_file_open,
+ .read = erdma_show_stats
+};
+
+static const struct file_operations erdma_cmdq_debug_fops = {
+ .owner = THIS_MODULE,
+ .open = erdma_dbgfs_file_open,
+ .read = erdma_show_cmdq
+};
+
+static const struct file_operations erdma_ceq_debug_fops = {
+ .owner = THIS_MODULE,
+ .open = erdma_dbgfs_file_open,
+ .read = erdma_show_ceq
+};
+
+static const struct file_operations erdma_cc_fops = {
+ .owner = THIS_MODULE,
+ .open = erdma_dbgfs_file_open,
+ .read = erdma_show_cc,
+ .write = erdma_set_cc,
+
+};
+
+void erdma_debugfs_add_one(struct erdma_dev *dev)
+{
+ if (!erdma_debugfs)
+ return;
+
+ dev->debugfs = debugfs_create_dir(dev->ibdev.name, erdma_debugfs);
+ if (dev->debugfs) {
+ debugfs_create_file("stats", 0400, dev->debugfs,
+ (void *)dev,
+ &erdma_stats_debug_fops);
+ debugfs_create_file("cmdq", 0400, dev->debugfs,
+ (void *)dev,
+ &erdma_cmdq_debug_fops);
+ debugfs_create_file("ceq", 0400, dev->debugfs,
+ (void *)dev,
+ &erdma_ceq_debug_fops);
+ debugfs_create_file("cc", 0400, dev->debugfs,
+ (void *)dev,
+ &erdma_cc_fops);
+ }
+
+}
+
+void erdma_debugfs_remove_one(struct erdma_dev *dev)
+{
+ debugfs_remove_recursive(dev->debugfs);
+ dev->debugfs = NULL;
+}
+
+void erdma_debugfs_init(void)
+{
+ erdma_debugfs = debugfs_create_dir("erdma", NULL);
+}
+
+void erdma_debugfs_exit(void)
+{
+ debugfs_remove_recursive(erdma_debugfs);
+ erdma_debugfs = NULL;
+}
new file mode 100644
@@ -0,0 +1,18 @@
+/* SPDX-License-Identifier: GPL-2.0 OR Linux-OpenIB
+ *
+ * Authors: Cheng Xu <chengyou@linux.alibaba.com>
+ * Kai Shen <kaishen@linux.alibaba.com>
+ * Copyright (c) 2020-2021, Alibaba Group.
+ */
+
+#ifndef __ERDMA_DEBUG_H__
+#define __ERDMA_DEBUG_H__
+
+#include <linux/uaccess.h>
+
+extern void erdma_debugfs_init(void);
+extern void erdma_debugfs_add_one(struct erdma_dev *dev);
+extern void erdma_debugfs_remove_one(struct erdma_dev *dev);
+extern void erdma_debugfs_exit(void);
+
+#endif
new file mode 100644
@@ -0,0 +1,711 @@
+// SPDX-License-Identifier: GPL-2.0 OR Linux-OpenIB
+/*
+ * Authors: Cheng Xu <chengyou@linux.alibaba.com>
+ * Kai Shen <kaishen@linux.alibaba.com>
+ * Copyright (c) 2020-2021, Alibaba Group.
+ */
+
+#include <linux/errno.h>
+#include <linux/init.h>
+#include <linux/kernel.h>
+#include <linux/list.h>
+#include <linux/netdevice.h>
+#include <linux/pci.h>
+#include <rdma/erdma-abi.h>
+#include <rdma/ib_verbs.h>
+#include <rdma/ib_user_verbs.h>
+
+#include "erdma.h"
+#include "erdma_cm.h"
+#include "erdma_debug.h"
+#include "erdma_hw.h"
+#include "erdma_verbs.h"
+
+#define DESC __stringify(ElasticRDMA(iWarp) Driver)
+
+MODULE_AUTHOR("Alibaba");
+MODULE_DESCRIPTION(DESC);
+MODULE_LICENSE("GPL v2");
+MODULE_VERSION("1.0");
+
+/*Common string that is matched to accept the device by the user library*/
+#define ERDMA_NODE_DESC_COMMON "Elastic RDMA(iWARP) stack"
+#define ERDMA_IBDEV_PREFIX "erdma_"
+
+static int max_vectors = 32;
+module_param(max_vectors, int, 0644);
+MODULE_PARM_DESC(max_vectors, "Specify the max vectors used, should whithin [1, 32].");
+
+static void erdma_device_register(struct erdma_dev *dev)
+{
+ struct ib_device *ibdev = &dev->ibdev;
+ struct net_device *netdev = dev->netdev;
+ int ret;
+
+ memset(ibdev->name, 0, IB_DEVICE_NAME_MAX);
+ ret = snprintf(ibdev->name, IB_DEVICE_NAME_MAX, "%s%.2x%.2x%.2x",
+ ERDMA_IBDEV_PREFIX,
+ *((u8 *)dev->netdev->dev_addr + 3),
+ *((u8 *)dev->netdev->dev_addr + 4),
+ *((u8 *)dev->netdev->dev_addr + 5));
+ if (ret < 0) {
+ pr_err("ERROR: copy ibdev name failed.\n");
+ return;
+ }
+
+ memset(&ibdev->node_guid, 0, sizeof(ibdev->node_guid));
+ memcpy(&ibdev->node_guid, netdev->dev_addr, 6);
+
+ ibdev->phys_port_cnt = 1;
+ ret = ib_device_set_netdev(ibdev, dev->netdev, 1);
+ if (ret)
+ return;
+
+ ret = ib_register_device(ibdev, ibdev->name, &dev->pdev->dev);
+ if (ret) {
+ pr_err("ERROR: ib_register_device(%s) failed: ret = %d\n",
+ ibdev->name, ret);
+ return;
+ }
+
+ erdma_debugfs_add_one(dev);
+
+ dev->is_registered = 1;
+}
+
+static void erdma_device_deregister(struct erdma_dev *dev)
+{
+ erdma_debugfs_remove_one(dev);
+
+ ib_unregister_device(&dev->ibdev);
+
+ WARN_ON(atomic_read(&dev->num_ctx));
+ WARN_ON(atomic_read(&dev->num_qp));
+ WARN_ON(atomic_read(&dev->num_cq));
+ WARN_ON(atomic_read(&dev->num_mr));
+ WARN_ON(atomic_read(&dev->num_pd));
+ WARN_ON(atomic_read(&dev->num_cep));
+}
+
+static int erdma_netdev_matched_edev(struct net_device *netdev, struct erdma_dev *dev)
+{
+ if (netdev->perm_addr[0] == dev->peer_addr[0] &&
+ netdev->perm_addr[1] == dev->peer_addr[1] &&
+ netdev->perm_addr[2] == dev->peer_addr[2] &&
+ netdev->perm_addr[3] == dev->peer_addr[3] &&
+ netdev->perm_addr[4] == dev->peer_addr[4] &&
+ netdev->perm_addr[5] == dev->peer_addr[5])
+ return 1;
+
+ return 0;
+}
+
+static int erdma_netdev_event(struct notifier_block *nb, unsigned long event,
+ void *arg)
+{
+ struct net_device *netdev = netdev_notifier_info_to_dev(arg);
+ struct erdma_dev *dev = container_of(nb, struct erdma_dev, netdev_nb);
+
+ if (dev->netdev != NULL && dev->netdev != netdev)
+ goto done;
+
+ switch (event) {
+ case NETDEV_UP:
+ if (dev->is_registered) {
+ dev->state = IB_PORT_ACTIVE;
+ erdma_port_event(dev, IB_EVENT_PORT_ACTIVE);
+ }
+ break;
+ case NETDEV_DOWN:
+ if (dev->is_registered) {
+ dev->state = IB_PORT_DOWN;
+ erdma_port_event(dev, IB_EVENT_PORT_ERR);
+ }
+ break;
+ case NETDEV_REGISTER:
+ if (!dev->is_registered && erdma_netdev_matched_edev(netdev, dev)) {
+ dev->netdev = netdev;
+ dev->state = IB_PORT_INIT;
+ erdma_device_register(dev);
+ }
+ break;
+ case NETDEV_UNREGISTER:
+ case NETDEV_CHANGEADDR:
+ case NETDEV_CHANGEMTU:
+ case NETDEV_GOING_DOWN:
+ case NETDEV_CHANGE:
+ default:
+ break;
+ }
+
+done:
+ return NOTIFY_OK;
+}
+
+static irqreturn_t erdma_comm_irq_handler(int irq, void *data)
+{
+ struct erdma_dev *dev = data;
+
+ erdma_cmdq_completion_handler(dev);
+ erdma_aeq_event_handler(dev);
+
+ return IRQ_HANDLED;
+}
+
+static int erdma_request_vectors(struct erdma_dev *dev)
+{
+ int msix_vecs, irq_num;
+
+ msix_vecs = max_vectors;
+ if (msix_vecs < 1 || msix_vecs > ERDMA_NUM_MSIX_VEC)
+ return -EINVAL;
+
+ irq_num = pci_alloc_irq_vectors(dev->pdev, 1, msix_vecs, PCI_IRQ_MSIX);
+
+ if (irq_num <= 0) {
+ dev_err(&dev->pdev->dev, "request irq vectors failed(%d), expected(%d).\n",
+ irq_num, msix_vecs);
+ return -ENOSPC;
+ }
+
+ dev_info(&dev->pdev->dev, "hardware return %d irqs.\n", irq_num);
+ dev->irq_num = irq_num;
+
+ return 0;
+}
+
+static int erdma_comm_irq_init(struct erdma_dev *dev)
+{
+ u32 cpu = 0;
+ int err;
+ struct erdma_irq_info *irq_info = &dev->comm_irq;
+
+ snprintf(irq_info->name, ERDMA_IRQNAME_SIZE, "erdma-common@pci:%s", pci_name(dev->pdev));
+ irq_info->handler = erdma_comm_irq_handler;
+ irq_info->data = dev;
+ irq_info->msix_vector = pci_irq_vector(dev->pdev, ERDMA_MSIX_VECTOR_CMDQ);
+
+ if (dev->numa_node >= 0)
+ cpu = cpumask_first(cpumask_of_node(dev->numa_node));
+
+ irq_info->cpu = cpu;
+ cpumask_set_cpu(cpu, &irq_info->affinity_hint_mask);
+ dev_info(&dev->pdev->dev, "setup irq:%p vector:%d name:%s\n",
+ irq_info,
+ irq_info->msix_vector,
+ irq_info->name);
+
+ err = request_irq(irq_info->msix_vector, irq_info->handler, 0,
+ irq_info->name, irq_info->data);
+ if (err) {
+ dev_err(&dev->pdev->dev, "failed to request_irq(%d)\n", err);
+ return err;
+ }
+
+ irq_set_affinity_hint(irq_info->msix_vector, &irq_info->affinity_hint_mask);
+
+ return 0;
+}
+
+static void erdma_comm_irq_uninit(struct erdma_dev *dev)
+{
+ struct erdma_irq_info *irq_info = &dev->comm_irq;
+
+ irq_set_affinity_hint(irq_info->msix_vector, NULL);
+ free_irq(irq_info->msix_vector, irq_info->data);
+}
+
+static void __erdma_dwqe_resource_init(struct erdma_dev *dev, int grp_num)
+{
+ int total_pages, type0, type1, shared;
+
+ if (grp_num < 4)
+ dev->disable_dwqe = 1;
+ else
+ dev->disable_dwqe = 0;
+
+ /* One page contains 4 goups. */
+ total_pages = grp_num * 4;
+ shared = 1;
+ if (grp_num >= ERDMA_DWQE_MAX_GRP_CNT) {
+ grp_num = ERDMA_DWQE_MAX_GRP_CNT;
+ type0 = ERDMA_DWQE_TYPE0_CNT;
+ type1 = ERDMA_DWQE_TYPE1_CNT / ERDMA_DWQE_TYPE1_CNT_PER_PAGE;
+ } else {
+ type1 = total_pages / 3;
+ type0 = total_pages - type1;
+ }
+
+ dev->dwqe_pages = type0;
+ dev->dwqe_entries = type1 * ERDMA_DWQE_TYPE1_CNT_PER_PAGE;
+
+ pr_info("grp_num:%d, total pages:%d, type0:%d, type1:%d, type1_db_cnt:%d, shared:%d\n",
+ grp_num, total_pages, type0, type1, type1 * 16, shared);
+}
+
+static int erdma_device_init(struct erdma_dev *dev, struct pci_dev *pdev)
+{
+ int err;
+
+ dev->grp_num = erdma_reg_read32(dev, ERDMA_REGS_GRP_NUM_REG);
+
+ dev_info(&pdev->dev, "hardware returned grp_num:%d\n", dev->grp_num);
+
+ __erdma_dwqe_resource_init(dev, dev->grp_num);
+
+ /* force dma width to 64. */
+ dev->dma_width = 64;
+
+ err = pci_set_dma_mask(pdev, DMA_BIT_MASK(dev->dma_width));
+ if (err) {
+ dev_err(&pdev->dev, "pci_set_dma_mask failed(%d)\n", err);
+ return err;
+ }
+
+ err = pci_set_consistent_dma_mask(pdev, DMA_BIT_MASK(dev->dma_width));
+ if (err) {
+ dev_err(&pdev->dev, "pci_set_consistent_dma_mask failed(%d)\n", err);
+ return err;
+ }
+
+ return err;
+}
+
+static void erdma_device_uninit(struct erdma_dev *dev)
+{
+ u32 ctrl;
+
+ ctrl = FIELD_PREP(ERDMA_REG_DEV_CTRL_RESET_MASK, 1);
+ erdma_reg_write32(dev, ERDMA_REGS_DEV_CTRL_REG, ctrl);
+}
+
+static const struct pci_device_id erdma_pci_tbl[] = {
+ {PCI_DEVICE(PCI_VENDOR_ID_ALIBABA, 0x107f)},
+ {PCI_DEVICE(PCI_VENDOR_ID_ALIBABA, 0x5007)},
+ {}
+};
+
+static int erdma_probe_dev(struct pci_dev *pdev)
+{
+ int err;
+ struct erdma_dev *dev;
+ u32 version;
+ int bars;
+ struct ib_device *ibdev;
+
+ err = pci_enable_device(pdev);
+ if (err) {
+ dev_err(&pdev->dev, "pci_enable_device failed(%d)\n", err);
+ return err;
+ }
+
+ pci_set_master(pdev);
+
+ dev = ib_alloc_device(erdma_dev, ibdev);
+ if (!dev) {
+ dev_err(&pdev->dev, "ib_alloc_device failed\n");
+ err = -ENOMEM;
+ goto err_disable_device;
+ }
+
+ ibdev = &dev->ibdev;
+
+ pci_set_drvdata(pdev, dev);
+ dev->pdev = pdev;
+ dev->numa_node = pdev->dev.numa_node;
+
+ bars = pci_select_bars(pdev, IORESOURCE_MEM);
+ err = pci_request_selected_regions(pdev, bars, DRV_MODULE_NAME);
+ if (bars != ERDMA_BAR_MASK || err) {
+ dev_err(&pdev->dev,
+ "pci_request_selected_regions failed(bars:%d, err:%d)\n", bars, err);
+ err = err == 0 ? -EINVAL : err;
+ goto err_ib_device_release;
+ }
+
+ dev->func_bar_addr = pci_resource_start(pdev, ERDMA_FUNC_BAR);
+ dev->func_bar_len = pci_resource_len(pdev, ERDMA_FUNC_BAR);
+
+ dev->func_bar = devm_ioremap(&pdev->dev, dev->func_bar_addr, dev->func_bar_len);
+ if (!dev->func_bar) {
+ dev_err(&pdev->dev, "devm_ioremap failed.\n");
+ err = -EFAULT;
+ goto err_release_bars;
+ }
+
+ version = erdma_reg_read32(dev, ERDMA_REGS_VERSION_REG);
+ if (version == 0) {
+ /* we knows that it is a non-functional function. */
+ err = -ENODEV;
+ goto err_iounmap_func_bar;
+ }
+
+ err = erdma_device_init(dev, pdev);
+ if (err)
+ goto err_iounmap_func_bar;
+
+ err = erdma_request_vectors(dev);
+ if (err)
+ goto err_iounmap_func_bar;
+
+ err = erdma_comm_irq_init(dev);
+ if (err)
+ goto err_free_vectors;
+
+ err = erdma_aeq_init(dev);
+ if (err)
+ goto err_uninit_comm_irq;
+
+ err = erdma_cmdq_init(dev);
+ if (err)
+ goto err_uninit_aeq;
+
+ err = erdma_ceqs_init(dev);
+ if (err)
+ goto err_uninit_cmdq;
+
+ erdma_finish_cmdq_init(dev);
+
+ return 0;
+
+err_uninit_cmdq:
+ erdma_device_uninit(dev);
+ erdma_cmdq_destroy(dev);
+
+err_uninit_aeq:
+ erdma_aeq_destroy(dev);
+
+err_uninit_comm_irq:
+ erdma_comm_irq_uninit(dev);
+
+err_free_vectors:
+ pci_free_irq_vectors(dev->pdev);
+
+err_iounmap_func_bar:
+ devm_iounmap(&pdev->dev, dev->func_bar);
+
+err_release_bars:
+ pci_release_selected_regions(pdev, bars);
+
+err_ib_device_release:
+ ib_dealloc_device(&dev->ibdev);
+
+err_disable_device:
+ pci_disable_device(pdev);
+
+ return err;
+}
+
+static void erdma_remove_dev(struct pci_dev *pdev)
+{
+ struct erdma_dev *dev = pci_get_drvdata(pdev);
+
+ erdma_ceqs_uninit(dev);
+
+ erdma_device_uninit(dev);
+
+ erdma_cmdq_destroy(dev);
+ erdma_aeq_destroy(dev);
+ erdma_comm_irq_uninit(dev);
+ pci_free_irq_vectors(dev->pdev);
+
+ devm_iounmap(&pdev->dev, dev->func_bar);
+ pci_release_selected_regions(pdev, ERDMA_BAR_MASK);
+
+ ib_dealloc_device(&dev->ibdev);
+
+ pci_disable_device(pdev);
+
+}
+
+static int erdma_dev_attrs_init(struct erdma_dev *dev)
+{
+ int err;
+ u64 req_hdr, cap0, cap1;
+
+ ERDMA_CMDQ_BUILD_REQ_HDR(&req_hdr, CMDQ_SUBMOD_RDMA, CMDQ_OPCODE_QUERY_DEVICE);
+
+ err = erdma_post_cmd_wait(&dev->cmdq, &req_hdr, sizeof(req_hdr), &cap0, &cap1);
+ if (err) {
+ dev_err(&dev->pdev->dev,
+ "ERROR: err code = %d, cmd of query capibility failed.\n", err);
+ return err;
+ }
+
+ dev->attrs.max_cqe = 1 << FIELD_GET(ERDMA_CMD_DEV_CAP0_MAX_CQE_MASK, cap0);
+ dev->attrs.max_mr_size = 1 << FIELD_GET(ERDMA_CMD_DEV_CAP0_MAX_MR_SIZE_MASK, cap0);
+ dev->attrs.max_mw = 1 << FIELD_GET(ERDMA_CMD_DEV_CAP1_MAX_MW_MASK, cap1);
+ dev->attrs.max_recv_wr = 1 << FIELD_GET(ERDMA_CMD_DEV_CAP0_MAX_RECV_WR_MASK, cap0);
+ dev->attrs.local_dma_key = FIELD_GET(ERDMA_CMD_DEV_CAP1_DMA_LOCAL_KEY_MASK, cap1);
+ dev->cc_method = FIELD_GET(ERDMA_CMD_DEV_CAP1_DEFAULT_CC_MASK, cap1);
+ dev->attrs.max_qp = ERDMA_NQP_PER_QBLOCK * FIELD_GET(ERDMA_CMD_DEV_CAP1_QBLOCK_MASK, cap1);
+ dev->attrs.max_mr = 2 * dev->attrs.max_qp;
+ dev->attrs.max_cq = 2 * dev->attrs.max_qp;
+
+ dev->attrs.max_send_wr = ERDMA_MAX_SEND_WR;
+ dev->attrs.vendor_id = PCI_VENDOR_ID_ALIBABA;
+ dev->attrs.max_ord = ERDMA_MAX_ORD;
+ dev->attrs.max_ird = ERDMA_MAX_IRD;
+ dev->attrs.cap_flags = IB_DEVICE_LOCAL_DMA_LKEY | IB_DEVICE_MEM_MGT_EXTENSIONS;
+ dev->attrs.max_send_sge = ERDMA_MAX_SEND_SGE;
+ dev->attrs.max_recv_sge = ERDMA_MAX_RECV_SGE;
+ dev->attrs.max_sge_rd = ERDMA_MAX_SGE_RD;
+ dev->attrs.max_pd = ERDMA_MAX_PD;
+ dev->attrs.max_srq = ERDMA_MAX_SRQ;
+ dev->attrs.max_srq_wr = ERDMA_MAX_SRQ_WR;
+ dev->attrs.max_srq_sge = ERDMA_MAX_SRQ_SGE;
+
+ dev->res_cb[ERDMA_RES_TYPE_PD].max_cap = ERDMA_MAX_PD;
+ dev->res_cb[ERDMA_RES_TYPE_STAG_IDX].max_cap = dev->attrs.max_mr;
+
+ return 0;
+}
+
+int erdma_res_cb_init(struct erdma_dev *dev)
+{
+ int i;
+
+ for (i = 0; i < ERDMA_RES_CNT; i++) {
+ dev->res_cb[i].next_alloc_idx = 1;
+ spin_lock_init(&dev->res_cb[i].lock);
+ dev->res_cb[i].bitmap = kcalloc(BITS_TO_LONGS(dev->res_cb[i].max_cap),
+ sizeof(unsigned long), GFP_KERNEL);
+ /* We will free the memory in erdma_res_cb_free */
+ if (!dev->res_cb[i].bitmap)
+ return -ENOMEM;
+ }
+
+ return 0;
+}
+
+void erdma_res_cb_free(struct erdma_dev *dev)
+{
+ int i;
+
+ for (i = 0; i < ERDMA_RES_CNT; i++)
+ kfree(dev->res_cb[i].bitmap);
+}
+
+static const struct ib_device_ops erdma_device_ops = {
+ .owner = THIS_MODULE,
+ .driver_id = RDMA_DRIVER_ERDMA,
+ .uverbs_abi_ver = ERDMA_ABI_VERSION,
+
+ .alloc_mr = erdma_ib_alloc_mr,
+ .alloc_pd = erdma_alloc_pd,
+ .alloc_ucontext = erdma_alloc_ucontext,
+ .create_cq = erdma_create_cq,
+ .create_qp = erdma_create_qp,
+ .dealloc_pd = erdma_dealloc_pd,
+ .dealloc_ucontext = erdma_dealloc_ucontext,
+ .dereg_mr = erdma_dereg_mr,
+ .destroy_cq = erdma_destroy_cq,
+ .destroy_qp = erdma_destroy_qp,
+ .disassociate_ucontext = erdma_disassociate_ucontext,
+ .get_dma_mr = erdma_get_dma_mr,
+ .get_netdev = erdma_get_netdev,
+ .get_port_immutable = erdma_get_port_immutable,
+ .iw_accept = erdma_accept,
+ .iw_add_ref = erdma_qp_get_ref,
+ .iw_connect = erdma_connect,
+ .iw_create_listen = erdma_create_listen,
+ .iw_destroy_listen = erdma_destroy_listen,
+ .iw_get_qp = erdma_get_ibqp,
+ .iw_reject = erdma_reject,
+ .iw_rem_ref = erdma_qp_put_ref,
+ .map_mr_sg = erdma_map_mr_sg,
+ .mmap = erdma_mmap,
+ .modify_qp = erdma_modify_qp,
+ .post_recv = erdma_post_recv,
+ .post_send = erdma_post_send,
+ .poll_cq = erdma_poll_cq,
+ .query_device = erdma_query_device,
+ .query_gid = erdma_query_gid,
+ .query_pkey = erdma_query_pkey,
+ .query_port = erdma_query_port,
+ .query_qp = erdma_query_qp,
+ .req_notify_cq = erdma_req_notify_cq,
+ .reg_user_mr = erdma_reg_user_mr,
+
+ INIT_RDMA_OBJ_SIZE(ib_cq, erdma_cq, ibcq),
+ INIT_RDMA_OBJ_SIZE(ib_pd, erdma_pd, ibpd),
+ INIT_RDMA_OBJ_SIZE(ib_ucontext, erdma_ucontext, ibucontext),
+ INIT_RDMA_OBJ_SIZE(ib_qp, erdma_qp, ibqp),
+};
+
+static int erdma_ib_device_add(struct pci_dev *pdev)
+{
+ struct erdma_dev *dev = pci_get_drvdata(pdev);
+ struct ib_device *ibdev = &dev->ibdev;
+ u32 mac_h, mac_l;
+ int ret = 0;
+
+ ret = erdma_dev_attrs_init(dev);
+ if (ret)
+ goto out;
+
+ ibdev->uverbs_cmd_mask =
+ (1ull << IB_USER_VERBS_CMD_GET_CONTEXT) |
+ (1ull << IB_USER_VERBS_CMD_QUERY_DEVICE) |
+ (1ull << IB_USER_VERBS_CMD_QUERY_PORT) |
+ (1ull << IB_USER_VERBS_CMD_ALLOC_PD) |
+ (1ull << IB_USER_VERBS_CMD_DEALLOC_PD) |
+ (1ull << IB_USER_VERBS_CMD_REG_MR) |
+ (1ull << IB_USER_VERBS_CMD_DEREG_MR) |
+ (1ull << IB_USER_VERBS_CMD_CREATE_COMP_CHANNEL) |
+ (1ull << IB_USER_VERBS_CMD_CREATE_CQ) |
+ (1ull << IB_USER_VERBS_CMD_DESTROY_CQ) |
+ (1ull << IB_USER_VERBS_CMD_CREATE_QP) |
+ (1ull << IB_USER_VERBS_CMD_QUERY_QP) |
+ (1ull << IB_USER_VERBS_CMD_MODIFY_QP) |
+ (1ull << IB_USER_VERBS_CMD_DESTROY_QP);
+
+ ibdev->node_type = RDMA_NODE_RNIC;
+ memcpy(ibdev->node_desc, ERDMA_NODE_DESC_COMMON, sizeof(ERDMA_NODE_DESC_COMMON));
+
+ /*
+ * Current model (one-to-one device association):
+ * One ERDMA device per net_device or, equivalently,
+ * per physical port.
+ */
+ ibdev->phys_port_cnt = 1;
+ ibdev->num_comp_vectors = dev->irq_num - 1;
+
+ ib_set_device_ops(ibdev, &erdma_device_ops);
+
+ INIT_LIST_HEAD(&dev->cep_list);
+
+ spin_lock_init(&dev->lock);
+ xa_init_flags(&dev->qp_xa, XA_FLAGS_ALLOC1);
+ xa_init_flags(&dev->cq_xa, XA_FLAGS_ALLOC1);
+ dev->next_alloc_cqn = 1;
+ dev->next_alloc_qpn = 1;
+
+ ret = erdma_res_cb_init(dev);
+ if (ret)
+ goto out;
+
+ spin_lock_init(&dev->db_bitmap_lock);
+ bitmap_zero(dev->sdb_page, ERDMA_DWQE_TYPE0_CNT);
+ bitmap_zero(dev->sdb_entry, ERDMA_DWQE_TYPE1_CNT);
+
+ atomic_set(&dev->num_ctx, 0);
+ atomic_set(&dev->num_qp, 0);
+ atomic_set(&dev->num_cq, 0);
+ atomic_set(&dev->num_mr, 0);
+ atomic_set(&dev->num_pd, 0);
+ atomic_set(&dev->num_cep, 0);
+
+ mac_l = erdma_reg_read32(dev, ERDMA_REGS_NETDEV_MAC_L_REG);
+ mac_h = erdma_reg_read32(dev, ERDMA_REGS_NETDEV_MAC_H_REG);
+
+ pr_info("assoc netdev mac addr is 0x%x-0x%x.\n", mac_h, mac_l);
+
+ dev->peer_addr[0] = (mac_h >> 8) & 0xFF;
+ dev->peer_addr[1] = mac_h & 0xFF;
+ dev->peer_addr[2] = (mac_l >> 24) & 0xFF;
+ dev->peer_addr[3] = (mac_l >> 16) & 0xFF;
+ dev->peer_addr[4] = (mac_l >> 8) & 0xFF;
+ dev->peer_addr[5] = mac_l & 0xFF;
+
+ dev->netdev_nb.notifier_call = erdma_netdev_event;
+ dev->netdev = NULL;
+
+ ret = register_netdevice_notifier(&dev->netdev_nb);
+ if (ret)
+ goto out;
+
+ return 0;
+out:
+ erdma_res_cb_free(dev);
+ xa_destroy(&dev->qp_xa);
+ xa_destroy(&dev->cq_xa);
+
+ return ret;
+}
+
+static void erdma_ib_device_remove(struct pci_dev *pdev)
+{
+ struct erdma_dev *dev = pci_get_drvdata(pdev);
+
+ unregister_netdevice_notifier(&dev->netdev_nb);
+
+ if (dev->is_registered) {
+ erdma_device_deregister(dev);
+ dev->is_registered = 0;
+ }
+
+ erdma_res_cb_free(dev);
+ xa_destroy(&dev->qp_xa);
+ xa_destroy(&dev->cq_xa);
+}
+
+static int erdma_probe(struct pci_dev *pdev, const struct pci_device_id *ent)
+{
+ int ret;
+
+ ret = erdma_probe_dev(pdev);
+ if (ret)
+ return ret;
+
+ ret = erdma_ib_device_add(pdev);
+ if (ret) {
+ erdma_remove_dev(pdev);
+ return ret;
+ }
+
+ return 0;
+}
+
+static void erdma_remove(struct pci_dev *pdev)
+{
+ erdma_ib_device_remove(pdev);
+ erdma_remove_dev(pdev);
+}
+
+static struct pci_driver erdma_pci_driver = {
+ .name = DRV_MODULE_NAME,
+ .id_table = erdma_pci_tbl,
+ .probe = erdma_probe,
+ .remove = erdma_remove
+};
+
+MODULE_DEVICE_TABLE(pci, erdma_pci_tbl);
+
+static __init int erdma_init_module(void)
+{
+ int ret;
+
+ erdma_debugfs_init();
+
+ ret = erdma_cm_init();
+ if (ret)
+ goto uninit_dbgfs;
+
+ ret = pci_register_driver(&erdma_pci_driver);
+ if (ret) {
+ pr_err("Couldn't register erdma driver.\n");
+ goto uninit_cm;
+ }
+
+ return ret;
+
+uninit_cm:
+ erdma_cm_exit();
+
+uninit_dbgfs:
+ erdma_debugfs_exit();
+
+ return ret;
+}
+
+static void __exit erdma_exit_module(void)
+{
+ pci_unregister_driver(&erdma_pci_driver);
+
+ erdma_cm_exit();
+ erdma_debugfs_exit();
+}
+
+module_init(erdma_init_module);
+module_exit(erdma_exit_module);
Add the main erdma module and debugfs files. The main module provides interface to infiniband subsytem, and the debugfs module provides a way to allow user can get the core status of the device and set the preferred congestion control algorithm. Signed-off-by: Cheng Xu <chengyou@linux.alibaba.com> --- drivers/infiniband/hw/erdma/erdma_debug.c | 314 ++++++++++ drivers/infiniband/hw/erdma/erdma_debug.h | 18 + drivers/infiniband/hw/erdma/erdma_main.c | 711 ++++++++++++++++++++++ 3 files changed, 1043 insertions(+) create mode 100644 drivers/infiniband/hw/erdma/erdma_debug.c create mode 100644 drivers/infiniband/hw/erdma/erdma_debug.h create mode 100644 drivers/infiniband/hw/erdma/erdma_main.c