]> git.proxmox.com Git - mirror_frr.git/blame - zebra/table_manager.c
Merge pull request #12687 from opensourcerouting/build-mkdir-p
[mirror_frr.git] / zebra / table_manager.c
CommitLineData
50261279
PG
1/* zebra table Manager for routing table identifier management
2 * Copyright (C) 2018 6WIND
3 *
4 * This program is free software; you can redistribute it and/or modify it
5 * under the terms of the GNU General Public License as published by the Free
6 * Software Foundation; either version 2 of the License, or (at your option)
7 * any later version.
8 *
9 * This program is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
12 * more details.
13 *
14 * You should have received a copy of the GNU General Public License along
15 * with this program; see the file COPYING; if not, write to the Free Software
16 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
17 */
18
453844ab
QY
19#include "zebra.h"
20
50261279
PG
21#include <stdio.h>
22#include <string.h>
23#include <sys/types.h>
24
50261279
PG
25#include "lib/log.h"
26#include "lib/memory.h"
27#include "lib/table.h"
28#include "lib/network.h"
29#include "lib/stream.h"
30#include "lib/zclient.h"
31#include "lib/libfrr.h"
32#include "lib/vrf.h"
33
453844ab
QY
34#include "zebra/zserv.h"
35#include "zebra/zebra_vrf.h"
36#include "zebra/label_manager.h" /* for NO_PROTO */
37#include "zebra/table_manager.h"
43e52561 38#include "zebra/zebra_errors.h"
50261279
PG
39
40/* routing table identifiers
41 *
42 */
cae8bc96 43#if !defined(GNU_LINUX)
50261279
PG
44/* BSD systems
45 */
46#else
47/* Linux Systems
48 */
49#define RT_TABLE_ID_LOCAL 255
50#define RT_TABLE_ID_MAIN 254
51#define RT_TABLE_ID_DEFAULT 253
52#define RT_TABLE_ID_COMPAT 252
53#define RT_TABLE_ID_UNSPEC 0
cae8bc96 54#endif /* !def(GNU_LINUX) */
50261279
PG
55#define RT_TABLE_ID_UNRESERVED_MIN 1
56#define RT_TABLE_ID_UNRESERVED_MAX 0xffffffff
57
50261279
PG
58DEFINE_MGROUP(TABLE_MGR, "Table Manager");
59DEFINE_MTYPE_STATIC(TABLE_MGR, TM_CHUNK, "Table Manager Chunk");
42d4b30e 60DEFINE_MTYPE_STATIC(TABLE_MGR, TM_TABLE, "Table Manager Context");
50261279
PG
61
62static void delete_table_chunk(void *val)
63{
64 XFREE(MTYPE_TM_CHUNK, val);
65}
66
67/**
68 * Init table manager
69 */
42d4b30e 70void table_manager_enable(struct zebra_vrf *zvrf)
50261279 71{
42d4b30e
PG
72
73 if (zvrf->tbl_mgr)
50261279 74 return;
9742796f
IR
75 if (!vrf_is_backend_netns()
76 && strcmp(zvrf_name(zvrf), VRF_DEFAULT_NAME)) {
42d4b30e
PG
77 struct zebra_vrf *def = zebra_vrf_lookup_by_id(VRF_DEFAULT);
78
79 if (def)
80 zvrf->tbl_mgr = def->tbl_mgr;
81 return;
82 }
83 zvrf->tbl_mgr = XCALLOC(MTYPE_TM_TABLE, sizeof(struct table_manager));
84 zvrf->tbl_mgr->lc_list = list_new();
85 zvrf->tbl_mgr->lc_list->del = delete_table_chunk;
50261279
PG
86}
87
88/**
89 * Core function, assigns table chunks
90 *
91 * It first searches through the list to check if there's one available
92 * (previously released). Otherwise it creates and assigns a new one
93 *
94 * @param proto Daemon protocol of client, to identify the owner
95 * @param instance Instance, to identify the owner
96 * @para size Size of the table chunk
97 * @return Pointer to the assigned table chunk
98 */
99struct table_manager_chunk *assign_table_chunk(uint8_t proto, uint16_t instance,
42d4b30e
PG
100 uint32_t size,
101 struct zebra_vrf *zvrf)
50261279
PG
102{
103 struct table_manager_chunk *tmc;
104 struct listnode *node;
105 uint32_t start;
42d4b30e
PG
106 bool manual_conf = false;
107
108 if (!zvrf)
109 return NULL;
50261279
PG
110
111 /* first check if there's one available */
42d4b30e 112 for (ALL_LIST_ELEMENTS_RO(zvrf->tbl_mgr->lc_list, node, tmc)) {
50261279
PG
113 if (tmc->proto == NO_PROTO
114 && tmc->end - tmc->start + 1 == size) {
115 tmc->proto = proto;
116 tmc->instance = instance;
117 return tmc;
118 }
119 }
120 /* otherwise create a new one */
121 tmc = XCALLOC(MTYPE_TM_CHUNK, sizeof(struct table_manager_chunk));
50261279 122
42d4b30e
PG
123 if (zvrf->tbl_mgr->start || zvrf->tbl_mgr->end)
124 manual_conf = true;
50261279
PG
125 /* table RT IDs range are [1;252] and [256;0xffffffff]
126 * - check if the requested range can be within the first range,
127 * otherwise elect second one
128 * - TODO : vrf-lites have their own table identifier.
129 * In that case, table_id should be removed from the table range.
130 */
42d4b30e
PG
131 if (list_isempty(zvrf->tbl_mgr->lc_list)) {
132 if (!manual_conf)
133 start = RT_TABLE_ID_UNRESERVED_MIN;
134 else
135 start = zvrf->tbl_mgr->start;
136 } else
50261279 137 start = ((struct table_manager_chunk *)listgetdata(
42d4b30e
PG
138 listtail(zvrf->tbl_mgr->lc_list)))
139 ->end
140 + 1;
141
142 if (!manual_conf) {
50261279 143
cae8bc96 144#if !defined(GNU_LINUX)
50261279
PG
145/* BSD systems
146 */
147#else
148/* Linux Systems
149 */
42d4b30e
PG
150 /* if not enough room space between MIN and COMPAT,
151 * then begin after LOCAL
152 */
153 if (start < RT_TABLE_ID_COMPAT
154 && (size > RT_TABLE_ID_COMPAT - RT_TABLE_ID_UNRESERVED_MIN))
155 start = RT_TABLE_ID_LOCAL + 1;
cae8bc96 156#endif /* !def(GNU_LINUX) */
42d4b30e
PG
157 tmc->start = start;
158 if (RT_TABLE_ID_UNRESERVED_MAX - size + 1 < start) {
159 flog_err(EC_ZEBRA_TM_EXHAUSTED_IDS,
160 "Reached max table id. Start/Size %u/%u",
161 start, size);
162 XFREE(MTYPE_TM_CHUNK, tmc);
163 return NULL;
164 }
165 } else {
166 tmc->start = start;
167 if (zvrf->tbl_mgr->end - size + 1 < start) {
168 flog_err(EC_ZEBRA_TM_EXHAUSTED_IDS,
169 "Reached max table id. Start/Size %u/%u",
170 start, size);
171 XFREE(MTYPE_TM_CHUNK, tmc);
172 return NULL;
173 }
50261279
PG
174 }
175 tmc->end = tmc->start + size - 1;
176 tmc->proto = proto;
177 tmc->instance = instance;
42d4b30e 178 listnode_add(zvrf->tbl_mgr->lc_list, tmc);
50261279
PG
179
180 return tmc;
181}
182
183/**
184 * Core function, release no longer used table chunks
185 *
186 * @param proto Daemon protocol of client, to identify the owner
187 * @param instance Instance, to identify the owner
188 * @param start First table RT ID of the chunk
189 * @param end Last table RT ID of the chunk
190 * @return 0 on success, -1 otherwise
191 */
192int release_table_chunk(uint8_t proto, uint16_t instance, uint32_t start,
42d4b30e 193 uint32_t end, struct zebra_vrf *zvrf)
50261279
PG
194{
195 struct listnode *node;
196 struct table_manager_chunk *tmc;
197 int ret = -1;
42d4b30e
PG
198 struct table_manager *tbl_mgr;
199
200 if (!zvrf)
201 return -1;
50261279 202
42d4b30e
PG
203 tbl_mgr = zvrf->tbl_mgr;
204 if (!tbl_mgr)
205 return ret;
50261279
PG
206 /* check that size matches */
207 zlog_debug("Releasing table chunk: %u - %u", start, end);
208 /* find chunk and disown */
42d4b30e 209 for (ALL_LIST_ELEMENTS_RO(tbl_mgr->lc_list, node, tmc)) {
50261279
PG
210 if (tmc->start != start)
211 continue;
212 if (tmc->end != end)
213 continue;
214 if (tmc->proto != proto || tmc->instance != instance) {
e914ccbe 215 flog_err(EC_ZEBRA_TM_DAEMON_MISMATCH,
1c50c1c0 216 "%s: Daemon mismatch!!", __func__);
50261279
PG
217 continue;
218 }
219 tmc->proto = NO_PROTO;
220 tmc->instance = 0;
221 ret = 0;
222 break;
223 }
224 if (ret != 0)
e914ccbe 225 flog_err(EC_ZEBRA_TM_UNRELEASED_CHUNK,
1c50c1c0 226 "%s: Table chunk not released!!", __func__);
50261279
PG
227
228 return ret;
229}
230
231/**
232 * Release table chunks from a client.
233 *
234 * Called on client disconnection or reconnection. It only releases chunks
235 * with empty keep value.
236 *
453844ab 237 * @param client the client to release chunks from
50261279
PG
238 * @return Number of chunks released
239 */
453844ab 240int release_daemon_table_chunks(struct zserv *client)
50261279 241{
453844ab
QY
242 uint8_t proto = client->proto;
243 uint16_t instance = client->instance;
50261279
PG
244 struct listnode *node;
245 struct table_manager_chunk *tmc;
246 int count = 0;
247 int ret;
42d4b30e
PG
248 struct vrf *vrf;
249 struct zebra_vrf *zvrf;
50261279 250
42d4b30e
PG
251 RB_FOREACH (vrf, vrf_name_head, &vrfs_by_name) {
252 zvrf = vrf->info;
253
254 if (!zvrf)
255 continue;
256 if (!vrf_is_backend_netns() && vrf->vrf_id != VRF_DEFAULT)
257 continue;
258 for (ALL_LIST_ELEMENTS_RO(zvrf->tbl_mgr->lc_list, node, tmc)) {
259 if (tmc->proto == proto && tmc->instance == instance) {
260 ret = release_table_chunk(
261 tmc->proto, tmc->instance, tmc->start,
262 tmc->end, zvrf);
263 if (ret == 0)
264 count++;
265 }
50261279
PG
266 }
267 }
50261279
PG
268 zlog_debug("%s: Released %d table chunks", __func__, count);
269
270 return count;
271}
272
42d4b30e
PG
273static void table_range_add(struct zebra_vrf *zvrf, uint32_t start,
274 uint32_t end)
275{
276 if (!zvrf->tbl_mgr)
277 return;
278 zvrf->tbl_mgr->start = start;
279 zvrf->tbl_mgr->end = end;
280}
281
282void table_manager_disable(struct zebra_vrf *zvrf)
50261279 283{
42d4b30e
PG
284 if (!zvrf->tbl_mgr)
285 return;
9742796f
IR
286 if (!vrf_is_backend_netns()
287 && strcmp(zvrf_name(zvrf), VRF_DEFAULT_NAME)) {
42d4b30e 288 zvrf->tbl_mgr = NULL;
50261279 289 return;
42d4b30e
PG
290 }
291 list_delete(&zvrf->tbl_mgr->lc_list);
292 XFREE(MTYPE_TM_TABLE, zvrf->tbl_mgr);
293 zvrf->tbl_mgr = NULL;
294}
295
296int table_manager_range(struct vty *vty, bool add, struct zebra_vrf *zvrf,
297 const char *start_table_str, const char *end_table_str)
298{
299 uint32_t start;
300 uint32_t end;
301
302 if (add) {
303 if (!start_table_str || !end_table_str) {
304 vty_out(vty, "%% Labels not specified\n");
305 return CMD_WARNING_CONFIG_FAILED;
306 }
307 start = atoi(start_table_str);
308 end = atoi(end_table_str);
309 if (end < start) {
310 vty_out(vty, "%% End table is less than Start table\n");
311 return CMD_WARNING_CONFIG_FAILED;
312 }
313
314#if !defined(GNU_LINUX)
315/* BSD systems
316 */
317#else
318 /* Linux Systems
319 */
320 if ((start >= RT_TABLE_ID_COMPAT && start <= RT_TABLE_ID_LOCAL)
321 || (end >= RT_TABLE_ID_COMPAT
322 && end <= RT_TABLE_ID_LOCAL)) {
323 vty_out(vty, "%% Values forbidden in range [%u;%u]\n",
324 RT_TABLE_ID_COMPAT, RT_TABLE_ID_LOCAL);
325 return CMD_WARNING_CONFIG_FAILED;
326 }
327 if (start < RT_TABLE_ID_COMPAT && end > RT_TABLE_ID_LOCAL) {
328 vty_out(vty,
329 "%% Range overlaps range [%u;%u] forbidden\n",
330 RT_TABLE_ID_COMPAT, RT_TABLE_ID_LOCAL);
331 return CMD_WARNING_CONFIG_FAILED;
332 }
333#endif
334 if (zvrf->tbl_mgr
335 && ((zvrf->tbl_mgr->start && zvrf->tbl_mgr->start != start)
336 || (zvrf->tbl_mgr->end && zvrf->tbl_mgr->end != end))) {
337 vty_out(vty,
338 "%% New range will be taken into account at restart\n");
339 }
340 table_range_add(zvrf, start, end);
341 } else
342 table_range_add(zvrf, 0, 0);
343 return CMD_SUCCESS;
50261279 344}