mlx4: Connect the infiniband part to the auxiliary bus

Use the auxiliary bus to perform device management of the infiniband
part of the mlx4 driver.

Signed-off-by: Petr Pavlu <petr.pavlu@suse.com>
Tested-by: Leon Romanovsky <leonro@nvidia.com>
Reviewed-by: Leon Romanovsky <leonro@nvidia.com>
Acked-by: Tariq Toukan <tariqt@nvidia.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
Petr Pavlu 2023-08-21 15:12:24 +02:00 committed by David S. Miller
parent eb93ae495a
commit 7d22b1cb9d
2 changed files with 67 additions and 23 deletions

View File

@ -2609,8 +2609,11 @@ static const struct ib_device_ops mlx4_ib_dev_fs_ops = {
.destroy_flow = mlx4_ib_destroy_flow, .destroy_flow = mlx4_ib_destroy_flow,
}; };
static void *mlx4_ib_add(struct mlx4_dev *dev) static int mlx4_ib_probe(struct auxiliary_device *adev,
const struct auxiliary_device_id *id)
{ {
struct mlx4_adev *madev = container_of(adev, struct mlx4_adev, adev);
struct mlx4_dev *dev = madev->mdev;
struct mlx4_ib_dev *ibdev; struct mlx4_ib_dev *ibdev;
int num_ports = 0; int num_ports = 0;
int i, j; int i, j;
@ -2630,27 +2633,31 @@ static void *mlx4_ib_add(struct mlx4_dev *dev)
/* No point in registering a device with no ports... */ /* No point in registering a device with no ports... */
if (num_ports == 0) if (num_ports == 0)
return NULL; return -ENODEV;
ibdev = ib_alloc_device(mlx4_ib_dev, ib_dev); ibdev = ib_alloc_device(mlx4_ib_dev, ib_dev);
if (!ibdev) { if (!ibdev) {
dev_err(&dev->persist->pdev->dev, dev_err(&dev->persist->pdev->dev,
"Device struct alloc failed\n"); "Device struct alloc failed\n");
return NULL; return -ENOMEM;
} }
iboe = &ibdev->iboe; iboe = &ibdev->iboe;
if (mlx4_pd_alloc(dev, &ibdev->priv_pdn)) err = mlx4_pd_alloc(dev, &ibdev->priv_pdn);
if (err)
goto err_dealloc; goto err_dealloc;
if (mlx4_uar_alloc(dev, &ibdev->priv_uar)) err = mlx4_uar_alloc(dev, &ibdev->priv_uar);
if (err)
goto err_pd; goto err_pd;
ibdev->uar_map = ioremap((phys_addr_t) ibdev->priv_uar.pfn << PAGE_SHIFT, ibdev->uar_map = ioremap((phys_addr_t) ibdev->priv_uar.pfn << PAGE_SHIFT,
PAGE_SIZE); PAGE_SIZE);
if (!ibdev->uar_map) if (!ibdev->uar_map) {
err = -ENOMEM;
goto err_uar; goto err_uar;
}
MLX4_INIT_DOORBELL_LOCK(&ibdev->uar_lock); MLX4_INIT_DOORBELL_LOCK(&ibdev->uar_lock);
ibdev->dev = dev; ibdev->dev = dev;
@ -2694,7 +2701,8 @@ static void *mlx4_ib_add(struct mlx4_dev *dev)
spin_lock_init(&iboe->lock); spin_lock_init(&iboe->lock);
if (init_node_data(ibdev)) err = init_node_data(ibdev);
if (err)
goto err_map; goto err_map;
mlx4_init_sl2vl_tbl(ibdev); mlx4_init_sl2vl_tbl(ibdev);
@ -2726,6 +2734,7 @@ static void *mlx4_ib_add(struct mlx4_dev *dev)
new_counter_index = kmalloc(sizeof(*new_counter_index), new_counter_index = kmalloc(sizeof(*new_counter_index),
GFP_KERNEL); GFP_KERNEL);
if (!new_counter_index) { if (!new_counter_index) {
err = -ENOMEM;
if (allocated) if (allocated)
mlx4_counter_free(ibdev->dev, counter_index); mlx4_counter_free(ibdev->dev, counter_index);
goto err_counter; goto err_counter;
@ -2743,8 +2752,10 @@ static void *mlx4_ib_add(struct mlx4_dev *dev)
new_counter_index = new_counter_index =
kmalloc(sizeof(struct counter_index), kmalloc(sizeof(struct counter_index),
GFP_KERNEL); GFP_KERNEL);
if (!new_counter_index) if (!new_counter_index) {
err = -ENOMEM;
goto err_counter; goto err_counter;
}
new_counter_index->index = counter_index; new_counter_index->index = counter_index;
new_counter_index->allocated = 0; new_counter_index->allocated = 0;
list_add_tail(&new_counter_index->list, list_add_tail(&new_counter_index->list,
@ -2773,8 +2784,10 @@ static void *mlx4_ib_add(struct mlx4_dev *dev)
ibdev->ib_uc_qpns_bitmap = bitmap_alloc(ibdev->steer_qpn_count, ibdev->ib_uc_qpns_bitmap = bitmap_alloc(ibdev->steer_qpn_count,
GFP_KERNEL); GFP_KERNEL);
if (!ibdev->ib_uc_qpns_bitmap) if (!ibdev->ib_uc_qpns_bitmap) {
err = -ENOMEM;
goto err_steer_qp_release; goto err_steer_qp_release;
}
if (dev->caps.flags2 & MLX4_DEV_CAP_FLAG2_DMFS_IPOIB) { if (dev->caps.flags2 & MLX4_DEV_CAP_FLAG2_DMFS_IPOIB) {
bitmap_zero(ibdev->ib_uc_qpns_bitmap, bitmap_zero(ibdev->ib_uc_qpns_bitmap,
@ -2794,17 +2807,21 @@ static void *mlx4_ib_add(struct mlx4_dev *dev)
for (j = 1; j <= ibdev->dev->caps.num_ports; j++) for (j = 1; j <= ibdev->dev->caps.num_ports; j++)
atomic64_set(&iboe->mac[j - 1], ibdev->dev->caps.def_mac[j]); atomic64_set(&iboe->mac[j - 1], ibdev->dev->caps.def_mac[j]);
if (mlx4_ib_alloc_diag_counters(ibdev)) err = mlx4_ib_alloc_diag_counters(ibdev);
if (err)
goto err_steer_free_bitmap; goto err_steer_free_bitmap;
if (ib_register_device(&ibdev->ib_dev, "mlx4_%d", err = ib_register_device(&ibdev->ib_dev, "mlx4_%d",
&dev->persist->pdev->dev)) &dev->persist->pdev->dev);
if (err)
goto err_diag_counters; goto err_diag_counters;
if (mlx4_ib_mad_init(ibdev)) err = mlx4_ib_mad_init(ibdev);
if (err)
goto err_reg; goto err_reg;
if (mlx4_ib_init_sriov(ibdev)) err = mlx4_ib_init_sriov(ibdev);
if (err)
goto err_mad; goto err_mad;
if (!iboe->nb.notifier_call) { if (!iboe->nb.notifier_call) {
@ -2844,7 +2861,8 @@ static void *mlx4_ib_add(struct mlx4_dev *dev)
err = mlx4_register_event_notifier(dev, &ibdev->mlx_nb); err = mlx4_register_event_notifier(dev, &ibdev->mlx_nb);
WARN(err, "failed to register mlx4 event notifier (%d)", err); WARN(err, "failed to register mlx4 event notifier (%d)", err);
return ibdev; auxiliary_set_drvdata(adev, ibdev);
return 0;
err_notif: err_notif:
if (ibdev->iboe.nb.notifier_call) { if (ibdev->iboe.nb.notifier_call) {
@ -2888,7 +2906,7 @@ err_pd:
err_dealloc: err_dealloc:
ib_dealloc_device(&ibdev->ib_dev); ib_dealloc_device(&ibdev->ib_dev);
return NULL; return err;
} }
int mlx4_ib_steer_qp_alloc(struct mlx4_ib_dev *dev, int count, int *qpn) int mlx4_ib_steer_qp_alloc(struct mlx4_ib_dev *dev, int count, int *qpn)
@ -2955,9 +2973,11 @@ int mlx4_ib_steer_qp_reg(struct mlx4_ib_dev *mdev, struct mlx4_ib_qp *mqp,
return err; return err;
} }
static void mlx4_ib_remove(struct mlx4_dev *dev, void *ibdev_ptr) static void mlx4_ib_remove(struct auxiliary_device *adev)
{ {
struct mlx4_ib_dev *ibdev = ibdev_ptr; struct mlx4_adev *madev = container_of(adev, struct mlx4_adev, adev);
struct mlx4_dev *dev = madev->mdev;
struct mlx4_ib_dev *ibdev = auxiliary_get_drvdata(adev);
int p; int p;
int i; int i;
@ -3303,9 +3323,20 @@ static int mlx4_ib_event(struct notifier_block *this, unsigned long event,
return NOTIFY_DONE; return NOTIFY_DONE;
} }
static struct mlx4_interface mlx4_ib_interface = { static const struct auxiliary_device_id mlx4_ib_id_table[] = {
.add = mlx4_ib_add, { .name = MLX4_ADEV_NAME ".ib" },
.remove = mlx4_ib_remove, {},
};
MODULE_DEVICE_TABLE(auxiliary, mlx4_ib_id_table);
static struct mlx4_adrv mlx4_ib_adrv = {
.adrv = {
.name = "ib",
.probe = mlx4_ib_probe,
.remove = mlx4_ib_remove,
.id_table = mlx4_ib_id_table,
},
.protocol = MLX4_PROT_IB_IPV6, .protocol = MLX4_PROT_IB_IPV6,
.flags = MLX4_INTFF_BONDING .flags = MLX4_INTFF_BONDING
}; };
@ -3330,7 +3361,7 @@ static int __init mlx4_ib_init(void)
if (err) if (err)
goto clean_cm; goto clean_cm;
err = mlx4_register_interface(&mlx4_ib_interface); err = mlx4_register_auxiliary_driver(&mlx4_ib_adrv);
if (err) if (err)
goto clean_mcg; goto clean_mcg;
@ -3352,7 +3383,7 @@ clean_qp_event:
static void __exit mlx4_ib_cleanup(void) static void __exit mlx4_ib_cleanup(void)
{ {
mlx4_unregister_interface(&mlx4_ib_interface); mlx4_unregister_auxiliary_driver(&mlx4_ib_adrv);
mlx4_ib_mcg_destroy(); mlx4_ib_mcg_destroy();
mlx4_ib_cm_destroy(); mlx4_ib_cm_destroy();
mlx4_ib_qp_event_cleanup(); mlx4_ib_qp_event_cleanup();

View File

@ -59,11 +59,24 @@ static bool is_eth_supported(struct mlx4_dev *dev)
return false; return false;
} }
static bool is_ib_supported(struct mlx4_dev *dev)
{
for (int port = 1; port <= dev->caps.num_ports; port++)
if (dev->caps.port_type[port] == MLX4_PORT_TYPE_IB)
return true;
if (dev->caps.flags & MLX4_DEV_CAP_FLAG_IBOE)
return true;
return false;
}
static const struct mlx4_adev_device { static const struct mlx4_adev_device {
const char *suffix; const char *suffix;
bool (*is_supported)(struct mlx4_dev *dev); bool (*is_supported)(struct mlx4_dev *dev);
} mlx4_adev_devices[] = { } mlx4_adev_devices[] = {
{ "eth", is_eth_supported }, { "eth", is_eth_supported },
{ "ib", is_ib_supported },
}; };
int mlx4_adev_init(struct mlx4_dev *dev) int mlx4_adev_init(struct mlx4_dev *dev)