]>
Commit | Line | Data |
---|---|---|
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 |
58 | DEFINE_MGROUP(TABLE_MGR, "Table Manager"); |
59 | DEFINE_MTYPE_STATIC(TABLE_MGR, TM_CHUNK, "Table Manager Chunk"); | |
42d4b30e | 60 | DEFINE_MTYPE_STATIC(TABLE_MGR, TM_TABLE, "Table Manager Context"); |
50261279 PG |
61 | |
62 | static void delete_table_chunk(void *val) | |
63 | { | |
64 | XFREE(MTYPE_TM_CHUNK, val); | |
65 | } | |
66 | ||
67 | /** | |
68 | * Init table manager | |
69 | */ | |
42d4b30e | 70 | void 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 | */ | |
99 | struct 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 | */ | |
192 | int 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 | 240 | int 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 |
273 | static 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 | ||
282 | void 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 | ||
296 | int 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 | } |