1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(c) 2018 Vladimir Medvedkin <medvedkinv@gmail.com>
3 * Copyright(c) 2019 Intel Corporation
9 #include <rte_eal_memconfig.h>
10 #include <rte_errno.h>
11 #include <rte_malloc.h>
12 #include <rte_string_fns.h>
13 #include <rte_tailq.h>
20 TAILQ_HEAD(rte_fib_list, rte_tailq_entry);
21 static struct rte_tailq_elem rte_fib_tailq = {
24 EAL_REGISTER_TAILQ(rte_fib_tailq)
26 /* Maximum length of a FIB name. */
27 #define RTE_FIB_NAMESIZE 64
29 #if defined(RTE_LIBRTE_FIB_DEBUG)
30 #define FIB_RETURN_IF_TRUE(cond, retval) do { \
35 #define FIB_RETURN_IF_TRUE(cond, retval)
39 char name[RTE_FIB_NAMESIZE];
40 enum rte_fib_type type; /**< Type of FIB struct */
41 struct rte_rib *rib; /**< RIB helper datastructure */
42 void *dp; /**< pointer to the dataplane struct*/
43 rte_fib_lookup_fn_t lookup; /**< FIB lookup function */
44 rte_fib_modify_fn_t modify; /**< modify FIB datastructure */
49 dummy_lookup(void *fib_p, const uint32_t *ips, uint64_t *next_hops,
53 struct rte_fib *fib = fib_p;
54 struct rte_rib_node *node;
56 for (i = 0; i < n; i++) {
57 node = rte_rib_lookup(fib->rib, ips[i]);
59 rte_rib_get_nh(node, &next_hops[i]);
61 next_hops[i] = fib->def_nh;
66 dummy_modify(struct rte_fib *fib, uint32_t ip, uint8_t depth,
67 uint64_t next_hop, int op)
69 struct rte_rib_node *node;
70 if ((fib == NULL) || (depth > RTE_FIB_MAXDEPTH))
73 node = rte_rib_lookup_exact(fib->rib, ip, depth);
78 node = rte_rib_insert(fib->rib, ip, depth);
81 return rte_rib_set_nh(node, next_hop);
85 rte_rib_remove(fib->rib, ip, depth);
92 init_dataplane(struct rte_fib *fib, __rte_unused int socket_id,
93 struct rte_fib_conf *conf)
95 char dp_name[sizeof(void *)];
97 snprintf(dp_name, sizeof(dp_name), "%p", fib);
101 fib->lookup = dummy_lookup;
102 fib->modify = dummy_modify;
104 case RTE_FIB_DIR24_8:
105 fib->dp = dir24_8_create(dp_name, socket_id, conf);
108 fib->lookup = dir24_8_get_lookup_fn(fib->dp,
109 RTE_FIB_LOOKUP_DEFAULT);
110 fib->modify = dir24_8_modify;
119 rte_fib_add(struct rte_fib *fib, uint32_t ip, uint8_t depth, uint64_t next_hop)
121 if ((fib == NULL) || (fib->modify == NULL) ||
122 (depth > RTE_FIB_MAXDEPTH))
124 return fib->modify(fib, ip, depth, next_hop, RTE_FIB_ADD);
128 rte_fib_delete(struct rte_fib *fib, uint32_t ip, uint8_t depth)
130 if ((fib == NULL) || (fib->modify == NULL) ||
131 (depth > RTE_FIB_MAXDEPTH))
133 return fib->modify(fib, ip, depth, 0, RTE_FIB_DEL);
137 rte_fib_lookup_bulk(struct rte_fib *fib, uint32_t *ips,
138 uint64_t *next_hops, int n)
140 FIB_RETURN_IF_TRUE(((fib == NULL) || (ips == NULL) ||
141 (next_hops == NULL) || (fib->lookup == NULL)), -EINVAL);
143 fib->lookup(fib->dp, ips, next_hops, n);
148 rte_fib_create(const char *name, int socket_id, struct rte_fib_conf *conf)
150 char mem_name[RTE_FIB_NAMESIZE];
152 struct rte_fib *fib = NULL;
153 struct rte_rib *rib = NULL;
154 struct rte_tailq_entry *te;
155 struct rte_fib_list *fib_list;
156 struct rte_rib_conf rib_conf;
158 /* Check user arguments. */
159 if ((name == NULL) || (conf == NULL) || (conf->max_routes < 0) ||
160 (conf->type > RTE_FIB_DIR24_8)) {
165 rib_conf.ext_sz = conf->rib_ext_sz;
166 rib_conf.max_nodes = conf->max_routes * 2;
168 rib = rte_rib_create(name, socket_id, &rib_conf);
171 "Can not allocate RIB %s\n", name);
175 snprintf(mem_name, sizeof(mem_name), "FIB_%s", name);
176 fib_list = RTE_TAILQ_CAST(rte_fib_tailq.head, rte_fib_list);
178 rte_mcfg_tailq_write_lock();
180 /* guarantee there's no existing */
181 TAILQ_FOREACH(te, fib_list, next) {
182 fib = (struct rte_fib *)te->data;
183 if (strncmp(name, fib->name, RTE_FIB_NAMESIZE) == 0)
192 /* allocate tailq entry */
193 te = rte_zmalloc("FIB_TAILQ_ENTRY", sizeof(*te), 0);
196 "Can not allocate tailq entry for FIB %s\n", name);
201 /* Allocate memory to store the FIB data structures. */
202 fib = rte_zmalloc_socket(mem_name,
203 sizeof(struct rte_fib), RTE_CACHE_LINE_SIZE, socket_id);
205 RTE_LOG(ERR, LPM, "FIB %s memory allocation failed\n", name);
210 rte_strlcpy(fib->name, name, sizeof(fib->name));
212 fib->type = conf->type;
213 fib->def_nh = conf->default_nh;
214 ret = init_dataplane(fib, socket_id, conf);
217 "FIB dataplane struct %s memory allocation failed "
218 "with err %d\n", name, ret);
223 te->data = (void *)fib;
224 TAILQ_INSERT_TAIL(fib_list, te, next);
226 rte_mcfg_tailq_write_unlock();
235 rte_mcfg_tailq_write_unlock();
242 rte_fib_find_existing(const char *name)
244 struct rte_fib *fib = NULL;
245 struct rte_tailq_entry *te;
246 struct rte_fib_list *fib_list;
248 fib_list = RTE_TAILQ_CAST(rte_fib_tailq.head, rte_fib_list);
250 rte_mcfg_tailq_read_lock();
251 TAILQ_FOREACH(te, fib_list, next) {
252 fib = (struct rte_fib *) te->data;
253 if (strncmp(name, fib->name, RTE_FIB_NAMESIZE) == 0)
256 rte_mcfg_tailq_read_unlock();
267 free_dataplane(struct rte_fib *fib)
272 case RTE_FIB_DIR24_8:
273 dir24_8_free(fib->dp);
280 rte_fib_free(struct rte_fib *fib)
282 struct rte_tailq_entry *te;
283 struct rte_fib_list *fib_list;
288 fib_list = RTE_TAILQ_CAST(rte_fib_tailq.head, rte_fib_list);
290 rte_mcfg_tailq_write_lock();
292 /* find our tailq entry */
293 TAILQ_FOREACH(te, fib_list, next) {
294 if (te->data == (void *)fib)
298 TAILQ_REMOVE(fib_list, te, next);
300 rte_mcfg_tailq_write_unlock();
303 rte_rib_free(fib->rib);
309 rte_fib_get_dp(struct rte_fib *fib)
311 return (fib == NULL) ? NULL : fib->dp;
315 rte_fib_get_rib(struct rte_fib *fib)
317 return (fib == NULL) ? NULL : fib->rib;
321 rte_fib_select_lookup(struct rte_fib *fib,
322 enum rte_fib_lookup_type type)
324 rte_fib_lookup_fn_t fn;
327 case RTE_FIB_DIR24_8:
328 fn = dir24_8_get_lookup_fn(fib->dp, type);