The Design and Implementation of the FreeBSD Operating System, Second Edition
Now available: The Design and Implementation of the FreeBSD Operating System (Second Edition)


[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]

FreeBSD/Linux Kernel Cross Reference
sys/dev/cxgbe/iw_cxgbe/device.c

Version: -  FREEBSD  -  FREEBSD-13-STABLE  -  FREEBSD-13-0  -  FREEBSD-12-STABLE  -  FREEBSD-12-0  -  FREEBSD-11-STABLE  -  FREEBSD-11-0  -  FREEBSD-10-STABLE  -  FREEBSD-10-0  -  FREEBSD-9-STABLE  -  FREEBSD-9-0  -  FREEBSD-8-STABLE  -  FREEBSD-8-0  -  FREEBSD-7-STABLE  -  FREEBSD-7-0  -  FREEBSD-6-STABLE  -  FREEBSD-6-0  -  FREEBSD-5-STABLE  -  FREEBSD-5-0  -  FREEBSD-4-STABLE  -  FREEBSD-3-STABLE  -  FREEBSD22  -  l41  -  OPENBSD  -  linux-2.6  -  MK84  -  PLAN9  -  xnu-8792 
SearchContext: -  none  -  3  -  10 

    1 /*-
    2  * SPDX-License-Identifier: BSD-2-Clause-FreeBSD
    3  *
    4  * Copyright (c) 2009-2013 Chelsio, Inc. All rights reserved.
    5  *
    6  * This software is available to you under a choice of one of two
    7  * licenses.  You may choose to be licensed under the terms of the GNU
    8  * General Public License (GPL) Version 2, available from the file
    9  * COPYING in the main directory of this source tree, or the
   10  * OpenIB.org BSD license below:
   11  *
   12  *     Redistribution and use in source and binary forms, with or
   13  *     without modification, are permitted provided that the following
   14  *     conditions are met:
   15  *
   16  *      - Redistributions of source code must retain the above
   17  *        copyright notice, this list of conditions and the following
   18  *        disclaimer.
   19  *
   20  *      - Redistributions in binary form must reproduce the above
   21  *        copyright notice, this list of conditions and the following
   22  *        disclaimer in the documentation and/or other materials
   23  *        provided with the distribution.
   24  *
   25  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
   26  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
   27  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
   28  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
   29  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
   30  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
   31  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
   32  * SOFTWARE.
   33  */
   34 #include <sys/cdefs.h>
   35 __FBSDID("$FreeBSD$");
   36 
   37 #include "opt_inet.h"
   38 
   39 #include <sys/ktr.h>
   40 
   41 #include <linux/module.h>
   42 #include <linux/moduleparam.h>
   43 
   44 #include <rdma/ib_verbs.h>
   45 #include <linux/idr.h>
   46 
   47 #ifdef TCP_OFFLOAD
   48 #include "iw_cxgbe.h"
   49 
   50 void
   51 c4iw_release_dev_ucontext(struct c4iw_rdev *rdev,
   52     struct c4iw_dev_ucontext *uctx)
   53 {
   54         struct list_head *pos, *nxt;
   55         struct c4iw_qid_list *entry;
   56 
   57         mutex_lock(&uctx->lock);
   58         list_for_each_safe(pos, nxt, &uctx->qpids) {
   59                 entry = list_entry(pos, struct c4iw_qid_list, entry);
   60                 list_del_init(&entry->entry);
   61                 if (!(entry->qid & rdev->qpmask)) {
   62                         c4iw_put_resource(&rdev->resource.qid_table,
   63                                           entry->qid);
   64                         mutex_lock(&rdev->stats.lock);
   65                         rdev->stats.qid.cur -= rdev->qpmask + 1;
   66                         mutex_unlock(&rdev->stats.lock);
   67                 }
   68                 kfree(entry);
   69         }
   70 
   71         list_for_each_safe(pos, nxt, &uctx->cqids) {
   72                 entry = list_entry(pos, struct c4iw_qid_list, entry);
   73                 list_del_init(&entry->entry);
   74                 kfree(entry);
   75         }
   76         mutex_unlock(&uctx->lock);
   77 }
   78 
   79 void
   80 c4iw_init_dev_ucontext(struct c4iw_rdev *rdev, struct c4iw_dev_ucontext *uctx)
   81 {
   82 
   83         INIT_LIST_HEAD(&uctx->qpids);
   84         INIT_LIST_HEAD(&uctx->cqids);
   85         mutex_init(&uctx->lock);
   86 }
   87 
   88 static int
   89 c4iw_rdev_open(struct c4iw_rdev *rdev)
   90 {
   91         struct adapter *sc = rdev->adap;
   92         struct sge_params *sp = &sc->params.sge;
   93         int rc;
   94         unsigned short ucq_density = 1 << sp->iq_s_qpp; /* # of user CQs/page */
   95         unsigned short udb_density = 1 << sp->eq_s_qpp; /* # of user DB/page */
   96 
   97 
   98         c4iw_init_dev_ucontext(rdev, &rdev->uctx);
   99 
  100         /*
  101          * This implementation assumes udb_density == ucq_density!  Eventually
  102          * we might need to support this but for now fail the open. Also the
  103          * cqid and qpid range must match for now.
  104          */
  105         if (udb_density != ucq_density) {
  106                 device_printf(sc->dev, "unsupported udb/ucq densities %u/%u\n",
  107                     udb_density, ucq_density);
  108                 rc = -EINVAL;
  109                 goto err1;
  110         }
  111         if (sc->vres.qp.start != sc->vres.cq.start ||
  112             sc->vres.qp.size != sc->vres.cq.size) {
  113                 device_printf(sc->dev, "%s: unsupported qp and cq id ranges "
  114                         "qp start %u size %u cq start %u size %u\n", __func__,
  115                         sc->vres.qp.start, sc->vres.qp.size, sc->vres.cq.start,
  116                         sc->vres.cq.size);
  117                 rc = -EINVAL;
  118                 goto err1;
  119         }
  120 
  121         rdev->qpshift = PAGE_SHIFT - sp->eq_s_qpp;
  122         rdev->qpmask = udb_density - 1;
  123         rdev->cqshift = PAGE_SHIFT - sp->iq_s_qpp;
  124         rdev->cqmask = ucq_density - 1;
  125 
  126         if (c4iw_num_stags(rdev) == 0) {
  127                 rc = -EINVAL;
  128                 goto err1;
  129         }
  130 
  131         rdev->stats.pd.total = T4_MAX_NUM_PD;
  132         rdev->stats.stag.total = sc->vres.stag.size;
  133         rdev->stats.pbl.total = sc->vres.pbl.size;
  134         rdev->stats.rqt.total = sc->vres.rq.size;
  135         rdev->stats.qid.total = sc->vres.qp.size;
  136 
  137         rc = c4iw_init_resource(rdev, c4iw_num_stags(rdev), T4_MAX_NUM_PD);
  138         if (rc) {
  139                 device_printf(sc->dev, "error %d initializing resources\n", rc);
  140                 goto err1;
  141         }
  142         rc = c4iw_pblpool_create(rdev);
  143         if (rc) {
  144                 device_printf(sc->dev, "error %d initializing pbl pool\n", rc);
  145                 goto err2;
  146         }
  147         rc = c4iw_rqtpool_create(rdev);
  148         if (rc) {
  149                 device_printf(sc->dev, "error %d initializing rqt pool\n", rc);
  150                 goto err3;
  151         }
  152         rdev->status_page = (struct t4_dev_status_page *)
  153                                 __get_free_page(GFP_KERNEL);
  154         if (!rdev->status_page) {
  155                 rc = -ENOMEM;
  156                 goto err4;
  157         }
  158         rdev->status_page->qp_start = sc->vres.qp.start;
  159         rdev->status_page->qp_size = sc->vres.qp.size;
  160         rdev->status_page->cq_start = sc->vres.cq.start;
  161         rdev->status_page->cq_size = sc->vres.cq.size;
  162 
  163         /* T5 and above devices don't need Doorbell recovery logic,
  164          * so db_off is always set to ''.
  165          */
  166         rdev->status_page->db_off = 0;
  167 
  168         rdev->status_page->wc_supported = rdev->adap->iwt.wc_en;
  169 
  170         rdev->free_workq = create_singlethread_workqueue("iw_cxgb4_free");
  171         if (!rdev->free_workq) {
  172                 rc = -ENOMEM;
  173                 goto err5;
  174         }
  175         return (0);
  176 err5:
  177         free_page((unsigned long)rdev->status_page);
  178 err4:
  179         c4iw_rqtpool_destroy(rdev);
  180 err3:
  181         c4iw_pblpool_destroy(rdev);
  182 err2:
  183         c4iw_destroy_resource(&rdev->resource);
  184 err1:
  185         return (rc);
  186 }
  187 
  188 static void c4iw_rdev_close(struct c4iw_rdev *rdev)
  189 {
  190         free_page((unsigned long)rdev->status_page);
  191         c4iw_pblpool_destroy(rdev);
  192         c4iw_rqtpool_destroy(rdev);
  193         c4iw_destroy_resource(&rdev->resource);
  194 }
  195 
  196 static void
  197 c4iw_dealloc(struct c4iw_dev *iwsc)
  198 {
  199 
  200         c4iw_rdev_close(&iwsc->rdev);
  201         idr_destroy(&iwsc->cqidr);
  202         idr_destroy(&iwsc->qpidr);
  203         idr_destroy(&iwsc->mmidr);
  204         ib_dealloc_device(&iwsc->ibdev);
  205 }
  206 
  207 static struct c4iw_dev *
  208 c4iw_alloc(struct adapter *sc)
  209 {
  210         struct c4iw_dev *iwsc;
  211         int rc;
  212 
  213         iwsc = (struct c4iw_dev *)ib_alloc_device(sizeof(*iwsc));
  214         if (iwsc == NULL) {
  215                 device_printf(sc->dev, "Cannot allocate ib device.\n");
  216                 return (ERR_PTR(-ENOMEM));
  217         }
  218         iwsc->rdev.adap = sc;
  219 
  220         /* init various hw-queue params based on lld info */
  221         iwsc->rdev.hw_queue.t4_eq_status_entries =
  222                 sc->params.sge.spg_len / EQ_ESIZE;
  223         iwsc->rdev.hw_queue.t4_max_eq_size = 65520;
  224         iwsc->rdev.hw_queue.t4_max_iq_size = 65520;
  225         iwsc->rdev.hw_queue.t4_max_rq_size = 8192 -
  226                 iwsc->rdev.hw_queue.t4_eq_status_entries - 1;
  227         iwsc->rdev.hw_queue.t4_max_sq_size =
  228                 iwsc->rdev.hw_queue.t4_max_eq_size -
  229                 iwsc->rdev.hw_queue.t4_eq_status_entries - 1;
  230         iwsc->rdev.hw_queue.t4_max_qp_depth =
  231                 iwsc->rdev.hw_queue.t4_max_rq_size;
  232         iwsc->rdev.hw_queue.t4_max_cq_depth =
  233                 iwsc->rdev.hw_queue.t4_max_iq_size - 2;
  234         iwsc->rdev.hw_queue.t4_stat_len = iwsc->rdev.adap->params.sge.spg_len;
  235 
  236         /* As T5 and above devices support BAR2 kernel doorbells & WC, we map
  237          * all of BAR2, for both User and Kernel Doorbells-GTS.
  238          */
  239         iwsc->rdev.bar2_kva = (void __iomem *)((u64)iwsc->rdev.adap->udbs_base);
  240         iwsc->rdev.bar2_pa = vtophys(iwsc->rdev.adap->udbs_base);
  241         iwsc->rdev.bar2_len = rman_get_size(iwsc->rdev.adap->udbs_res);
  242 
  243         rc = c4iw_rdev_open(&iwsc->rdev);
  244         if (rc != 0) {
  245                 device_printf(sc->dev, "Unable to open CXIO rdev (%d)\n", rc);
  246                 ib_dealloc_device(&iwsc->ibdev);
  247                 return (ERR_PTR(rc));
  248         }
  249 
  250         idr_init(&iwsc->cqidr);
  251         idr_init(&iwsc->qpidr);
  252         idr_init(&iwsc->mmidr);
  253         spin_lock_init(&iwsc->lock);
  254         mutex_init(&iwsc->rdev.stats.lock);
  255         iwsc->avail_ird = iwsc->rdev.adap->params.max_ird_adapter;
  256 
  257         return (iwsc);
  258 }
  259 
  260 static int c4iw_mod_load(void);
  261 static int c4iw_mod_unload(void);
  262 static int c4iw_activate(struct adapter *);
  263 static int c4iw_deactivate(struct adapter *);
  264 static void c4iw_async_event(struct adapter *);
  265 
  266 static struct uld_info c4iw_uld_info = {
  267         .uld_id = ULD_IWARP,
  268         .activate = c4iw_activate,
  269         .deactivate = c4iw_deactivate,
  270         .async_event = c4iw_async_event,
  271 };
  272 
  273 static int
  274 c4iw_activate(struct adapter *sc)
  275 {
  276         struct c4iw_dev *iwsc;
  277         int rc;
  278 
  279         ASSERT_SYNCHRONIZED_OP(sc);
  280 
  281         if (is_t4(sc)) {
  282                 device_printf(sc->dev, "No iWARP support for T4 devices, "
  283                                 "please install T5 or above devices.\n");
  284                 return (ENOSYS);
  285         }
  286 
  287         if (uld_active(sc, ULD_IWARP)) {
  288                 KASSERT(0, ("%s: RDMA already eanbled on sc %p", __func__, sc));
  289                 return (0);
  290         }
  291 
  292         if (sc->rdmacaps == 0) {
  293                 device_printf(sc->dev,
  294                     "RDMA not supported or RDMA cap is not enabled.\n");
  295                 return (ENOSYS);
  296         }
  297 
  298         iwsc = c4iw_alloc(sc);
  299         if (IS_ERR(iwsc)) {
  300                 rc = -PTR_ERR(iwsc);
  301                 device_printf(sc->dev, "initialization failed: %d\n", rc);
  302                 return (rc);
  303         }
  304 
  305         sc->iwarp_softc = iwsc;
  306 
  307         rc = -c4iw_register_device(iwsc);
  308         if (rc) {
  309                 device_printf(sc->dev, "RDMA registration failed: %d\n", rc);
  310                 c4iw_dealloc(iwsc);
  311                 sc->iwarp_softc = NULL;
  312         }
  313 
  314         return (rc);
  315 }
  316 
  317 static int
  318 c4iw_deactivate(struct adapter *sc)
  319 {
  320         struct c4iw_dev *iwsc = sc->iwarp_softc;
  321 
  322         ASSERT_SYNCHRONIZED_OP(sc);
  323 
  324         c4iw_unregister_device(iwsc);
  325         c4iw_dealloc(iwsc);
  326         sc->iwarp_softc = NULL;
  327 
  328         return (0);
  329 }
  330 
  331 static void
  332 c4iw_async_event(struct adapter *sc)
  333 {
  334         struct c4iw_dev *iwsc = sc->iwarp_softc;
  335 
  336         if (iwsc) {
  337                 struct ib_event event = {0};
  338 
  339                 device_printf(sc->dev,
  340                               "iWARP driver received FATAL ERROR event.\n");
  341                 iwsc->rdev.flags |= T4_FATAL_ERROR;
  342                 event.event  = IB_EVENT_DEVICE_FATAL;
  343                 event.device = &iwsc->ibdev;
  344                 ib_dispatch_event(&event);
  345         }
  346 }
  347 
  348 static void
  349 c4iw_activate_all(struct adapter *sc, void *arg __unused)
  350 {
  351 
  352         if (begin_synchronized_op(sc, NULL, SLEEP_OK | INTR_OK, "t4iwact") != 0)
  353                 return;
  354 
  355         /* Activate iWARP if any port on this adapter has IFCAP_TOE enabled. */
  356         if (sc->offload_map && !uld_active(sc, ULD_IWARP))
  357                 (void) t4_activate_uld(sc, ULD_IWARP);
  358 
  359         end_synchronized_op(sc, 0);
  360 }
  361 
  362 static void
  363 c4iw_deactivate_all(struct adapter *sc, void *arg __unused)
  364 {
  365 
  366         if (begin_synchronized_op(sc, NULL, SLEEP_OK | INTR_OK, "t4iwdea") != 0)
  367                 return;
  368 
  369         if (uld_active(sc, ULD_IWARP))
  370             (void) t4_deactivate_uld(sc, ULD_IWARP);
  371 
  372         end_synchronized_op(sc, 0);
  373 }
  374 
  375 static int
  376 c4iw_mod_load(void)
  377 {
  378         int rc;
  379 
  380         rc = -c4iw_cm_init();
  381         if (rc != 0)
  382                 return (rc);
  383 
  384         rc = t4_register_uld(&c4iw_uld_info);
  385         if (rc != 0) {
  386                 c4iw_cm_term();
  387                 return (rc);
  388         }
  389 
  390         t4_iterate(c4iw_activate_all, NULL);
  391 
  392         return (rc);
  393 }
  394 
  395 static int
  396 c4iw_mod_unload(void)
  397 {
  398 
  399         t4_iterate(c4iw_deactivate_all, NULL);
  400 
  401         c4iw_cm_term();
  402 
  403         if (t4_unregister_uld(&c4iw_uld_info) == EBUSY)
  404                 return (EBUSY);
  405 
  406         return (0);
  407 }
  408 
  409 #endif
  410 
  411 /*
  412  * t4_tom won't load on kernels without TCP_OFFLOAD and this module's dependency
  413  * on t4_tom ensures that it won't either.  So we don't directly check for
  414  * TCP_OFFLOAD here.
  415  */
  416 static int
  417 c4iw_modevent(module_t mod, int cmd, void *arg)
  418 {
  419         int rc = 0;
  420 
  421 #ifdef TCP_OFFLOAD
  422         switch (cmd) {
  423         case MOD_LOAD:
  424                 rc = c4iw_mod_load();
  425                 if (rc == 0)
  426                         printf("iw_cxgbe: Chelsio T5/T6 RDMA driver loaded.\n");
  427                 break;
  428 
  429         case MOD_UNLOAD:
  430                 rc = c4iw_mod_unload();
  431                 break;
  432 
  433         default:
  434                 rc = EINVAL;
  435         }
  436 #else
  437         printf("t4_tom: compiled without TCP_OFFLOAD support.\n");
  438         rc = EOPNOTSUPP;
  439 #endif
  440         return (rc);
  441 }
  442 
  443 static moduledata_t c4iw_mod_data = {
  444         "iw_cxgbe",
  445         c4iw_modevent,
  446         0
  447 };
  448 
  449 MODULE_VERSION(iw_cxgbe, 1);
  450 MODULE_DEPEND(iw_cxgbe, t4nex, 1, 1, 1);
  451 MODULE_DEPEND(iw_cxgbe, t4_tom, 1, 1, 1);
  452 MODULE_DEPEND(iw_cxgbe, ibcore, 1, 1, 1);
  453 MODULE_DEPEND(iw_cxgbe, linuxkpi, 1, 1, 1);
  454 DECLARE_MODULE(iw_cxgbe, c4iw_mod_data, SI_SUB_EXEC, SI_ORDER_ANY);

Cache object: 98bbbea5823ccc2456a0e45ee963db38


[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]


This page is part of the FreeBSD/Linux Linux Kernel Cross-Reference, and was automatically generated using a modified version of the LXR engine.