drivers/net/ethernet/mellanox/mlx5/core/ipoib/ipoib.c

   1 /*
   2  * Copyright (c) 2017, Mellanox Technologies. All rights reserved.
   3  *
   4  * This software is available to you under a choice of one of two
   5  * licenses.  You may choose to be licensed under the terms of the GNU
   6  * General Public License (GPL) Version 2, available from the file
   7  * COPYING in the main directory of this source tree, or the
   8  * OpenIB.org BSD license below:
   9  *
  10  *     Redistribution and use in source and binary forms, with or
  11  *     without modification, are permitted provided that the following
  12  *     conditions are met:
  13  *
  14  *      - Redistributions of source code must retain the above
  15  *        copyright notice, this list of conditions and the following
  16  *        disclaimer.
  17  *
  18  *      - Redistributions in binary form must reproduce the above
  19  *        copyright notice, this list of conditions and the following
  20  *        disclaimer in the documentation and/or other materials
  21  *        provided with the distribution.
  22  *
  23  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  24  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  25  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  26  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  27  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  28  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  29  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  30  * SOFTWARE.
  31  */
  32
  33 #include <rdma/ib_verbs.h>
  34 #include <linux/mlx5/fs.h>
  35 #include "en.h"
  36 #include "en/params.h"
  37 #include "ipoib.h"
  38
  39 #define IB_DEFAULT_Q_KEY   0xb1b
  40 #define MLX5I_PARAMS_DEFAULT_LOG_RQ_SIZE 9
  41
  42 static int mlx5i_open(struct net_device *netdev);
  43 static int mlx5i_close(struct net_device *netdev);
  44 static int mlx5i_change_mtu(struct net_device *netdev, int new_mtu);
  45
  46 static const struct net_device_ops mlx5i_netdev_ops = {
  47         .ndo_open                = mlx5i_open,
  48         .ndo_stop                = mlx5i_close,
  49         .ndo_get_stats64         = mlx5i_get_stats,
  50         .ndo_init                = mlx5i_dev_init,
  51         .ndo_uninit              = mlx5i_dev_cleanup,
  52         .ndo_change_mtu          = mlx5i_change_mtu,
  53         .ndo_do_ioctl            = mlx5i_ioctl,
  54 };
  55
  56 /* IPoIB mlx5 netdev profile */
  57 static void mlx5i_build_nic_params(struct mlx5_core_dev *mdev,
  58                                    struct mlx5e_params *params)
  59 {
  60         /* Override RQ params as IPoIB supports only LINKED LIST RQ for now */
  61         MLX5E_SET_PFLAG(params, MLX5E_PFLAG_RX_STRIDING_RQ, false);
  62         mlx5e_set_rq_type(mdev, params);
  63         mlx5e_init_rq_type_params(mdev, params);
  64
  65         /* RQ size in ipoib by default is 512 */
  66         params->log_rq_mtu_frames = is_kdump_kernel() ?
  67                 MLX5E_PARAMS_MINIMUM_LOG_RQ_SIZE :
  68                 MLX5I_PARAMS_DEFAULT_LOG_RQ_SIZE;
  69
  70         params->lro_en = false;
  71         params->hard_mtu = MLX5_IB_GRH_BYTES + MLX5_IPOIB_HARD_LEN;
  72         params->tunneled_offload_en = false;
  73 }
  74
  75 /* Called directly after IPoIB netdevice was created to initialize SW structs */
  76 int mlx5i_init(struct mlx5_core_dev *mdev, struct net_device *netdev)
  77 {
  78         struct mlx5e_priv *priv  = mlx5i_epriv(netdev);
  79
  80         netif_carrier_off(netdev);
  81         mlx5e_set_netdev_mtu_boundaries(priv);
  82         netdev->mtu = netdev->max_mtu;
  83
  84         mlx5e_build_nic_params(priv, NULL, netdev->mtu);
  85         mlx5i_build_nic_params(mdev, &priv->channels.params);
  86
  87         mlx5e_timestamp_init(priv);
  88
  89         /* netdev init */
  90         netdev->hw_features    |= NETIF_F_SG;
  91         netdev->hw_features    |= NETIF_F_IP_CSUM;
  92         netdev->hw_features    |= NETIF_F_IPV6_CSUM;
  93         netdev->hw_features    |= NETIF_F_GRO;
  94         netdev->hw_features    |= NETIF_F_TSO;
  95         netdev->hw_features    |= NETIF_F_TSO6;
  96         netdev->hw_features    |= NETIF_F_RXCSUM;
  97         netdev->hw_features    |= NETIF_F_RXHASH;
  98
  99         netdev->netdev_ops = &mlx5i_netdev_ops;
 100         netdev->ethtool_ops = &mlx5i_ethtool_ops;
 101
 102         return 0;
 103 }
 104
 105 /* Called directly before IPoIB netdevice is destroyed to cleanup SW structs */
 106 void mlx5i_cleanup(struct mlx5e_priv *priv)
 107 {
 108         mlx5e_priv_cleanup(priv);
 109 }
 110
 111 static void mlx5i_grp_sw_update_stats(struct mlx5e_priv *priv)
 112 {
 113         struct mlx5e_sw_stats s = { 0 };
 114         int i, j;
 115
 116         for (i = 0; i < priv->max_nch; i++) {
 117                 struct mlx5e_channel_stats *channel_stats;
 118                 struct mlx5e_rq_stats *rq_stats;
 119
 120                 channel_stats = &priv->channel_stats[i];
 121                 rq_stats = &channel_stats->rq;
 122
 123                 s.rx_packets += rq_stats->packets;
 124                 s.rx_bytes   += rq_stats->bytes;
 125
 126                 for (j = 0; j < priv->max_opened_tc; j++) {
 127                         struct mlx5e_sq_stats *sq_stats = &channel_stats->sq[j];
 128
 129                         s.tx_packets           += sq_stats->packets;
 130                         s.tx_bytes             += sq_stats->bytes;
 131                         s.tx_queue_dropped     += sq_stats->dropped;
 132                 }
 133         }
 134
 135         memcpy(&priv->stats.sw, &s, sizeof(s));
 136 }
 137
 138 void mlx5i_get_stats(struct net_device *dev, struct rtnl_link_stats64 *stats)
 139 {
 140         struct mlx5e_priv     *priv   = mlx5i_epriv(dev);
 141         struct mlx5e_sw_stats *sstats = &priv->stats.sw;
 142
 143         mlx5i_grp_sw_update_stats(priv);
 144
 145         stats->rx_packets = sstats->rx_packets;
 146         stats->rx_bytes   = sstats->rx_bytes;
 147         stats->tx_packets = sstats->tx_packets;
 148         stats->tx_bytes   = sstats->tx_bytes;
 149         stats->tx_dropped = sstats->tx_queue_dropped;
 150 }
 151
 152 int mlx5i_init_underlay_qp(struct mlx5e_priv *priv)
 153 {
 154         struct mlx5_core_dev *mdev = priv->mdev;
 155         struct mlx5i_priv *ipriv = priv->ppriv;
 156         int ret;
 157
 158         {
 159                 u32 in[MLX5_ST_SZ_DW(rst2init_qp_in)] = {};
 160                 u32 *qpc;
 161
 162                 qpc = MLX5_ADDR_OF(rst2init_qp_in, in, qpc);
 163
 164                 MLX5_SET(qpc, qpc, pm_state, MLX5_QP_PM_MIGRATED);
 165                 MLX5_SET(qpc, qpc, primary_address_path.pkey_index,
 166                          ipriv->pkey_index);
 167                 MLX5_SET(qpc, qpc, primary_address_path.vhca_port_num, 1);
 168                 MLX5_SET(qpc, qpc, q_key, IB_DEFAULT_Q_KEY);
 169
 170                 MLX5_SET(rst2init_qp_in, in, opcode, MLX5_CMD_OP_RST2INIT_QP);
 171                 MLX5_SET(rst2init_qp_in, in, qpn, ipriv->qpn);
 172                 ret = mlx5_cmd_exec_in(mdev, rst2init_qp, in);
 173                 if (ret)
 174                         goto err_qp_modify_to_err;
 175         }
 176         {
 177                 u32 in[MLX5_ST_SZ_DW(init2rtr_qp_in)] = {};
 178
 179                 MLX5_SET(init2rtr_qp_in, in, opcode, MLX5_CMD_OP_INIT2RTR_QP);
 180                 MLX5_SET(init2rtr_qp_in, in, qpn, ipriv->qpn);
 181                 ret = mlx5_cmd_exec_in(mdev, init2rtr_qp, in);
 182                 if (ret)
 183                         goto err_qp_modify_to_err;
 184         }
 185         {
 186                 u32 in[MLX5_ST_SZ_DW(rtr2rts_qp_in)] = {};
 187
 188                 MLX5_SET(rtr2rts_qp_in, in, opcode, MLX5_CMD_OP_RTR2RTS_QP);
 189                 MLX5_SET(rtr2rts_qp_in, in, qpn, ipriv->qpn);
 190                 ret = mlx5_cmd_exec_in(mdev, rtr2rts_qp, in);
 191                 if (ret)
 192                         goto err_qp_modify_to_err;
 193         }
 194         return 0;
 195
 196 err_qp_modify_to_err:
 197         {
 198                 u32 in[MLX5_ST_SZ_DW(qp_2err_in)] = {};
 199
 200                 MLX5_SET(qp_2err_in, in, opcode, MLX5_CMD_OP_2ERR_QP);
 201                 MLX5_SET(qp_2err_in, in, qpn, ipriv->qpn);
 202                 mlx5_cmd_exec_in(mdev, qp_2err, in);
 203         }
 204         return ret;
 205 }
 206
 207 void mlx5i_uninit_underlay_qp(struct mlx5e_priv *priv)
 208 {
 209         struct mlx5i_priv *ipriv = priv->ppriv;
 210         struct mlx5_core_dev *mdev = priv->mdev;
 211         u32 in[MLX5_ST_SZ_DW(qp_2rst_in)] = {};
 212
 213         MLX5_SET(qp_2rst_in, in, opcode, MLX5_CMD_OP_2RST_QP);
 214         MLX5_SET(qp_2rst_in, in, qpn, ipriv->qpn);
 215         mlx5_cmd_exec_in(mdev, qp_2rst, in);
 216 }
 217
 218 #define MLX5_QP_ENHANCED_ULP_STATELESS_MODE 2
 219
 220 int mlx5i_create_underlay_qp(struct mlx5e_priv *priv)
 221 {
 222         unsigned char *dev_addr = priv->netdev->dev_addr;
 223         u32 out[MLX5_ST_SZ_DW(create_qp_out)] = {};
 224         u32 in[MLX5_ST_SZ_DW(create_qp_in)] = {};
 225         struct mlx5i_priv *ipriv = priv->ppriv;
 226         void *addr_path;
 227         int qpn = 0;
 228         int ret = 0;
 229         void *qpc;
 230
 231         if (MLX5_CAP_GEN(priv->mdev, mkey_by_name)) {
 232                 qpn = (dev_addr[1] << 16) + (dev_addr[2] << 8) + dev_addr[3];
 233                 MLX5_SET(create_qp_in, in, input_qpn, qpn);
 234         }
 235
 236         qpc = MLX5_ADDR_OF(create_qp_in, in, qpc);
 237         MLX5_SET(qpc, qpc, ts_format, mlx5_get_qp_default_ts(priv->mdev));
 238         MLX5_SET(qpc, qpc, st, MLX5_QP_ST_UD);
 239         MLX5_SET(qpc, qpc, pm_state, MLX5_QP_PM_MIGRATED);
 240         MLX5_SET(qpc, qpc, ulp_stateless_offload_mode,
 241                  MLX5_QP_ENHANCED_ULP_STATELESS_MODE);
 242
 243         addr_path = MLX5_ADDR_OF(qpc, qpc, primary_address_path);
 244         MLX5_SET(ads, addr_path, vhca_port_num, 1);
 245         MLX5_SET(ads, addr_path, grh, 1);
 246
 247         MLX5_SET(create_qp_in, in, opcode, MLX5_CMD_OP_CREATE_QP);
 248         ret = mlx5_cmd_exec_inout(priv->mdev, create_qp, in, out);
 249         if (ret)
 250                 return ret;
 251
 252         ipriv->qpn = MLX5_GET(create_qp_out, out, qpn);
 253
 254         return 0;
 255 }
 256
 257 void mlx5i_destroy_underlay_qp(struct mlx5_core_dev *mdev, u32 qpn)
 258 {
 259         u32 in[MLX5_ST_SZ_DW(destroy_qp_in)] = {};
 260
 261         MLX5_SET(destroy_qp_in, in, opcode, MLX5_CMD_OP_DESTROY_QP);
 262         MLX5_SET(destroy_qp_in, in, qpn, qpn);
 263         mlx5_cmd_exec_in(mdev, destroy_qp, in);
 264 }
 265
 266 int mlx5i_update_nic_rx(struct mlx5e_priv *priv)
 267 {
 268         return mlx5e_refresh_tirs(priv, true, true);
 269 }
 270
 271 int mlx5i_create_tis(struct mlx5_core_dev *mdev, u32 underlay_qpn, u32 *tisn)
 272 {
 273         u32 in[MLX5_ST_SZ_DW(create_tis_in)] = {};
 274         void *tisc;
 275
 276         tisc = MLX5_ADDR_OF(create_tis_in, in, ctx);
 277
 278         MLX5_SET(tisc, tisc, underlay_qpn, underlay_qpn);
 279
 280         return mlx5e_create_tis(mdev, in, tisn);
 281 }
 282
 283 static int mlx5i_init_tx(struct mlx5e_priv *priv)
 284 {
 285         struct mlx5i_priv *ipriv = priv->ppriv;
 286         int err;
 287
 288         err = mlx5i_create_underlay_qp(priv);
 289         if (err) {
 290                 mlx5_core_warn(priv->mdev, "create underlay QP failed, %d\n", err);
 291                 return err;
 292         }
 293
 294         err = mlx5i_create_tis(priv->mdev, ipriv->qpn, &priv->tisn[0][0]);
 295         if (err) {
 296                 mlx5_core_warn(priv->mdev, "create tis failed, %d\n", err);
 297                 goto err_destroy_underlay_qp;
 298         }
 299
 300         return 0;
 301
 302 err_destroy_underlay_qp:
 303         mlx5i_destroy_underlay_qp(priv->mdev, ipriv->qpn);
 304         return err;
 305 }
 306
 307 static void mlx5i_cleanup_tx(struct mlx5e_priv *priv)
 308 {
 309         struct mlx5i_priv *ipriv = priv->ppriv;
 310
 311         mlx5e_destroy_tis(priv->mdev, priv->tisn[0][0]);
 312         mlx5i_destroy_underlay_qp(priv->mdev, ipriv->qpn);
 313 }
 314
 315 static int mlx5i_create_flow_steering(struct mlx5e_priv *priv)
 316 {
 317         struct ttc_params ttc_params = {};
 318         int tt, err;
 319
 320         priv->fs.ns = mlx5_get_flow_namespace(priv->mdev,
 321                                                MLX5_FLOW_NAMESPACE_KERNEL);
 322
 323         if (!priv->fs.ns)
 324                 return -EINVAL;
 325
 326         err = mlx5e_arfs_create_tables(priv);
 327         if (err) {
 328                 netdev_err(priv->netdev, "Failed to create arfs tables, err=%d\n",
 329                            err);
 330                 priv->netdev->hw_features &= ~NETIF_F_NTUPLE;
 331         }
 332
 333         mlx5e_set_ttc_basic_params(priv, &ttc_params);
 334         mlx5e_set_ttc_ft_params(&ttc_params);
 335         for (tt = 0; tt < MLX5E_NUM_INDIR_TIRS; tt++)
 336                 ttc_params.indir_tirn[tt] = priv->indir_tir[tt].tirn;
 337
 338         err = mlx5e_create_ttc_table(priv, &ttc_params, &priv->fs.ttc);
 339         if (err) {
 340                 netdev_err(priv->netdev, "Failed to create ttc table, err=%d\n",
 341                            err);
 342                 goto err_destroy_arfs_tables;
 343         }
 344
 345         return 0;
 346
 347 err_destroy_arfs_tables:
 348         mlx5e_arfs_destroy_tables(priv);
 349
 350         return err;
 351 }
 352
 353 static void mlx5i_destroy_flow_steering(struct mlx5e_priv *priv)
 354 {
 355         mlx5e_destroy_ttc_table(priv, &priv->fs.ttc);
 356         mlx5e_arfs_destroy_tables(priv);
 357 }
 358
 359 static int mlx5i_init_rx(struct mlx5e_priv *priv)
 360 {
 361         struct mlx5_core_dev *mdev = priv->mdev;
 362         u16 max_nch = priv->max_nch;
 363         int err;
 364
 365         mlx5e_build_rss_params(&priv->rss_params, priv->channels.params.num_channels);
 366
 367         mlx5e_create_q_counters(priv);
 368
 369         err = mlx5e_open_drop_rq(priv, &priv->drop_rq);
 370         if (err) {
 371                 mlx5_core_err(mdev, "open drop rq failed, %d\n", err);
 372                 goto err_destroy_q_counters;
 373         }
 374
 375         err = mlx5e_create_indirect_rqt(priv);
 376         if (err)
 377                 goto err_close_drop_rq;
 378
 379         err = mlx5e_create_direct_rqts(priv, priv->direct_tir, max_nch);
 380         if (err)
 381                 goto err_destroy_indirect_rqts;
 382
 383         err = mlx5e_create_indirect_tirs(priv, false);
 384         if (err)
 385                 goto err_destroy_direct_rqts;
 386
 387         err = mlx5e_create_direct_tirs(priv, priv->direct_tir, max_nch);
 388         if (err)
 389                 goto err_destroy_indirect_tirs;
 390
 391         err = mlx5i_create_flow_steering(priv);
 392         if (err)
 393                 goto err_destroy_direct_tirs;
 394
 395         return 0;
 396
 397 err_destroy_direct_tirs:
 398         mlx5e_destroy_direct_tirs(priv, priv->direct_tir, max_nch);
 399 err_destroy_indirect_tirs:
 400         mlx5e_destroy_indirect_tirs(priv);
 401 err_destroy_direct_rqts:
 402         mlx5e_destroy_direct_rqts(priv, priv->direct_tir, max_nch);
 403 err_destroy_indirect_rqts:
 404         priv->indir_rqt_enabled = false;
 405         mlx5e_rqt_destroy(&priv->indir_rqt);
 406 err_close_drop_rq:
 407         mlx5e_close_drop_rq(&priv->drop_rq);
 408 err_destroy_q_counters:
 409         mlx5e_destroy_q_counters(priv);
 410         return err;
 411 }
 412
 413 static void mlx5i_cleanup_rx(struct mlx5e_priv *priv)
 414 {
 415         u16 max_nch = priv->max_nch;
 416
 417         mlx5i_destroy_flow_steering(priv);
 418         mlx5e_destroy_direct_tirs(priv, priv->direct_tir, max_nch);
 419         mlx5e_destroy_indirect_tirs(priv);
 420         mlx5e_destroy_direct_rqts(priv, priv->direct_tir, max_nch);
 421         priv->indir_rqt_enabled = false;
 422         mlx5e_rqt_destroy(&priv->indir_rqt);
 423         mlx5e_close_drop_rq(&priv->drop_rq);
 424         mlx5e_destroy_q_counters(priv);
 425 }
 426
 427 /* The stats groups order is opposite to the update_stats() order calls */
 428 static mlx5e_stats_grp_t mlx5i_stats_grps[] = {
 429         &MLX5E_STATS_GRP(sw),
 430         &MLX5E_STATS_GRP(qcnt),
 431         &MLX5E_STATS_GRP(vnic_env),
 432         &MLX5E_STATS_GRP(vport),
 433         &MLX5E_STATS_GRP(802_3),
 434         &MLX5E_STATS_GRP(2863),
 435         &MLX5E_STATS_GRP(2819),
 436         &MLX5E_STATS_GRP(phy),
 437         &MLX5E_STATS_GRP(pcie),
 438         &MLX5E_STATS_GRP(per_prio),
 439         &MLX5E_STATS_GRP(pme),
 440         &MLX5E_STATS_GRP(channels),
 441         &MLX5E_STATS_GRP(per_port_buff_congest),
 442 };
 443
 444 static unsigned int mlx5i_stats_grps_num(struct mlx5e_priv *priv)
 445 {
 446         return ARRAY_SIZE(mlx5i_stats_grps);
 447 }
 448
 449 static const struct mlx5e_profile mlx5i_nic_profile = {
 450         .init              = mlx5i_init,
 451         .cleanup           = mlx5i_cleanup,
 452         .init_tx           = mlx5i_init_tx,
 453         .cleanup_tx        = mlx5i_cleanup_tx,
 454         .init_rx           = mlx5i_init_rx,
 455         .cleanup_rx        = mlx5i_cleanup_rx,
 456         .enable            = NULL, /* mlx5i_enable */
 457         .disable           = NULL, /* mlx5i_disable */
 458         .update_rx         = mlx5i_update_nic_rx,
 459         .update_stats      = NULL, /* mlx5i_update_stats */
 460         .update_carrier    = NULL, /* no HW update in IB link */
 461         .rx_handlers       = &mlx5i_rx_handlers,
 462         .max_tc            = MLX5I_MAX_NUM_TC,
 463         .rq_groups         = MLX5E_NUM_RQ_GROUPS(REGULAR),
 464         .stats_grps        = mlx5i_stats_grps,
 465         .stats_grps_num    = mlx5i_stats_grps_num,
 466         .rx_ptp_support    = false,
 467 };
 468
 469 /* mlx5i netdev NDos */
 470
 471 static int mlx5i_change_mtu(struct net_device *netdev, int new_mtu)
 472 {
 473         struct mlx5e_priv *priv = mlx5i_epriv(netdev);
 474         struct mlx5e_params new_params;
 475         int err = 0;
 476
 477         mutex_lock(&priv->state_lock);
 478
 479         new_params = priv->channels.params;
 480         new_params.sw_mtu = new_mtu;
 481
 482         err = mlx5e_safe_switch_params(priv, &new_params, NULL, NULL, true);
 483         if (err)
 484                 goto out;
 485
 486         netdev->mtu = new_params.sw_mtu;
 487
 488 out:
 489         mutex_unlock(&priv->state_lock);
 490         return err;
 491 }
 492
 493 int mlx5i_dev_init(struct net_device *dev)
 494 {
 495         struct mlx5e_priv    *priv   = mlx5i_epriv(dev);
 496         struct mlx5i_priv    *ipriv  = priv->ppriv;
 497
 498         /* Set dev address using underlay QP */
 499         dev->dev_addr[1] = (ipriv->qpn >> 16) & 0xff;
 500         dev->dev_addr[2] = (ipriv->qpn >>  8) & 0xff;
 501         dev->dev_addr[3] = (ipriv->qpn) & 0xff;
 502
 503         /* Add QPN to net-device mapping to HT */
 504         mlx5i_pkey_add_qpn(dev, ipriv->qpn);
 505
 506         return 0;
 507 }
 508
 509 int mlx5i_ioctl(struct net_device *dev, struct ifreq *ifr, int cmd)
 510 {
 511         struct mlx5e_priv *priv = mlx5i_epriv(dev);
 512
 513         switch (cmd) {
 514         case SIOCSHWTSTAMP:
 515                 return mlx5e_hwstamp_set(priv, ifr);
 516         case SIOCGHWTSTAMP:
 517                 return mlx5e_hwstamp_get(priv, ifr);
 518         default:
 519                 return -EOPNOTSUPP;
 520         }
 521 }
 522
 523 void mlx5i_dev_cleanup(struct net_device *dev)
 524 {
 525         struct mlx5e_priv    *priv   = mlx5i_epriv(dev);
 526         struct mlx5i_priv    *ipriv = priv->ppriv;
 527
 528         mlx5i_uninit_underlay_qp(priv);
 529
 530         /* Delete QPN to net-device mapping from HT */
 531         mlx5i_pkey_del_qpn(dev, ipriv->qpn);
 532 }
 533
 534 static int mlx5i_open(struct net_device *netdev)
 535 {
 536         struct mlx5e_priv *epriv = mlx5i_epriv(netdev);
 537         struct mlx5i_priv *ipriv = epriv->ppriv;
 538         struct mlx5_core_dev *mdev = epriv->mdev;
 539         int err;
 540
 541         mutex_lock(&epriv->state_lock);
 542
 543         set_bit(MLX5E_STATE_OPENED, &epriv->state);
 544
 545         err = mlx5i_init_underlay_qp(epriv);
 546         if (err) {
 547                 mlx5_core_warn(mdev, "prepare underlay qp state failed, %d\n", err);
 548                 goto err_clear_state_opened_flag;
 549         }
 550
 551         err = mlx5_fs_add_rx_underlay_qpn(mdev, ipriv->qpn);
 552         if (err) {
 553                 mlx5_core_warn(mdev, "attach underlay qp to ft failed, %d\n", err);
 554                 goto err_reset_qp;
 555         }
 556
 557         err = mlx5e_open_channels(epriv, &epriv->channels);
 558         if (err)
 559                 goto err_remove_fs_underlay_qp;
 560
 561         epriv->profile->update_rx(epriv);
 562         mlx5e_activate_priv_channels(epriv);
 563
 564         mutex_unlock(&epriv->state_lock);
 565         return 0;
 566
 567 err_remove_fs_underlay_qp:
 568         mlx5_fs_remove_rx_underlay_qpn(mdev, ipriv->qpn);
 569 err_reset_qp:
 570         mlx5i_uninit_underlay_qp(epriv);
 571 err_clear_state_opened_flag:
 572         clear_bit(MLX5E_STATE_OPENED, &epriv->state);
 573         mutex_unlock(&epriv->state_lock);
 574         return err;
 575 }
 576
 577 static int mlx5i_close(struct net_device *netdev)
 578 {
 579         struct mlx5e_priv *epriv = mlx5i_epriv(netdev);
 580         struct mlx5i_priv *ipriv = epriv->ppriv;
 581         struct mlx5_core_dev *mdev = epriv->mdev;
 582
 583         /* May already be CLOSED in case a previous configuration operation
 584          * (e.g RX/TX queue size change) that involves close&open failed.
 585          */
 586         mutex_lock(&epriv->state_lock);
 587
 588         if (!test_bit(MLX5E_STATE_OPENED, &epriv->state))
 589                 goto unlock;
 590
 591         clear_bit(MLX5E_STATE_OPENED, &epriv->state);
 592
 593         netif_carrier_off(epriv->netdev);
 594         mlx5_fs_remove_rx_underlay_qpn(mdev, ipriv->qpn);
 595         mlx5e_deactivate_priv_channels(epriv);
 596         mlx5e_close_channels(&epriv->channels);
 597         mlx5i_uninit_underlay_qp(epriv);
 598 unlock:
 599         mutex_unlock(&epriv->state_lock);
 600         return 0;
 601 }
 602
 603 /* IPoIB RDMA netdev callbacks */
 604 static int mlx5i_attach_mcast(struct net_device *netdev, struct ib_device *hca,
 605                               union ib_gid *gid, u16 lid, int set_qkey,
 606                               u32 qkey)
 607 {
 608         struct mlx5e_priv    *epriv = mlx5i_epriv(netdev);
 609         struct mlx5_core_dev *mdev  = epriv->mdev;
 610         struct mlx5i_priv    *ipriv = epriv->ppriv;
 611         int err;
 612
 613         mlx5_core_dbg(mdev, "attaching QPN 0x%x, MGID %pI6\n", ipriv->qpn,
 614                       gid->raw);
 615         err = mlx5_core_attach_mcg(mdev, gid, ipriv->qpn);
 616         if (err)
 617                 mlx5_core_warn(mdev, "failed attaching QPN 0x%x, MGID %pI6\n",
 618                                ipriv->qpn, gid->raw);
 619
 620         if (set_qkey) {
 621                 mlx5_core_dbg(mdev, "%s setting qkey 0x%x\n",
 622                               netdev->name, qkey);
 623                 ipriv->qkey = qkey;
 624         }
 625
 626         return err;
 627 }
 628
 629 static int mlx5i_detach_mcast(struct net_device *netdev, struct ib_device *hca,
 630                               union ib_gid *gid, u16 lid)
 631 {
 632         struct mlx5e_priv    *epriv = mlx5i_epriv(netdev);
 633         struct mlx5_core_dev *mdev  = epriv->mdev;
 634         struct mlx5i_priv    *ipriv = epriv->ppriv;
 635         int err;
 636
 637         mlx5_core_dbg(mdev, "detaching QPN 0x%x, MGID %pI6\n", ipriv->qpn,
 638                       gid->raw);
 639
 640         err = mlx5_core_detach_mcg(mdev, gid, ipriv->qpn);
 641         if (err)
 642                 mlx5_core_dbg(mdev, "failed detaching QPN 0x%x, MGID %pI6\n",
 643                               ipriv->qpn, gid->raw);
 644
 645         return err;
 646 }
 647
 648 static int mlx5i_xmit(struct net_device *dev, struct sk_buff *skb,
 649                       struct ib_ah *address, u32 dqpn)
 650 {
 651         struct mlx5e_priv *epriv = mlx5i_epriv(dev);
 652         struct mlx5e_txqsq *sq   = epriv->txq2sq[skb_get_queue_mapping(skb)];
 653         struct mlx5_ib_ah *mah   = to_mah(address);
 654         struct mlx5i_priv *ipriv = epriv->ppriv;
 655
 656         mlx5i_sq_xmit(sq, skb, &mah->av, dqpn, ipriv->qkey, netdev_xmit_more());
 657
 658         return NETDEV_TX_OK;
 659 }
 660
 661 static void mlx5i_set_pkey_index(struct net_device *netdev, int id)
 662 {
 663         struct mlx5i_priv *ipriv = netdev_priv(netdev);
 664
 665         ipriv->pkey_index = (u16)id;
 666 }
 667
 668 static int mlx5i_check_required_hca_cap(struct mlx5_core_dev *mdev)
 669 {
 670         if (MLX5_CAP_GEN(mdev, port_type) != MLX5_CAP_PORT_TYPE_IB)
 671                 return -EOPNOTSUPP;
 672
 673         if (!MLX5_CAP_GEN(mdev, ipoib_enhanced_offloads)) {
 674                 mlx5_core_warn(mdev, "IPoIB enhanced offloads are not supported\n");
 675                 return -EOPNOTSUPP;
 676         }
 677
 678         return 0;
 679 }
 680
 681 static void mlx5_rdma_netdev_free(struct net_device *netdev)
 682 {
 683         struct mlx5e_priv *priv = mlx5i_epriv(netdev);
 684         struct mlx5_core_dev *mdev = priv->mdev;
 685         struct mlx5i_priv *ipriv = priv->ppriv;
 686         const struct mlx5e_profile *profile = priv->profile;
 687
 688         mlx5e_detach_netdev(priv);
 689         profile->cleanup(priv);
 690
 691         if (!ipriv->sub_interface) {
 692                 mlx5i_pkey_qpn_ht_cleanup(netdev);
 693                 mlx5e_destroy_mdev_resources(mdev);
 694         }
 695 }
 696
 697 static bool mlx5_is_sub_interface(struct mlx5_core_dev *mdev)
 698 {
 699         return mdev->mlx5e_res.hw_objs.pdn != 0;
 700 }
 701
 702 static const struct mlx5e_profile *mlx5_get_profile(struct mlx5_core_dev *mdev)
 703 {
 704         if (mlx5_is_sub_interface(mdev))
 705                 return mlx5i_pkey_get_profile();
 706         return &mlx5i_nic_profile;
 707 }
 708
 709 static int mlx5_rdma_setup_rn(struct ib_device *ibdev, u32 port_num,
 710                               struct net_device *netdev, void *param)
 711 {
 712         struct mlx5_core_dev *mdev = (struct mlx5_core_dev *)param;
 713         const struct mlx5e_profile *prof = mlx5_get_profile(mdev);
 714         struct mlx5i_priv *ipriv;
 715         struct mlx5e_priv *epriv;
 716         struct rdma_netdev *rn;
 717         int err;
 718
 719         ipriv = netdev_priv(netdev);
 720         epriv = mlx5i_epriv(netdev);
 721
 722         ipriv->sub_interface = mlx5_is_sub_interface(mdev);
 723         if (!ipriv->sub_interface) {
 724                 err = mlx5i_pkey_qpn_ht_init(netdev);
 725                 if (err) {
 726                         mlx5_core_warn(mdev, "allocate qpn_to_netdev ht failed\n");
 727                         return err;
 728                 }
 729
 730                 /* This should only be called once per mdev */
 731                 err = mlx5e_create_mdev_resources(mdev);
 732                 if (err)
 733                         goto destroy_ht;
 734         }
 735
 736         err = mlx5e_priv_init(epriv, netdev, mdev);
 737         if (err)
 738                 goto destroy_mdev_resources;
 739
 740         epriv->profile = prof;
 741         epriv->ppriv = ipriv;
 742
 743         prof->init(mdev, netdev);
 744
 745         err = mlx5e_attach_netdev(epriv);
 746         if (err)
 747                 goto detach;
 748         netif_carrier_off(netdev);
 749
 750         /* set rdma_netdev func pointers */
 751         rn = &ipriv->rn;
 752         rn->hca  = ibdev;
 753         rn->send = mlx5i_xmit;
 754         rn->attach_mcast = mlx5i_attach_mcast;
 755         rn->detach_mcast = mlx5i_detach_mcast;
 756         rn->set_id = mlx5i_set_pkey_index;
 757
 758         netdev->priv_destructor = mlx5_rdma_netdev_free;
 759         netdev->needs_free_netdev = 1;
 760
 761         return 0;
 762
 763 detach:
 764         prof->cleanup(epriv);
 765         if (ipriv->sub_interface)
 766                 return err;
 767 destroy_mdev_resources:
 768         mlx5e_destroy_mdev_resources(mdev);
 769 destroy_ht:
 770         mlx5i_pkey_qpn_ht_cleanup(netdev);
 771         return err;
 772 }
 773
 774 int mlx5_rdma_rn_get_params(struct mlx5_core_dev *mdev,
 775                             struct ib_device *device,
 776                             struct rdma_netdev_alloc_params *params)
 777 {
 778         int nch;
 779         int rc;
 780
 781         rc = mlx5i_check_required_hca_cap(mdev);
 782         if (rc)
 783                 return rc;
 784
 785         nch = mlx5e_get_max_num_channels(mdev);
 786
 787         *params = (struct rdma_netdev_alloc_params){
 788                 .sizeof_priv = sizeof(struct mlx5i_priv) +
 789                                sizeof(struct mlx5e_priv),
 790                 .txqs = nch * MLX5E_MAX_NUM_TC,
 791                 .rxqs = nch,
 792                 .param = mdev,
 793                 .initialize_rdma_netdev = mlx5_rdma_setup_rn,
 794         };
 795
 796         return 0;
 797 }
 798 EXPORT_SYMBOL(mlx5_rdma_rn_get_params);