Branch data Line data Source code
1 : : /* SPDX-License-Identifier: BSD-3-Clause
2 : : * Copyright(c) 2018 Vladimir Medvedkin <medvedkinv@gmail.com>
3 : : * Copyright(c) 2019 Intel Corporation
4 : : */
5 : :
6 : : #include <stdint.h>
7 : : #include <string.h>
8 : : #include <sys/queue.h>
9 : :
10 : : #include <eal_export.h>
11 : : #include <rte_eal_memconfig.h>
12 : : #include <rte_tailq.h>
13 : : #include <rte_errno.h>
14 : : #include <rte_log.h>
15 : : #include <rte_malloc.h>
16 : : #include <rte_string_fns.h>
17 : :
18 : : #include <rte_ip6.h>
19 : : #include <rte_rib6.h>
20 : : #include <rte_fib6.h>
21 : :
22 : : #include "trie.h"
23 : : #include "fib_log.h"
24 : :
25 : : TAILQ_HEAD(rte_fib6_list, rte_tailq_entry);
26 : : static struct rte_tailq_elem rte_fib6_tailq = {
27 : : .name = "RTE_FIB6",
28 : : };
29 [ - + ]: 252 : EAL_REGISTER_TAILQ(rte_fib6_tailq)
30 : :
31 : : /* Maximum length of a FIB name. */
32 : : #define FIB6_NAMESIZE 64
33 : :
34 : : #if defined(RTE_LIBRTE_FIB_DEBUG)
35 : : #define FIB6_RETURN_IF_TRUE(cond, retval) do { \
36 : : if (cond) \
37 : : return retval; \
38 : : } while (0)
39 : : #else
40 : : #define FIB6_RETURN_IF_TRUE(cond, retval)
41 : : #endif
42 : :
43 : : struct rte_fib6 {
44 : : char name[FIB6_NAMESIZE];
45 : : enum rte_fib6_type type; /**< Type of FIB struct */
46 : : struct rte_rib6 *rib; /**< RIB helper datastructure */
47 : : void *dp; /**< pointer to the dataplane struct*/
48 : : rte_fib6_lookup_fn_t lookup; /**< FIB lookup function */
49 : : rte_fib6_modify_fn_t modify; /**< modify FIB datastructure */
50 : : uint64_t def_nh;
51 : : };
52 : :
53 : : static void
54 : 1026 : dummy_lookup(void *fib_p, const struct rte_ipv6_addr *ips,
55 : : uint64_t *next_hops, const unsigned int n)
56 : : {
57 : : unsigned int i;
58 : : struct rte_fib6 *fib = fib_p;
59 : : struct rte_rib6_node *node;
60 : :
61 [ + + ]: 67203 : for (i = 0; i < n; i++) {
62 : 66177 : node = rte_rib6_lookup(fib->rib, &ips[i]);
63 [ + + ]: 66177 : if (node != NULL)
64 : 49024 : rte_rib6_get_nh(node, &next_hops[i]);
65 : : else
66 : 17153 : next_hops[i] = fib->def_nh;
67 : : }
68 : 1026 : }
69 : :
70 : : static int
71 : 512 : dummy_modify(struct rte_fib6 *fib, const struct rte_ipv6_addr *ip,
72 : : uint8_t depth, uint64_t next_hop, int op)
73 : : {
74 : : struct rte_rib6_node *node;
75 [ + - ]: 512 : if ((fib == NULL) || (depth > RTE_IPV6_MAX_DEPTH))
76 : : return -EINVAL;
77 : :
78 : 512 : node = rte_rib6_lookup_exact(fib->rib, ip, depth);
79 : :
80 [ + + - ]: 512 : switch (op) {
81 : 256 : case RTE_FIB6_ADD:
82 [ + - ]: 256 : if (node == NULL)
83 : 256 : node = rte_rib6_insert(fib->rib, ip, depth);
84 [ - + ]: 256 : if (node == NULL)
85 : 0 : return -rte_errno;
86 : 256 : return rte_rib6_set_nh(node, next_hop);
87 : 256 : case RTE_FIB6_DEL:
88 [ + - ]: 256 : if (node == NULL)
89 : : return -ENOENT;
90 : 256 : rte_rib6_remove(fib->rib, ip, depth);
91 : 256 : return 0;
92 : : }
93 : : return -EINVAL;
94 : : }
95 : :
96 : : static int
97 [ + + - ]: 8 : init_dataplane(struct rte_fib6 *fib, __rte_unused int socket_id,
98 : : struct rte_fib6_conf *conf)
99 : : {
100 : : char dp_name[sizeof(void *)];
101 : :
102 : : snprintf(dp_name, sizeof(dp_name), "%p", fib);
103 [ + + - ]: 8 : switch (conf->type) {
104 : 3 : case RTE_FIB6_DUMMY:
105 : 3 : fib->dp = fib;
106 : 3 : fib->lookup = dummy_lookup;
107 : 3 : fib->modify = dummy_modify;
108 : 3 : return 0;
109 : 5 : case RTE_FIB6_TRIE:
110 : 5 : fib->dp = trie_create(dp_name, socket_id, conf);
111 [ + + ]: 5 : if (fib->dp == NULL)
112 : 2 : return -rte_errno;
113 : 3 : fib->lookup = trie_get_lookup_fn(fib->dp, RTE_FIB6_LOOKUP_DEFAULT);
114 : 3 : fib->modify = trie_modify;
115 : 3 : return 0;
116 : : default:
117 : : return -EINVAL;
118 : : }
119 : : return 0;
120 : : }
121 : :
122 : : RTE_EXPORT_SYMBOL(rte_fib6_add)
123 : : int
124 : 1026 : rte_fib6_add(struct rte_fib6 *fib, const struct rte_ipv6_addr *ip,
125 : : uint8_t depth, uint64_t next_hop)
126 : : {
127 [ + + + - : 1026 : if ((fib == NULL) || (ip == NULL) || (fib->modify == NULL) ||
+ + ]
128 : : (depth > RTE_IPV6_MAX_DEPTH))
129 : : return -EINVAL;
130 : 1024 : return fib->modify(fib, ip, depth, next_hop, RTE_FIB6_ADD);
131 : : }
132 : :
133 : : RTE_EXPORT_SYMBOL(rte_fib6_delete)
134 : : int
135 : 1026 : rte_fib6_delete(struct rte_fib6 *fib, const struct rte_ipv6_addr *ip,
136 : : uint8_t depth)
137 : : {
138 [ + + + - : 1026 : if ((fib == NULL) || (ip == NULL) || (fib->modify == NULL) ||
+ + ]
139 : : (depth > RTE_IPV6_MAX_DEPTH))
140 : : return -EINVAL;
141 : 1024 : return fib->modify(fib, ip, depth, 0, RTE_FIB6_DEL);
142 : : }
143 : :
144 : : RTE_EXPORT_SYMBOL(rte_fib6_lookup_bulk)
145 : : int
146 : 4104 : rte_fib6_lookup_bulk(struct rte_fib6 *fib,
147 : : const struct rte_ipv6_addr *ips,
148 : : uint64_t *next_hops, int n)
149 : : {
150 : : FIB6_RETURN_IF_TRUE((fib == NULL) || (ips == NULL) ||
151 : : (next_hops == NULL) || (fib->lookup == NULL), -EINVAL);
152 : 4104 : fib->lookup(fib->dp, ips, next_hops, n);
153 : 4104 : return 0;
154 : : }
155 : :
156 : : RTE_EXPORT_SYMBOL(rte_fib6_create)
157 : : struct rte_fib6 *
158 : 13 : rte_fib6_create(const char *name, int socket_id, struct rte_fib6_conf *conf)
159 : : {
160 : : char mem_name[FIB6_NAMESIZE];
161 : : int ret;
162 : : struct rte_fib6 *fib = NULL;
163 : : struct rte_rib6 *rib = NULL;
164 : : struct rte_tailq_entry *te;
165 : : struct rte_fib6_list *fib_list;
166 : : struct rte_rib6_conf rib_conf;
167 : :
168 : : /* Check user arguments. */
169 [ + + + - ]: 13 : if ((name == NULL) || (conf == NULL) || (conf->max_routes < 0) ||
170 [ + + ]: 11 : (conf->type > RTE_FIB6_TRIE)) {
171 : 3 : rte_errno = EINVAL;
172 : 3 : return NULL;
173 : : }
174 : :
175 : 10 : rib_conf.ext_sz = conf->rib_ext_sz;
176 : 10 : rib_conf.max_nodes = conf->max_routes * 2;
177 : :
178 : 10 : rib = rte_rib6_create(name, socket_id, &rib_conf);
179 [ + + ]: 10 : if (rib == NULL) {
180 : 2 : FIB_LOG(ERR,
181 : : "Can not allocate RIB %s", name);
182 : 2 : return NULL;
183 : : }
184 : :
185 : : snprintf(mem_name, sizeof(mem_name), "FIB6_%s", name);
186 : 8 : fib_list = RTE_TAILQ_CAST(rte_fib6_tailq.head, rte_fib6_list);
187 : :
188 : 8 : rte_mcfg_tailq_write_lock();
189 : :
190 : : /* guarantee there's no existing */
191 [ - + ]: 8 : TAILQ_FOREACH(te, fib_list, next) {
192 : 0 : fib = (struct rte_fib6 *)te->data;
193 [ # # ]: 0 : if (strncmp(name, fib->name, FIB6_NAMESIZE) == 0)
194 : : break;
195 : : }
196 : : fib = NULL;
197 [ - + ]: 8 : if (te != NULL) {
198 : 0 : rte_errno = EEXIST;
199 : 0 : goto exit;
200 : : }
201 : :
202 : : /* allocate tailq entry */
203 : 8 : te = rte_zmalloc("FIB_TAILQ_ENTRY", sizeof(*te), 0);
204 [ - + ]: 8 : if (te == NULL) {
205 : 0 : FIB_LOG(ERR,
206 : : "Can not allocate tailq entry for FIB %s", name);
207 : 0 : rte_errno = ENOMEM;
208 : 0 : goto exit;
209 : : }
210 : :
211 : : /* Allocate memory to store the FIB data structures. */
212 : 8 : fib = rte_zmalloc_socket(mem_name,
213 : : sizeof(struct rte_fib6), RTE_CACHE_LINE_SIZE, socket_id);
214 [ - + ]: 8 : if (fib == NULL) {
215 : 0 : FIB_LOG(ERR, "FIB %s memory allocation failed", name);
216 : 0 : rte_errno = ENOMEM;
217 : 0 : goto free_te;
218 : : }
219 : :
220 : 8 : rte_strlcpy(fib->name, name, sizeof(fib->name));
221 : 8 : fib->rib = rib;
222 : 8 : fib->type = conf->type;
223 : 8 : fib->def_nh = conf->default_nh;
224 : 8 : ret = init_dataplane(fib, socket_id, conf);
225 [ + + ]: 8 : if (ret < 0) {
226 : 2 : FIB_LOG(ERR,
227 : : "FIB dataplane struct %s memory allocation failed",
228 : : name);
229 : 2 : rte_errno = -ret;
230 : 2 : goto free_fib;
231 : : }
232 : :
233 : 6 : te->data = (void *)fib;
234 : 6 : TAILQ_INSERT_TAIL(fib_list, te, next);
235 : :
236 : 6 : rte_mcfg_tailq_write_unlock();
237 : :
238 : 6 : return fib;
239 : :
240 : : free_fib:
241 : 2 : rte_free(fib);
242 : 2 : free_te:
243 : 2 : rte_free(te);
244 : 2 : exit:
245 : 2 : rte_mcfg_tailq_write_unlock();
246 : 2 : rte_rib6_free(rib);
247 : :
248 : 2 : return NULL;
249 : : }
250 : :
251 : : RTE_EXPORT_SYMBOL(rte_fib6_find_existing)
252 : : struct rte_fib6 *
253 : 0 : rte_fib6_find_existing(const char *name)
254 : : {
255 : : struct rte_fib6 *fib = NULL;
256 : : struct rte_tailq_entry *te;
257 : : struct rte_fib6_list *fib_list;
258 : :
259 : 0 : fib_list = RTE_TAILQ_CAST(rte_fib6_tailq.head, rte_fib6_list);
260 : :
261 : 0 : rte_mcfg_tailq_read_lock();
262 [ # # ]: 0 : TAILQ_FOREACH(te, fib_list, next) {
263 : 0 : fib = (struct rte_fib6 *) te->data;
264 [ # # ]: 0 : if (strncmp(name, fib->name, FIB6_NAMESIZE) == 0)
265 : : break;
266 : : }
267 : 0 : rte_mcfg_tailq_read_unlock();
268 : :
269 [ # # ]: 0 : if (te == NULL) {
270 : 0 : rte_errno = ENOENT;
271 : 0 : return NULL;
272 : : }
273 : :
274 : : return fib;
275 : : }
276 : :
277 : : static void
278 : : free_dataplane(struct rte_fib6 *fib)
279 : : {
280 [ + + ]: 6 : switch (fib->type) {
281 : : case RTE_FIB6_DUMMY:
282 : : return;
283 : 3 : case RTE_FIB6_TRIE:
284 : 3 : trie_free(fib->dp);
285 : : default:
286 : : return;
287 : : }
288 : : }
289 : :
290 : : RTE_EXPORT_SYMBOL(rte_fib6_free)
291 : : void
292 : 7 : rte_fib6_free(struct rte_fib6 *fib)
293 : : {
294 : : struct rte_tailq_entry *te;
295 : : struct rte_fib6_list *fib_list;
296 : :
297 [ + + ]: 7 : if (fib == NULL)
298 : : return;
299 : :
300 : 6 : fib_list = RTE_TAILQ_CAST(rte_fib6_tailq.head, rte_fib6_list);
301 : :
302 : 6 : rte_mcfg_tailq_write_lock();
303 : :
304 : : /* find our tailq entry */
305 [ + - ]: 6 : TAILQ_FOREACH(te, fib_list, next) {
306 [ - + ]: 6 : if (te->data == (void *)fib)
307 : : break;
308 : : }
309 [ + - ]: 6 : if (te != NULL)
310 [ - + ]: 6 : TAILQ_REMOVE(fib_list, te, next);
311 : :
312 : 6 : rte_mcfg_tailq_write_unlock();
313 : :
314 : : free_dataplane(fib);
315 : 6 : rte_rib6_free(fib->rib);
316 : 6 : rte_free(fib);
317 : 6 : rte_free(te);
318 : : }
319 : :
320 : : RTE_EXPORT_SYMBOL(rte_fib6_get_dp)
321 : : void *
322 : 1537 : rte_fib6_get_dp(struct rte_fib6 *fib)
323 : : {
324 [ + + ]: 1537 : return (fib == NULL) ? NULL : fib->dp;
325 : : }
326 : :
327 : : RTE_EXPORT_SYMBOL(rte_fib6_get_rib)
328 : : struct rte_rib6 *
329 : 1537 : rte_fib6_get_rib(struct rte_fib6 *fib)
330 : : {
331 [ + + ]: 1537 : return (fib == NULL) ? NULL : fib->rib;
332 : : }
333 : :
334 : : RTE_EXPORT_SYMBOL(rte_fib6_select_lookup)
335 : : int
336 : 0 : rte_fib6_select_lookup(struct rte_fib6 *fib,
337 : : enum rte_fib6_lookup_type type)
338 : : {
339 : : rte_fib6_lookup_fn_t fn;
340 : :
341 [ # # ]: 0 : switch (fib->type) {
342 : 0 : case RTE_FIB6_TRIE:
343 : 0 : fn = trie_get_lookup_fn(fib->dp, type);
344 [ # # ]: 0 : if (fn == NULL)
345 : : return -EINVAL;
346 : 0 : fib->lookup = fn;
347 : 0 : return 0;
348 : : default:
349 : : return -EINVAL;
350 : : }
351 : : }
|
