examples/ip_pipeline/kni.c

   1 /* SPDX-License-Identifier: BSD-3-Clause
   2  * Copyright(c) 2010-2018 Intel Corporation
   3  */
   4
   5 #include <stdlib.h>
   6 #include <string.h>
   7
   8 #include <rte_ethdev.h>
   9 #include <rte_bus_pci.h>
  10 #include <rte_string_fns.h>
  11
  12 #include "kni.h"
  13 #include "mempool.h"
  14 #include "link.h"
  15
  16 static struct kni_list kni_list;
  17
  18 #ifndef KNI_MAX
  19 #define KNI_MAX                                            16
  20 #endif
  21
  22 int
  23 kni_init(void)
  24 {
  25         TAILQ_INIT(&kni_list);
  26
  27 #ifdef RTE_LIBRTE_KNI
  28         rte_kni_init(KNI_MAX);
  29 #endif
  30
  31         return 0;
  32 }
  33
  34 struct kni *
  35 kni_find(const char *name)
  36 {
  37         struct kni *kni;
  38
  39         if (name == NULL)
  40                 return NULL;
  41
  42         TAILQ_FOREACH(kni, &kni_list, node)
  43                 if (strcmp(kni->name, name) == 0)
  44                         return kni;
  45
  46         return NULL;
  47 }
  48
  49 #ifndef RTE_LIBRTE_KNI
  50
  51 struct kni *
  52 kni_create(const char *name __rte_unused,
  53         struct kni_params *params __rte_unused)
  54 {
  55         return NULL;
  56 }
  57
  58 void
  59 kni_handle_request(void)
  60 {
  61         return;
  62 }
  63
  64 #else
  65
  66 static int
  67 kni_config_network_interface(uint16_t port_id, uint8_t if_up)
  68 {
  69         int ret = 0;
  70
  71         if (!rte_eth_dev_is_valid_port(port_id))
  72                 return -EINVAL;
  73
  74         ret = (if_up) ?
  75                 rte_eth_dev_set_link_up(port_id) :
  76                 rte_eth_dev_set_link_down(port_id);
  77
  78         return ret;
  79 }
  80
  81 static int
  82 kni_change_mtu(uint16_t port_id, unsigned int new_mtu)
  83 {
  84         int ret;
  85
  86         if (!rte_eth_dev_is_valid_port(port_id))
  87                 return -EINVAL;
  88
  89         if (new_mtu > RTE_ETHER_MAX_LEN)
  90                 return -EINVAL;
  91
  92         /* Set new MTU */
  93         ret = rte_eth_dev_set_mtu(port_id, new_mtu);
  94         if (ret < 0)
  95                 return ret;
  96
  97         return 0;
  98 }
  99
 100 struct kni *
 101 kni_create(const char *name, struct kni_params *params)
 102 {
 103         struct rte_eth_dev_info dev_info;
 104         struct rte_kni_conf kni_conf;
 105         struct rte_kni_ops kni_ops;
 106         struct kni *kni;
 107         struct mempool *mempool;
 108         struct link *link;
 109         struct rte_kni *k;
 110         const struct rte_pci_device *pci_dev;
 111         const struct rte_bus *bus = NULL;
 112
 113         /* Check input params */
 114         if ((name == NULL) ||
 115                 kni_find(name) ||
 116                 (params == NULL))
 117                 return NULL;
 118
 119         mempool = mempool_find(params->mempool_name);
 120         link = link_find(params->link_name);
 121         if ((mempool == NULL) ||
 122                 (link == NULL))
 123                 return NULL;
 124
 125         /* Resource create */
 126         rte_eth_dev_info_get(link->port_id, &dev_info);
 127
 128         memset(&kni_conf, 0, sizeof(kni_conf));
 129         strlcpy(kni_conf.name, name, RTE_KNI_NAMESIZE);
 130         kni_conf.force_bind = params->force_bind;
 131         kni_conf.core_id = params->thread_id;
 132         kni_conf.group_id = link->port_id;
 133         kni_conf.mbuf_size = mempool->buffer_size;
 134         if (dev_info.device)
 135                 bus = rte_bus_find_by_device(dev_info.device);
 136         if (bus && !strcmp(bus->name, "pci")) {
 137                 pci_dev = RTE_DEV_TO_PCI(dev_info.device);
 138                 kni_conf.addr = pci_dev->addr;
 139                 kni_conf.id = pci_dev->id;
 140         }
 141
 142         memset(&kni_ops, 0, sizeof(kni_ops));
 143         kni_ops.port_id = link->port_id;
 144         kni_ops.config_network_if = kni_config_network_interface;
 145         kni_ops.change_mtu = kni_change_mtu;
 146
 147         k = rte_kni_alloc(mempool->m, &kni_conf, &kni_ops);
 148         if (k == NULL)
 149                 return NULL;
 150
 151         /* Node allocation */
 152         kni = calloc(1, sizeof(struct kni));
 153         if (kni == NULL)
 154                 return NULL;
 155
 156         /* Node fill in */
 157         strlcpy(kni->name, name, sizeof(kni->name));
 158         kni->k = k;
 159
 160         /* Node add to list */
 161         TAILQ_INSERT_TAIL(&kni_list, kni, node);
 162
 163         return kni;
 164 }
 165
 166 void
 167 kni_handle_request(void)
 168 {
 169         struct kni *kni;
 170
 171         TAILQ_FOREACH(kni, &kni_list, node)
 172                 rte_kni_handle_request(kni->k);
 173 }
 174
 175 #endif