]> git.proxmox.com Git - mirror_frr.git/blame - ldpd/lde.h
Merge pull request #5806 from ton31337/fix/remove_break_after_return
[mirror_frr.git] / ldpd / lde.h
CommitLineData
8429abe0
RW
1/* $OpenBSD$ */
2
3/*
4 * Copyright (c) 2013, 2016 Renato Westphal <renato@openbsd.org>
5 * Copyright (c) 2009 Michele Marchetto <michele@openbsd.org>
6 * Copyright (c) 2004, 2005 Esben Norby <norby@openbsd.org>
7 *
8 * Permission to use, copy, modify, and distribute this software for any
9 * purpose with or without fee is hereby granted, provided that the above
10 * copyright notice and this permission notice appear in all copies.
11 *
12 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
13 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
14 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
15 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
16 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
17 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
18 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
19 */
20
21#ifndef _LDE_H_
22#define _LDE_H_
23
cd85bc2e 24#include "queue.h"
eac6e3f0 25#include "openbsd-tree.h"
88d88a9c 26#include "if.h"
8429abe0
RW
27
28enum fec_type {
29 FEC_TYPE_IPV4,
30 FEC_TYPE_IPV6,
31 FEC_TYPE_PWID
32};
33
34struct fec {
35 RB_ENTRY(fec) entry;
36 enum fec_type type;
37 union {
38 struct {
39 struct in_addr prefix;
40 uint8_t prefixlen;
41 } ipv4;
42 struct {
43 struct in6_addr prefix;
44 uint8_t prefixlen;
45 } ipv6;
46 struct {
47 uint16_t type;
48 uint32_t pwid;
49 struct in_addr lsr_id;
50 } pwid;
51 } u;
52};
53RB_HEAD(fec_tree, fec);
54RB_PROTOTYPE(fec_tree, fec, entry, fec_compare)
55
56/* request entries */
57struct lde_req {
58 struct fec fec;
59 uint32_t msg_id;
60};
61
62/* mapping entries */
63struct lde_map {
64 struct fec fec;
d3e1887a
RW
65 struct lde_map_head *head; /* fec_node's upstream/downstream */
66 RB_ENTRY(lde_map) entry;
8429abe0
RW
67 struct lde_nbr *nexthop;
68 struct map map;
69};
d3e1887a
RW
70RB_HEAD(lde_map_head, lde_map);
71RB_PROTOTYPE(lde_map_head, lde_map, entry, lde_map_cmp);
8429abe0
RW
72
73/* withdraw entries */
74struct lde_wdraw {
75 struct fec fec;
76 uint32_t label;
77};
78
79/* Addresses belonging to neighbor */
80struct lde_addr {
81 TAILQ_ENTRY(lde_addr) entry;
82 int af;
83 union ldpd_addr addr;
84};
85
86/* just the info LDE needs */
87struct lde_nbr {
88 RB_ENTRY(lde_nbr) entry;
89 uint32_t peerid;
90 struct in_addr id;
91 int v4_enabled; /* announce/process v4 msgs */
92 int v6_enabled; /* announce/process v6 msgs */
257799cd 93 int flags; /* capabilities */
8429abe0
RW
94 struct fec_tree recv_req;
95 struct fec_tree sent_req;
96 struct fec_tree recv_map;
97 struct fec_tree sent_map;
7c2abbd7 98 struct fec_tree sent_map_pending;
8429abe0
RW
99 struct fec_tree sent_wdraw;
100 TAILQ_HEAD(, lde_addr) addr_list;
101};
102RB_HEAD(nbr_tree, lde_nbr);
103RB_PROTOTYPE(nbr_tree, lde_nbr, entry, lde_nbr_compare)
104
105struct fec_nh {
106 LIST_ENTRY(fec_nh) entry;
107 int af;
108 union ldpd_addr nexthop;
88d88a9c 109 ifindex_t ifindex;
8429abe0 110 uint32_t remote_label;
e132dea0
RW
111 uint8_t route_type;
112 unsigned short route_instance;
134970a2 113 uint8_t flags;
8429abe0 114};
134970a2 115#define F_FEC_NH_NEW 0x01
8cb1fc45 116#define F_FEC_NH_CONNECTED 0x02
8429abe0
RW
117
118struct fec_node {
119 struct fec fec;
120
121 LIST_HEAD(, fec_nh) nexthops; /* fib nexthops */
d3e1887a
RW
122 struct lde_map_head downstream; /* recv mappings */
123 struct lde_map_head upstream; /* sent mappings */
8429abe0
RW
124
125 uint32_t local_label;
126 void *data; /* fec specific data */
127};
128
fea12efb 129#define CHUNK_SIZE 64
130struct label_chunk {
131 uint32_t start;
132 uint32_t end;
133 uint64_t used_mask;
134};
135
8429abe0
RW
136#define LDE_GC_INTERVAL 300
137
138extern struct ldpd_conf *ldeconf;
139extern struct fec_tree ft;
140extern struct nbr_tree lde_nbrs;
eac6e3f0 141extern struct thread *gc_timer;
8429abe0
RW
142
143/* lde.c */
274f5abf
RW
144void lde(void);
145void lde_init(struct ldpd_init *);
eac6e3f0 146int lde_imsg_compose_parent(int, pid_t, void *, uint16_t);
f2232fdf 147void lde_imsg_compose_parent_sync(int, pid_t, void *, uint16_t);
8429abe0 148int lde_imsg_compose_ldpe(int, uint32_t, pid_t, void *, uint16_t);
45a8eba9 149int lde_acl_check(char *, int, union ldpd_addr *, uint8_t);
8cb1fc45 150uint32_t lde_update_label(struct fec_node *);
f4ec681c 151void lde_free_label(uint32_t label);
8429abe0
RW
152void lde_send_change_klabel(struct fec_node *, struct fec_nh *);
153void lde_send_delete_klabel(struct fec_node *, struct fec_nh *);
154void lde_fec2map(struct fec *, struct map *);
155void lde_map2fec(struct map *, struct in_addr, struct fec *);
156void lde_send_labelmapping(struct lde_nbr *, struct fec_node *,
157 int);
158void lde_send_labelwithdraw(struct lde_nbr *, struct fec_node *,
0bcc2916
RW
159 struct map *, struct status_tlv *);
160void lde_send_labelwithdraw_wcard(struct lde_nbr *, uint32_t);
d4afb819
RW
161void lde_send_labelwithdraw_twcard_prefix(struct lde_nbr *,
162 uint16_t, uint32_t);
aba50a83
RW
163void lde_send_labelwithdraw_twcard_pwid(struct lde_nbr *, uint16_t,
164 uint32_t);
0bcc2916 165void lde_send_labelwithdraw_pwid_wcard(struct lde_nbr *, uint16_t,
8429abe0 166 uint32_t);
0bcc2916
RW
167void lde_send_labelrelease(struct lde_nbr *, struct fec_node *,
168 struct map *, uint32_t);
05aac414
RW
169void lde_send_notification(struct lde_nbr *, uint32_t, uint32_t,
170 uint16_t);
257799cd
RW
171void lde_send_notification_eol_prefix(struct lde_nbr *, int);
172void lde_send_notification_eol_pwid(struct lde_nbr *, uint16_t);
8429abe0
RW
173struct lde_nbr *lde_nbr_find_by_lsrid(struct in_addr);
174struct lde_nbr *lde_nbr_find_by_addr(int, union ldpd_addr *);
175struct lde_map *lde_map_add(struct lde_nbr *, struct fec_node *, int);
176void lde_map_del(struct lde_nbr *, struct lde_map *, int);
7c2abbd7
RW
177struct fec *lde_map_pending_add(struct lde_nbr *, struct fec_node *);
178void lde_map_pending_del(struct lde_nbr *, struct fec *);
8429abe0
RW
179struct lde_req *lde_req_add(struct lde_nbr *, struct fec *, int);
180void lde_req_del(struct lde_nbr *, struct lde_req *, int);
181struct lde_wdraw *lde_wdraw_add(struct lde_nbr *, struct fec_node *);
182void lde_wdraw_del(struct lde_nbr *, struct lde_wdraw *);
45a8eba9 183void lde_change_egress_label(int);
8429abe0
RW
184struct lde_addr *lde_address_find(struct lde_nbr *, int,
185 union ldpd_addr *);
186
187/* lde_lib.c */
188void fec_init(struct fec_tree *);
189struct fec *fec_find(struct fec_tree *, struct fec *);
190int fec_insert(struct fec_tree *, struct fec *);
191int fec_remove(struct fec_tree *, struct fec *);
192void fec_clear(struct fec_tree *, void (*)(void *));
193void rt_dump(pid_t);
194void fec_snap(struct lde_nbr *);
195void fec_tree_clear(void);
196struct fec_nh *fec_nh_find(struct fec_node *, int, union ldpd_addr *,
e132dea0 197 ifindex_t, uint8_t, unsigned short);
8429abe0 198void lde_kernel_insert(struct fec *, int, union ldpd_addr *,
e132dea0 199 ifindex_t, uint8_t, unsigned short, int, void *);
8429abe0 200void lde_kernel_remove(struct fec *, int, union ldpd_addr *,
e132dea0 201 ifindex_t, uint8_t, unsigned short);
8cb1fc45 202void lde_kernel_update(struct fec *);
8429abe0
RW
203void lde_check_mapping(struct map *, struct lde_nbr *);
204void lde_check_request(struct map *, struct lde_nbr *);
d4afb819 205void lde_check_request_wcard(struct map *, struct lde_nbr *);
8429abe0
RW
206void lde_check_release(struct map *, struct lde_nbr *);
207void lde_check_release_wcard(struct map *, struct lde_nbr *);
208void lde_check_withdraw(struct map *, struct lde_nbr *);
209void lde_check_withdraw_wcard(struct map *, struct lde_nbr *);
0bcc2916
RW
210int lde_wildcard_apply(struct map *, struct fec *,
211 struct lde_map *);
eac6e3f0 212int lde_gc_timer(struct thread *);
8429abe0
RW
213void lde_gc_start_timer(void);
214void lde_gc_stop_timer(void);
215
216/* l2vpn.c */
217struct l2vpn *l2vpn_new(const char *);
218struct l2vpn *l2vpn_find(struct ldpd_conf *, const char *);
219void l2vpn_del(struct l2vpn *);
220void l2vpn_init(struct l2vpn *);
221void l2vpn_exit(struct l2vpn *);
52b530fc 222struct l2vpn_if *l2vpn_if_new(struct l2vpn *, const char *);
52bd4c23 223struct l2vpn_if *l2vpn_if_find(struct l2vpn *, const char *);
52b530fc 224void l2vpn_if_update_info(struct l2vpn_if *, struct kif *);
26519d8c 225void l2vpn_if_update(struct l2vpn_if *);
52b530fc 226struct l2vpn_pw *l2vpn_pw_new(struct l2vpn *, const char *);
52bd4c23 227struct l2vpn_pw *l2vpn_pw_find(struct l2vpn *, const char *);
5c3f00af
RW
228struct l2vpn_pw *l2vpn_pw_find_active(struct l2vpn *, const char *);
229struct l2vpn_pw *l2vpn_pw_find_inactive(struct l2vpn *, const char *);
52b530fc 230void l2vpn_pw_update_info(struct l2vpn_pw *, struct kif *);
8429abe0
RW
231void l2vpn_pw_init(struct l2vpn_pw *);
232void l2vpn_pw_exit(struct l2vpn_pw *);
233void l2vpn_pw_reset(struct l2vpn_pw *);
234int l2vpn_pw_ok(struct l2vpn_pw *, struct fec_nh *);
235int l2vpn_pw_negotiate(struct lde_nbr *, struct fec_node *,
236 struct map *);
0bcc2916
RW
237void l2vpn_send_pw_status(struct lde_nbr *, uint32_t, struct fec *);
238void l2vpn_send_pw_status_wcard(struct lde_nbr *, uint32_t,
239 uint16_t, uint32_t);
8429abe0 240void l2vpn_recv_pw_status(struct lde_nbr *, struct notify_msg *);
0bcc2916
RW
241void l2vpn_recv_pw_status_wcard(struct lde_nbr *,
242 struct notify_msg *);
87b5f1b7 243int l2vpn_pw_status_update(struct zapi_pw_status *);
8429abe0
RW
244void l2vpn_pw_ctl(pid_t);
245void l2vpn_binding_ctl(pid_t);
246
247#endif /* _LDE_H_ */