]> git.proxmox.com Git - mirror_frr.git/blame - eigrpd/eigrp_filter.c
Merge pull request #5175 from opensourcerouting/debug-nb-yang
[mirror_frr.git] / eigrpd / eigrp_filter.c
CommitLineData
7f57883e
DS
1/*
2 * EIGRP Filter Functions.
3 * Copyright (C) 2013-2015
4 * Authors:
5 * Donnie Savage
6 * Jan Janovic
7 * Matej Perina
8 * Peter Orsag
9 * Peter Paluch
10 * Frantisek Gazo
11 * Tomas Hvorkovy
12 * Martin Kontsek
13 * Lukas Koribsky
14 *
15 *
16 * This file is part of GNU Zebra.
17 *
18 * GNU Zebra is free software; you can redistribute it and/or modify it
19 * under the terms of the GNU General Public License as published by the
20 * Free Software Foundation; either version 2, or (at your option) any
21 * later version.
22 *
23 * GNU Zebra is distributed in the hope that it will be useful, but
24 * WITHOUT ANY WARRANTY; without even the implied warranty of
25 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
26 * General Public License for more details.
27 *
896014f4
DL
28 * You should have received a copy of the GNU General Public License along
29 * with this program; see the file COPYING; if not, write to the Free Software
30 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
7f57883e
DS
31 */
32
33#include <zebra.h>
34
35#include "if.h"
36#include "command.h"
37#include "prefix.h"
38#include "table.h"
39#include "thread.h"
40#include "memory.h"
41#include "log.h"
42#include "stream.h"
43#include "filter.h"
44#include "sockunion.h"
45#include "sockopt.h"
46#include "routemap.h"
47#include "if_rmap.h"
48#include "plist.h"
49#include "distribute.h"
50#include "md5.h"
51#include "keychain.h"
52#include "privs.h"
53#include "vrf.h"
54
55#include "eigrpd/eigrp_structs.h"
56#include "eigrpd/eigrpd.h"
57#include "eigrpd/eigrp_const.h"
58#include "eigrpd/eigrp_filter.h"
59#include "eigrpd/eigrp_packet.h"
60#include "eigrpd/eigrp_memory.h"
61
62/*
63 * Distribute-list update functions.
64 */
03a38493
PG
65void eigrp_distribute_update(struct distribute_ctx *ctx,
66 struct distribute *dist)
7f57883e 67{
4cfff48a 68 struct eigrp *e = eigrp_lookup(ctx->vrf->vrf_id);
d62a17ae 69 struct interface *ifp;
70 struct eigrp_interface *ei = NULL;
71 struct access_list *alist;
72 struct prefix_list *plist;
73 // struct route_map *routemap;
d62a17ae 74
75 /* if no interface address is present, set list to eigrp process struct
76 */
d62a17ae 77
78 /* Check if distribute-list was set for process or interface */
79 if (!dist->ifname) {
80 /* access list IN for whole process */
81 if (dist->list[DISTRIBUTE_V4_IN]) {
82 alist = access_list_lookup(
83 AFI_IP, dist->list[DISTRIBUTE_V4_IN]);
84 if (alist)
85 e->list[EIGRP_FILTER_IN] = alist;
86 else
87 e->list[EIGRP_FILTER_IN] = NULL;
88 } else {
89 e->list[EIGRP_FILTER_IN] = NULL;
90 }
91
92 /* access list OUT for whole process */
93 if (dist->list[DISTRIBUTE_V4_OUT]) {
94 alist = access_list_lookup(
95 AFI_IP, dist->list[DISTRIBUTE_V4_OUT]);
96 if (alist)
97 e->list[EIGRP_FILTER_OUT] = alist;
98 else
99 e->list[EIGRP_FILTER_OUT] = NULL;
100 } else {
101 e->list[EIGRP_FILTER_OUT] = NULL;
102 }
103
104 /* PREFIX_LIST IN for process */
105 if (dist->prefix[DISTRIBUTE_V4_IN]) {
106 plist = prefix_list_lookup(
107 AFI_IP, dist->prefix[DISTRIBUTE_V4_IN]);
108 if (plist) {
109 e->prefix[EIGRP_FILTER_IN] = plist;
110 } else
111 e->prefix[EIGRP_FILTER_IN] = NULL;
112 } else
113 e->prefix[EIGRP_FILTER_IN] = NULL;
114
115 /* PREFIX_LIST OUT for process */
116 if (dist->prefix[DISTRIBUTE_V4_OUT]) {
117 plist = prefix_list_lookup(
118 AFI_IP, dist->prefix[DISTRIBUTE_V4_OUT]);
119 if (plist) {
120 e->prefix[EIGRP_FILTER_OUT] = plist;
121
122 } else
123 e->prefix[EIGRP_FILTER_OUT] = NULL;
124 } else
125 e->prefix[EIGRP_FILTER_OUT] = NULL;
126
127// This is commented out, because the distribute.[ch] code
128// changes looked poorly written from first glance
129// commit was 133bdf2d
130// TODO: DBS
7f57883e 131#if 0
f9e5c9ca
DS
132 /* route-map IN for whole process */
133 if (dist->route[DISTRIBUTE_V4_IN])
134 {
135 routemap = route_map_lookup_by_name (dist->route[DISTRIBUTE_V4_IN]);
136 if (routemap)
137 e->routemap[EIGRP_FILTER_IN] = routemap;
138 else
139 e->routemap[EIGRP_FILTER_IN] = NULL;
140 }
141 else
142 {
143 e->routemap[EIGRP_FILTER_IN] = NULL;
144 }
145
146 /* route-map OUT for whole process */
147 if (dist->route[DISTRIBUTE_V4_OUT])
148 {
149 routemap = route_map_lookup_by_name (dist->route[DISTRIBUTE_V4_OUT]);
150 if (routemap)
151 e->routemap[EIGRP_FILTER_OUT] = routemap;
152 else
153 e->routemap[EIGRP_FILTER_OUT] = NULL;
154 }
155 else
156 {
157 e->routemap[EIGRP_FILTER_OUT] = NULL;
158 }
7f57883e 159#endif
d62a17ae 160 // TODO: check Graceful restart after 10sec
161
162 /* check if there is already GR scheduled */
163 if (e->t_distribute != NULL) {
164 /* if is, cancel schedule */
165 thread_cancel(e->t_distribute);
166 }
167 /* schedule Graceful restart for whole process in 10sec */
168 e->t_distribute = NULL;
169 thread_add_timer(master, eigrp_distribute_timer_process, e,
170 (10), &e->t_distribute);
171
172 return;
173 }
174
daa64bdf 175 ifp = if_lookup_by_name(dist->ifname, e->vrf_id);
d62a17ae 176 if (ifp == NULL)
177 return;
178
179 /*struct eigrp_if_info * info = ifp->info;
180 ei = info->eigrp_interface;*/
181 struct listnode *node, *nnode;
182 struct eigrp_interface *ei2;
183 /* Find proper interface */
184 for (ALL_LIST_ELEMENTS(e->eiflist, node, nnode, ei2)) {
185 if (strcmp(ei2->ifp->name, ifp->name) == 0) {
186 ei = ei2;
187 break;
188 }
189 }
85bbc95d 190 assert(ei != NULL);
d62a17ae 191
192 /* Access-list for interface in */
193 if (dist->list[DISTRIBUTE_V4_IN]) {
194 alist = access_list_lookup(AFI_IP,
195 dist->list[DISTRIBUTE_V4_IN]);
196 if (alist) {
197 ei->list[EIGRP_FILTER_IN] = alist;
198 } else
199 ei->list[EIGRP_FILTER_IN] = NULL;
200 } else {
201 ei->list[EIGRP_FILTER_IN] = NULL;
202 }
203
204 /* Access-list for interface in */
205 if (dist->list[DISTRIBUTE_V4_OUT]) {
206 alist = access_list_lookup(AFI_IP,
207 dist->list[DISTRIBUTE_V4_OUT]);
208 if (alist)
209 ei->list[EIGRP_FILTER_OUT] = alist;
210 else
211 ei->list[EIGRP_FILTER_OUT] = NULL;
212
213 } else
214 ei->list[EIGRP_FILTER_OUT] = NULL;
215
216 /* Prefix-list for interface in */
217 if (dist->prefix[DISTRIBUTE_V4_IN]) {
218 plist = prefix_list_lookup(AFI_IP,
219 dist->prefix[DISTRIBUTE_V4_IN]);
220 if (plist)
221 ei->prefix[EIGRP_FILTER_IN] = plist;
222 else
223 ei->prefix[EIGRP_FILTER_IN] = NULL;
224 } else
225 ei->prefix[EIGRP_FILTER_IN] = NULL;
226
227 /* Prefix-list for interface out */
228 if (dist->prefix[DISTRIBUTE_V4_OUT]) {
229 plist = prefix_list_lookup(AFI_IP,
230 dist->prefix[DISTRIBUTE_V4_OUT]);
231 if (plist)
232 ei->prefix[EIGRP_FILTER_OUT] = plist;
233 else
234 ei->prefix[EIGRP_FILTER_OUT] = NULL;
235 } else
236 ei->prefix[EIGRP_FILTER_OUT] = NULL;
7f57883e
DS
237
238#if 0
239 /* route-map IN for whole process */
240 if (dist->route[DISTRIBUTE_V4_IN])
f9e5c9ca
DS
241 {
242 zlog_info("<DEBUG ACL ALL in");
243 routemap = route_map_lookup_by_name (dist->route[DISTRIBUTE_V4_IN]);
244 if (routemap)
245 ei->routemap[EIGRP_FILTER_IN] = routemap;
246 else
247 ei->routemap[EIGRP_FILTER_IN] = NULL;
248 }
7f57883e 249 else
f9e5c9ca
DS
250 {
251 ei->routemap[EIGRP_FILTER_IN] = NULL;
252 }
7f57883e
DS
253
254 /* route-map OUT for whole process */
255 if (dist->route[DISTRIBUTE_V4_OUT])
f9e5c9ca
DS
256 {
257 routemap = route_map_lookup_by_name (dist->route[DISTRIBUTE_V4_OUT]);
258 if (routemap)
259 ei->routemap[EIGRP_FILTER_OUT] = routemap;
260 else
261 ei->routemap[EIGRP_FILTER_OUT] = NULL;
262 }
7f57883e 263 else
f9e5c9ca
DS
264 {
265 ei->routemap[EIGRP_FILTER_OUT] = NULL;
266 }
7f57883e 267#endif
d62a17ae 268 // TODO: check Graceful restart after 10sec
269
270 /* check if there is already GR scheduled */
271 if (ei->t_distribute != NULL) {
272 /* if is, cancel schedule */
273 thread_cancel(ei->t_distribute);
274 }
275 /* schedule Graceful restart for interface in 10sec */
276 e->t_distribute = NULL;
277 thread_add_timer(master, eigrp_distribute_timer_interface, ei, 10,
278 &e->t_distribute);
7f57883e
DS
279}
280
281/*
282 * Function called by prefix-list and access-list update
283 */
d62a17ae 284void eigrp_distribute_update_interface(struct interface *ifp)
7f57883e 285{
d62a17ae 286 struct distribute *dist;
03a38493 287 struct eigrp *eigrp;
7f57883e 288
e9449961 289 eigrp = eigrp_lookup(ifp->vrf_id);
03a38493
PG
290 if (!eigrp)
291 return;
292 dist = distribute_lookup(eigrp->distribute_ctx, ifp->name);
d62a17ae 293 if (dist)
03a38493
PG
294 eigrp_distribute_update(eigrp->distribute_ctx,
295 dist);
7f57883e
DS
296}
297
298/* Update all interface's distribute list.
299 * Function used in hook for prefix-list
300 */
d62a17ae 301void eigrp_distribute_update_all(struct prefix_list *notused)
7f57883e 302{
4cfff48a 303 struct vrf *vrf;
d62a17ae 304 struct interface *ifp;
7f57883e 305
4cfff48a
DS
306 RB_FOREACH (vrf, vrf_name_head, &vrfs_by_name) {
307 FOR_ALL_INTERFACES (vrf, ifp)
308 eigrp_distribute_update_interface(ifp);
309 }
7f57883e
DS
310}
311
312/*
313 * Function used in hook for acces-list
314 */
d62a17ae 315void eigrp_distribute_update_all_wrapper(struct access_list *notused)
7f57883e 316{
d62a17ae 317 eigrp_distribute_update_all(NULL);
7f57883e
DS
318}
319
320/*
321 * @fn eigrp_distribute_timer_process
322 *
f9e5c9ca 323 * @param[in] thread current execution thread timer is associated with
7f57883e 324 *
f9e5c9ca 325 * @return int always returns 0
7f57883e
DS
326 *
327 * @par
328 * Called when 10sec waiting time expire and
329 * executes Graceful restart for whole process
330 */
d62a17ae 331int eigrp_distribute_timer_process(struct thread *thread)
7f57883e 332{
d62a17ae 333 struct eigrp *eigrp;
7f57883e 334
d62a17ae 335 eigrp = THREAD_ARG(thread);
336 eigrp->t_distribute = NULL;
7f57883e 337
d62a17ae 338 /* execute GR for whole process */
339 eigrp_update_send_process_GR(eigrp, EIGRP_GR_FILTER, NULL);
7f57883e 340
d62a17ae 341 return 0;
7f57883e
DS
342}
343
344/*
345 * @fn eigrp_distribute_timer_interface
346 *
f9e5c9ca 347 * @param[in] thread current execution thread timer is associated with
7f57883e 348 *
f9e5c9ca 349 * @return int always returns 0
7f57883e
DS
350 *
351 * @par
352 * Called when 10sec waiting time expire and
353 * executes Graceful restart for interface
354 */
d62a17ae 355int eigrp_distribute_timer_interface(struct thread *thread)
7f57883e 356{
d62a17ae 357 struct eigrp_interface *ei;
7f57883e 358
d62a17ae 359 ei = THREAD_ARG(thread);
360 ei->t_distribute = NULL;
7f57883e 361
d62a17ae 362 /* execute GR for interface */
363 eigrp_update_send_interface_GR(ei, EIGRP_GR_FILTER, NULL);
7f57883e 364
d62a17ae 365 return 0;
7f57883e 366}